aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_udp.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/plugin_transport_udp.c')
-rw-r--r--src/transport/plugin_transport_udp.c11
1 files changed, 1 insertions, 10 deletions
diff --git a/src/transport/plugin_transport_udp.c b/src/transport/plugin_transport_udp.c
index 45387cfc8..474180db5 100644
--- a/src/transport/plugin_transport_udp.c
+++ b/src/transport/plugin_transport_udp.c
@@ -846,16 +846,11 @@ create_session (struct Plugin *plugin, const struct GNUNET_PeerIdentity *target,
846 GNUNET_break_op (0); 846 GNUNET_break_op (0);
847 return NULL; 847 return NULL;
848 } 848 }
849
850 s->addrlen = len; 849 s->addrlen = len;
851 s->target = *target; 850 s->target = *target;
852 s->sock_addr = (const struct sockaddr *) &s[1]; 851 s->sock_addr = (const struct sockaddr *) &s[1];
853 s->flow_delay_for_other_peer = GNUNET_TIME_relative_get_zero();
854 s->flow_delay_from_other_peer = GNUNET_TIME_absolute_get_zero();
855 s->last_expected_delay = GNUNET_TIME_UNIT_SECONDS; 852 s->last_expected_delay = GNUNET_TIME_UNIT_SECONDS;
856
857 start_session_timeout(s); 853 start_session_timeout(s);
858
859 return s; 854 return s;
860} 855}
861 856
@@ -1521,14 +1516,10 @@ ack_proc (void *cls, uint32_t id, const struct GNUNET_MessageHeader *msg)
1521 sockaddr_in6)), 1516 sockaddr_in6)),
1522 delay); 1517 delay);
1523 udpw = GNUNET_malloc (sizeof (struct UDPMessageWrapper) + msize); 1518 udpw = GNUNET_malloc (sizeof (struct UDPMessageWrapper) + msize);
1524 udpw->cont = NULL;
1525 udpw->cont_cls = NULL;
1526 udpw->frag_ctx = NULL;
1527 udpw->msg_size = msize; 1519 udpw->msg_size = msize;
1528 udpw->session = s; 1520 udpw->session = s;
1529 udpw->timeout = GNUNET_TIME_absolute_get_forever(); 1521 udpw->timeout = GNUNET_TIME_UNIT_FOREVER_ABS;
1530 udpw->udp = (char *)&udpw[1]; 1522 udpw->udp = (char *)&udpw[1];
1531
1532 udp_ack = (struct UDP_ACK_Message *) udpw->udp; 1523 udp_ack = (struct UDP_ACK_Message *) udpw->udp;
1533 udp_ack->header.size = htons ((uint16_t) msize); 1524 udp_ack->header.size = htons ((uint16_t) msize);
1534 udp_ack->header.type = htons (GNUNET_MESSAGE_TYPE_TRANSPORT_UDP_ACK); 1525 udp_ack->header.type = htons (GNUNET_MESSAGE_TYPE_TRANSPORT_UDP_ACK);