mirror of
https://github.com/QuilibriumNetwork/ceremonyclient.git
synced 2026-02-22 19:07:26 +08:00
32 lines
517 B
Go
32 lines
517 B
Go
package hypergraph
|
|
|
|
import (
|
|
"sync/atomic"
|
|
"time"
|
|
)
|
|
|
|
type SyncController struct {
|
|
isSyncing atomic.Bool
|
|
SyncStatus map[string]*SyncInfo
|
|
}
|
|
|
|
func (s *SyncController) TryEstablishSyncSession() bool {
|
|
return !s.isSyncing.Swap(true)
|
|
}
|
|
|
|
func (s *SyncController) EndSyncSession() {
|
|
s.isSyncing.Store(false)
|
|
}
|
|
|
|
type SyncInfo struct {
|
|
Unreachable bool
|
|
LastSynced time.Time
|
|
}
|
|
|
|
func NewSyncController() *SyncController {
|
|
return &SyncController{
|
|
isSyncing: atomic.Bool{},
|
|
SyncStatus: map[string]*SyncInfo{},
|
|
}
|
|
}
|