aboutsummaryrefslogtreecommitdiff
path: root/src/transport/transport_api.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/transport_api.c')
-rw-r--r--src/transport/transport_api.c39
1 files changed, 18 insertions, 21 deletions
diff --git a/src/transport/transport_api.c b/src/transport/transport_api.c
index 2da6e9a54..d672b4d46 100644
--- a/src/transport/transport_api.c
+++ b/src/transport/transport_api.c
@@ -689,8 +689,8 @@ demultiplexer (void *cls,
689 break; 689 break;
690 } 690 }
691 LOG (GNUNET_ERROR_TYPE_DEBUG, 691 LOG (GNUNET_ERROR_TYPE_DEBUG,
692 "Receiving `%s' message for `%4s'.\n", 692 "Receiving CONNECT message for `%4s'.\n",
693 "CONNECT", GNUNET_i2s (&cim->id)); 693 GNUNET_i2s (&cim->id));
694 n = neighbour_find (h, &cim->id); 694 n = neighbour_find (h, &cim->id);
695 if (NULL != n) 695 if (NULL != n)
696 { 696 {
@@ -699,8 +699,7 @@ demultiplexer (void *cls,
699 } 699 }
700 n = neighbour_add (h, &cim->id); 700 n = neighbour_add (h, &cim->id);
701 LOG (GNUNET_ERROR_TYPE_DEBUG, 701 LOG (GNUNET_ERROR_TYPE_DEBUG,
702 "Receiving `%s' message for `%4s' with quota %u\n", 702 "Receiving CONNECT message for `%4s' with quota %u\n",
703 "CONNECT",
704 GNUNET_i2s (&cim->id), 703 GNUNET_i2s (&cim->id),
705 ntohl (cim->quota_out.value__)); 704 ntohl (cim->quota_out.value__));
706 GNUNET_BANDWIDTH_tracker_update_quota (&n->out_tracker, 705 GNUNET_BANDWIDTH_tracker_update_quota (&n->out_tracker,
@@ -717,8 +716,8 @@ demultiplexer (void *cls,
717 dim = (const struct DisconnectInfoMessage *) msg; 716 dim = (const struct DisconnectInfoMessage *) msg;
718 GNUNET_break (ntohl (dim->reserved) == 0); 717 GNUNET_break (ntohl (dim->reserved) == 0);
719 LOG (GNUNET_ERROR_TYPE_DEBUG, 718 LOG (GNUNET_ERROR_TYPE_DEBUG,
720 "Receiving `%s' message for `%4s'.\n", 719 "Receiving DISCONNECT message for `%4s'.\n",
721 "DISCONNECT", GNUNET_i2s (&dim->peer)); 720 GNUNET_i2s (&dim->peer));
722 n = neighbour_find (h, &dim->peer); 721 n = neighbour_find (h, &dim->peer);
723 if (NULL == n) 722 if (NULL == n)
724 { 723 {
@@ -766,9 +765,6 @@ demultiplexer (void *cls,
766 } 765 }
767 break; 766 break;
768 case GNUNET_MESSAGE_TYPE_TRANSPORT_RECV: 767 case GNUNET_MESSAGE_TYPE_TRANSPORT_RECV:
769 LOG (GNUNET_ERROR_TYPE_DEBUG,
770 "Receiving `%s' message.\n",
771 "RECV");
772 if (size < 768 if (size <
773 sizeof (struct InboundMessage) + sizeof (struct GNUNET_MessageHeader)) 769 sizeof (struct InboundMessage) + sizeof (struct GNUNET_MessageHeader))
774 { 770 {
@@ -795,8 +791,6 @@ demultiplexer (void *cls,
795 h->rec (h->cls, &im->peer, imm); 791 h->rec (h->cls, &im->peer, imm);
796 break; 792 break;
797 case GNUNET_MESSAGE_TYPE_TRANSPORT_SET_QUOTA: 793 case GNUNET_MESSAGE_TYPE_TRANSPORT_SET_QUOTA:
798 LOG (GNUNET_ERROR_TYPE_DEBUG,
799 "Receiving `%s' message.\n", "SET_QUOTA");
800 if (size != sizeof (struct QuotaSetMessage)) 794 if (size != sizeof (struct QuotaSetMessage))
801 { 795 {
802 GNUNET_break (0); 796 GNUNET_break (0);
@@ -807,16 +801,18 @@ demultiplexer (void *cls,
807 if (NULL == n) 801 if (NULL == n)
808 break; 802 break;
809 LOG (GNUNET_ERROR_TYPE_DEBUG, 803 LOG (GNUNET_ERROR_TYPE_DEBUG,
810 "Receiving `%s' message for `%4s' with quota %u\n", 804 "Receiving SET_QUOTA message for `%4s' with quota %u\n",
811 "SET_QUOTA",
812 GNUNET_i2s (&qm->peer), 805 GNUNET_i2s (&qm->peer),
813 ntohl (qm->quota.value__)); 806 ntohl (qm->quota.value__));
814 GNUNET_BANDWIDTH_tracker_update_quota (&n->out_tracker, qm->quota); 807 GNUNET_BANDWIDTH_tracker_update_quota (&n->out_tracker,
808 qm->quota);
815 break; 809 break;
816 default: 810 default:
817 LOG (GNUNET_ERROR_TYPE_ERROR, 811 LOG (GNUNET_ERROR_TYPE_ERROR,
818 _("Received unexpected message of type %u in %s:%u\n"), 812 _("Received unexpected message of type %u in %s:%u\n"),
819 ntohs (msg->type), __FILE__, __LINE__); 813 ntohs (msg->type),
814 __FILE__,
815 __LINE__);
820 GNUNET_break (0); 816 GNUNET_break (0);
821 break; 817 break;
822 } 818 }
@@ -880,11 +876,14 @@ transport_notify_ready (void *cls, size_t size, void *buf)
880 /* first send control messages */ 876 /* first send control messages */
881 while ((NULL != (th = h->control_head)) && (th->notify_size <= size)) 877 while ((NULL != (th = h->control_head)) && (th->notify_size <= size))
882 { 878 {
883 GNUNET_CONTAINER_DLL_remove (h->control_head, h->control_tail, th); 879 GNUNET_CONTAINER_DLL_remove (h->control_head,
880 h->control_tail,
881 th);
884 nret = th->notify (th->notify_cls, size, &cbuf[ret]); 882 nret = th->notify (th->notify_cls, size, &cbuf[ret]);
885 LOG (GNUNET_ERROR_TYPE_DEBUG, 883 LOG (GNUNET_ERROR_TYPE_DEBUG,
886 "Added %u bytes of control message at %u\n", 884 "Added %u bytes of control message at %u\n",
887 nret, ret); 885 nret,
886 ret);
888 GNUNET_free (th); 887 GNUNET_free (th);
889 ret += nret; 888 ret += nret;
890 size -= nret; 889 size -= nret;
@@ -1093,13 +1092,11 @@ send_start (void *cls, size_t size, void *buf)
1093 { 1092 {
1094 /* Can only be shutdown, just give up */ 1093 /* Can only be shutdown, just give up */
1095 LOG (GNUNET_ERROR_TYPE_DEBUG, 1094 LOG (GNUNET_ERROR_TYPE_DEBUG,
1096 "Shutdown while trying to transmit `%s' request.\n", 1095 "Shutdown while trying to transmit START request.\n");
1097 "START");
1098 return 0; 1096 return 0;
1099 } 1097 }
1100 LOG (GNUNET_ERROR_TYPE_DEBUG, 1098 LOG (GNUNET_ERROR_TYPE_DEBUG,
1101 "Transmitting `%s' request.\n", 1099 "Transmitting START request.\n");
1102 "START");
1103 GNUNET_assert (size >= sizeof (struct StartMessage)); 1100 GNUNET_assert (size >= sizeof (struct StartMessage));
1104 s.header.size = htons (sizeof (struct StartMessage)); 1101 s.header.size = htons (sizeof (struct StartMessage));
1105 s.header.type = htons (GNUNET_MESSAGE_TYPE_TRANSPORT_START); 1102 s.header.type = htons (GNUNET_MESSAGE_TYPE_TRANSPORT_START);