diff --git a/go.mod b/go.mod index 7679704..2259bbe 100644 --- a/go.mod +++ b/go.mod @@ -5,6 +5,7 @@ go 1.17 require ( MINSync v0.0.0 //github.com/rakanalh/scheduler v0.1 + github.com/deckarep/golang-set v1.8.0 github.com/go-co-op/gocron v1.13.0 github.com/liyue201/gostl v1.0.1 github.com/olekukonko/tablewriter v0.0.5 diff --git a/lsdb/Lsdb.go b/lsdb/Lsdb.go index 042cdc3..c8b0883 100644 --- a/lsdb/Lsdb.go +++ b/lsdb/Lsdb.go @@ -1,6 +1,7 @@ // Package lsdb // @Author: Wang Feng // @Description: +// Set的用法:https://www.jianshu.com/p/fee89fbb5f27 // @Version: 0.1.0 // @Date: 2022/3/24 11:41 // @Copyright: MIN-Group;国家重大科技基础设施——未来网络北大实验室;深圳市信息论与未来网络重点实验室 @@ -9,6 +10,7 @@ package lsdb import ( + "MINSync" "bytes" common2 "minlib/common" "minlib/component" @@ -58,6 +60,14 @@ type Lsdb struct { // 不同类型lsa的序列号管理器 sequencingManager *SequencingManager + // todo 信号接收器: + m_onNewLsaConnection *utils.SignalConnection + + // todo 分片获取器、分片发送器 + m_fetchers *MINSync.FragmentFetcher + m_segmentPublisher *MINSync.FragmentPublisher + + // todo InMemoryStoragePersistent isBuildAdjLsaScheduled bool // 是否安排构建邻接LSA adjBuildCount uint64 // 邻接LSA的构建的统计数目