From 2d1b66fcbc3efc5338015cad096e354b7d599b3d Mon Sep 17 00:00:00 2001 From: Sergey Matveev Date: Tue, 17 Jan 2017 00:12:18 +0300 Subject: [PATCH] Delete downloaded file state --- src/cypherpunks.ru/nncp/sp.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/cypherpunks.ru/nncp/sp.go b/src/cypherpunks.ru/nncp/sp.go index 085d96f..9a46961 100644 --- a/src/cypherpunks.ru/nncp/sp.go +++ b/src/cypherpunks.ru/nncp/sp.go @@ -851,6 +851,9 @@ func (state *SPState) ProcessSP(payload []byte) ([][]byte, error) { } state.ctx.LogI("sp-done", SdsAdd(sdsp, SDS{"xx": string(TRx)}), "") os.Rename(filePath+PartSuffix, filePath) + state.Lock() + delete(state.infosTheir, *file.Hash) + state.Unlock() go func() { state.payloads <- MarshalSP(SPTypeDone, SPDone{file.Hash}) }() -- 2.44.0