func()

in api/datanode/datanode.go [116:131]


func (dnClient *DatanodeClient) CreateAndWriteChunk(id *dnapi.DatanodeBlockID, blockOffset uint64, buffer []byte, length uint64) (dnapi.ChunkInfo, error) {
	bpc := uint32(12)
	checksumType := dnapi.ChecksumType_NONE
	checksumDataProto := dnapi.ChecksumData{
		Type:             &checksumType,
		BytesPerChecksum: &bpc,
	}
	chunkName := fmt.Sprintf("chunk_%d", blockOffset)
	chunkInfoProto := dnapi.ChunkInfo{
		ChunkName:    &chunkName,
		Offset:       &blockOffset,
		Len:          &length,
		ChecksumData: &checksumDataProto,
	}
	return dnClient.WriteChunk(id, chunkInfoProto, buffer[0:length])
}