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])
}