226 	struct smcd_cdc_msg cdc;  in smcd_cdc_msg_send()  local
229 	memset(&cdc, 0, sizeof(cdc));  in smcd_cdc_msg_send()
230 	cdc.common.type = SMC_CDC_MSG_TYPE;  in smcd_cdc_msg_send()
232 	cdc.prod.wrap = curs.wrap;  in smcd_cdc_msg_send()
233 	cdc.prod.count = curs.count;  in smcd_cdc_msg_send()
235 	cdc.cons.wrap = curs.wrap;  in smcd_cdc_msg_send()
236 	cdc.cons.count = curs.count;  in smcd_cdc_msg_send()
237 	cdc.cons.prod_flags = conn->local_tx_ctrl.prod_flags;  in smcd_cdc_msg_send()
238 	cdc.cons.conn_state_flags = conn->local_tx_ctrl.conn_state_flags;  in smcd_cdc_msg_send()
239 	rc = smcd_tx_ism_write(conn, &cdc, sizeof(cdc), 0, 1);  in smcd_cdc_msg_send()
285 static void smc_cdc_msg_validate(struct smc_sock *smc, struct smc_cdc_msg *cdc,  in smc_cdc_msg_validate()  argument
289 	u16 recv_seq = ntohs(cdc->seqno);  in smc_cdc_msg_validate()
308 				    struct smc_cdc_msg *cdc)  in smc_cdc_msg_recv_action()  argument
316 	smc_cdc_msg_to_host(&conn->local_rx_ctrl, cdc, conn);  in smc_cdc_msg_recv_action()
377 static void smc_cdc_msg_recv(struct smc_sock *smc, struct smc_cdc_msg *cdc)  in smc_cdc_msg_recv()  argument
381 	smc_cdc_msg_recv_action(smc, cdc);  in smc_cdc_msg_recv()
396 	struct smcd_cdc_msg cdc;  in smcd_cdc_rx_tsklet()  local
403 	smcd_curs_copy(&cdc.prod, &data_cdc->prod, conn);  in smcd_cdc_rx_tsklet()
404 	smcd_curs_copy(&cdc.cons, &data_cdc->cons, conn);  in smcd_cdc_rx_tsklet()
406 	smc_cdc_msg_recv(smc, (struct smc_cdc_msg *)&cdc);  in smcd_cdc_rx_tsklet()
422 	struct smc_cdc_msg *cdc = buf;  in smc_cdc_rx_handler()  local
429 	if (cdc->len != SMC_WR_TX_SIZE)  in smc_cdc_rx_handler()
435 	conn = smc_lgr_find_conn(ntohl(cdc->token), lgr);  in smc_cdc_rx_handler()
441 	if (cdc->prod_flags.failover_validation) {  in smc_cdc_rx_handler()
442 		smc_cdc_msg_validate(smc, cdc, link);  in smc_cdc_rx_handler()
445 	if (smc_cdc_before(ntohs(cdc->seqno),  in smc_cdc_rx_handler()
450 	smc_cdc_msg_recv(smc, cdc);  in smc_cdc_rx_handler()