Fix comments
parent
1024965db7
commit
4ec77d8b84
|
@ -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
|
||||
|
|
|
@ -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
|
||||
|
|
|
@ -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
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue