diff options
author | ng0 <ng0@n0.is> | 2019-03-01 11:04:39 +0000 |
---|---|---|
committer | ng0 <ng0@n0.is> | 2019-03-01 11:04:39 +0000 |
commit | 81bbd92b679d441b39653e8453884627c8682350 (patch) | |
tree | 408436542479a81154949756abceaed5751b1154 | |
parent | a2ecd781d51ba697f8e739466562c91399debae3 (diff) | |
parent | de9b22505b9e236bb7ef7b0a2ae4c77973ff1cb3 (diff) | |
download | gnunet-81bbd92b679d441b39653e8453884627c8682350.tar.gz gnunet-81bbd92b679d441b39653e8453884627c8682350.zip |
Merge branch 'master' of gnunet.org:gnunet
-rw-r--r-- | ChangeLog | 3 | ||||
-rw-r--r-- | contrib/benchmark/collect.awk | 4 | ||||
-rw-r--r-- | src/cadet/gnunet-service-cadet_channel.c | 7 |
3 files changed, 10 insertions, 4 deletions
@@ -1,3 +1,6 @@ | |||
1 | Thu Feb 28 19:07:59 CET 2019 | ||
2 | CADET: Fix in order, unrealiable message ordering | ||
3 | |||
1 | Thu 28 Feb 2019 10:54:58 AM CET | 4 | Thu 28 Feb 2019 10:54:58 AM CET |
2 | Releasing GNUnet 0.11.0. -CG | 5 | Releasing GNUnet 0.11.0. -CG |
3 | 6 | ||
diff --git a/contrib/benchmark/collect.awk b/contrib/benchmark/collect.awk index c10191162..66bdf387e 100644 --- a/contrib/benchmark/collect.awk +++ b/contrib/benchmark/collect.awk | |||
@@ -94,8 +94,8 @@ END { | |||
94 | "time_avg_us", avg(url[x][y]["time_us"], url[x][y]["count"]), \ | 94 | "time_avg_us", avg(url[x][y]["time_us"], url[x][y]["count"]), \ |
95 | "stdev", stdev(url[x][y]["time_us"], url[x][y]["time_us_sq"], url[x][y]["count"]), \ | 95 | "stdev", stdev(url[x][y]["time_us"], url[x][y]["time_us_sq"], url[x][y]["count"]), \ |
96 | "time_us_max", url[x][y]["time_us_max"], \ | 96 | "time_us_max", url[x][y]["time_us_max"], \ |
97 | "bytes_sent_avg", avg(url[x][y]["bytes_sent"], url[x][y]["count]), \ | 97 | "bytes_sent_avg", avg(url[x][y]["bytes_sent"], url[x][y]["count"]), \ |
98 | "bytes_received_avg", avg(url[x][y]["bytes_received"], url[x][y]["count]); | 98 | "bytes_received_avg", avg(url[x][y]["bytes_received"], url[x][y]["count"]); |
99 | } | 99 | } |
100 | } | 100 | } |
101 | if (total_ops) { | 101 | if (total_ops) { |
diff --git a/src/cadet/gnunet-service-cadet_channel.c b/src/cadet/gnunet-service-cadet_channel.c index 1746fc509..1e898c1eb 100644 --- a/src/cadet/gnunet-service-cadet_channel.c +++ b/src/cadet/gnunet-service-cadet_channel.c | |||
@@ -1331,7 +1331,10 @@ GCCH_handle_channel_plaintext_data (struct CadetChannel *ch, | |||
1331 | ccc->client_ready = GNUNET_NO; | 1331 | ccc->client_ready = GNUNET_NO; |
1332 | GSC_send_to_client (ccc->c, | 1332 | GSC_send_to_client (ccc->c, |
1333 | env); | 1333 | env); |
1334 | ch->mid_recv.mid = htonl (1 + ntohl (ch->mid_recv.mid)); | 1334 | if (GNUNET_NO == ch->out_of_order) |
1335 | ch->mid_recv.mid = htonl (1 + ntohl (msg->mid.mid)); | ||
1336 | else | ||
1337 | ch->mid_recv.mid = htonl (1 + ntohl (ch->mid_recv.mid)); | ||
1335 | ch->mid_futures >>= 1; | 1338 | ch->mid_futures >>= 1; |
1336 | if ( (GNUNET_YES == ch->out_of_order) && | 1339 | if ( (GNUNET_YES == ch->out_of_order) && |
1337 | (GNUNET_NO == ch->reliable) ) | 1340 | (GNUNET_NO == ch->reliable) ) |
@@ -1422,7 +1425,7 @@ GCCH_handle_channel_plaintext_data (struct CadetChannel *ch, | |||
1422 | ccc->client_ready = GNUNET_NO; | 1425 | ccc->client_ready = GNUNET_NO; |
1423 | GSC_send_to_client (ccc->c, | 1426 | GSC_send_to_client (ccc->c, |
1424 | next_msg->env); | 1427 | next_msg->env); |
1425 | ch->mid_recv.mid = htonl (1 + ntohl (ch->mid_recv.mid)); | 1428 | ch->mid_recv.mid = htonl (1 + ntohl (next_msg->mid.mid)); |
1426 | ch->mid_futures >>= 1; | 1429 | ch->mid_futures >>= 1; |
1427 | send_channel_data_ack (ch); | 1430 | send_channel_data_ack (ch); |
1428 | GNUNET_CONTAINER_DLL_remove (ccc->head_recv, | 1431 | GNUNET_CONTAINER_DLL_remove (ccc->head_recv, |