diff options
Diffstat (limited to 'src/psycstore/plugin_psycstore_sqlite.c')
-rw-r--r-- | src/psycstore/plugin_psycstore_sqlite.c | 72 |
1 files changed, 36 insertions, 36 deletions
diff --git a/src/psycstore/plugin_psycstore_sqlite.c b/src/psycstore/plugin_psycstore_sqlite.c index 592eaf384..adc52c254 100644 --- a/src/psycstore/plugin_psycstore_sqlite.c +++ b/src/psycstore/plugin_psycstore_sqlite.c | |||
@@ -610,13 +610,13 @@ database_shutdown (struct Plugin *plugin) | |||
610 | GNUNET_free_non_null (plugin->fn); | 610 | GNUNET_free_non_null (plugin->fn); |
611 | } | 611 | } |
612 | 612 | ||
613 | /** | 613 | /** |
614 | * Execute a prepared statement with a @a channel_key argument. | 614 | * Execute a prepared statement with a @a channel_key argument. |
615 | * | 615 | * |
616 | * @param plugin Plugin handle. | 616 | * @param plugin Plugin handle. |
617 | * @param stmt Statement to execute. | 617 | * @param stmt Statement to execute. |
618 | * @param channel_key Public key of the channel. | 618 | * @param channel_key Public key of the channel. |
619 | * | 619 | * |
620 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 620 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
621 | */ | 621 | */ |
622 | static int | 622 | static int |
@@ -778,7 +778,7 @@ slave_key_store (struct Plugin *plugin, | |||
778 | } | 778 | } |
779 | 779 | ||
780 | 780 | ||
781 | /** | 781 | /** |
782 | * Store join/leave events for a PSYC channel in order to be able to answer | 782 | * Store join/leave events for a PSYC channel in order to be able to answer |
783 | * membership test queries later. | 783 | * membership test queries later. |
784 | * | 784 | * |
@@ -840,11 +840,11 @@ membership_store (void *cls, | |||
840 | return GNUNET_OK; | 840 | return GNUNET_OK; |
841 | } | 841 | } |
842 | 842 | ||
843 | /** | 843 | /** |
844 | * Test if a member was admitted to the channel at the given message ID. | 844 | * Test if a member was admitted to the channel at the given message ID. |
845 | * | 845 | * |
846 | * @see GNUNET_PSYCSTORE_membership_test() | 846 | * @see GNUNET_PSYCSTORE_membership_test() |
847 | * | 847 | * |
848 | * @return #GNUNET_YES if the member was admitted, #GNUNET_NO if not, | 848 | * @return #GNUNET_YES if the member was admitted, #GNUNET_NO if not, |
849 | * #GNUNET_SYSERR if there was en error. | 849 | * #GNUNET_SYSERR if there was en error. |
850 | */ | 850 | */ |
@@ -888,11 +888,11 @@ membership_test (void *cls, | |||
888 | return ret; | 888 | return ret; |
889 | } | 889 | } |
890 | 890 | ||
891 | /** | 891 | /** |
892 | * Store a message fragment sent to a channel. | 892 | * Store a message fragment sent to a channel. |
893 | * | 893 | * |
894 | * @see GNUNET_PSYCSTORE_fragment_store() | 894 | * @see GNUNET_PSYCSTORE_fragment_store() |
895 | * | 895 | * |
896 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 896 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
897 | */ | 897 | */ |
898 | static int | 898 | static int |
@@ -961,11 +961,11 @@ fragment_store (void *cls, | |||
961 | return GNUNET_OK; | 961 | return GNUNET_OK; |
962 | } | 962 | } |
963 | 963 | ||
964 | /** | 964 | /** |
965 | * Set additional flags for a given message. | 965 | * Set additional flags for a given message. |
966 | * | 966 | * |
967 | * They are OR'd with any existing flags set. | 967 | * They are OR'd with any existing flags set. |
968 | * | 968 | * |
969 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 969 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
970 | */ | 970 | */ |
971 | static int | 971 | static int |
@@ -1036,11 +1036,11 @@ fragment_row (sqlite3_stmt *stmt, GNUNET_PSYCSTORE_FragmentCallback cb, | |||
1036 | return cb (cb_cls, (void *) msg, sqlite3_column_int64 (stmt, 8)); | 1036 | return cb (cb_cls, (void *) msg, sqlite3_column_int64 (stmt, 8)); |
1037 | } | 1037 | } |
1038 | 1038 | ||
1039 | /** | 1039 | /** |
1040 | * Retrieve a message fragment by fragment ID. | 1040 | * Retrieve a message fragment by fragment ID. |
1041 | * | 1041 | * |
1042 | * @see GNUNET_PSYCSTORE_fragment_get() | 1042 | * @see GNUNET_PSYCSTORE_fragment_get() |
1043 | * | 1043 | * |
1044 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 1044 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
1045 | */ | 1045 | */ |
1046 | static int | 1046 | static int |
@@ -1087,11 +1087,11 @@ fragment_get (void *cls, | |||
1087 | return ret; | 1087 | return ret; |
1088 | } | 1088 | } |
1089 | 1089 | ||
1090 | /** | 1090 | /** |
1091 | * Retrieve all fragments of a message. | 1091 | * Retrieve all fragments of a message. |
1092 | * | 1092 | * |
1093 | * @see GNUNET_PSYCSTORE_message_get() | 1093 | * @see GNUNET_PSYCSTORE_message_get() |
1094 | * | 1094 | * |
1095 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 1095 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
1096 | */ | 1096 | */ |
1097 | static int | 1097 | static int |
@@ -1150,12 +1150,12 @@ message_get (void *cls, | |||
1150 | return ret; | 1150 | return ret; |
1151 | } | 1151 | } |
1152 | 1152 | ||
1153 | /** | 1153 | /** |
1154 | * Retrieve a fragment of message specified by its message ID and fragment | 1154 | * Retrieve a fragment of message specified by its message ID and fragment |
1155 | * offset. | 1155 | * offset. |
1156 | * | 1156 | * |
1157 | * @see GNUNET_PSYCSTORE_message_get_fragment() | 1157 | * @see GNUNET_PSYCSTORE_message_get_fragment() |
1158 | * | 1158 | * |
1159 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 1159 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
1160 | */ | 1160 | */ |
1161 | static int | 1161 | static int |
@@ -1204,11 +1204,11 @@ message_get_fragment (void *cls, | |||
1204 | return ret; | 1204 | return ret; |
1205 | } | 1205 | } |
1206 | 1206 | ||
1207 | /** | 1207 | /** |
1208 | * Retrieve the max. values of message counters for a channel. | 1208 | * Retrieve the max. values of message counters for a channel. |
1209 | * | 1209 | * |
1210 | * @see GNUNET_PSYCSTORE_counters_get() | 1210 | * @see GNUNET_PSYCSTORE_counters_get() |
1211 | * | 1211 | * |
1212 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 1212 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
1213 | */ | 1213 | */ |
1214 | static int | 1214 | static int |
@@ -1257,11 +1257,11 @@ counters_message_get (void *cls, | |||
1257 | return ret; | 1257 | return ret; |
1258 | } | 1258 | } |
1259 | 1259 | ||
1260 | /** | 1260 | /** |
1261 | * Retrieve the max. values of state counters for a channel. | 1261 | * Retrieve the max. values of state counters for a channel. |
1262 | * | 1262 | * |
1263 | * @see GNUNET_PSYCSTORE_counters_get() | 1263 | * @see GNUNET_PSYCSTORE_counters_get() |
1264 | * | 1264 | * |
1265 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 1265 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
1266 | */ | 1266 | */ |
1267 | static int | 1267 | static int |
@@ -1307,9 +1307,9 @@ counters_state_get (void *cls, | |||
1307 | } | 1307 | } |
1308 | 1308 | ||
1309 | 1309 | ||
1310 | /** | 1310 | /** |
1311 | * Set a state variable to the given value. | 1311 | * Set a state variable to the given value. |
1312 | * | 1312 | * |
1313 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 1313 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
1314 | */ | 1314 | */ |
1315 | static int | 1315 | static int |
@@ -1440,11 +1440,11 @@ state_modify_begin (void *cls, | |||
1440 | } | 1440 | } |
1441 | 1441 | ||
1442 | 1442 | ||
1443 | /** | 1443 | /** |
1444 | * Set the current value of state variable. | 1444 | * Set the current value of state variable. |
1445 | * | 1445 | * |
1446 | * @see GNUNET_PSYCSTORE_state_modify() | 1446 | * @see GNUNET_PSYCSTORE_state_modify() |
1447 | * | 1447 | * |
1448 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 1448 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
1449 | */ | 1449 | */ |
1450 | static int | 1450 | static int |
@@ -1494,11 +1494,11 @@ state_sync_begin (void *cls, | |||
1494 | } | 1494 | } |
1495 | 1495 | ||
1496 | 1496 | ||
1497 | /** | 1497 | /** |
1498 | * Set the current value of state variable. | 1498 | * Set the current value of state variable. |
1499 | * | 1499 | * |
1500 | * @see GNUNET_PSYCSTORE_state_modify() | 1500 | * @see GNUNET_PSYCSTORE_state_modify() |
1501 | * | 1501 | * |
1502 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 1502 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
1503 | */ | 1503 | */ |
1504 | static int | 1504 | static int |
@@ -1539,11 +1539,11 @@ state_sync_end (void *cls, | |||
1539 | } | 1539 | } |
1540 | 1540 | ||
1541 | 1541 | ||
1542 | /** | 1542 | /** |
1543 | * Reset the state of a channel. | 1543 | * Reset the state of a channel. |
1544 | * | 1544 | * |
1545 | * @see GNUNET_PSYCSTORE_state_reset() | 1545 | * @see GNUNET_PSYCSTORE_state_reset() |
1546 | * | 1546 | * |
1547 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 1547 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
1548 | */ | 1548 | */ |
1549 | static int | 1549 | static int |
@@ -1554,11 +1554,11 @@ state_reset (void *cls, const struct GNUNET_CRYPTO_EccPublicSignKey *channel_key | |||
1554 | } | 1554 | } |
1555 | 1555 | ||
1556 | 1556 | ||
1557 | /** | 1557 | /** |
1558 | * Update signed values of state variables in the state store. | 1558 | * Update signed values of state variables in the state store. |
1559 | * | 1559 | * |
1560 | * @see GNUNET_PSYCSTORE_state_hash_update() | 1560 | * @see GNUNET_PSYCSTORE_state_hash_update() |
1561 | * | 1561 | * |
1562 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 1562 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
1563 | */ | 1563 | */ |
1564 | static int | 1564 | static int |
@@ -1570,11 +1570,11 @@ state_update_signed (void *cls, | |||
1570 | } | 1570 | } |
1571 | 1571 | ||
1572 | 1572 | ||
1573 | /** | 1573 | /** |
1574 | * Retrieve a state variable by name. | 1574 | * Retrieve a state variable by name. |
1575 | * | 1575 | * |
1576 | * @see GNUNET_PSYCSTORE_state_get() | 1576 | * @see GNUNET_PSYCSTORE_state_get() |
1577 | * | 1577 | * |
1578 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 1578 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
1579 | */ | 1579 | */ |
1580 | static int | 1580 | static int |
@@ -1621,11 +1621,11 @@ state_get (void *cls, const struct GNUNET_CRYPTO_EccPublicSignKey *channel_key, | |||
1621 | } | 1621 | } |
1622 | 1622 | ||
1623 | 1623 | ||
1624 | /** | 1624 | /** |
1625 | * Retrieve all state variables for a channel with the given prefix. | 1625 | * Retrieve all state variables for a channel with the given prefix. |
1626 | * | 1626 | * |
1627 | * @see GNUNET_PSYCSTORE_state_get_prefix() | 1627 | * @see GNUNET_PSYCSTORE_state_get_prefix() |
1628 | * | 1628 | * |
1629 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 1629 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
1630 | */ | 1630 | */ |
1631 | static int | 1631 | static int |
@@ -1688,11 +1688,11 @@ state_get_prefix (void *cls, const struct GNUNET_CRYPTO_EccPublicSignKey *channe | |||
1688 | } | 1688 | } |
1689 | 1689 | ||
1690 | 1690 | ||
1691 | /** | 1691 | /** |
1692 | * Retrieve all signed state variables for a channel. | 1692 | * Retrieve all signed state variables for a channel. |
1693 | * | 1693 | * |
1694 | * @see GNUNET_PSYCSTORE_state_get_signed() | 1694 | * @see GNUNET_PSYCSTORE_state_get_signed() |
1695 | * | 1695 | * |
1696 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR | 1696 | * @return #GNUNET_OK on success, else #GNUNET_SYSERR |
1697 | */ | 1697 | */ |
1698 | static int | 1698 | static int |
@@ -1748,7 +1748,7 @@ state_get_signed (void *cls, | |||
1748 | } | 1748 | } |
1749 | 1749 | ||
1750 | 1750 | ||
1751 | /** | 1751 | /** |
1752 | * Entry point for the plugin. | 1752 | * Entry point for the plugin. |
1753 | * | 1753 | * |
1754 | * @param cls The struct GNUNET_CONFIGURATION_Handle. | 1754 | * @param cls The struct GNUNET_CONFIGURATION_Handle. |