diff options
Diffstat (limited to 'src/psycstore/gnunet-service-psycstore.c')
-rw-r--r-- | src/psycstore/gnunet-service-psycstore.c | 23 |
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 | ||
515 | static void | 515 | static void |
516 | recv_state_message_part (void *cls, | 516 | recv_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, |