LBRYCommunity/reflector.go
1
0
Fork 0
Code Issues 7 Pull requests Projects Releases 10 Packages Wiki Activity

store uploaded blobs

Browse source
This commit is contained in:
Niko Storni 2020-10-15 00:12:18 +02:00
parent a80e0f5b0d
commit f1875454cc
1 changed files with 10 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
cmd/reflector.go
View file

@ -93,15 +93,6 @@ func reflectorCmd(cmd *cobra.Command, args []string) {
} }
blobStore = store.NewDBBackedStore(blobStore, db) blobStore = store.NewDBBackedStore(blobStore, db)
reflectorServer = reflector.NewServer(blobStore)
reflectorServer.Timeout = 3 * time.Minute
reflectorServer.EnableBlocklist = !disableBlocklist
err = reflectorServer.Start(":" + strconv.Itoa(receiverPort))
if err != nil {
log.Fatal(err)
}
} }
if reflectorCmdCacheDir != "" { if reflectorCmdCacheDir != "" {
@ -112,6 +103,16 @@ func reflectorCmd(cmd *cobra.Command, args []string) {
blobStore = store.NewCachingBlobStore(blobStore, store.NewDiskBlobStore(reflectorCmdCacheDir, 2)) blobStore = store.NewCachingBlobStore(blobStore, store.NewDiskBlobStore(reflectorCmdCacheDir, 2))
} }
if !disableUploads {
reflectorServer = reflector.NewServer(blobStore)
reflectorServer.Timeout = 3 * time.Minute
reflectorServer.EnableBlocklist = !disableBlocklist
err = reflectorServer.Start(":" + strconv.Itoa(receiverPort))
if err != nil {
log.Fatal(err)
}
}
peerServer := peer.NewServer(blobStore) peerServer := peer.NewServer(blobStore)
err = peerServer.Start(":" + strconv.Itoa(tcpPeerPort)) err = peerServer.Start(":" + strconv.Itoa(tcpPeerPort))
if err != nil { if err != nil {