func()

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
}