File tree Expand file tree Collapse file tree 5 files changed +891
-13
lines changed Expand file tree Collapse file tree 5 files changed +891
-13
lines changed Original file line number Diff line number Diff line change @@ -73,6 +73,7 @@ pub struct Blobs<S> {
7373 events : EventSender ,
7474 downloader : Downloader ,
7575 batches : tokio:: sync:: Mutex < BlobBatches > ,
76+ endpoint : Endpoint ,
7677}
7778
7879/// Name used for logging when new node addresses are added from gossip.
@@ -135,12 +136,14 @@ impl<S: crate::store::Store> Blobs<S> {
135136 rt : LocalPoolHandle ,
136137 events : EventSender ,
137138 downloader : Downloader ,
139+ endpoint : Endpoint ,
138140 ) -> Self {
139141 Self {
140142 rt,
141143 store,
142144 events,
143145 downloader,
146+ endpoint,
144147 batches : Default :: default ( ) ,
145148 }
146149 }
@@ -149,6 +152,14 @@ impl<S: crate::store::Store> Blobs<S> {
149152 & self . store
150153 }
151154
155+ pub ( crate ) fn rt ( & self ) -> LocalPoolHandle {
156+ self . rt . clone ( )
157+ }
158+
159+ pub ( crate ) fn endpoint ( & self ) -> & Endpoint {
160+ & self . endpoint
161+ }
162+
152163 pub async fn batches ( & self ) -> tokio:: sync:: MutexGuard < ' _ , BlobBatches > {
153164 self . batches . lock ( ) . await
154165 }
You can’t perform that action at this time.
0 commit comments