aboutsummaryrefslogtreecommitdiff
path: root/src/psycstore/gnunet-service-psycstore.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/psycstore/gnunet-service-psycstore.c')
-rw-r--r--src/psycstore/gnunet-service-psycstore.c23
1 files changed, 12 insertions, 11 deletions
diff --git a/src/psycstore/gnunet-service-psycstore.c b/src/psycstore/gnunet-service-psycstore.c
index 3b5047f8f..ae108fc4d 100644
--- a/src/psycstore/gnunet-service-psycstore.c
+++ b/src/psycstore/gnunet-service-psycstore.c
@@ -514,25 +514,26 @@ struct StateModifyClosure
514 514
515static void 515static void
516recv_state_message_part (void *cls, 516recv_state_message_part (void *cls,
517 const struct GNUNET_CRYPTO_EcdsaPublicKey *slave_key, 517 const struct GNUNET_PSYC_MessageHeader *msg,
518 uint64_t message_id, uint32_t flags, uint64_t data_offset, 518 const struct GNUNET_MessageHeader *pmsg)
519 const struct GNUNET_MessageHeader *msg)
520{ 519{
521 struct StateModifyClosure *scls = cls; 520 struct StateModifyClosure *scls = cls;
522 uint16_t psize; 521 uint16_t psize;
523 522
524 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 523 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
525 "recv_state_message_part() message_id: %" PRIu64 524 "recv_state_message_part() message_id: %" PRIu64
526 ", data_offset: %" PRIu64 ", flags: %u\n", 525 ", fragment_offset: %" PRIu64 ", flags: %u\n",
527 message_id, data_offset, flags); 526 GNUNET_ntohll (msg->message_id),
527 GNUNET_ntohll (msg->fragment_offset),
528 ntohl (msg->flags));
528 529
529 if (NULL == msg) 530 if (NULL == pmsg)
530 { 531 {
531 scls->msg_state = GNUNET_PSYC_MESSAGE_STATE_ERROR; 532 scls->msg_state = GNUNET_PSYC_MESSAGE_STATE_ERROR;
532 return; 533 return;
533 } 534 }
534 535
535 switch (ntohs (msg->type)) 536 switch (ntohs (pmsg->type))
536 { 537 {
537 case GNUNET_MESSAGE_TYPE_PSYC_MESSAGE_METHOD: 538 case GNUNET_MESSAGE_TYPE_PSYC_MESSAGE_METHOD:
538 { 539 {
@@ -543,7 +544,7 @@ recv_state_message_part (void *cls,
543 case GNUNET_MESSAGE_TYPE_PSYC_MESSAGE_MODIFIER: 544 case GNUNET_MESSAGE_TYPE_PSYC_MESSAGE_MODIFIER:
544 { 545 {
545 struct GNUNET_PSYC_MessageModifier * 546 struct GNUNET_PSYC_MessageModifier *
546 pmod = (struct GNUNET_PSYC_MessageModifier *) msg; 547 pmod = (struct GNUNET_PSYC_MessageModifier *) pmsg;
547 psize = ntohs (pmod->header.size); 548 psize = ntohs (pmod->header.size);
548 uint16_t name_size = ntohs (pmod->name_size); 549 uint16_t name_size = ntohs (pmod->name_size);
549 uint32_t value_size = ntohl (pmod->value_size); 550 uint32_t value_size = ntohl (pmod->value_size);
@@ -583,10 +584,10 @@ recv_state_message_part (void *cls,
583 GNUNET_break_op (0); 584 GNUNET_break_op (0);
584 scls->msg_state = GNUNET_PSYC_MESSAGE_STATE_ERROR; 585 scls->msg_state = GNUNET_PSYC_MESSAGE_STATE_ERROR;
585 } 586 }
586 psize = ntohs (msg->size); 587 psize = ntohs (pmsg->size);
587 memcpy (scls->mod_value + (scls->mod_value_size - scls->mod_value_remaining), 588 memcpy (scls->mod_value + (scls->mod_value_size - scls->mod_value_remaining),
588 &msg[1], psize - sizeof (*msg)); 589 &pmsg[1], psize - sizeof (*pmsg));
589 scls->mod_value_remaining -= psize - sizeof (*msg); 590 scls->mod_value_remaining -= psize - sizeof (*pmsg);
590 if (0 == scls->mod_value_remaining) 591 if (0 == scls->mod_value_remaining)
591 { 592 {
592 db->state_modify_op (db->cls, &scls->channel_key, 593 db->state_modify_op (db->cls, &scls->channel_key,