Skip to content

Commit 9545fd5

Browse files
Send for upload also
1 parent 4f722ff commit 9545fd5

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

pkg/throughput1/protocol.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -211,7 +211,8 @@ func (p *Protocol) sendCounterflow(ctx context.Context,
211211
for {
212212
select {
213213
case <-ctx.Done():
214-
// TODO: do we need to send a final wiremessage here?
214+
// Attempt to send final write message before close. Ignore errors.
215+
p.sendWireMeasurement(ctx, p.measurer.Measure(ctx))
215216
p.close(ctx)
216217
return
217218
case m := <-measurerCh:

0 commit comments

Comments
 (0)