void kcs_read()

in common/host/kcs.c [41:117]
66 lines of code
14 McCabe index (conditional complexity)

void kcs_read(void *arvg0, void *arvg1, void *arvg2)
{
	int i, rc;
	uint8_t ibuf[KCS_buff_size];
	ipmi_msg bridge_msg;
	ipmi_msg_cfg current_msg;
	ipmb_error status;

	struct kcs_request *req;

	while (1) {
		k_msleep(KCS_POLLING_INTERVAL);

		rc = kcs_aspeed_read(kcs_dev, ibuf, sizeof(ibuf));
		if (rc < 0) {
			if (rc != -ENODATA)
				printk("failed to read KCS data, rc=%d\n", rc);
			continue;
		}

		if (DEBUG_KCS) {
			printk("host KCS read: netfn=0x%02x, cmd=0x%02x, data:\n", ibuf[0],
			       ibuf[1]);
			for (i = 2; i < rc; ++i) {
				if (i && (i % 16 == 0))
					printk("\n");
				printk("%02x ", ibuf[i]);
			}
			printk("\n");
		}

		proc_kcs_ok = true;
		req = (struct kcs_request *)ibuf;
		req->netfn = req->netfn >> 2;

		if (pal_is_to_ipmi_handler(
			    req->netfn, req->cmd)) { // In-band update command, not bridging to bmc
			current_msg.buffer.InF_source = HOST_KCS_IFs;
			current_msg.buffer.netfn = req->netfn;
			current_msg.buffer.cmd = req->cmd;
			current_msg.buffer.data_len = rc - 2; // exclude netfn, cmd
			if (current_msg.buffer.data_len != 0) {
				memcpy(current_msg.buffer.data, req->data,
				       current_msg.buffer.data_len);
			}

			if (DEBUG_KCS) {
				printk("kcs to ipmi netfn %x, cmd %x, length %d\n",
				       current_msg.buffer.netfn, current_msg.buffer.cmd,
				       current_msg.buffer.data_len);
			}

			//if ( ( status = ( IPMI_handler(&current_msg) ) ) != ipmi_error_success ) {
			while (k_msgq_put(&ipmi_msgq, &current_msg, K_NO_WAIT) != 0) {
				k_msgq_purge(&ipmi_msgq);
				printf("KCS retrying put ipmi msgq\n");
			}

		} else { // default command for BMC, should add BIC firmware update, BMC reset, real time sensor read in future
			bridge_msg.data_len = rc - 2; // exclude netfn, cmd
			bridge_msg.seq_source = 0xff; // No seq for KCS
			bridge_msg.InF_source = HOST_KCS_IFs;
			bridge_msg.InF_target =
				BMC_IPMB_IFs; // default bypassing IPMI standard command to BMC
			bridge_msg.netfn = req->netfn;
			bridge_msg.cmd = req->cmd;
			if (bridge_msg.data_len != 0) {
				memcpy(&bridge_msg.data[0], &ibuf[2], rc);
			}

			status = ipmb_send_request(&bridge_msg, IPMB_inf_index_map[BMC_IPMB_IFs]);
			if (status != ipmb_error_success) {
				printk("kcs_read_task send to BMC fail status: %x", status);
			}
		}
	}
}