Merge pull request #33 from bogdanovich/ab/limit-open-files

Limit goleveldb OpenFilesCacheCapacity to 64 files per queue
bogdanovich · Jan 2, 2016 · cd4b8e7 · cd4b8e7
2 parents 98beb30 + 840ee54
commit cd4b8e7
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 2 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,6 @@
+## 0.6.2
+- Limit OpenFilesCacheCapacity to 64 per queue
+
 ## 0.6.0
 - Change durable cursor separator from `:` to `.` for Kestrel compatibility.<br>
   Kestrel uses `:` as a namespace separator.

diff --git a/queue/queue.go b/queue/queue.go
@@ -33,6 +33,8 @@ var (
 	ErrSharedFlush = errors.New("queue: can't flush shared queue")
 )
 
+const levelDBOpenFilesCacheCapacity = 64
+
 var validQueueNameRegex = regexp.MustCompile(`[^a-zA-Z0-9_\-\:]+`)
 
 // Consumer represents a queue consumer
@@ -278,7 +280,10 @@ func (q *Queue) open() error {
 
 	if !q.isShared {
 		var err error
-		q.db, err = leveldb.OpenFile(q.Path(), &opt.Options{})
+		q.db, err = leveldb.OpenFile(
+			q.Path(),
+			&opt.Options{OpenFilesCacheCapacity: levelDBOpenFilesCacheCapacity},
+		)
 		if err != nil {
 			return err
 		}

diff --git a/repository/repository.go b/repository/repository.go
@@ -13,7 +13,7 @@ import (
 )
 
 // Version represents siberite version
-const Version = "siberite-0.6.1"
+const Version = "siberite-0.6.2"
 
 // QueueRepository represents a repository of queues
 type QueueRepository struct {