aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-10-10 12:31:57 +0000
committerChristian Grothoff <christian@grothoff.org>2011-10-10 12:31:57 +0000
commit5add96019deec64775c8229e99dce6fa6d4f8728 (patch)
tree8733d7d84d67cf1038afe2b7b5b879df228dc11f /src
parent78659ecd60209b7bd0e4ed6060bc0e8c33247b37 (diff)
downloadgnunet-5add96019deec64775c8229e99dce6fa6d4f8728.tar.gz
gnunet-5add96019deec64775c8229e99dce6fa6d4f8728.zip
fixes
Diffstat (limited to 'src')
-rw-r--r--src/core/gnunet-service-core_kx.c2
-rw-r--r--src/core/gnunet-service-core_neighbours.c6
-rw-r--r--src/core/gnunet-service-core_sessions.c4
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}