aboutsummaryrefslogtreecommitdiff
path: root/cmd/main.go
diff options
context:
space:
mode:
authorFelix Hanley <felix@userspace.com.au>2018-03-20 10:12:21 +0000
committerFelix Hanley <felix@userspace.com.au>2018-03-20 10:12:21 +0000
commitef4aec50a8f6ace8076d4bfeef0ba64cf8598048 (patch)
tree8a51ab35cbe0a984485093ffc20aea8647dc7157 /cmd/main.go
parent6f21e57cfb1baf80aa195327cfecff2d732319aa (diff)
downloaddhtsearch-ef4aec50a8f6ace8076d4bfeef0ba64cf8598048.tar.gz
dhtsearch-ef4aec50a8f6ace8076d4bfeef0ba64cf8598048.tar.bz2
Only defer store close if opened successfully
Diffstat (limited to 'cmd/main.go')
-rw-r--r--cmd/main.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/cmd/main.go b/cmd/main.go
index 9faca75..62a5826 100644
--- a/cmd/main.go
+++ b/cmd/main.go
@@ -79,11 +79,11 @@ func main() {
log.Debug("debugging")
store, err := db.NewStore(dsn)
- defer store.Close()
if err != nil {
log.Error("failed to connect store", "error", err)
os.Exit(1)
}
+ defer store.Close()
createTagRegexps()
@@ -144,7 +144,7 @@ func startDHTNodes(s models.PeerStore) {
func processPendingPeers(s models.InfohashStore) {
log.Debug("processing pending peers")
for {
- peers, err := s.PendingInfohashes(1)
+ peers, err := s.PendingInfohashes(10)
if err != nil {
log.Debug("failed to get pending peer", "error", err)
time.Sleep(time.Second * 1)