Home
last modified time | relevance | path

Searched refs:rx (Results 1 – 10 of 10) sorted by relevance

/system/bt/stack/rfcomm/
Dport_utils.cc122 memset(&p_port->rx, 0, sizeof(p_port->rx)); in port_set_defaults()
126 p_port->rx.queue = fixed_queue_new(SIZE_MAX); in port_set_defaults()
209 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->rx.queue)) != in port_release_port()
213 p_port->rx.queue_size = 0; in port_release_port()
239 fixed_queue_free(p_port->rx.queue, nullptr); in port_release_port()
240 p_port->rx.queue = nullptr; in port_release_port()
470 if ((p_port->credit_rx <= p_port->credit_rx_low) && !p_port->rx.user_fc && in port_flow_control_peer()
477 p_port->rx.peer_fc = false; in port_flow_control_peer()
484 p_port->rx.peer_fc = true; in port_flow_control_peer()
487 else if (fixed_queue_length(p_port->rx.queue) >= p_port->credit_rx_max) { in port_flow_control_peer()
[all …]
Dport_api.cc630 p_port->rx.user_fc = !enable; in PORT_FlowControl_MaxCredit()
633 if (!p_port->rx.user_fc) { in PORT_FlowControl_MaxCredit()
640 p_port->local_ctrl.fc = (p_port->rx.user_fc | p_port->rx.peer_fc); in PORT_FlowControl_MaxCredit()
647 if (enable && (p_port->rx.queue_size != 0)) { in PORT_FlowControl_MaxCredit()
701 if (fixed_queue_is_empty(p_port->rx.queue)) return (PORT_SUCCESS); in PORT_ReadData()
706 p_buf = (BT_HDR*)fixed_queue_try_peek_first(p_port->rx.queue); in PORT_ReadData()
718 p_port->rx.queue_size -= max_len; in PORT_ReadData()
731 p_port->rx.queue_size -= p_buf->len; in PORT_ReadData()
737 osi_free(fixed_queue_try_dequeue(p_port->rx.queue)); in PORT_ReadData()
747 p_port->rx.queue_size, *p_len, (p_data[0])); in PORT_ReadData()
[all …]
Dport_rfc.cc793 if ((p_port->rx.queue_size + p_buf->len > PORT_RX_CRITICAL_WM) || in PORT_DataInd()
794 (fixed_queue_length(p_port->rx.queue) + 1 > p_port->rx_buf_critical)) { in PORT_DataInd()
815 fixed_queue_enqueue(p_port->rx.queue, p_buf); in PORT_DataInd()
816 p_port->rx.queue_size += p_buf->len; in PORT_DataInd()
824 if (p_port->rx.user_fc) { in PORT_DataInd()
Dport_int.h152 tPORT_DATA rx; /* Control block for data from peer to app */ member
Drfc_port_fsm.cc442 (!p_port->rx.user_fc) && in rfc_port_sm_opened()
471 if (!fixed_queue_is_empty(p_port->rx.queue)) { in rfc_port_sm_opened()
/system/core/trusty/storage/lib/
Dstorage.c150 struct iovec rx[2] = {{&msg, sizeof(msg)}, {&rsp, sizeof(rsp)}}; in storage_open_file() local
152 ssize_t rc = send_reqv(session, tx, 3, rx, 2); in storage_open_file()
171 struct iovec rx[1] = {{&msg, sizeof(msg)}}; in storage_close_file() local
173 ssize_t rc = send_reqv(_to_session(fh), tx, 2, rx, 1); in storage_close_file()
185 struct iovec rx[1] = {{&msg, sizeof(msg)}}; in storage_delete_file() local
187 ssize_t rc = send_reqv(session, tx, 3, rx, 1); in storage_delete_file()
196 struct iovec rx[2] = {{&msg, sizeof(msg)}, {buf, size}}; in _read_chunk() local
198 ssize_t rc = send_reqv(_to_session(fh), tx, 2, rx, 2); in _read_chunk()
231 struct iovec rx[1] = {{&msg, sizeof(msg)}}; in _write_req() local
233 ssize_t rc = send_reqv(_to_session(fh), tx, 3, rx, 1); in _write_req()
[all …]
/system/netd/server/
DNetlinkListener.cpp136 auto rx = sys.recvfrom(mSock, makeSlice(rxbuf), 0); in run() local
137 int err = rx.status().code(); in run()
146 forEachNetlinkMessage(rx.value(), rxHandler); in run()
/system/bt/gd/common/
Dbidi_queue.h33 …ueueEnd(::bluetooth::os::IQueueEnqueue<TENQUEUE>* tx, ::bluetooth::os::IQueueDequeue<TDEQUEUE>* rx) in BidiQueueEnd() argument
34 : tx_(tx), rx_(rx) {} in BidiQueueEnd()
/system/iorap/src/inode2filename/
Dsearch_directories.cc50 namespace rx = rxcpp;
240 using ObservableT = rx::observable<ResultT>;
546 void TreeTraversalPreOrderObservableImpl(rx::subscriber<TSimple> dest, T&& node, F&& fn) { in TreeTraversalPreOrderObservableImpl()
608 return rx::observable<>::create<T_simple>( in TreeTraversalPreOrderObservable()
610 [node=node,fn=std::forward<F>(fn)](rx::subscriber<T_simple> dest) { in TreeTraversalPreOrderObservable()
/system/core/logcat/
Devent.logtags107 52001 http_stats (useragent|3),(response|2|3),(processing|2|3),(tx|1|2),(rx|1|2)