diff options
author | Sree Harsha Totakura <totakura@in.tum.de> | 2012-03-09 08:50:42 +0000 |
---|---|---|
committer | Sree Harsha Totakura <totakura@in.tum.de> | 2012-03-09 08:50:42 +0000 |
commit | f341d685cc6170e656a7d8b11c3358aa6bd3b929 (patch) | |
tree | 09f846ec979dff125014f3d13776fa4c303b7500 /src/stream/stream_api.c | |
parent | 62e9c20cdc25be22ef3d8246cc7e002d246dce35 (diff) | |
download | gnunet-f341d685cc6170e656a7d8b11c3358aa6bd3b929.tar.gz gnunet-f341d685cc6170e656a7d8b11c3358aa6bd3b929.zip |
corrected HELLO_ACK message size
Diffstat (limited to 'src/stream/stream_api.c')
-rw-r--r-- | src/stream/stream_api.c | 23 |
1 files changed, 15 insertions, 8 deletions
diff --git a/src/stream/stream_api.c b/src/stream/stream_api.c index 4014f4957..8d09474c4 100644 --- a/src/stream/stream_api.c +++ b/src/stream/stream_api.c | |||
@@ -970,7 +970,7 @@ handle_data (struct GNUNET_STREAM_Socket *socket, | |||
970 | case STATE_ESTABLISHED: | 970 | case STATE_ESTABLISHED: |
971 | case STATE_TRANSMIT_CLOSED: | 971 | case STATE_TRANSMIT_CLOSED: |
972 | case STATE_TRANSMIT_CLOSE_WAIT: | 972 | case STATE_TRANSMIT_CLOSE_WAIT: |
973 | 973 | ||
974 | /* check if the message's sequence number is in the range we are | 974 | /* check if the message's sequence number is in the range we are |
975 | expecting */ | 975 | expecting */ |
976 | relative_sequence_number = | 976 | relative_sequence_number = |
@@ -984,6 +984,14 @@ handle_data (struct GNUNET_STREAM_Socket *socket, | |||
984 | return GNUNET_YES; | 984 | return GNUNET_YES; |
985 | } | 985 | } |
986 | 986 | ||
987 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
988 | "%x: Receiving DATA with sequence number: %u and size: %d " | ||
989 | "from %x\n", | ||
990 | socket->our_id, | ||
991 | ntohl (msg->sequence_number), | ||
992 | ntohs (msg->header.header.size), | ||
993 | socket->other_peer); | ||
994 | |||
987 | /* Check if we have to allocate the buffer */ | 995 | /* Check if we have to allocate the buffer */ |
988 | size -= sizeof (struct GNUNET_STREAM_DataMessage); | 996 | size -= sizeof (struct GNUNET_STREAM_DataMessage); |
989 | relative_offset = ntohl (msg->offset) - socket->read_offset; | 997 | relative_offset = ntohl (msg->offset) - socket->read_offset; |
@@ -1181,7 +1189,7 @@ client_handle_hello_ack (void *cls, | |||
1181 | reply = | 1189 | reply = |
1182 | GNUNET_malloc (sizeof (struct GNUNET_STREAM_HelloAckMessage)); | 1190 | GNUNET_malloc (sizeof (struct GNUNET_STREAM_HelloAckMessage)); |
1183 | reply->header.header.size = | 1191 | reply->header.header.size = |
1184 | htons (sizeof (struct GNUNET_STREAM_MessageHeader)); | 1192 | htons (sizeof (struct GNUNET_STREAM_HelloAckMessage)); |
1185 | reply->header.header.type = | 1193 | reply->header.header.type = |
1186 | htons (GNUNET_MESSAGE_TYPE_STREAM_HELLO_ACK); | 1194 | htons (GNUNET_MESSAGE_TYPE_STREAM_HELLO_ACK); |
1187 | reply->sequence_number = htonl (socket->write_sequence_number); | 1195 | reply->sequence_number = htonl (socket->write_sequence_number); |
@@ -1508,11 +1516,6 @@ server_handle_hello (void *cls, | |||
1508 | socket->our_id, | 1516 | socket->our_id, |
1509 | socket->other_peer); | 1517 | socket->other_peer); |
1510 | 1518 | ||
1511 | /* Catch possible protocol breaks */ | ||
1512 | GNUNET_break_op (0 == memcmp (&socket->other_peer, | ||
1513 | sender, | ||
1514 | sizeof (struct GNUNET_PeerIdentity))); | ||
1515 | |||
1516 | if (STATE_INIT == socket->state) | 1519 | if (STATE_INIT == socket->state) |
1517 | { | 1520 | { |
1518 | /* Get the random sequence number */ | 1521 | /* Get the random sequence number */ |
@@ -1525,7 +1528,7 @@ server_handle_hello (void *cls, | |||
1525 | reply = | 1528 | reply = |
1526 | GNUNET_malloc (sizeof (struct GNUNET_STREAM_HelloAckMessage)); | 1529 | GNUNET_malloc (sizeof (struct GNUNET_STREAM_HelloAckMessage)); |
1527 | reply->header.header.size = | 1530 | reply->header.header.size = |
1528 | htons (sizeof (struct GNUNET_STREAM_MessageHeader)); | 1531 | htons (sizeof (struct GNUNET_STREAM_HelloAckMessage)); |
1529 | reply->header.header.type = | 1532 | reply->header.header.type = |
1530 | htons (GNUNET_MESSAGE_TYPE_STREAM_HELLO_ACK); | 1533 | htons (GNUNET_MESSAGE_TYPE_STREAM_HELLO_ACK); |
1531 | reply->sequence_number = htonl (socket->write_sequence_number); | 1534 | reply->sequence_number = htonl (socket->write_sequence_number); |
@@ -1574,6 +1577,10 @@ server_handle_hello_ack (void *cls, | |||
1574 | ack_message = (struct GNUNET_STREAM_HelloAckMessage *) message; | 1577 | ack_message = (struct GNUNET_STREAM_HelloAckMessage *) message; |
1575 | if (STATE_HELLO_WAIT == socket->state) | 1578 | if (STATE_HELLO_WAIT == socket->state) |
1576 | { | 1579 | { |
1580 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
1581 | "%x: Received HELLO_ACK from %x\n", | ||
1582 | socket->our_id, | ||
1583 | socket->other_peer); | ||
1577 | socket->read_sequence_number = ntohl (ack_message->sequence_number); | 1584 | socket->read_sequence_number = ntohl (ack_message->sequence_number); |
1578 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1585 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1579 | "%x: Read sequence number %u\n", | 1586 | "%x: Read sequence number %u\n", |