diff options
| author | Felix Hanley <felix@userspace.com.au> | 2018-03-20 10:12:21 +0000 |
|---|---|---|
| committer | Felix Hanley <felix@userspace.com.au> | 2018-03-20 10:12:21 +0000 |
| commit | ef4aec50a8f6ace8076d4bfeef0ba64cf8598048 (patch) | |
| tree | 8a51ab35cbe0a984485093ffc20aea8647dc7157 /cmd/main.go | |
| parent | 6f21e57cfb1baf80aa195327cfecff2d732319aa (diff) | |
| download | dhtsearch-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.go | 4 |
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) |
