diff options
| author | Jeffrey Wilcke <jeffrey@ethereum.org> | 2015-05-14 23:15:51 +0800 |
|---|---|---|
| committer | Jeffrey Wilcke <jeffrey@ethereum.org> | 2015-05-14 23:15:51 +0800 |
| commit | 90b94e64fcdc6a2099ec5c48e41acf7f95a6b804 (patch) | |
| tree | f8b7c0336f69aa3c66560a57dc9e172eb81418e8 /p2p/discover | |
| parent | ff87c241a715833fa09cbed5e4acf0f1dfa9b745 (diff) | |
| parent | d2f119cf9b30a7568b5ebe7c290c3be30dc0f2de (diff) | |
| download | dexon-90b94e64fcdc6a2099ec5c48e41acf7f95a6b804.tar dexon-90b94e64fcdc6a2099ec5c48e41acf7f95a6b804.tar.gz dexon-90b94e64fcdc6a2099ec5c48e41acf7f95a6b804.tar.bz2 dexon-90b94e64fcdc6a2099ec5c48e41acf7f95a6b804.tar.lz dexon-90b94e64fcdc6a2099ec5c48e41acf7f95a6b804.tar.xz dexon-90b94e64fcdc6a2099ec5c48e41acf7f95a6b804.tar.zst dexon-90b94e64fcdc6a2099ec5c48e41acf7f95a6b804.zip | |
Merge pull request #971 from fjl/p2p-limit-tweaks
p2p: tweak connection limits
Diffstat (limited to 'p2p/discover')
| -rw-r--r-- | p2p/discover/database.go | 5 | ||||
| -rw-r--r-- | p2p/discover/table.go | 2 |
2 files changed, 4 insertions, 3 deletions
diff --git a/p2p/discover/database.go b/p2p/discover/database.go index dc0b97ddf..2b9da0423 100644 --- a/p2p/discover/database.go +++ b/p2p/discover/database.go @@ -17,6 +17,7 @@ import ( "github.com/syndtr/goleveldb/leveldb" "github.com/syndtr/goleveldb/leveldb/errors" "github.com/syndtr/goleveldb/leveldb/iterator" + "github.com/syndtr/goleveldb/leveldb/opt" "github.com/syndtr/goleveldb/leveldb/storage" "github.com/syndtr/goleveldb/leveldb/util" ) @@ -72,8 +73,8 @@ func newMemoryNodeDB() (*nodeDB, error) { // newPersistentNodeDB creates/opens a leveldb backed persistent node database, // also flushing its contents in case of a version mismatch. func newPersistentNodeDB(path string, version int) (*nodeDB, error) { - // Try to open the cache, recovering any corruption - db, err := leveldb.OpenFile(path, nil) + opts := &opt.Options{OpenFilesCacheCapacity: 5} + db, err := leveldb.OpenFile(path, opts) if _, iscorrupted := err.(*errors.ErrCorrupted); iscorrupted { db, err = leveldb.RecoverFile(path, nil) } diff --git a/p2p/discover/table.go b/p2p/discover/table.go index 2c9cb80d5..5e6dd8d0d 100644 --- a/p2p/discover/table.go +++ b/p2p/discover/table.go @@ -25,7 +25,7 @@ const ( hashBits = len(common.Hash{}) * 8 nBuckets = hashBits + 1 // Number of buckets - maxBondingPingPongs = 10 + maxBondingPingPongs = 16 ) type Table struct { |