aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorng0 <ng0@n0.is>2019-03-01 11:04:39 +0000
committerng0 <ng0@n0.is>2019-03-01 11:04:39 +0000
commit81bbd92b679d441b39653e8453884627c8682350 (patch)
tree408436542479a81154949756abceaed5751b1154
parenta2ecd781d51ba697f8e739466562c91399debae3 (diff)
parentde9b22505b9e236bb7ef7b0a2ae4c77973ff1cb3 (diff)
downloadgnunet-81bbd92b679d441b39653e8453884627c8682350.tar.gz
gnunet-81bbd92b679d441b39653e8453884627c8682350.zip
Merge branch 'master' of gnunet.org:gnunet
-rw-r--r--ChangeLog3
-rw-r--r--contrib/benchmark/collect.awk4
-rw-r--r--src/cadet/gnunet-service-cadet_channel.c7
3 files changed, 10 insertions, 4 deletions
diff --git a/ChangeLog b/ChangeLog
index 1e5109eff..1da6fa2cd 100644
--- a/ChangeLog
+++ b/ChangeLog
@@ -1,3 +1,6 @@
1Thu Feb 28 19:07:59 CET 2019
2 CADET: Fix in order, unrealiable message ordering
3
1Thu 28 Feb 2019 10:54:58 AM CET 4Thu 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,