()
| 370 | } |
| 371 | |
| 372 | func (srv *SyncServer) SaveProvidedBlobs() { |
| 373 | ticker := time.NewTicker(5 * time.Minute) |
| 374 | defer ticker.Stop() |
| 375 | for { |
| 376 | select { |
| 377 | case <-ticker.C: |
| 378 | srv.saveProvidedBlobs() |
| 379 | case <-srv.exitCh: |
| 380 | srv.lg.Info("Stopped P2P req-resp L2 block sync server") |
| 381 | return |
| 382 | } |
| 383 | } |
| 384 | } |
| 385 | |
| 386 | func (srv *SyncServer) Close() { |
| 387 | close(srv.exitCh) |
no test coverage detected