diff options
author | Omar Tarabai <tarabai@devegypt.com> | 2014-05-16 16:45:43 +0000 |
---|---|---|
committer | Omar Tarabai <tarabai@devegypt.com> | 2014-05-16 16:45:43 +0000 |
commit | 3c9e8b1b0f7f83f27fefb02bd67b481c67cad0c8 (patch) | |
tree | 525ae2f8cec03f298783aa693d465f789171cf51 /src/peerstore/gnunet-service-peerstore.c | |
parent | aeaf5c97d7d115d99f30e86be66c622b7a6ebf4f (diff) | |
download | gnunet-3c9e8b1b0f7f83f27fefb02bd67b481c67cad0c8.tar.gz gnunet-3c9e8b1b0f7f83f27fefb02bd67b481c67cad0c8.zip |
peerstore API now uses MQ
Diffstat (limited to 'src/peerstore/gnunet-service-peerstore.c')
-rw-r--r-- | src/peerstore/gnunet-service-peerstore.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/peerstore/gnunet-service-peerstore.c b/src/peerstore/gnunet-service-peerstore.c index be5394ff5..50af4342c 100644 --- a/src/peerstore/gnunet-service-peerstore.c +++ b/src/peerstore/gnunet-service-peerstore.c | |||
@@ -87,7 +87,7 @@ handle_client_disconnect (void *cls, | |||
87 | * @param sub_system name of the GNUnet sub system responsible | 87 | * @param sub_system name of the GNUnet sub system responsible |
88 | * @param value stored value | 88 | * @param value stored value |
89 | * @param size size of stored value | 89 | * @param size size of stored value |
90 | */ | 90 | * |
91 | int record_iterator(void *cls, | 91 | int record_iterator(void *cls, |
92 | const char *sub_system, | 92 | const char *sub_system, |
93 | const struct GNUNET_PeerIdentity *peer, | 93 | const struct GNUNET_PeerIdentity *peer, |
@@ -108,7 +108,7 @@ int record_iterator(void *cls, | |||
108 | GNUNET_MESSAGE_TYPE_PEERSTORE_ITERATE); | 108 | GNUNET_MESSAGE_TYPE_PEERSTORE_ITERATE); |
109 | GNUNET_SERVER_transmit_context_append_message(tc, (const struct GNUNET_MessageHeader *)srm); | 109 | GNUNET_SERVER_transmit_context_append_message(tc, (const struct GNUNET_MessageHeader *)srm); |
110 | return GNUNET_YES; | 110 | return GNUNET_YES; |
111 | } | 111 | }*/ |
112 | 112 | ||
113 | /** | 113 | /** |
114 | * Handle an iterate request from client | 114 | * Handle an iterate request from client |
@@ -116,7 +116,7 @@ int record_iterator(void *cls, | |||
116 | * @param cls unused | 116 | * @param cls unused |
117 | * @param client identification of the client | 117 | * @param client identification of the client |
118 | * @param message the actual message | 118 | * @param message the actual message |
119 | */ | 119 | * |
120 | void handle_iterate (void *cls, | 120 | void handle_iterate (void *cls, |
121 | struct GNUNET_SERVER_Client *client, | 121 | struct GNUNET_SERVER_Client *client, |
122 | const struct GNUNET_MessageHeader *message) | 122 | const struct GNUNET_MessageHeader *message) |
@@ -147,7 +147,7 @@ void handle_iterate (void *cls, | |||
147 | { | 147 | { |
148 | 148 | ||
149 | } | 149 | } |
150 | } | 150 | }*/ |
151 | 151 | ||
152 | /** | 152 | /** |
153 | * Handle a store request from client | 153 | * Handle a store request from client |
@@ -190,7 +190,7 @@ void handle_store (void *cls, | |||
190 | record->key, | 190 | record->key, |
191 | record->value, | 191 | record->value, |
192 | record->value_size, | 192 | record->value_size, |
193 | record->expiry)) | 193 | *record->expiry)) |
194 | { | 194 | { |
195 | response_type = GNUNET_MESSAGE_TYPE_PEERSTORE_STORE_RESULT_OK; | 195 | response_type = GNUNET_MESSAGE_TYPE_PEERSTORE_STORE_RESULT_OK; |
196 | } | 196 | } |
@@ -220,7 +220,7 @@ run (void *cls, | |||
220 | { | 220 | { |
221 | static const struct GNUNET_SERVER_MessageHandler handlers[] = { | 221 | static const struct GNUNET_SERVER_MessageHandler handlers[] = { |
222 | {&handle_store, NULL, GNUNET_MESSAGE_TYPE_PEERSTORE_STORE, 0}, | 222 | {&handle_store, NULL, GNUNET_MESSAGE_TYPE_PEERSTORE_STORE, 0}, |
223 | {&handle_iterate, NULL, GNUNET_MESSAGE_TYPE_PEERSTORE_ITERATE, 0}, | 223 | // {&handle_iterate, NULL, GNUNET_MESSAGE_TYPE_PEERSTORE_ITERATE, 0}, |
224 | {NULL, NULL, 0, 0} | 224 | {NULL, NULL, 0, 0} |
225 | }; | 225 | }; |
226 | char *database; | 226 | char *database; |