238 	struct smcd_cdc_msg cdc;  in smcd_cdc_msg_send()  local
241 	memset(&cdc, 0, sizeof(cdc));  in smcd_cdc_msg_send()
242 	cdc.common.type = SMC_CDC_MSG_TYPE;  in smcd_cdc_msg_send()
244 	cdc.prod.wrap = curs.wrap;  in smcd_cdc_msg_send()
245 	cdc.prod.count = curs.count;  in smcd_cdc_msg_send()
247 	cdc.cons.wrap = curs.wrap;  in smcd_cdc_msg_send()
248 	cdc.cons.count = curs.count;  in smcd_cdc_msg_send()
249 	cdc.cons.prod_flags = conn->local_tx_ctrl.prod_flags;  in smcd_cdc_msg_send()
250 	cdc.cons.conn_state_flags = conn->local_tx_ctrl.conn_state_flags;  in smcd_cdc_msg_send()
251 	rc = smcd_tx_ism_write(conn, &cdc, sizeof(cdc), 0, 1);  in smcd_cdc_msg_send()
297 static void smc_cdc_msg_validate(struct smc_sock *smc, struct smc_cdc_msg *cdc,  in smc_cdc_msg_validate()  argument
301 	u16 recv_seq = ntohs(cdc->seqno);  in smc_cdc_msg_validate()
320 				    struct smc_cdc_msg *cdc)  in smc_cdc_msg_recv_action()  argument
328 	smc_cdc_msg_to_host(&conn->local_rx_ctrl, cdc, conn);  in smc_cdc_msg_recv_action()
393 static void smc_cdc_msg_recv(struct smc_sock *smc, struct smc_cdc_msg *cdc)  in smc_cdc_msg_recv()  argument
397 	smc_cdc_msg_recv_action(smc, cdc);  in smc_cdc_msg_recv()
412 	struct smcd_cdc_msg cdc;  in smcd_cdc_rx_tsklet()  local
419 	smcd_curs_copy(&cdc.prod, &data_cdc->prod, conn);  in smcd_cdc_rx_tsklet()
420 	smcd_curs_copy(&cdc.cons, &data_cdc->cons, conn);  in smcd_cdc_rx_tsklet()
422 	smc_cdc_msg_recv(smc, (struct smc_cdc_msg *)&cdc);  in smcd_cdc_rx_tsklet()
438 	struct smc_cdc_msg *cdc = buf;  in smc_cdc_rx_handler()  local
445 	if (cdc->len != SMC_WR_TX_SIZE)  in smc_cdc_rx_handler()
451 	conn = smc_lgr_find_conn(ntohl(cdc->token), lgr);  in smc_cdc_rx_handler()
457 	if (cdc->prod_flags.failover_validation) {  in smc_cdc_rx_handler()
458 		smc_cdc_msg_validate(smc, cdc, link);  in smc_cdc_rx_handler()
461 	if (smc_cdc_before(ntohs(cdc->seqno),  in smc_cdc_rx_handler()
466 	smc_cdc_msg_recv(smc, cdc);  in smc_cdc_rx_handler()