MCPcopy
hub / github.com/cubefs/cubefs / handlePacket

Method handlePacket

client/blockcache/bcache/service.go:206–218  ·  view source on GitHub ↗
(conn net.Conn, p *BlockCachePacket)

Source from the content-addressed store, hash-verified

204}
205
206func (s *bcacheStore) handlePacket(conn net.Conn, p *BlockCachePacket) (err error) {
207 switch p.Opcode {
208 case OpBlockCachePut:
209 err = s.opBlockCachePut(conn, p)
210 case OpBlockCacheGet:
211 err = s.opBlockCacheGet(conn, p)
212 case OpBlockCacheDel:
213 err = s.opBlockCacheEvict(conn, p)
214 default:
215 err = fmt.Errorf("unknown Opcode: %d", p.Opcode)
216 }
217 return
218}
219
220func (s *bcacheStore) opBlockCachePut(conn net.Conn, p *BlockCachePacket) (err error) {
221 req := &PutCacheRequest{}

Callers 1

serveConnMethod · 0.95

Calls 4

opBlockCachePutMethod · 0.95
opBlockCacheGetMethod · 0.95
opBlockCacheEvictMethod · 0.95
ErrorfMethod · 0.65

Tested by

no test coverage detected