Lines Matching refs:flow
207 struct smc_llc_qentry *smc_llc_flow_qentry_clr(struct smc_llc_flow *flow) in smc_llc_flow_qentry_clr() argument
209 struct smc_llc_qentry *qentry = flow->qentry; in smc_llc_flow_qentry_clr()
211 flow->qentry = NULL; in smc_llc_flow_qentry_clr()
215 void smc_llc_flow_qentry_del(struct smc_llc_flow *flow) in smc_llc_flow_qentry_del() argument
219 if (flow->qentry) { in smc_llc_flow_qentry_del()
220 qentry = flow->qentry; in smc_llc_flow_qentry_del()
221 flow->qentry = NULL; in smc_llc_flow_qentry_del()
226 static inline void smc_llc_flow_qentry_set(struct smc_llc_flow *flow, in smc_llc_flow_qentry_set() argument
229 flow->qentry = qentry; in smc_llc_flow_qentry_set()
254 static bool smc_llc_flow_start(struct smc_llc_flow *flow, in smc_llc_flow_start() argument
260 if (flow->type) { in smc_llc_flow_start()
262 smc_llc_flow_parallel(lgr, flow->type, qentry); in smc_llc_flow_start()
268 flow->type = SMC_LLC_FLOW_ADD_LINK; in smc_llc_flow_start()
271 flow->type = SMC_LLC_FLOW_DEL_LINK; in smc_llc_flow_start()
275 flow->type = SMC_LLC_FLOW_RKEY; in smc_llc_flow_start()
278 flow->type = SMC_LLC_FLOW_NONE; in smc_llc_flow_start()
280 smc_llc_flow_qentry_set(flow, qentry); in smc_llc_flow_start()
320 void smc_llc_flow_stop(struct smc_link_group *lgr, struct smc_llc_flow *flow) in smc_llc_flow_stop() argument
323 memset(flow, 0, sizeof(*flow)); in smc_llc_flow_stop()
324 flow->type = SMC_LLC_FLOW_NONE; in smc_llc_flow_stop()
327 flow == &lgr->llc_flow_lcl) in smc_llc_flow_stop()
340 struct smc_llc_flow *flow = &lgr->llc_flow_lcl; in smc_llc_wait() local
344 (flow->qentry || in smc_llc_wait()
348 if (!flow->qentry || in smc_llc_wait()
350 smc_llc_flow_qentry_del(flow); in smc_llc_wait()
353 rcv_msg = flow->qentry->msg.raw.hdr.common.llc_type; in smc_llc_wait()
359 smc_llc_flow_qentry_clr(flow)); in smc_llc_wait()
366 flow->type, lgr->role, in smc_llc_wait()
367 flow->qentry->msg.raw.hdr.flags); in smc_llc_wait()
368 smc_llc_flow_qentry_del(flow); in smc_llc_wait()
371 return flow->qentry; in smc_llc_wait()
2027 struct smc_llc_flow *flow = &link->lgr->llc_flow_lcl; in smc_llc_rx_response() local
2038 if (flowtype != SMC_LLC_FLOW_ADD_LINK || flow->qentry) in smc_llc_rx_response()
2042 if (flowtype != SMC_LLC_FLOW_DEL_LINK || flow->qentry) in smc_llc_rx_response()
2047 if (flowtype != SMC_LLC_FLOW_RKEY || flow->qentry) in smc_llc_rx_response()