Commitbe08ec5

committed

optimize sync interest buffer

1 parent62f9113 commitbe08ec5Copy full SHA for be08ec5

File tree

-1

lines changed

-1

lines changed

Lines changed: 5 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -110,6 +110,7 @@ def sync_handler(self, name: FormalName, _param: InterestParam, _app_param: Bina`
`110`	`110`
`111`	`111`	`need_fetch=False`
`112`	`112`	`forrsv_id,rsv_seqinrsv_dict.items():`
	`113`	`+already_sent= []`
`113`	`114`	`lsv_seq=self.local_sv.get(rsv_id,0)`
`114`	`115`	`iflsv_seq<rsv_seq:`
`115`	`116`	`# Remote is latest`
`@@ -121,7 +122,10 @@ def sync_handler(self, name: FormalName, _param: InterestParam, _app_param: Bina`
`121`	`122`	`# Local is latest`
`122`	`123`	`self.logger.debug(f'Outdated remote on: [{Name.to_str(rsv_id)}]:{rsv_seq} <{lsv_seq}')`
`123`	`124`	`raw_inst=self.inst_buffer[rsv_id]`
`124`		`-self.send_interest(raw_inst)`
	`125`	`+ifraw_instnotinalready_sent:`
	`126`	`+already_sent.append(raw_inst)`
	`127`	`+self.send_interest(raw_inst)`
	`128`	`+else:pass`
`125`	`129`
`126`	`130`	`# Notify remote there are mising nodes`
`127`	`131`	`diff=self.local_sv.keys()-rsv_dict.keys()`

Comments

(0)