Skip to content

Commit

Permalink
distsqlrun: remove redundant Close()
Browse files Browse the repository at this point in the history
Close() is already called when timedOut is set.

fixes cockroachdb#13989
  • Loading branch information
vivekmenezes committed Mar 13, 2017
1 parent 437dfc7 commit 087571b
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions pkg/sql/distsqlrun/flow_registry.go
Original file line number Diff line number Diff line change
Expand Up @@ -270,10 +270,6 @@ func (fr *flowRegistry) finishInboundStreamLocked(is *inboundStreamInfo) {
panic("double finish")
}

if is.timedOut {
is.receiver.Close(errors.Errorf("inbound stream timed out"))
}

is.finished = true
is.waitGroup.Done()
}
Expand Down

0 comments on commit 087571b

Please sign in to comment.