diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-10-10 12:31:57 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-10-10 12:31:57 +0000 |
commit | 5add96019deec64775c8229e99dce6fa6d4f8728 (patch) | |
tree | 8733d7d84d67cf1038afe2b7b5b879df228dc11f /src | |
parent | 78659ecd60209b7bd0e4ed6060bc0e8c33247b37 (diff) | |
download | gnunet-5add96019deec64775c8229e99dce6fa6d4f8728.tar.gz gnunet-5add96019deec64775c8229e99dce6fa6d4f8728.zip |
fixes
Diffstat (limited to 'src')
-rw-r--r-- | src/core/gnunet-service-core_kx.c | 2 | ||||
-rw-r--r-- | src/core/gnunet-service-core_neighbours.c | 6 | ||||
-rw-r--r-- | src/core/gnunet-service-core_sessions.c | 4 |
3 files changed, 7 insertions, 5 deletions
diff --git a/src/core/gnunet-service-core_kx.c b/src/core/gnunet-service-core_kx.c index ba3ab87b9..8daf49826 100644 --- a/src/core/gnunet-service-core_kx.c +++ b/src/core/gnunet-service-core_kx.c | |||
@@ -590,7 +590,6 @@ process_hello (void *cls, const struct GNUNET_PeerIdentity *peer, | |||
590 | struct GSC_KeyExchangeInfo *kx = cls; | 590 | struct GSC_KeyExchangeInfo *kx = cls; |
591 | struct SetKeyMessage *skm; | 591 | struct SetKeyMessage *skm; |
592 | 592 | ||
593 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == kx->retry_set_key_task); | ||
594 | if (err_msg != NULL) | 593 | if (err_msg != NULL) |
595 | { | 594 | { |
596 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 595 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
@@ -623,6 +622,7 @@ process_hello (void *cls, const struct GNUNET_PeerIdentity *peer, | |||
623 | GNUNET_break (0); | 622 | GNUNET_break (0); |
624 | return; | 623 | return; |
625 | } | 624 | } |
625 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == kx->retry_set_key_task); | ||
626 | kx->public_key = | 626 | kx->public_key = |
627 | GNUNET_malloc (sizeof (struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded)); | 627 | GNUNET_malloc (sizeof (struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded)); |
628 | if (GNUNET_OK != GNUNET_HELLO_get_key (hello, kx->public_key)) | 628 | if (GNUNET_OK != GNUNET_HELLO_get_key (hello, kx->public_key)) |
diff --git a/src/core/gnunet-service-core_neighbours.c b/src/core/gnunet-service-core_neighbours.c index 3603fc073..60ce0e512 100644 --- a/src/core/gnunet-service-core_neighbours.c +++ b/src/core/gnunet-service-core_neighbours.c | |||
@@ -459,9 +459,9 @@ GSC_NEIGHBOURS_transmit (const struct GNUNET_PeerIdentity *target, | |||
459 | me->deadline = GNUNET_TIME_relative_to_absolute (timeout); | 459 | me->deadline = GNUNET_TIME_relative_to_absolute (timeout); |
460 | me->size = msize; | 460 | me->size = msize; |
461 | memcpy (&me[1], msg, msize); | 461 | memcpy (&me[1], msg, msize); |
462 | GNUNET_CONTAINER_DLL_insert (n->message_head, | 462 | GNUNET_CONTAINER_DLL_insert_tail (n->message_head, |
463 | n->message_tail, | 463 | n->message_tail, |
464 | me); | 464 | me); |
465 | process_queue (n); | 465 | process_queue (n); |
466 | } | 466 | } |
467 | 467 | ||
diff --git a/src/core/gnunet-service-core_sessions.c b/src/core/gnunet-service-core_sessions.c index 4a3fc1e87..a1b40129c 100644 --- a/src/core/gnunet-service-core_sessions.c +++ b/src/core/gnunet-service-core_sessions.c | |||
@@ -444,10 +444,10 @@ try_transmission (struct Session *session) | |||
444 | min_deadline = GNUNET_TIME_UNIT_FOREVER_ABS; | 444 | min_deadline = GNUNET_TIME_UNIT_FOREVER_ABS; |
445 | /* check 'ready' messages */ | 445 | /* check 'ready' messages */ |
446 | pos = session->sme_head; | 446 | pos = session->sme_head; |
447 | GNUNET_assert (pos->size < GNUNET_CONSTANTS_MAX_ENCRYPTED_MESSAGE_SIZE); | ||
448 | while ( (NULL != pos) && | 447 | while ( (NULL != pos) && |
449 | (msize + pos->size <= GNUNET_CONSTANTS_MAX_ENCRYPTED_MESSAGE_SIZE) ) | 448 | (msize + pos->size <= GNUNET_CONSTANTS_MAX_ENCRYPTED_MESSAGE_SIZE) ) |
450 | { | 449 | { |
450 | GNUNET_assert (pos->size < GNUNET_CONSTANTS_MAX_ENCRYPTED_MESSAGE_SIZE); | ||
451 | msize += pos->size; | 451 | msize += pos->size; |
452 | min_deadline = GNUNET_TIME_absolute_min (min_deadline, | 452 | min_deadline = GNUNET_TIME_absolute_min (min_deadline, |
453 | pos->deadline); | 453 | pos->deadline); |
@@ -565,6 +565,8 @@ GSC_SESSIONS_solicit (const struct GNUNET_PeerIdentity *pid) | |||
565 | struct Session *session; | 565 | struct Session *session; |
566 | 566 | ||
567 | session = find_session (pid); | 567 | session = find_session (pid); |
568 | if (NULL == session) | ||
569 | return; | ||
568 | session->ready_to_transmit = GNUNET_YES; | 570 | session->ready_to_transmit = GNUNET_YES; |
569 | try_transmission (session); | 571 | try_transmission (session); |
570 | } | 572 | } |