aboutsummaryrefslogtreecommitdiff
path: root/src/datastore
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2013-11-18 20:58:26 +0000
committerChristian Grothoff <christian@grothoff.org>2013-11-18 20:58:26 +0000
commit52a8cdf68084f35bde47132849cf0243eca35c35 (patch)
tree741f6a031b12aa5df68b6b662312b4fc05a855dd /src/datastore
parente1f3b5eb1559882ec646b297c9fb7bd9c7b17307 (diff)
downloadgnunet-52a8cdf68084f35bde47132849cf0243eca35c35.tar.gz
gnunet-52a8cdf68084f35bde47132849cf0243eca35c35.zip
-doxygen fixes
Diffstat (limited to 'src/datastore')
-rw-r--r--src/datastore/datastore_api.c46
1 files changed, 24 insertions, 22 deletions
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c
index 13e0a1162..6a994fbb0 100644
--- a/src/datastore/datastore_api.c
+++ b/src/datastore/datastore_api.c
@@ -293,10 +293,10 @@ disconnect_after_drop (void *cls,
293/** 293/**
294 * Transmit DROP message to datastore service. 294 * Transmit DROP message to datastore service.
295 * 295 *
296 * @param cls the 'struct GNUNET_DATASTORE_Handle' 296 * @param cls the `struct GNUNET_DATASTORE_Handle`
297 * @param size number of bytes that can be copied to buf 297 * @param size number of bytes that can be copied to @a buf
298 * @param buf where to copy the drop message 298 * @param buf where to copy the drop message
299 * @return number of bytes written to buf 299 * @return number of bytes written to @a buf
300 */ 300 */
301static size_t 301static size_t
302transmit_drop (void *cls, size_t size, void *buf) 302transmit_drop (void *cls, size_t size, void *buf)
@@ -327,7 +327,7 @@ transmit_drop (void *cls, size_t size, void *buf)
327 * associated resources). 327 * associated resources).
328 * 328 *
329 * @param h handle to the datastore 329 * @param h handle to the datastore
330 * @param drop set to GNUNET_YES to delete all data in datastore (!) 330 * @param drop set to #GNUNET_YES to delete all data in datastore (!)
331 */ 331 */
332void 332void
333GNUNET_DATASTORE_disconnect (struct GNUNET_DATASTORE_Handle *h, int drop) 333GNUNET_DATASTORE_disconnect (struct GNUNET_DATASTORE_Handle *h, int drop)
@@ -512,7 +512,7 @@ process_queue (struct GNUNET_DATASTORE_Handle *h);
512/** 512/**
513 * Try reconnecting to the datastore service. 513 * Try reconnecting to the datastore service.
514 * 514 *
515 * @param cls the 'struct GNUNET_DATASTORE_Handle' 515 * @param cls the `struct GNUNET_DATASTORE_Handle`
516 * @param tc scheduler context 516 * @param tc scheduler context
517 */ 517 */
518static void 518static void
@@ -594,10 +594,10 @@ receive_cb (void *cls, const struct GNUNET_MessageHeader *msg)
594/** 594/**
595 * Transmit request from queue to datastore service. 595 * Transmit request from queue to datastore service.
596 * 596 *
597 * @param cls the 'struct GNUNET_DATASTORE_Handle' 597 * @param cls the `struct GNUNET_DATASTORE_Handle`
598 * @param size number of bytes that can be copied to buf 598 * @param size number of bytes that can be copied to @a buf
599 * @param buf where to copy the drop message 599 * @param buf where to copy the drop message
600 * @return number of bytes written to buf 600 * @return number of bytes written to @a buf
601 */ 601 */
602static size_t 602static size_t
603transmit_request (void *cls, size_t size, void *buf) 603transmit_request (void *cls, size_t size, void *buf)
@@ -835,7 +835,7 @@ process_status_message (void *cls, const struct GNUNET_MessageHeader *msg)
835 * (if other requests of higher priority are in the queue) 835 * (if other requests of higher priority are in the queue)
836 * @param timeout timeout for the operation 836 * @param timeout timeout for the operation
837 * @param cont continuation to call when done 837 * @param cont continuation to call when done
838 * @param cont_cls closure for cont 838 * @param cont_cls closure for @a cont
839 * @return NULL if the entry was not queued, otherwise a handle that can be used to 839 * @return NULL if the entry was not queued, otherwise a handle that can be used to
840 * cancel; note that even if NULL is returned, the callback will be invoked 840 * cancel; note that even if NULL is returned, the callback will be invoked
841 * (or rather, will already have been invoked) 841 * (or rather, will already have been invoked)
@@ -908,7 +908,7 @@ GNUNET_DATASTORE_put (struct GNUNET_DATASTORE_Handle *h, uint32_t rid,
908 * @param timeout how long to wait at most for a response (or before dying in queue) 908 * @param timeout how long to wait at most for a response (or before dying in queue)
909 * @param cont continuation to call when done; "success" will be set to 909 * @param cont continuation to call when done; "success" will be set to
910 * a positive reservation value if space could be reserved. 910 * a positive reservation value if space could be reserved.
911 * @param cont_cls closure for cont 911 * @param cont_cls closure for @a cont
912 * @return NULL if the entry was not queued, otherwise a handle that can be used to 912 * @return NULL if the entry was not queued, otherwise a handle that can be used to
913 * cancel; note that even if NULL is returned, the callback will be invoked 913 * cancel; note that even if NULL is returned, the callback will be invoked
914 * (or rather, will already have been invoked) 914 * (or rather, will already have been invoked)
@@ -936,7 +936,8 @@ GNUNET_DATASTORE_reserve (struct GNUNET_DATASTORE_Handle *h, uint64_t amount,
936 max_queue_size, timeout, &process_status_message, &qc); 936 max_queue_size, timeout, &process_status_message, &qc);
937 if (qe == NULL) 937 if (qe == NULL)
938 { 938 {
939 LOG (GNUNET_ERROR_TYPE_DEBUG, "Could not create queue entry to reserve\n"); 939 LOG (GNUNET_ERROR_TYPE_DEBUG,
940 "Could not create queue entry to reserve\n");
940 return NULL; 941 return NULL;
941 } 942 }
942 GNUNET_STATISTICS_update (h->stats, 943 GNUNET_STATISTICS_update (h->stats,
@@ -968,7 +969,7 @@ GNUNET_DATASTORE_reserve (struct GNUNET_DATASTORE_Handle *h, uint64_t amount,
968 * (if other requests of higher priority are in the queue) 969 * (if other requests of higher priority are in the queue)
969 * @param timeout how long to wait at most for a response 970 * @param timeout how long to wait at most for a response
970 * @param cont continuation to call when done 971 * @param cont continuation to call when done
971 * @param cont_cls closure for cont 972 * @param cont_cls closure for @a cont
972 * @return NULL if the entry was not queued, otherwise a handle that can be used to 973 * @return NULL if the entry was not queued, otherwise a handle that can be used to
973 * cancel; note that even if NULL is returned, the callback will be invoked 974 * cancel; note that even if NULL is returned, the callback will be invoked
974 * (or rather, will already have been invoked) 975 * (or rather, will already have been invoked)
@@ -1024,7 +1025,7 @@ GNUNET_DATASTORE_release_reserve (struct GNUNET_DATASTORE_Handle *h,
1024 * (if other requests of higher priority are in the queue) 1025 * (if other requests of higher priority are in the queue)
1025 * @param timeout how long to wait at most for a response 1026 * @param timeout how long to wait at most for a response
1026 * @param cont continuation to call when done 1027 * @param cont continuation to call when done
1027 * @param cont_cls closure for cont 1028 * @param cont_cls closure for @a cont
1028 * @return NULL if the entry was not queued, otherwise a handle that can be used to 1029 * @return NULL if the entry was not queued, otherwise a handle that can be used to
1029 * cancel; note that even if NULL is returned, the callback will be invoked 1030 * cancel; note that even if NULL is returned, the callback will be invoked
1030 * (or rather, will already have been invoked) 1031 * (or rather, will already have been invoked)
@@ -1056,7 +1057,8 @@ GNUNET_DATASTORE_update (struct GNUNET_DATASTORE_Handle *h, uint64_t uid,
1056 max_queue_size, timeout, &process_status_message, &qc); 1057 max_queue_size, timeout, &process_status_message, &qc);
1057 if (qe == NULL) 1058 if (qe == NULL)
1058 { 1059 {
1059 LOG (GNUNET_ERROR_TYPE_DEBUG, "Could not create queue entry for UPDATE\n"); 1060 LOG (GNUNET_ERROR_TYPE_DEBUG,
1061 "Could not create queue entry for UPDATE\n");
1060 return NULL; 1062 return NULL;
1061 } 1063 }
1062 GNUNET_STATISTICS_update (h->stats, 1064 GNUNET_STATISTICS_update (h->stats,
@@ -1075,9 +1077,9 @@ GNUNET_DATASTORE_update (struct GNUNET_DATASTORE_Handle *h, uint64_t uid,
1075 1077
1076/** 1078/**
1077 * Explicitly remove some content from the database. 1079 * Explicitly remove some content from the database.
1078 * The "cont"inuation will be called with status 1080 * The @a cont continuation will be called with `status`
1079 * "GNUNET_OK" if content was removed, "GNUNET_NO" 1081 * #GNUNET_OK" if content was removed, #GNUNET_NO
1080 * if no matching entry was found and "GNUNET_SYSERR" 1082 * if no matching entry was found and #GNUNET_SYSERR
1081 * on all other types of errors. 1083 * on all other types of errors.
1082 * 1084 *
1083 * @param h handle to the datastore 1085 * @param h handle to the datastore
@@ -1089,7 +1091,7 @@ GNUNET_DATASTORE_update (struct GNUNET_DATASTORE_Handle *h, uint64_t uid,
1089 * (if other requests of higher priority are in the queue) 1091 * (if other requests of higher priority are in the queue)
1090 * @param timeout how long to wait at most for a response 1092 * @param timeout how long to wait at most for a response
1091 * @param cont continuation to call when done 1093 * @param cont continuation to call when done
1092 * @param cont_cls closure for cont 1094 * @param cont_cls closure for @a cont
1093 * @return NULL if the entry was not queued, otherwise a handle that can be used to 1095 * @return NULL if the entry was not queued, otherwise a handle that can be used to
1094 * cancel; note that even if NULL is returned, the callback will be invoked 1096 * cancel; note that even if NULL is returned, the callback will be invoked
1095 * (or rather, will already have been invoked) 1097 * (or rather, will already have been invoked)
@@ -1147,7 +1149,7 @@ GNUNET_DATASTORE_remove (struct GNUNET_DATASTORE_Handle *h,
1147 * Type of a function to call when we receive a message 1149 * Type of a function to call when we receive a message
1148 * from the service. 1150 * from the service.
1149 * 1151 *
1150 * @param cls closure 1152 * @param cls closure with the `struct GNUNET_DATASTORE_Handle *`
1151 * @param msg message received, NULL on timeout or fatal error 1153 * @param msg message received, NULL on timeout or fatal error
1152 */ 1154 */
1153static void 1155static void
@@ -1262,7 +1264,7 @@ process_result_message (void *cls, const struct GNUNET_MessageHeader *msg)
1262 * @param proc function to call on a random value; it 1264 * @param proc function to call on a random value; it
1263 * will be called once with a value (if available) 1265 * will be called once with a value (if available)
1264 * and always once with a value of NULL. 1266 * and always once with a value of NULL.
1265 * @param proc_cls closure for proc 1267 * @param proc_cls closure for @a proc
1266 * @return NULL if the entry was not queued, otherwise a handle that can be used to 1268 * @return NULL if the entry was not queued, otherwise a handle that can be used to
1267 * cancel 1269 * cancel
1268 */ 1270 */
@@ -1321,7 +1323,7 @@ GNUNET_DATASTORE_get_for_replication (struct GNUNET_DATASTORE_Handle *h,
1321 * @param proc function to call on a random value; it 1323 * @param proc function to call on a random value; it
1322 * will be called once with a value (if available) 1324 * will be called once with a value (if available)
1323 * or with NULL if none value exists. 1325 * or with NULL if none value exists.
1324 * @param proc_cls closure for proc 1326 * @param proc_cls closure for @a proc
1325 * @return NULL if the entry was not queued, otherwise a handle that can be used to 1327 * @return NULL if the entry was not queued, otherwise a handle that can be used to
1326 * cancel 1328 * cancel
1327 */ 1329 */
@@ -1387,7 +1389,7 @@ GNUNET_DATASTORE_get_zero_anonymity (struct GNUNET_DATASTORE_Handle *h,
1387 * @param timeout how long to wait at most for a response 1389 * @param timeout how long to wait at most for a response
1388 * @param proc function to call on each matching value; 1390 * @param proc function to call on each matching value;
1389 * will be called once with a NULL value at the end 1391 * will be called once with a NULL value at the end
1390 * @param proc_cls closure for proc 1392 * @param proc_cls closure for @a proc
1391 * @return NULL if the entry was not queued, otherwise a handle that can be used to 1393 * @return NULL if the entry was not queued, otherwise a handle that can be used to
1392 * cancel 1394 * cancel
1393 */ 1395 */