diff options
author | Christian Grothoff <christian@grothoff.org> | 2010-10-20 13:17:43 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2010-10-20 13:17:43 +0000 |
commit | d6cf94d0e01acaef84292a052c2cc045dfd7d0b2 (patch) | |
tree | ea155327d7dec37d9b619881d018874d402da58b /src/datastore | |
parent | 6a9d2a6399b00fedb0ec0b921d1e7068f0be33b1 (diff) | |
download | gnunet-d6cf94d0e01acaef84292a052c2cc045dfd7d0b2.tar.gz gnunet-d6cf94d0e01acaef84292a052c2cc045dfd7d0b2.zip |
logging
Diffstat (limited to 'src/datastore')
-rw-r--r-- | src/datastore/datastore_api.c | 40 |
1 files changed, 35 insertions, 5 deletions
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c index 58340ed6c..abc8c7645 100644 --- a/src/datastore/datastore_api.c +++ b/src/datastore/datastore_api.c | |||
@@ -799,7 +799,13 @@ GNUNET_DATASTORE_put (struct GNUNET_DATASTORE_Handle *h, | |||
799 | queue_priority, max_queue_size, timeout, | 799 | queue_priority, max_queue_size, timeout, |
800 | &process_status_message, &qc); | 800 | &process_status_message, &qc); |
801 | if (qe == NULL) | 801 | if (qe == NULL) |
802 | return NULL; | 802 | { |
803 | #if DEBUG_DATASTORE | ||
804 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
805 | "Could not create queue entry for PUT\n"); | ||
806 | #endif | ||
807 | return NULL; | ||
808 | } | ||
803 | dm = (struct DataMessage* ) &qe[1]; | 809 | dm = (struct DataMessage* ) &qe[1]; |
804 | dm->header.type = htons(GNUNET_MESSAGE_TYPE_DATASTORE_PUT); | 810 | dm->header.type = htons(GNUNET_MESSAGE_TYPE_DATASTORE_PUT); |
805 | dm->header.size = htons(msize); | 811 | dm->header.size = htons(msize); |
@@ -864,7 +870,13 @@ GNUNET_DATASTORE_reserve (struct GNUNET_DATASTORE_Handle *h, | |||
864 | queue_priority, max_queue_size, timeout, | 870 | queue_priority, max_queue_size, timeout, |
865 | &process_status_message, &qc); | 871 | &process_status_message, &qc); |
866 | if (qe == NULL) | 872 | if (qe == NULL) |
867 | return NULL; | 873 | { |
874 | #if DEBUG_DATASTORE | ||
875 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
876 | "Could not create queue entry to reserve\n"); | ||
877 | #endif | ||
878 | return NULL; | ||
879 | } | ||
868 | rm = (struct ReserveMessage*) &qe[1]; | 880 | rm = (struct ReserveMessage*) &qe[1]; |
869 | rm->header.type = htons(GNUNET_MESSAGE_TYPE_DATASTORE_RESERVE); | 881 | rm->header.type = htons(GNUNET_MESSAGE_TYPE_DATASTORE_RESERVE); |
870 | rm->header.size = htons(sizeof (struct ReserveMessage)); | 882 | rm->header.size = htons(sizeof (struct ReserveMessage)); |
@@ -922,7 +934,13 @@ GNUNET_DATASTORE_release_reserve (struct GNUNET_DATASTORE_Handle *h, | |||
922 | queue_priority, max_queue_size, timeout, | 934 | queue_priority, max_queue_size, timeout, |
923 | &process_status_message, &qc); | 935 | &process_status_message, &qc); |
924 | if (qe == NULL) | 936 | if (qe == NULL) |
925 | return NULL; | 937 | { |
938 | #if DEBUG_DATASTORE | ||
939 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
940 | "Could not create queue entry to release reserve\n"); | ||
941 | #endif | ||
942 | return NULL; | ||
943 | } | ||
926 | rrm = (struct ReleaseReserveMessage*) &qe[1]; | 944 | rrm = (struct ReleaseReserveMessage*) &qe[1]; |
927 | rrm->header.type = htons(GNUNET_MESSAGE_TYPE_DATASTORE_RELEASE_RESERVE); | 945 | rrm->header.type = htons(GNUNET_MESSAGE_TYPE_DATASTORE_RELEASE_RESERVE); |
928 | rrm->header.size = htons(sizeof (struct ReleaseReserveMessage)); | 946 | rrm->header.size = htons(sizeof (struct ReleaseReserveMessage)); |
@@ -979,7 +997,13 @@ GNUNET_DATASTORE_update (struct GNUNET_DATASTORE_Handle *h, | |||
979 | queue_priority, max_queue_size, timeout, | 997 | queue_priority, max_queue_size, timeout, |
980 | &process_status_message, &qc); | 998 | &process_status_message, &qc); |
981 | if (qe == NULL) | 999 | if (qe == NULL) |
982 | return NULL; | 1000 | { |
1001 | #if DEBUG_DATASTORE | ||
1002 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
1003 | "Could not create queue entry for UPDATE\n"); | ||
1004 | #endif | ||
1005 | return NULL; | ||
1006 | } | ||
983 | um = (struct UpdateMessage*) &qe[1]; | 1007 | um = (struct UpdateMessage*) &qe[1]; |
984 | um->header.type = htons(GNUNET_MESSAGE_TYPE_DATASTORE_UPDATE); | 1008 | um->header.type = htons(GNUNET_MESSAGE_TYPE_DATASTORE_UPDATE); |
985 | um->header.size = htons(sizeof (struct UpdateMessage)); | 1009 | um->header.size = htons(sizeof (struct UpdateMessage)); |
@@ -1256,7 +1280,13 @@ GNUNET_DATASTORE_get_zero_anonymity (struct GNUNET_DATASTORE_Handle *h, | |||
1256 | queue_priority, max_queue_size, timeout, | 1280 | queue_priority, max_queue_size, timeout, |
1257 | &process_result_message, &qc); | 1281 | &process_result_message, &qc); |
1258 | if (qe == NULL) | 1282 | if (qe == NULL) |
1259 | return NULL; | 1283 | { |
1284 | #if DEBUG_DATASTORE | ||
1285 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
1286 | "Could not create queue entry for zero-anonymity iteration\n"); | ||
1287 | #endif | ||
1288 | return NULL; | ||
1289 | } | ||
1260 | m = (struct GetZeroAnonymityMessage*) &qe[1]; | 1290 | m = (struct GetZeroAnonymityMessage*) &qe[1]; |
1261 | m->header.type = htons(GNUNET_MESSAGE_TYPE_DATASTORE_GET_RANDOM); | 1291 | m->header.type = htons(GNUNET_MESSAGE_TYPE_DATASTORE_GET_RANDOM); |
1262 | m->header.size = htons(sizeof (struct GetZeroAnonymityMessage)); | 1292 | m->header.size = htons(sizeof (struct GetZeroAnonymityMessage)); |