231 	struct smcd_cdc_msg cdc;  in smcd_cdc_msg_send()  local
234 	memset(&cdc, 0, sizeof(cdc));  in smcd_cdc_msg_send()
235 	cdc.common.type = SMC_CDC_MSG_TYPE;  in smcd_cdc_msg_send()
237 	cdc.prod.wrap = curs.wrap;  in smcd_cdc_msg_send()
238 	cdc.prod.count = curs.count;  in smcd_cdc_msg_send()
240 	cdc.cons.wrap = curs.wrap;  in smcd_cdc_msg_send()
241 	cdc.cons.count = curs.count;  in smcd_cdc_msg_send()
242 	cdc.cons.prod_flags = conn->local_tx_ctrl.prod_flags;  in smcd_cdc_msg_send()
243 	cdc.cons.conn_state_flags = conn->local_tx_ctrl.conn_state_flags;  in smcd_cdc_msg_send()
244 	rc = smcd_tx_ism_write(conn, &cdc, sizeof(cdc), 0, 1);  in smcd_cdc_msg_send()
290 static void smc_cdc_msg_validate(struct smc_sock *smc, struct smc_cdc_msg *cdc,  in smc_cdc_msg_validate()  argument
294 	u16 recv_seq = ntohs(cdc->seqno);  in smc_cdc_msg_validate()
313 				    struct smc_cdc_msg *cdc)  in smc_cdc_msg_recv_action()  argument
321 	smc_cdc_msg_to_host(&conn->local_rx_ctrl, cdc, conn);  in smc_cdc_msg_recv_action()
382 static void smc_cdc_msg_recv(struct smc_sock *smc, struct smc_cdc_msg *cdc)  in smc_cdc_msg_recv()  argument
386 	smc_cdc_msg_recv_action(smc, cdc);  in smc_cdc_msg_recv()
401 	struct smcd_cdc_msg cdc;  in smcd_cdc_rx_tsklet()  local
408 	smcd_curs_copy(&cdc.prod, &data_cdc->prod, conn);  in smcd_cdc_rx_tsklet()
409 	smcd_curs_copy(&cdc.cons, &data_cdc->cons, conn);  in smcd_cdc_rx_tsklet()
411 	smc_cdc_msg_recv(smc, (struct smc_cdc_msg *)&cdc);  in smcd_cdc_rx_tsklet()
427 	struct smc_cdc_msg *cdc = buf;  in smc_cdc_rx_handler()  local
434 	if (cdc->len != SMC_WR_TX_SIZE)  in smc_cdc_rx_handler()
440 	conn = smc_lgr_find_conn(ntohl(cdc->token), lgr);  in smc_cdc_rx_handler()
446 	if (cdc->prod_flags.failover_validation) {  in smc_cdc_rx_handler()
447 		smc_cdc_msg_validate(smc, cdc, link);  in smc_cdc_rx_handler()
450 	if (smc_cdc_before(ntohs(cdc->seqno),  in smc_cdc_rx_handler()
455 	smc_cdc_msg_recv(smc, cdc);  in smc_cdc_rx_handler()