229 	struct smcd_cdc_msg cdc;  in smcd_cdc_msg_send()  local
232 	memset(&cdc, 0, sizeof(cdc));  in smcd_cdc_msg_send()
233 	cdc.common.type = SMC_CDC_MSG_TYPE;  in smcd_cdc_msg_send()
235 	cdc.prod.wrap = curs.wrap;  in smcd_cdc_msg_send()
236 	cdc.prod.count = curs.count;  in smcd_cdc_msg_send()
238 	cdc.cons.wrap = curs.wrap;  in smcd_cdc_msg_send()
239 	cdc.cons.count = curs.count;  in smcd_cdc_msg_send()
240 	cdc.cons.prod_flags = conn->local_tx_ctrl.prod_flags;  in smcd_cdc_msg_send()
241 	cdc.cons.conn_state_flags = conn->local_tx_ctrl.conn_state_flags;  in smcd_cdc_msg_send()
242 	rc = smcd_tx_ism_write(conn, &cdc, sizeof(cdc), 0, 1);  in smcd_cdc_msg_send()
288 static void smc_cdc_msg_validate(struct smc_sock *smc, struct smc_cdc_msg *cdc,  in smc_cdc_msg_validate()  argument
292 	u16 recv_seq = ntohs(cdc->seqno);  in smc_cdc_msg_validate()
311 				    struct smc_cdc_msg *cdc)  in smc_cdc_msg_recv_action()  argument
319 	smc_cdc_msg_to_host(&conn->local_rx_ctrl, cdc, conn);  in smc_cdc_msg_recv_action()
380 static void smc_cdc_msg_recv(struct smc_sock *smc, struct smc_cdc_msg *cdc)  in smc_cdc_msg_recv()  argument
384 	smc_cdc_msg_recv_action(smc, cdc);  in smc_cdc_msg_recv()
399 	struct smcd_cdc_msg cdc;  in smcd_cdc_rx_tsklet()  local
406 	smcd_curs_copy(&cdc.prod, &data_cdc->prod, conn);  in smcd_cdc_rx_tsklet()
407 	smcd_curs_copy(&cdc.cons, &data_cdc->cons, conn);  in smcd_cdc_rx_tsklet()
409 	smc_cdc_msg_recv(smc, (struct smc_cdc_msg *)&cdc);  in smcd_cdc_rx_tsklet()
425 	struct smc_cdc_msg *cdc = buf;  in smc_cdc_rx_handler()  local
432 	if (cdc->len != SMC_WR_TX_SIZE)  in smc_cdc_rx_handler()
438 	conn = smc_lgr_find_conn(ntohl(cdc->token), lgr);  in smc_cdc_rx_handler()
444 	if (cdc->prod_flags.failover_validation) {  in smc_cdc_rx_handler()
445 		smc_cdc_msg_validate(smc, cdc, link);  in smc_cdc_rx_handler()
448 	if (smc_cdc_before(ntohs(cdc->seqno),  in smc_cdc_rx_handler()
453 	smc_cdc_msg_recv(smc, cdc);  in smc_cdc_rx_handler()