aboutsummaryrefslogtreecommitdiff
path: root/src/peerstore/gnunet-service-peerstore.c
diff options
context:
space:
mode:
authorOmar Tarabai <tarabai@devegypt.com>2014-05-16 16:45:43 +0000
committerOmar Tarabai <tarabai@devegypt.com>2014-05-16 16:45:43 +0000
commit3c9e8b1b0f7f83f27fefb02bd67b481c67cad0c8 (patch)
tree525ae2f8cec03f298783aa693d465f789171cf51 /src/peerstore/gnunet-service-peerstore.c
parentaeaf5c97d7d115d99f30e86be66c622b7a6ebf4f (diff)
downloadgnunet-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.c12
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 *
91int record_iterator(void *cls, 91int 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 *
120void handle_iterate (void *cls, 120void 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;