benjamyn/any-sync
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Change head sync update behaviour

Browse Source
This commit is contained in:
mcrakhman 2023-07-10 23:47:29 +02:00
parent 94aea5bafb
commit b4cc8d0a61
No known key found for this signature in database
GPG Key ID: DED12CFEF5B8396B
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
commonspace/object/acl/syncacl/aclsyncprotocol.go
View File

@ -54,11 +54,11 @@ func (a *aclSyncProtocol) HeadUpdate(ctx context.Context, senderId string, updat
return return
} }
err = a.aclList.AddRawRecords(update.Records) err = a.aclList.AddRawRecords(update.Records)
if err != nil && err != list.ErrIncorrectRecordSequence { if err == list.ErrIncorrectRecordSequence {
return
}
return a.reqFactory.CreateFullSyncRequest(a.aclList, update.Head) return a.reqFactory.CreateFullSyncRequest(a.aclList, update.Head)
} }
return
}
func (a *aclSyncProtocol) FullSyncRequest(ctx context.Context, senderId string, request *consensusproto.LogFullSyncRequest) (response *consensusproto.LogSyncMessage, err error) { func (a *aclSyncProtocol) FullSyncRequest(ctx context.Context, senderId string, request *consensusproto.LogFullSyncRequest) (response *consensusproto.LogSyncMessage, err error) {
log := a.log.With( log := a.log.With(