diff options
Diffstat (limited to 'src/rps/rps_api.c')
-rw-r--r-- | src/rps/rps_api.c | 8 |
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 | ||