Method Store

chunk/storage.go:362–404

Store stores a chunk in the RAM and adds it to the disk storage queue

(id RequestID, bytes []byte)

// Store stores a chunk in the RAM and adds it to the disk storage queue
func (s *Storage) Store(id RequestID, bytes []byte) (err error) {
	s.lock.RLock()

	// Avoid storing same chunk multiple times
	chunk := s.fetch(id)
	if nil != chunk && chunk.clean {
		Log.Tracef("Create chunk %v (exists: clean)", id)
		s.lock.RUnlock()
		return nil
	}

	s.lock.RUnlock()
	s.lock.Lock()
	defer s.lock.Unlock()

	if nil != chunk {
		if chunk.valid(id) {
			Log.Debugf("Create chunk %v (exists: valid)", id)
			return nil
		}
		Log.Warningf("Create chunk %v(exists: overwrite)", id)
	} else {
		index := s.stack.Pop()
		if -1 == index {
			Log.Debugf("Create chunk %v (failed)", id)
			return fmt.Errorf("No buffers available")
		}
		chunk = s.buffers[index]
		deleteID := chunk.id
		if blankRequestID != deleteID {
			delete(s.chunks, deleteID)
			Log.Debugf("Create chunk %v (reused)", id)
		} else {
			Log.Debugf("Create chunk %v (stored)", id)
		}
		s.chunks[id] = index
		chunk.item = s.stack.Push(index)
	}

	chunk.update(id, bytes)

	return nil
}

// fetch chunk and index by id
func (s *Storage) fetch(id RequestID) *Chunk {