Lines Matching refs:p_mcb
61 tRFC_MCB* p_mcb = rfc_alloc_multiplexer_channel(p_port->bd_addr, true); in port_open_continue() local
62 if (p_mcb == nullptr) { in port_open_continue()
68 p_port->rfc.p_mcb = p_mcb; in port_open_continue()
70 p_mcb->port_handles[p_port->dlci] = p_port->handle; in port_open_continue()
75 if (p_mcb->state == RFC_MX_STATE_CONNECTED) { in port_open_continue()
76 RFCOMM_ParameterNegotiationRequest(p_mcb, p_port->dlci, p_port->mtu); in port_open_continue()
77 } else if ((p_mcb->state == RFC_MX_STATE_IDLE) || in port_open_continue()
78 (p_mcb->state == RFC_MX_STATE_DISC_WAIT_UA)) { in port_open_continue()
82 RFCOMM_StartReq(p_mcb); in port_open_continue()
88 p_mcb->state); in port_open_continue()
104 tRFC_MCB* p_mcb = p_port->rfc.p_mcb; in port_start_control() local
106 if (p_mcb == NULL) return; in port_start_control()
108 RFCOMM_ControlReq(p_mcb, p_port->dlci, &p_port->local_ctrl); in port_start_control()
122 tRFC_MCB* p_mcb = p_port->rfc.p_mcb; in port_start_par_neg() local
124 if (p_mcb == NULL) return; in port_start_par_neg()
126 RFCOMM_PortParameterNegotiationRequest(p_mcb, p_port->dlci, in port_start_par_neg()
141 tRFC_MCB* p_mcb = p_port->rfc.p_mcb; in port_start_close() local
164 if ((p_mcb == NULL) || (p_port->rfc.state == RFC_STATE_CLOSED)) { in port_start_close()
172 RFCOMM_DlcReleaseReq(p_mcb, p_port->dlci); in port_start_close()
186 void PORT_StartCnf(tRFC_MCB* p_mcb, uint16_t result) { in PORT_StartCnf() argument
193 if (p_port->rfc.p_mcb == p_mcb) { in PORT_StartCnf()
198 RFCOMM_ParameterNegotiationRequest(p_mcb, p_port->dlci, p_port->mtu); in PORT_StartCnf()
210 rfc_release_multiplexer_channel(p_mcb); in PORT_StartCnf()
229 rfc_check_mcb_active(p_mcb); in PORT_StartCnf()
243 void PORT_StartInd(tRFC_MCB* p_mcb) { in PORT_StartInd() argument
251 if ((p_port->rfc.p_mcb == NULL) || (p_port->rfc.p_mcb == p_mcb)) { in PORT_StartInd()
253 "PORT_StartInd, RFCOMM_StartRsp RFCOMM_SUCCESS: p_mcb:%p", p_mcb); in PORT_StartInd()
254 RFCOMM_StartRsp(p_mcb, RFCOMM_SUCCESS); in PORT_StartInd()
258 RFCOMM_StartRsp(p_mcb, RFCOMM_ERROR); in PORT_StartInd()
271 void PORT_ParNegInd(tRFC_MCB* p_mcb, uint8_t dlci, uint16_t mtu, uint8_t cl, in PORT_ParNegInd() argument
274 p_mcb->bd_addr.ToString().c_str(), dlci, mtu); in PORT_ParNegInd()
275 tPORT* p_port = port_find_mcb_dlci_port(p_mcb, dlci); in PORT_ParNegInd()
281 << std::to_string(dlci) << ", p_mcb=" << p_mcb in PORT_ParNegInd()
282 << ", bd_addr=" << p_mcb->bd_addr; in PORT_ParNegInd()
284 rfc_send_dm(p_mcb, dlci, false); in PORT_ParNegInd()
287 rfc_check_mcb_active(p_mcb); in PORT_ParNegInd()
291 p_mcb->port_handles[dlci], p_port->handle); in PORT_ParNegInd()
292 p_mcb->port_handles[dlci] = p_port->handle; in PORT_ParNegInd()
295 p_port->bd_addr = p_mcb->bd_addr; in PORT_ParNegInd()
300 p_port->rfc.p_mcb = p_mcb; in PORT_ParNegInd()
310 if (p_mcb->flow == PORT_FC_UNDEFINED) { in PORT_ParNegInd()
313 p_mcb->flow = PORT_FC_TS710; in PORT_ParNegInd()
315 p_mcb->flow = PORT_FC_CREDIT; in PORT_ParNegInd()
332 } else if (p_mcb->flow == PORT_FC_CREDIT) { in PORT_ParNegInd()
346 RFCOMM_ParameterNegotiationResponse(p_mcb, dlci, p_port->mtu, our_cl, our_k); in PORT_ParNegInd()
360 void PORT_ParNegCnf(tRFC_MCB* p_mcb, uint8_t dlci, uint16_t mtu, uint8_t cl, in PORT_ParNegCnf() argument
364 tPORT* p_port = port_find_mcb_dlci_port(p_mcb, dlci); in PORT_ParNegCnf()
366 LOG(WARNING) << __func__ << ": port is null for " << p_mcb->bd_addr; in PORT_ParNegCnf()
371 if (p_mcb->flow == PORT_FC_UNDEFINED) { in PORT_ParNegCnf()
379 rfc_send_disc(p_mcb, p_port->dlci); in PORT_ParNegCnf()
385 p_mcb->flow = PORT_FC_CREDIT; in PORT_ParNegCnf()
389 p_mcb->flow = PORT_FC_TS710; in PORT_ParNegCnf()
399 if (p_mcb->flow == PORT_FC_CREDIT) { in PORT_ParNegCnf()
404 RFCOMM_DlcEstablishReq(p_mcb, p_port->dlci, p_port->mtu); in PORT_ParNegCnf()
420 void PORT_DlcEstablishInd(tRFC_MCB* p_mcb, uint8_t dlci, uint16_t mtu) { in PORT_DlcEstablishInd() argument
421 tPORT* p_port = port_find_mcb_dlci_port(p_mcb, dlci); in PORT_DlcEstablishInd()
424 "PORT_DlcEstablishInd p_mcb:%p, dlci:%d mtu:%di, p_port:%p", p_mcb, dlci, in PORT_DlcEstablishInd()
426 VLOG(1) << __func__ << " p_mcb addr:" << p_mcb->bd_addr; in PORT_DlcEstablishInd()
432 RFCOMM_DlcEstablishRsp(p_mcb, dlci, 0, RFCOMM_ERROR); in PORT_DlcEstablishInd()
435 p_mcb->port_handles[dlci] = p_port->handle; in PORT_DlcEstablishInd()
442 rfc_timer_stop(p_mcb); in PORT_DlcEstablishInd()
444 RFCOMM_DlcEstablishRsp(p_mcb, dlci, p_port->mtu, RFCOMM_SUCCESS); in PORT_DlcEstablishInd()
467 void PORT_DlcEstablishCnf(tRFC_MCB* p_mcb, uint8_t dlci, uint16_t mtu, in PORT_DlcEstablishCnf() argument
469 tPORT* p_port = port_find_mcb_dlci_port(p_mcb, dlci); in PORT_DlcEstablishCnf()
486 rfc_timer_stop(p_mcb); in PORT_DlcEstablishCnf()
500 RFCOMM_PortParameterNegotiationRequest(p_port->rfc.p_mcb, p_port->dlci, in PORT_DlcEstablishCnf()
503 RFCOMM_ControlReq(p_port->rfc.p_mcb, p_port->dlci, &p_port->local_ctrl); in PORT_DlcEstablishCnf()
517 void PORT_PortNegInd(tRFC_MCB* p_mcb, uint8_t dlci, tPORT_STATE* p_pars, in PORT_PortNegInd() argument
519 tPORT* p_port = port_find_mcb_dlci_port(p_mcb, dlci); in PORT_PortNegInd()
527 RFCOMM_PortParameterNegotiationResponse(p_mcb, dlci, p_pars, 0); in PORT_PortNegInd()
530 p_mcb->port_handles[dlci] = p_port->handle; in PORT_PortNegInd()
535 RFCOMM_PortParameterNegotiationResponse(p_mcb, dlci, p_pars, param_mask); in PORT_PortNegInd()
546 void PORT_PortNegCnf(tRFC_MCB* p_mcb, uint8_t dlci, in PORT_PortNegCnf() argument
548 tPORT* p_port = port_find_mcb_dlci_port(p_mcb, dlci); in PORT_PortNegCnf()
560 RFCOMM_DlcReleaseReq(p_mcb, p_port->dlci); in PORT_PortNegCnf()
567 RFCOMM_ControlReq(p_port->rfc.p_mcb, p_port->dlci, &p_port->local_ctrl); in PORT_PortNegCnf()
581 void PORT_ControlInd(tRFC_MCB* p_mcb, uint8_t dlci, tPORT_CTRL* p_pars) { in PORT_ControlInd() argument
582 tPORT* p_port = port_find_mcb_dlci_port(p_mcb, dlci); in PORT_ControlInd()
597 RFCOMM_ControlReq(p_port->rfc.p_mcb, p_port->dlci, &p_port->local_ctrl); in PORT_ControlInd()
633 void PORT_ControlCnf(tRFC_MCB* p_mcb, uint8_t dlci, in PORT_ControlCnf() argument
635 tPORT* p_port = port_find_mcb_dlci_port(p_mcb, dlci); in PORT_ControlCnf()
666 void PORT_LineStatusInd(tRFC_MCB* p_mcb, uint8_t dlci, uint8_t line_status) { in PORT_LineStatusInd() argument
667 tPORT* p_port = port_find_mcb_dlci_port(p_mcb, dlci); in PORT_LineStatusInd()
694 void PORT_DlcReleaseInd(tRFC_MCB* p_mcb, uint8_t dlci) { in PORT_DlcReleaseInd() argument
696 << ", bd_addr=" << p_mcb->bd_addr; in PORT_DlcReleaseInd()
697 tPORT* p_port = port_find_mcb_dlci_port(p_mcb, dlci); in PORT_DlcReleaseInd()
710 void PORT_CloseInd(tRFC_MCB* p_mcb) { in PORT_CloseInd() argument
718 if (p_port->rfc.p_mcb == p_mcb) { in PORT_CloseInd()
722 rfc_release_multiplexer_channel(p_mcb); in PORT_CloseInd()
733 void Port_TimeOutCloseMux(tRFC_MCB* p_mcb) { in Port_TimeOutCloseMux() argument
741 if (p_port->rfc.p_mcb == p_mcb) { in Port_TimeOutCloseMux()
755 void PORT_DataInd(tRFC_MCB* p_mcb, uint8_t dlci, BT_HDR* p_buf) { in PORT_DataInd() argument
756 tPORT* p_port = port_find_mcb_dlci_port(p_mcb, dlci); in PORT_DataInd()
764 p_buf->len, p_mcb, p_port, dlci); in PORT_DataInd()
796 RFCOMM_LineStatusReq(p_mcb, dlci, LINE_STATUS_OVERRUN); in PORT_DataInd()
846 void PORT_FlowInd(tRFC_MCB* p_mcb, uint8_t dlci, bool enable_data) { in PORT_FlowInd() argument
854 p_mcb->peer_ready = enable_data; in PORT_FlowInd()
856 p_port = port_find_mcb_dlci_port(p_mcb, dlci); in PORT_FlowInd()
866 if (!p_port->in_use || (p_port->rfc.p_mcb != p_mcb) || in PORT_FlowInd()
904 while (!p_port->tx.peer_fc && p_port->rfc.p_mcb && in port_rfc_send_tx_data()
905 p_port->rfc.p_mcb->peer_ready) { in port_rfc_send_tx_data()
918 RFCOMM_DataReq(p_port->rfc.p_mcb, p_port->dlci, p_buf); in port_rfc_send_tx_data()
951 tRFC_MCB* p_mcb = p_port->rfc.p_mcb; in port_rfc_closed() local
960 if (p_mcb) { in port_rfc_closed()
961 p_mcb->port_handles[p_port->dlci] = 0; in port_rfc_closed()
964 rfc_check_mcb_active(p_mcb); in port_rfc_closed()
965 p_port->rfc.p_mcb = NULL; in port_rfc_closed()