From 9545fd5e7ee5229daa859c8faa152d8ab82ece95 Mon Sep 17 00:00:00 2001 From: Stephen Soltesz Date: Wed, 3 Jan 2024 17:47:48 -0500 Subject: [PATCH] Send for upload also --- pkg/throughput1/protocol.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/throughput1/protocol.go b/pkg/throughput1/protocol.go index a7ba88e..5d14056 100644 --- a/pkg/throughput1/protocol.go +++ b/pkg/throughput1/protocol.go @@ -211,7 +211,8 @@ func (p *Protocol) sendCounterflow(ctx context.Context, for { select { case <-ctx.Done(): - // TODO: do we need to send a final wiremessage here? + // Attempt to send final write message before close. Ignore errors. + p.sendWireMeasurement(ctx, p.measurer.Measure(ctx)) p.close(ctx) return case m := <-measurerCh: