aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_http_client.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2016-07-21 23:10:54 +0000
committerChristian Grothoff <christian@grothoff.org>2016-07-21 23:10:54 +0000
commit0979ddcbd310b856b7c36c6ed9c8dc17c0b032db (patch)
tree18b0fa2c1b2ecd41187d8197dcf3f88d82417d32 /src/transport/plugin_transport_http_client.c
parentae9918852bed2d822c12e110d6b754520e601388 (diff)
downloadgnunet-0979ddcbd310b856b7c36c6ed9c8dc17c0b032db.tar.gz
gnunet-0979ddcbd310b856b7c36c6ed9c8dc17c0b032db.zip
generalize send API for transport tests
Diffstat (limited to 'src/transport/plugin_transport_http_client.c')
-rw-r--r--src/transport/plugin_transport_http_client.c10
1 files changed, 7 insertions, 3 deletions
diff --git a/src/transport/plugin_transport_http_client.c b/src/transport/plugin_transport_http_client.c
index 4e0cde998..ceed94af8 100644
--- a/src/transport/plugin_transport_http_client.c
+++ b/src/transport/plugin_transport_http_client.c
@@ -1061,8 +1061,10 @@ client_send_cb (void *stream,
1061 "Session %p/request %p: nothing to send, suspending\n", 1061 "Session %p/request %p: nothing to send, suspending\n",
1062 s, 1062 s,
1063 s->put.easyhandle); 1063 s->put.easyhandle);
1064 s->put_disconnect_task = GNUNET_SCHEDULER_add_delayed (PUT_DISCONNECT_TIMEOUT, 1064 s->put_disconnect_task
1065 &client_put_disconnect, s); 1065 = GNUNET_SCHEDULER_add_delayed (PUT_DISCONNECT_TIMEOUT,
1066 &client_put_disconnect,
1067 s);
1066 s->put.state = H_PAUSED; 1068 s->put.state = H_PAUSED;
1067 return CURL_READFUNC_PAUSE; 1069 return CURL_READFUNC_PAUSE;
1068 } 1070 }
@@ -1071,7 +1073,9 @@ client_send_cb (void *stream,
1071 /* calculate how much fits in buffer */ 1073 /* calculate how much fits in buffer */
1072 len = GNUNET_MIN (msg->size - msg->pos, 1074 len = GNUNET_MIN (msg->size - msg->pos,
1073 size * nmemb); 1075 size * nmemb);
1074 GNUNET_memcpy (stream, &msg->buf[msg->pos], len); 1076 GNUNET_memcpy (stream,
1077 &msg->buf[msg->pos],
1078 len);
1075 msg->pos += len; 1079 msg->pos += len;
1076 if (msg->pos == msg->size) 1080 if (msg->pos == msg->size)
1077 { 1081 {