aboutsummaryrefslogtreecommitdiff
path: root/src/fs/fs_search.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2012-01-08 09:23:47 +0000
committerChristian Grothoff <christian@grothoff.org>2012-01-08 09:23:47 +0000
commit539be627c009c2f13da19d6ae847168c1f5d496e (patch)
tree78814fdb491c52349f793af5898858a56e32117a /src/fs/fs_search.c
parent941c7ee262792114da1811cf4404b04550e071b1 (diff)
downloadgnunet-539be627c009c2f13da19d6ae847168c1f5d496e.tar.gz
gnunet-539be627c009c2f13da19d6ae847168c1f5d496e.zip
-LRN: my experimental block download time measurer. The results
can be found there - [1]. [1] http://lrn.no-ip.info/other/gnunet_download_tie.log
Diffstat (limited to 'src/fs/fs_search.c')
-rw-r--r--src/fs/fs_search.c8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/fs/fs_search.c b/src/fs/fs_search.c
index 55db586b0..03b4a7dfd 100644
--- a/src/fs/fs_search.c
+++ b/src/fs/fs_search.c
@@ -835,11 +835,11 @@ static void
835receive_results (void *cls, const struct GNUNET_MessageHeader *msg) 835receive_results (void *cls, const struct GNUNET_MessageHeader *msg)
836{ 836{
837 struct GNUNET_FS_SearchContext *sc = cls; 837 struct GNUNET_FS_SearchContext *sc = cls;
838 const struct PutMessage *cm; 838 const struct ClientPutMessage *cm;
839 uint16_t msize; 839 uint16_t msize;
840 840
841 if ((NULL == msg) || (ntohs (msg->type) != GNUNET_MESSAGE_TYPE_FS_PUT) || 841 if ((NULL == msg) || (ntohs (msg->type) != GNUNET_MESSAGE_TYPE_FS_PUT) ||
842 (ntohs (msg->size) <= sizeof (struct PutMessage))) 842 (ntohs (msg->size) <= sizeof (struct ClientPutMessage)))
843 { 843 {
844 try_reconnect (sc); 844 try_reconnect (sc);
845 return; 845 return;
@@ -847,10 +847,10 @@ receive_results (void *cls, const struct GNUNET_MessageHeader *msg)
847 msize = ntohs (msg->size); 847 msize = ntohs (msg->size);
848 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 848 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
849 "Receiving %u bytes of result from fs service\n", msize); 849 "Receiving %u bytes of result from fs service\n", msize);
850 cm = (const struct PutMessage *) msg; 850 cm = (const struct ClientPutMessage *) msg;
851 process_result (sc, ntohl (cm->type), 851 process_result (sc, ntohl (cm->type),
852 GNUNET_TIME_absolute_ntoh (cm->expiration), &cm[1], 852 GNUNET_TIME_absolute_ntoh (cm->expiration), &cm[1],
853 msize - sizeof (struct PutMessage)); 853 msize - sizeof (struct ClientPutMessage));
854 /* continue receiving */ 854 /* continue receiving */
855 GNUNET_CLIENT_receive (sc->client, &receive_results, sc, 855 GNUNET_CLIENT_receive (sc->client, &receive_results, sc,
856 GNUNET_TIME_UNIT_FOREVER_REL); 856 GNUNET_TIME_UNIT_FOREVER_REL);