From 29d62185cffd486b8d9a0f6512303b806450bfe1 Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Mon, 26 Dec 2016 08:22:25 +0100 Subject: [PATCH] notify read and write on remote close --- transport/internet/kcp/connection.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/transport/internet/kcp/connection.go b/transport/internet/kcp/connection.go index 367244812..3913cbf9f 100644 --- a/transport/internet/kcp/connection.go +++ b/transport/internet/kcp/connection.go @@ -517,6 +517,10 @@ func (v *Connection) Input(segments []Segment) { v.SetState(StateTerminated) } } + if seg.Option == SegmentOptionClose || seg.Command() == CommandTerminate { + v.OnDataInput() + v.OnDataOutput() + } v.sendingWorker.ProcessReceivingNext(seg.ReceivinNext) v.receivingWorker.ProcessSendingNext(seg.SendingNext) v.roundTrip.UpdatePeerRTO(seg.PeerRTO, current)