in api/datanode/datanode.go [133:154]
func (dnClient *DatanodeClient) WriteChunk(id *dnapi.DatanodeBlockID, info dnapi.ChunkInfo, data []byte) (dnapi.ChunkInfo, error) {
req := dnapi.WriteChunkRequestProto{
BlockID: id,
ChunkData: &info,
Data: data,
}
commandType := dnapi.Type_WriteChunk
uuid := dnClient.currentDatanode.GetUuid()
proto := dnapi.ContainerCommandRequestProto{
CmdType: &commandType,
WriteChunk: &req,
ContainerID: id.ContainerID,
DatanodeUuid: &uuid,
}
_, err := dnClient.sendDatanodeCommand(proto)
if err != nil {
return info, err
}
return info, nil
}