aboutsummaryrefslogtreecommitdiff
path: root/src/rps/rps_api.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/rps/rps_api.c')
-rw-r--r--src/rps/rps_api.c8
1 files changed, 2 insertions, 6 deletions
diff --git a/src/rps/rps_api.c b/src/rps/rps_api.c
index 30f0a75c5..91612c2f7 100644
--- a/src/rps/rps_api.c
+++ b/src/rps/rps_api.c
@@ -128,18 +128,14 @@ handle_reply (void *cls,
128 const struct GNUNET_MessageHeader *message) 128 const struct GNUNET_MessageHeader *message)
129{ 129{
130 struct GNUNET_RPS_CS_ReplyMessage *msg; 130 struct GNUNET_RPS_CS_ReplyMessage *msg;
131 //struct cb_cls_pack *pack;
132 //struct GNUNET_RPS_Handle *h;
133 struct GNUNET_PeerIdentity *peers; 131 struct GNUNET_PeerIdentity *peers;
134 struct GNUNET_RPS_Request_Handle *rh; 132 struct GNUNET_RPS_Request_Handle *rh;
135 133
136 /* Give the peers back */ 134 /* Give the peers back */
137 msg = (struct GNUNET_RPS_CS_ReplyMessage *) message; 135 msg = (struct GNUNET_RPS_CS_ReplyMessage *) message;
138 //pack = (struct cb_cls_pack *) cls;
139 //h = (struct GNUNET_RPS_Handle *) cls;
140 peers = (struct GNUNET_PeerIdentity *) &msg[1]; 136 peers = (struct GNUNET_PeerIdentity *) &msg[1];
141 rh = &req_handlers[msg->n]; 137 rh = &req_handlers[msg->n];
142 rh->ready_cb((rh)->ready_cb_cls, msg->num_peers, peers); 138 rh->ready_cb((rh)->ready_cb_cls, msg->num_peers, peers); // FIXME? ntohl ()
143 139
144 /* Disconnect */ 140 /* Disconnect */
145 //GNUNET_CLIENT_disconnect(pack->service_conn); 141 //GNUNET_CLIENT_disconnect(pack->service_conn);
@@ -270,7 +266,7 @@ GNUNET_RPS_seed_ids (struct GNUNET_RPS_Handle *h,
270 { 266 {
271 ev = GNUNET_MQ_msg_extra (msg, num_peers_max * sizeof (struct GNUNET_PeerIdentity), 267 ev = GNUNET_MQ_msg_extra (msg, num_peers_max * sizeof (struct GNUNET_PeerIdentity),
272 GNUNET_MESSAGE_TYPE_RPS_CS_SEED); 268 GNUNET_MESSAGE_TYPE_RPS_CS_SEED);
273 msg->num_peers = ntohl (num_peers_max); 269 msg->num_peers = htonl (num_peers_max);
274 memcpy (&msg[1], tmp_peer_pointer, num_peers_max * sizeof (struct GNUNET_PeerIdentity)); 270 memcpy (&msg[1], tmp_peer_pointer, num_peers_max * sizeof (struct GNUNET_PeerIdentity));
275 GNUNET_MQ_send (h->mq, ev); 271 GNUNET_MQ_send (h->mq, ev);
276 272