Lines Matching defs:cdc
240 struct smcd_cdc_msg cdc;
243 memset(&cdc, 0, sizeof(cdc));
244 cdc.common.type = SMC_CDC_MSG_TYPE;
246 cdc.prod.wrap = curs.wrap;
247 cdc.prod.count = curs.count;
249 cdc.cons.wrap = curs.wrap;
250 cdc.cons.count = curs.count;
251 cdc.cons.prod_flags = conn->local_tx_ctrl.prod_flags;
252 cdc.cons.conn_state_flags = conn->local_tx_ctrl.conn_state_flags;
253 rc = smcd_tx_ism_write(conn, &cdc, sizeof(cdc), 0, 1);
299 static void smc_cdc_msg_validate(struct smc_sock *smc, struct smc_cdc_msg *cdc,
303 u16 recv_seq = ntohs(cdc->seqno);
322 struct smc_cdc_msg *cdc)
330 smc_cdc_msg_to_host(&conn->local_rx_ctrl, cdc, conn);
395 static void smc_cdc_msg_recv(struct smc_sock *smc, struct smc_cdc_msg *cdc)
399 smc_cdc_msg_recv_action(smc, cdc);
414 struct smcd_cdc_msg cdc;
421 smcd_curs_copy(&cdc.prod, &data_cdc->prod, conn);
422 smcd_curs_copy(&cdc.cons, &data_cdc->cons, conn);
424 smc_cdc_msg_recv(smc, (struct smc_cdc_msg *)&cdc);
440 struct smc_cdc_msg *cdc = buf;
447 if (cdc->len != SMC_WR_TX_SIZE)
453 conn = smc_lgr_find_conn(ntohl(cdc->token), lgr);
459 if (cdc->prod_flags.failover_validation) {
460 smc_cdc_msg_validate(smc, cdc, link);
463 if (smc_cdc_before(ntohs(cdc->seqno),
468 smc_cdc_msg_recv(smc, cdc);