diff --git a/services/hh/processor.go b/services/hh/processor.go index a54b791ba3..d734d5da97 100644 --- a/services/hh/processor.go +++ b/services/hh/processor.go @@ -31,7 +31,6 @@ type ProcessorOptions struct { } func NewProcessor(dir string, writer shardWriter, options ProcessorOptions) (*Processor, error) { - p := &Processor{ dir: dir, queues: map[uint64]*queue{}, @@ -69,7 +68,6 @@ func (p *Processor) loadQueues() error { } for _, file := range files { - nodeID, err := strconv.ParseUint(file.Name(), 10, 64) if err != nil { return err diff --git a/services/hh/queue.go b/services/hh/queue.go index f2143856fb..0925a02094 100644 --- a/services/hh/queue.go +++ b/services/hh/queue.go @@ -513,7 +513,7 @@ func (l *segment) advance() error { return ErrNotOpen } - // If we're ad the end of the file, can't advance + // If we're at the end of the file, can't advance if int64(l.pos) == l.size-footerSize { l.currentSize = 0 return io.EOF diff --git a/services/hh/service.go b/services/hh/service.go index c03f8f5f35..124f2dfd8d 100644 --- a/services/hh/service.go +++ b/services/hh/service.go @@ -57,9 +57,7 @@ func (s *Service) Open() error { s.closing = make(chan struct{}) go s.retryWrites() - go s.expireWrites() - // go s.evictWrites() return nil }