localhots/burlesque
1
0
Fork 0
Code Releases Activity

Fix storage

Browse Source
This commit is contained in:
Gregory Eremin 2014-09-11 14:27:34 +04:00
parent 6ed63b93ff
commit 557b1da99f
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
storage/storage.go
View File

@ -36,7 +36,7 @@ func New(path string) (s *Storage, err error) {
} }
func (s *Storage) Get(queue string) (message []byte, ok bool) { func (s *Storage) Get(queue string) (message []byte, ok bool) {
if _, ok := s.counters[queue]; !ok { if _, exist := s.counters[queue]; !exist {
return return
} }
if size := s.counters[queue].distance(); size == 0 { if size := s.counters[queue].distance(); size == 0 {
@ -51,14 +51,14 @@ func (s *Storage) Get(queue string) (message []byte, ok bool) {
} }
key := makeKey(queue, index) key := makeKey(queue, index)
ok = true message, err := s.kyoto.Get(key)
if err != nil {
if message, err := s.kyoto.Get(key); err != nil {
panic(err) panic(err)
} }
if err := s.kyoto.Remove(key); err != nil { if err := s.kyoto.Remove(key); err != nil {
panic(err) panic(err)
} }
ok = true
return return
} }