Method Load

chunk/storage.go:335–359

Load a chunk from ram or creates it

(id RequestID)

// Load a chunk from ram or creates it
func (s *Storage) Load(id RequestID) []byte {
	s.lock.RLock()
	chunk := s.fetch(id)
	if nil == chunk {
		Log.Tracef("Load chunk %v (missing)", id)
		s.lock.RUnlock()
		return nil
	}
	if chunk.clean {
		Log.Tracef("Load chunk %v (clean)", id)
		defer s.lock.RUnlock()
		return chunk.bytes
	}
	s.lock.RUnlock()
	// Switch to write lock to avoid races on crc verification
	s.lock.Lock()
	defer s.lock.Unlock()
	if chunk.valid(id) {
		Log.Debugf("Load chunk %v (verified)", id)
		return chunk.bytes
	}
	Log.Warningf("Load chunk %v (bad checksum: %08x <> %08x)", id, chunk.checksum, chunk.calculateChecksum())
	s.stack.Purge(chunk.item)
	return nil
}

// 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) {