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

Start peermanager as a component

Browse source
This commit is contained in:
mcrakhman 2024-02-01 12:42:55 +01:00
parent 850a4a632e
commit 54cfaae3ce
No known key found for this signature in database
GPG key ID: DED12CFEF5B8396B
1 changed files with 11 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

11
commonspace/spaceservice.go
View file

@ -236,6 +236,17 @@ func (s *spaceService) getSpaceStorageFromRemote(ctx context.Context, id string)
if err != nil {
return nil, err
}
peerApp := s.app.ChildApp().Register(pm)
err = peerApp.Start(ctx)
if err != nil {
return
}
defer func() {
err := peerApp.Close(ctx)
if err != nil {
log.Warn("failed to close peer manager")
}
}()
var peers []peer.Peer
for {
peers, err = pm.GetResponsiblePeers(ctx)