aboutsummaryrefslogtreecommitdiff
path: root/src/psyc/gnunet-service-psyc.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/psyc/gnunet-service-psyc.c')
-rw-r--r--src/psyc/gnunet-service-psyc.c28
1 files changed, 14 insertions, 14 deletions
diff --git a/src/psyc/gnunet-service-psyc.c b/src/psyc/gnunet-service-psyc.c
index 8fd2fbf35..792164b95 100644
--- a/src/psyc/gnunet-service-psyc.c
+++ b/src/psyc/gnunet-service-psyc.c
@@ -677,7 +677,7 @@ client_send_result (struct GNUNET_SERVER_Client *client, uint64_t op_id,
677 res->result_code = GNUNET_htonll (result_code); 677 res->result_code = GNUNET_htonll (result_code);
678 res->op_id = op_id; 678 res->op_id = op_id;
679 if (0 < data_size) 679 if (0 < data_size)
680 memcpy (&res[1], data, data_size); 680 GNUNET_memcpy (&res[1], data, data_size);
681 681
682 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 682 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
683 "%p Sending result to client for operation #%" PRIu64 ": " 683 "%p Sending result to client for operation #%" PRIu64 ": "
@@ -771,7 +771,7 @@ mcast_recv_join_request (void *cls,
771 req->header.type = htons (GNUNET_MESSAGE_TYPE_PSYC_JOIN_REQUEST); 771 req->header.type = htons (GNUNET_MESSAGE_TYPE_PSYC_JOIN_REQUEST);
772 req->slave_pub_key = *slave_pub_key; 772 req->slave_pub_key = *slave_pub_key;
773 if (0 < join_msg_size) 773 if (0 < join_msg_size)
774 memcpy (&req[1], join_msg, join_msg_size); 774 GNUNET_memcpy (&req[1], join_msg, join_msg_size);
775 775
776 struct JoinMemTestClosure *jcls = GNUNET_malloc (sizeof (*jcls)); 776 struct JoinMemTestClosure *jcls = GNUNET_malloc (sizeof (*jcls));
777 jcls->slave_pub_key = *slave_pub_key; 777 jcls->slave_pub_key = *slave_pub_key;
@@ -812,7 +812,7 @@ mcast_recv_join_decision (void *cls, int is_admitted,
812 dcsn->header.type = htons (GNUNET_MESSAGE_TYPE_PSYC_JOIN_DECISION); 812 dcsn->header.type = htons (GNUNET_MESSAGE_TYPE_PSYC_JOIN_DECISION);
813 dcsn->is_admitted = htonl (is_admitted); 813 dcsn->is_admitted = htonl (is_admitted);
814 if (0 < join_resp_size) 814 if (0 < join_resp_size)
815 memcpy (&dcsn[1], join_resp, join_resp_size); 815 GNUNET_memcpy (&dcsn[1], join_resp, join_resp_size);
816 816
817 client_send_msg (chn, &dcsn->header); 817 client_send_msg (chn, &dcsn->header);
818 818
@@ -962,7 +962,7 @@ psyc_msg_init (struct GNUNET_PSYC_MessageHeader *pmsg,
962 pmsg->fragment_offset = mmsg->fragment_offset; 962 pmsg->fragment_offset = mmsg->fragment_offset;
963 pmsg->flags = htonl (flags); 963 pmsg->flags = htonl (flags);
964 964
965 memcpy (&pmsg[1], &mmsg[1], size - sizeof (*mmsg)); 965 GNUNET_memcpy (&pmsg[1], &mmsg[1], size - sizeof (*mmsg));
966} 966}
967 967
968 968
@@ -1029,7 +1029,7 @@ client_send_mcast_req (struct Master *mst,
1029 pmsg->fragment_offset = req->fragment_offset; 1029 pmsg->fragment_offset = req->fragment_offset;
1030 pmsg->flags = htonl (GNUNET_PSYC_MESSAGE_REQUEST); 1030 pmsg->flags = htonl (GNUNET_PSYC_MESSAGE_REQUEST);
1031 pmsg->slave_pub_key = req->member_pub_key; 1031 pmsg->slave_pub_key = req->member_pub_key;
1032 memcpy (&pmsg[1], &req[1], size - sizeof (*req)); 1032 GNUNET_memcpy (&pmsg[1], &req[1], size - sizeof (*req));
1033 1033
1034 client_send_msg (chn, &pmsg->header); 1034 client_send_msg (chn, &pmsg->header);
1035 1035
@@ -1100,7 +1100,7 @@ fragment_queue_insert (struct Channel *chn,
1100 cache_entry = GNUNET_new (struct RecvCacheEntry); 1100 cache_entry = GNUNET_new (struct RecvCacheEntry);
1101 cache_entry->ref_count = 1; 1101 cache_entry->ref_count = 1;
1102 cache_entry->mmsg = GNUNET_malloc (size); 1102 cache_entry->mmsg = GNUNET_malloc (size);
1103 memcpy (cache_entry->mmsg, mmsg, size); 1103 GNUNET_memcpy (cache_entry->mmsg, mmsg, size);
1104 GNUNET_CONTAINER_multihashmap_put (chan_msgs, &frag_id_hash, cache_entry, 1104 GNUNET_CONTAINER_multihashmap_put (chan_msgs, &frag_id_hash, cache_entry,
1105 GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST); 1105 GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST);
1106 } 1106 }
@@ -1784,7 +1784,7 @@ client_recv_slave_join (void *cls, struct GNUNET_SERVER_Client *client,
1784 join_msg = (struct GNUNET_PSYC_Message *) (((char *) &req[1]) + relay_size); 1784 join_msg = (struct GNUNET_PSYC_Message *) (((char *) &req[1]) + relay_size);
1785 join_msg_size = ntohs (join_msg->header.size); 1785 join_msg_size = ntohs (join_msg->header.size);
1786 slv->join_msg = GNUNET_malloc (join_msg_size); 1786 slv->join_msg = GNUNET_malloc (join_msg_size);
1787 memcpy (slv->join_msg, join_msg, join_msg_size); 1787 GNUNET_memcpy (slv->join_msg, join_msg, join_msg_size);
1788 } 1788 }
1789 if (sizeof (*req) + relay_size + join_msg_size != req_size) 1789 if (sizeof (*req) + relay_size + join_msg_size != req_size)
1790 { 1790 {
@@ -1802,7 +1802,7 @@ client_recv_slave_join (void *cls, struct GNUNET_SERVER_Client *client,
1802 if (0 < slv->relay_count) 1802 if (0 < slv->relay_count)
1803 { 1803 {
1804 slv->relays = GNUNET_malloc (relay_size); 1804 slv->relays = GNUNET_malloc (relay_size);
1805 memcpy (slv->relays, &req[1], relay_size); 1805 GNUNET_memcpy (slv->relays, &req[1], relay_size);
1806 } 1806 }
1807 1807
1808 chn = &slv->chn; 1808 chn = &slv->chn;
@@ -1994,7 +1994,7 @@ transmit_notify (void *cls, size_t *data_size, void *data)
1994 "%p transmit_notify: sending %u bytes.\n", chn, tmit_msg->size); 1994 "%p transmit_notify: sending %u bytes.\n", chn, tmit_msg->size);
1995 1995
1996 *data_size = tmit_msg->size; 1996 *data_size = tmit_msg->size;
1997 memcpy (data, &tmit_msg[1], *data_size); 1997 GNUNET_memcpy (data, &tmit_msg[1], *data_size);
1998 1998
1999 int ret 1999 int ret
2000 = (tmit_msg->last_ptype < GNUNET_MESSAGE_TYPE_PSYC_MESSAGE_END) 2000 = (tmit_msg->last_ptype < GNUNET_MESSAGE_TYPE_PSYC_MESSAGE_END)
@@ -2203,7 +2203,7 @@ queue_message (struct Channel *chn,
2203{ 2203{
2204 struct TransmitMessage * 2204 struct TransmitMessage *
2205 tmit_msg = GNUNET_malloc (sizeof (*tmit_msg) + data_size); 2205 tmit_msg = GNUNET_malloc (sizeof (*tmit_msg) + data_size);
2206 memcpy (&tmit_msg[1], data, data_size); 2206 GNUNET_memcpy (&tmit_msg[1], data, data_size);
2207 tmit_msg->client = client; 2207 tmit_msg->client = client;
2208 tmit_msg->size = data_size; 2208 tmit_msg->size = data_size;
2209 tmit_msg->first_ptype = first_ptype; 2209 tmit_msg->first_ptype = first_ptype;
@@ -2390,7 +2390,7 @@ store_recv_fragment_history (void *cls,
2390 2390
2391 pmsg = (struct GNUNET_PSYC_MessageHeader *) &res[1]; 2391 pmsg = (struct GNUNET_PSYC_MessageHeader *) &res[1];
2392 GNUNET_PSYC_message_header_init (pmsg, mmsg, flags | GNUNET_PSYC_MESSAGE_HISTORIC); 2392 GNUNET_PSYC_message_header_init (pmsg, mmsg, flags | GNUNET_PSYC_MESSAGE_HISTORIC);
2393 memcpy (&res[1], pmsg, psize); 2393 GNUNET_memcpy (&res[1], pmsg, psize);
2394 2394
2395 /** @todo FIXME: send only to requesting client */ 2395 /** @todo FIXME: send only to requesting client */
2396 client_send_msg (chn, &res->header); 2396 client_send_msg (chn, &res->header);
@@ -2510,8 +2510,8 @@ store_recv_state_var (void *cls, const char *name,
2510 mod->name_size = htons (name_size); 2510 mod->name_size = htons (name_size);
2511 mod->value_size = htonl (value_size); 2511 mod->value_size = htonl (value_size);
2512 mod->oper = htons (GNUNET_PSYC_OP_ASSIGN); 2512 mod->oper = htons (GNUNET_PSYC_OP_ASSIGN);
2513 memcpy (&mod[1], name, name_size); 2513 GNUNET_memcpy (&mod[1], name, name_size);
2514 memcpy (((char *) &mod[1]) + name_size, value, value_size); 2514 GNUNET_memcpy (((char *) &mod[1]) + name_size, value, value_size);
2515 } 2515 }
2516 else /* Continuation */ 2516 else /* Continuation */
2517 { 2517 {
@@ -2524,7 +2524,7 @@ store_recv_state_var (void *cls, const char *name,
2524 mod = (struct GNUNET_MessageHeader *) &res[1]; 2524 mod = (struct GNUNET_MessageHeader *) &res[1];
2525 mod->size = htons (sizeof (*mod) + value_size); 2525 mod->size = htons (sizeof (*mod) + value_size);
2526 mod->type = htons (GNUNET_MESSAGE_TYPE_PSYC_MESSAGE_MOD_CONT); 2526 mod->type = htons (GNUNET_MESSAGE_TYPE_PSYC_MESSAGE_MOD_CONT);
2527 memcpy (&mod[1], value, value_size); 2527 GNUNET_memcpy (&mod[1], value, value_size);
2528 } 2528 }
2529 2529
2530 // FIXME: client might have been disconnected 2530 // FIXME: client might have been disconnected