diff options
author | Christian Grothoff <christian@grothoff.org> | 2012-01-08 09:23:47 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2012-01-08 09:23:47 +0000 |
commit | 539be627c009c2f13da19d6ae847168c1f5d496e (patch) | |
tree | 78814fdb491c52349f793af5898858a56e32117a /src/fs/fs_search.c | |
parent | 941c7ee262792114da1811cf4404b04550e071b1 (diff) | |
download | gnunet-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.c | 8 |
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 | |||
835 | receive_results (void *cls, const struct GNUNET_MessageHeader *msg) | 835 | receive_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); |