From: Sergey Matveev Date: Mon, 16 Jan 2017 21:12:18 +0000 (+0300) Subject: Delete downloaded file state X-Git-Tag: 0.2^2~1 X-Git-Url: http://www.git.cypherpunks.su/?a=commitdiff_plain;h=2d1b66fcbc3efc5338015cad096e354b7d599b3d;p=nncp.git Delete downloaded file state --- 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}) }()