Commitfce1297

committed

util: avoid redundant sync interests when remote has missing nodes

1 parent43abefa commitfce1297Copy full SHA for fce1297

File tree

-2

lines changed

-2

lines changed

Lines changed: 6 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -132,9 +132,13 @@ def sync_handler(self, name: FormalName, _param: InterestParam, _app_param: Bina`
`132`	`132`	`iflen(diff)>0:`
`133`	`133`	`self.logger.info(f'Remote missing nodes:{list(diff)}')`
`134`	`134`	`# Missing nodes may only exist in other nodes' sync interest,`
`135`		`-# therefore we have to send all buffered sync interest out`
	`135`	`+# therefore we have to send all buffered sync interest out,`
	`136`	`+# unless they were sent before.`
	`137`	`+already_sent= []`
`136`	`138`	`for_,raw_instinself.inst_buffer.items():`
`137`		`-self.send_interest(raw_inst)`
	`139`	`+ifraw_instnotinalready_sent:`
	`140`	`+already_sent.append(raw_inst)`
	`141`	`+self.send_interest(raw_inst)`
`138`	`142`	`ifneed_fetch:`
`139`	`143`	`self.on_missing_data(self)`
`140`	`144`

Comments

(0)