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