241 	struct smcd_cdc_msg cdc;  in smcd_cdc_msg_send()  local
244 	memset(&cdc, 0, sizeof(cdc));  in smcd_cdc_msg_send()
245 	cdc.common.type = SMC_CDC_MSG_TYPE;  in smcd_cdc_msg_send()
247 	cdc.prod.wrap = curs.wrap;  in smcd_cdc_msg_send()
248 	cdc.prod.count = curs.count;  in smcd_cdc_msg_send()
250 	cdc.cons.wrap = curs.wrap;  in smcd_cdc_msg_send()
251 	cdc.cons.count = curs.count;  in smcd_cdc_msg_send()
252 	cdc.cons.prod_flags = conn->local_tx_ctrl.prod_flags;  in smcd_cdc_msg_send()
253 	cdc.cons.conn_state_flags = conn->local_tx_ctrl.conn_state_flags;  in smcd_cdc_msg_send()
254 	rc = smcd_tx_ism_write(conn, &cdc, sizeof(cdc), 0, 1);  in smcd_cdc_msg_send()
308 static void smc_cdc_msg_validate(struct smc_sock *smc, struct smc_cdc_msg *cdc,  in smc_cdc_msg_validate()  argument
312 	u16 recv_seq = ntohs(cdc->seqno);  in smc_cdc_msg_validate()
331 				    struct smc_cdc_msg *cdc)  in smc_cdc_msg_recv_action()  argument
339 	smc_cdc_msg_to_host(&conn->local_rx_ctrl, cdc, conn);  in smc_cdc_msg_recv_action()
427 static void smc_cdc_msg_recv(struct smc_sock *smc, struct smc_cdc_msg *cdc)  in smc_cdc_msg_recv()  argument
431 	smc_cdc_msg_recv_action(smc, cdc);  in smc_cdc_msg_recv()
446 	struct smcd_cdc_msg cdc;  in smcd_cdc_rx_tsklet()  local
453 	smcd_curs_copy(&cdc.prod, &data_cdc->prod, conn);  in smcd_cdc_rx_tsklet()
454 	smcd_curs_copy(&cdc.cons, &data_cdc->cons, conn);  in smcd_cdc_rx_tsklet()
456 	smc_cdc_msg_recv(smc, (struct smc_cdc_msg *)&cdc);  in smcd_cdc_rx_tsklet()
472 	struct smc_cdc_msg *cdc = buf;  in smc_cdc_rx_handler()  local
479 	if (cdc->len != SMC_WR_TX_SIZE)  in smc_cdc_rx_handler()
485 	conn = smc_lgr_find_conn(ntohl(cdc->token), lgr);  in smc_cdc_rx_handler()
491 	if (cdc->prod_flags.failover_validation) {  in smc_cdc_rx_handler()
492 		smc_cdc_msg_validate(smc, cdc, link);  in smc_cdc_rx_handler()
495 	if (smc_cdc_before(ntohs(cdc->seqno),  in smc_cdc_rx_handler()
500 	smc_cdc_msg_recv(smc, cdc);  in smc_cdc_rx_handler()