func()

in api/datanode/datanode.go [194:218]

• 23 lines of code
• 2 McCabe index (conditional complexity)

func (dnClient *DatanodeClient) PutBlock(id *dnapi.DatanodeBlockID, chunks []*dnapi.ChunkInfo) error {

	flags := int64(0)
	req := dnapi.PutBlockRequestProto{
		BlockData: &dnapi.BlockData{
			BlockID:  id,
			Flags:    &flags,
			Metadata: make([]*dnapi.KeyValue, 0),
			Chunks:   chunks,
		},
	}
	commandType := dnapi.Type_PutBlock
	proto := dnapi.ContainerCommandRequestProto{
		CmdType:      &commandType,
		PutBlock:     &req,
		ContainerID:  id.ContainerID,
		DatanodeUuid: dnClient.GetCurrentDnUUid(),
	}

	_, err := dnClient.sendDatanodeCommand(proto)
	if err != nil {
		return err
	}
	return nil
}