File tree Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -164,6 +164,7 @@ func (d *Downloader) runStateSync(s *stateSync) *stateSync {
164
164
// Finalize the request and queue up for processing
165
165
req .timer .Stop ()
166
166
req .dropped = true
167
+ req .delivered = time .Now ()
167
168
168
169
finished = append (finished , req )
169
170
delete (active , p .id )
@@ -176,6 +177,7 @@ func (d *Downloader) runStateSync(s *stateSync) *stateSync {
176
177
if active [req .peer .id ] != req {
177
178
continue
178
179
}
180
+ req .delivered = time .Now ()
179
181
// Move the timed out data back into the download queue
180
182
finished = append (finished , req )
181
183
delete (active , req .peer .id )
@@ -193,6 +195,7 @@ func (d *Downloader) runStateSync(s *stateSync) *stateSync {
193
195
// Move the previous request to the finished set
194
196
old .timer .Stop ()
195
197
old .dropped = true
198
+ old .delivered = time .Now ()
196
199
finished = append (finished , old )
197
200
}
198
201
// Start a timer to notify the sync loop if the peer stalled.
You can’t perform that action at this time.
0 commit comments