Lines Matching refs:cdc
180 struct smcd_cdc_msg cdc; in smcd_cdc_msg_send() local
183 memset(&cdc, 0, sizeof(cdc)); in smcd_cdc_msg_send()
184 cdc.common.type = SMC_CDC_MSG_TYPE; in smcd_cdc_msg_send()
185 cdc.prod_wrap = conn->local_tx_ctrl.prod.wrap; in smcd_cdc_msg_send()
186 cdc.prod_count = conn->local_tx_ctrl.prod.count; in smcd_cdc_msg_send()
188 cdc.cons_wrap = conn->local_tx_ctrl.cons.wrap; in smcd_cdc_msg_send()
189 cdc.cons_count = conn->local_tx_ctrl.cons.count; in smcd_cdc_msg_send()
190 cdc.prod_flags = conn->local_tx_ctrl.prod_flags; in smcd_cdc_msg_send()
191 cdc.conn_state_flags = conn->local_tx_ctrl.conn_state_flags; in smcd_cdc_msg_send()
192 rc = smcd_tx_ism_write(conn, &cdc, sizeof(cdc), 0, 1); in smcd_cdc_msg_send()
239 struct smc_cdc_msg *cdc) in smc_cdc_msg_recv_action() argument
247 smc_cdc_msg_to_host(&conn->local_rx_ctrl, cdc, conn); in smc_cdc_msg_recv_action()
316 static void smc_cdc_msg_recv(struct smc_sock *smc, struct smc_cdc_msg *cdc) in smc_cdc_msg_recv() argument
320 smc_cdc_msg_recv_action(smc, cdc); in smc_cdc_msg_recv()
334 struct smcd_cdc_msg cdc; in smcd_cdc_rx_tsklet() local
340 memcpy(&cdc, conn->rmb_desc->cpu_addr, sizeof(cdc)); in smcd_cdc_rx_tsklet()
342 smc_cdc_msg_recv(smc, (struct smc_cdc_msg *)&cdc); in smcd_cdc_rx_tsklet()
358 struct smc_cdc_msg *cdc = buf; in smc_cdc_rx_handler() local
365 if (cdc->len != SMC_WR_TX_SIZE) in smc_cdc_rx_handler()
371 conn = smc_lgr_find_conn(ntohl(cdc->token), lgr); in smc_cdc_rx_handler()
377 if (!cdc->prod_flags.failover_validation) { in smc_cdc_rx_handler()
378 if (smc_cdc_before(ntohs(cdc->seqno), in smc_cdc_rx_handler()
383 smc_cdc_msg_recv(smc, cdc); in smc_cdc_rx_handler()