anyproto/any-sync
1
0
Fork 0
mirror of https://github.com/anyproto/any-sync.git synced 2025-06-08 05:57:03 +09:00
Code Activity

Run request pool

Browse source
This commit is contained in:
mcrakhman 2024-08-09 11:13:53 +02:00
parent 54245aef82
commit eed5019bff
No known key found for this signature in database
GPG key ID: DED12CFEF5B8396B
3 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

1
commonspace/globalsync/requestpool.go
View file

@ -13,6 +13,7 @@ import (
type RequestPool interface {
TryTake(peerId, objectId string) bool
Release(peerId, objectId string)
Run()
QueueRequestAction(peerId, objectId string, action func(ctx context.Context), remove func()) (err error)
Close()
}

1
commonspace/globalsync/sync.go
View file

@ -41,6 +41,7 @@ func (g *globalSync) Init(a *app.App) (err error) {
}
func (g *globalSync) Run(ctx context.Context) (err error) {
g.rp.Run()
return
}

1
commonspace/sync/requestmanager.go
View file

@ -126,7 +126,6 @@ func (r *requestManager) HandleStreamRequest(ctx context.Context, rq syncdeps.Re
}
func (r *requestManager) Close() {
r.requestPool.Close()
}
func fullId(peerId, objectId string) string {