| /foundation/multimedia/av_session/services/session/server/test/ |
| H A D | avsession_service_test.cpp | 1585 int transport = 111222; in HWTEST_F() local
1595 int transport = OHOS::Bluetooth::BTTransport::ADAPTER_BREDR; in HWTEST_F() local
1605 int transport = OHOS::Bluetooth::BTTransport::ADAPTER_BREDR; in HWTEST_F() local
1616 int transport = OHOS::Bluetooth::BTTransport::ADAPTER_BREDR; in HWTEST_F() local
|
| /foundation/communication/dsoftbus/tests/adapter/bluetooth/ |
| H A D | bluetooth_mock.cpp | 89 bool PairRequestReply(const BdAddr *bdAddr, int32_t transport, bool accept) in PairRequestReply() argument
94 bool SetDevicePairingConfirmation(const BdAddr *bdAddr, int32_t transport, bool accept) in SetDevicePairingConfirmation() argument
129 BleGattcConnect( int32_t clientId, BtGattClientCallbacks *func, const BdAddr *bdAddr, bool isAutoConnect, BtTransportType transport) BleGattcConnect() argument
|
| /foundation/distributedhardware/distributed_input/services/sink/transport/src/ |
| H A D | distributed_input_sink_transport.cpp | 321 DInputTransbaseSinkListener( DistributedInputSinkTransport *transport) DInputTransbaseSinkListener() argument
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/transport/ |
| H A D | transport_l2cap.cpp | 211 L2capTransport *L2capTransport::FindAcceptTransport(L2capTransport *transport, uint16_t lcid) in FindAcceptTransport() argument
232 L2capTransport *transport in GetTransport() local
248 auto transport = static_cast<L2capTransport *>(context); TransportL2cConnectReqCallback() local
282 auto transport = static_cast<L2capTransport *>(ctx); TransportRecvConnectionReqCallback() local
299 L2capTransport *transport = GetTransport(lcid, ctx); TransportRecvConnectionRspCallback() local
320 L2capTransport *transport = GetTransport(lcid, ctx); TransportRecvConfigReqCallback() local
338 L2capTransport *transport = GetTransport(lcid, ctx); TransportRecvConfigRspCallback() local
354 L2capTransport *transport = GetTransport(lcid, ctx); TransportRecvDisconnectionReqCallback() local
373 L2capTransport *transport = GetTransport(lcid, ctx); TransportRecvDisconnectionRspCallback() local
392 L2capTransport *transport = GetTransport(lcid, ctx); TransportDisconnectAbnormalCallback() local
411 L2capTransport *transport = GetTransport(lcid, ctx); TransportRecvDataCallback() local
426 L2capTransport *transport = GetTransport(lcid, ctx); TransportRemoteBusyCallback() local
436 TransportL2cConnectReqCallbackNative( L2capTransport *transport, const BtAddr &addr, uint16_t lcid, int result) TransportL2cConnectReqCallbackNative() argument
447 TransportRecvConnectionReqCallbackNative( L2capTransport *transport, uint16_t lcid, uint8_t id, const L2capConnectionInfo info, uint16_t lpsm) TransportRecvConnectionReqCallbackNative() argument
470 TransportRecvConnectionRspCallbackNative( L2capTransport *transport, uint16_t lcid, const L2capConnectionInfo info, uint16_t result, uint16_t status) TransportRecvConnectionRspCallbackNative() argument
506 TransportRecvConfigReqCallbackNative( L2capTransport *transport, uint16_t lcid, uint8_t id, const L2capConfigInfo cfg) TransportRecvConfigReqCallbackNative() argument
530 TransportRecvConfigRspCallbackNative( L2capTransport *transport, uint16_t lcid, const L2capConfigInfo cfg, uint16_t result) TransportRecvConfigRspCallbackNative() argument
578 TransportRecvDisconnectionReqCallbackNative(L2capTransport *transport, uint16_t lcid, uint8_t id) TransportRecvDisconnectionReqCallbackNative() argument
616 TransportRecvDisconnectionRspCallbackNative(L2capTransport *transport, uint16_t lcid) TransportRecvDisconnectionRspCallbackNative() argument
644 TransportDisconnectAbnormalCallbackNative(L2capTransport *transport, uint16_t lcid, uint8_t reason) TransportDisconnectAbnormalCallbackNative() argument
684 TransportRecvDataCallbackNative(L2capTransport *transport, uint16_t lcid, Packet *pkt) TransportRecvDataCallbackNative() argument
701 TransportRemoteBusyCallbackNative(L2capTransport *transport, uint16_t lcid, uint8_t isBusy) TransportRemoteBusyCallbackNative() argument
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/obex/ |
| H A D | obex_socket_transport.cpp | 186 OnConnected( DataTransport *transport, uint16_t sendMTU, uint16_t recvMTU) OnConnected() argument
195 OnDisconnected(DataTransport *transport) OnDisconnected() argument
203 OnDisconnectSuccess(DataTransport *transport) OnDisconnectSuccess() argument
211 OnDataAvailable(DataTransport *transport) OnDataAvailable() argument
219 OnDataAvailable(DataTransport *transport, Packet *pkt) OnDataAvailable() argument
227 OnDataBusy(DataTransport *transport, uint8_t isBusy) OnDataBusy() argument
235 OnTransportError(DataTransport *transport, int errType) OnTransportError() argument
243 ProcessOnConnected( DataTransport *transport, uint16_t sendMTU, uint16_t recvMTU) ProcessOnConnected() argument
278 ProcessOnDataAvailable(DataTransport *transport, Packet *pkt) ProcessOnDataAvailable() argument
477 OnConnected( DataTransport *transport, uint16_t sendMTU, uint16_t recvMTU) OnConnected() argument
486 OnDisconnected(DataTransport *transport) OnDisconnected() argument
493 OnDisconnectSuccess(DataTransport *transport) OnDisconnectSuccess() argument
501 OnDataAvailable(DataTransport *transport) OnDataAvailable() argument
509 OnDataAvailable(DataTransport *transport, Packet *pkt) OnDataAvailable() argument
517 OnTransportError(DataTransport *transport, int errType) OnTransportError() argument
525 OnDataBusy(DataTransport *transport, uint8_t isBusy) OnDataBusy() argument
570 ProcessOnConnected( DataTransport *transport, uint16_t sendMTU, uint16_t recvMTU) ProcessOnConnected() argument
594 ProcessOnDisconnected(DataTransport *transport) ProcessOnDisconnected() argument
617 ProcessOnDisconnectSuccess(DataTransport *transport) ProcessOnDisconnectSuccess() argument
624 ProcessOnDataAvailable(DataTransport *transport, Packet *pkt) ProcessOnDataAvailable() argument
666 ProcessOnDataBusy(DataTransport *transport, uint8_t isBusy) ProcessOnDataBusy() argument
676 ProcessOnTransportError(DataTransport *transport, int errType) ProcessOnTransportError() argument
[all...] |
| H A D | obex_session.cpp | 24 ObexServerSession::ObexServerSession(ObexTransport &transport, bool isSupportSrm, utility::Dispatcher &dispatcher, in ObexServerSession() argument
|
| /kernel/linux/linux-5.10/drivers/infiniband/hw/usnic/ |
| H A D | usnic_ib_qp_grp.c | 676 enum usnic_transport_type transport = transport_spec->trans_type; in usnic_ib_qp_grp_create() local
|
| /kernel/linux/linux-5.10/drivers/usb/storage/ |
| H A D | usb.h | 118 trans_cmnd transport; /* transport function */ member
|
| /kernel/linux/linux-5.10/include/net/ |
| H A D | af_vsock.h | 30 const struct vsock_transport *transport; member
|
| /kernel/linux/linux-5.10/sound/usb/usx2y/ |
| H A D | usbus428ctldefs.h | 43 unsigned char transport; member
|
| /kernel/linux/linux-5.10/include/uapi/linux/ |
| H A D | rxrpc.h | 27 } transport; member
|
| /kernel/linux/linux-5.10/drivers/nvme/host/ |
| H A D | fabrics.h | 95 char *transport; member
|
| /kernel/linux/linux-6.6/drivers/usb/storage/ |
| H A D | usb.h | 118 trans_cmnd transport; /* transport function */ member
|
| /kernel/linux/linux-6.6/include/uapi/linux/ |
| H A D | rxrpc.h | 27 } transport; member
|
| /kernel/linux/linux-6.6/drivers/nvme/host/ |
| H A D | fabrics.h | 109 char *transport; member
|
| /kernel/linux/linux-6.6/drivers/infiniband/hw/usnic/ |
| H A D | usnic_ib_qp_grp.c | 674 enum usnic_transport_type transport = transport_spec->trans_type; in usnic_ib_qp_grp_create() local
|
| /kernel/linux/linux-6.6/sound/usb/usx2y/ |
| H A D | usbus428ctldefs.h | 43 unsigned char transport; member
|
| /kernel/linux/patches/linux-6.6/prebuilts/usr/include/linux/ |
| H A D | rxrpc.h | 33 } transport; member
|
| /kernel/linux/patches/linux-4.19/prebuilts/usr/include/linux/ |
| H A D | rxrpc.h | 20 } transport; member
|
| /kernel/linux/patches/linux-5.10/prebuilts/usr/include/linux/ |
| H A D | rxrpc.h | 33 } transport; member
|
| /third_party/curl/lib/ |
| H A D | rtsp.c | 983 CURLcode rtsp_parse_transport(struct Curl_easy *data, char *transport) in rtsp_parse_transport() argument
|
| /third_party/curl/lib/vquic/ |
| H A D | vquic.c | 604 Curl_cf_quic_create(struct Curl_cfilter **pcf, struct Curl_easy *data, struct connectdata *conn, const struct Curl_addrinfo *ai, int transport) Curl_cf_quic_create() argument
|
| /third_party/mesa3d/src/intel/compiler/ |
| H A D | brw_fs_scoreboard.cpp | 390 assert(from < n); if (is[from] != from) assign(is[from], to); is[from] = to; } } unsigned *is; unsigned n; }; struct dependency { dependency() : ordered(TGL_REGDIST_NULL), jp(), unordered(TGL_SBID_NULL), id(0), exec_all(false) {} dependency(tgl_regdist_mode mode, const ordered_address &jp, bool exec_all) : ordered(mode), jp(jp), unordered(TGL_SBID_NULL), id(0), exec_all(exec_all) {} dependency(tgl_sbid_mode mode, unsigned id, bool exec_all) : ordered(TGL_REGDIST_NULL), jp(), unordered(mode), id(id), exec_all(exec_all) {} tgl_regdist_mode ordered; ordered_address jp; tgl_sbid_mode unordered; unsigned id; bool exec_all; static const dependency done; friend bool operator==(const dependency &dep0, const dependency &dep1) { return dep0.ordered == dep1.ordered && dep0.jp == dep1.jp && dep0.unordered == dep1.unordered && dep0.id == dep1.id && dep0.exec_all == dep1.exec_all; } friend bool operator!=(const dependency &dep0, const dependency &dep1) { return !(dep0 == dep1); } }; const dependency dependency::done = dependency(TGL_REGDIST_DST, ordered_address(), false); bool is_valid(const dependency &dep) { return dep.ordered || dep.unordered; } dependency merge(equivalence_relation &eq, const dependency &dep0, const dependency &dep1) { dependency dep; if (dep0.ordered || dep1.ordered) { dep.ordered = dep0.ordered | dep1.ordered; for (unsigned p = 0; p < IDX(TGL_PIPE_ALL); p++) dep.jp.jp[p] = MAX2(dep0.jp.jp[p], dep1.jp.jp[p]); } if (dep0.unordered || dep1.unordered) { dep.unordered = dep0.unordered | dep1.unordered; dep.id = eq.link(dep0.unordered ? dep0.id : dep1.id, dep1.unordered ? dep1.id : dep0.id); } dep.exec_all = dep0.exec_all || dep1.exec_all; return dep; } dependency shadow(const dependency &dep0, const dependency &dep1) { if (dep0.ordered == TGL_REGDIST_SRC && is_valid(dep1) && !(dep1.unordered & TGL_SBID_DST) && !(dep1.ordered & TGL_REGDIST_DST)) { dependency dep = dep1; dep.ordered |= dep0.ordered; for (unsigned p = 0; p < IDX(TGL_PIPE_ALL); p++) dep.jp.jp[p] = MAX2(dep.jp.jp[p], dep0.jp.jp[p]); return dep; } else { return is_valid(dep1) ? dep1 : dep0; } } dependency transport(dependency dep, int delta[IDX(TGL_PIPE_ALL)]) { if (dep.ordered) { for (unsigned p = 0; p < IDX(TGL_PIPE_ALL); p++) { if (dep.jp.jp[p] > INT_MIN) dep.jp.jp[p] += delta[p]; } } return dep; } dependency dependency_for_read(dependency dep) { dep.ordered &= TGL_REGDIST_DST; return dep; } dependency dependency_for_write(const struct intel_device_info *devinfo, const fs_inst *inst, dependency dep) { if (!is_unordered(inst) && is_single_pipe(dep.jp, inferred_exec_pipe(devinfo, inst))) dep.ordered &= TGL_REGDIST_DST; return dep; } class scoreboard { public: dependency get(const fs_reg &r) const { if (const dependency *p = const_cast<scoreboard *>(this)->dep(r)) return *p; else return dependency(); } void set(const fs_reg &r, const dependency &d) { if (dependency *p = dep(r)) *p = d; } friend scoreboard merge(equivalence_relation &eq, const scoreboard &sb0, const scoreboard &sb1) { scoreboard sb; for (unsigned i = 0; i < ARRAY_SIZE(sb.grf_deps); i++) sb.grf_deps[i] = merge(eq, sb0.grf_deps[i], sb1.grf_deps[i]); sb.addr_dep = merge(eq, sb0.addr_dep, sb1.addr_dep); sb.accum_dep = merge(eq, sb0.accum_dep, sb1.accum_dep); return sb; } friend scoreboard shadow(const scoreboard &sb0, const scoreboard &sb1) { scoreboard sb; for (unsigned i = 0; i < ARRAY_SIZE(sb.grf_deps); i++) sb.grf_deps[i] = shadow(sb0.grf_deps[i], sb1.grf_deps[i]); sb.addr_dep = shadow(sb0.addr_dep, sb1.addr_dep); sb.accum_dep = shadow(sb0.accum_dep, sb1.accum_dep); return sb; } friend scoreboard transport(const scoreboard &sb0, int delta[IDX(TGL_PIPE_ALL)]) { scoreboard sb; for (unsigned i = 0; i < ARRAY_SIZE(sb.grf_deps); i++) sb.grf_deps[i] = transport(sb0.grf_deps[i], delta); sb.addr_dep = transport(sb0.addr_dep, delta); sb.accum_dep = transport(sb0.accum_dep, delta); return sb; } friend bool operator==(const scoreboard &sb0, const scoreboard &sb1) { for (unsigned i = 0; i < ARRAY_SIZE(sb0.grf_deps); i++) { if (sb0.grf_deps[i] != sb1.grf_deps[i]) return false; } if (sb0.addr_dep != sb1.addr_dep) return false; if (sb0.accum_dep != sb1.accum_dep) return false; return true; } friend bool operator!=(const scoreboard &sb0, const scoreboard &sb1) { return !(sb0 == sb1); } private: dependency grf_deps[BRW_MAX_GRF]; dependency addr_dep; dependency accum_dep; dependency * dep(const fs_reg &r) { const unsigned reg = (r.file == VGRF ? r.nr + r.offset / REG_SIZE : reg_offset(r) / REG_SIZE); return (r.file == VGRF || r.file == FIXED_GRF ? &grf_deps[reg] : r.file == MRF ? &grf_deps[GFX7_MRF_HACK_START + reg] : r.file == ARF && reg >= BRW_ARF_ADDRESS && reg < BRW_ARF_ACCUMULATOR ? &addr_dep : r.file == ARF && reg >= BRW_ARF_ACCUMULATOR && reg < BRW_ARF_FLAG ? &accum_dep : NULL); } }; struct dependency_list { dependency_list() : deps(NULL), n(0) {} ~dependency_list() { free(deps); } void push_back(const dependency &dep) { deps = (dependency *)realloc(deps, (n + 1) * sizeof(*deps)); deps[n++] = dep; } unsigned size() const { return n; } const dependency & operator[](unsigned i) const { assert(i < n); return deps[i]; } dependency & operator[](unsigned i) { assert(i < n); return deps[i]; } private: dependency_list(const dependency_list &); dependency_list & operator=(const dependency_list &); dependency *deps; unsigned n; }; void add_dependency(const unsigned *ids, dependency_list &deps, dependency dep) { if (is_valid(dep)) { if (dep.unordered) dep.id = ids[dep.id]; for (unsigned i = 0; i < deps.size(); i++) { if (deps[i].exec_all != dep.exec_all && (!deps[i].exec_all || (dep.unordered & TGL_SBID_SET)) && (!dep.exec_all || (deps[i].unordered & TGL_SBID_SET))) continue; if (dep.ordered && deps[i].ordered) { for (unsigned p = 0; p < IDX(TGL_PIPE_ALL); p++) deps[i].jp.jp[p] = MAX2(deps[i].jp.jp[p], dep.jp.jp[p]); deps[i].ordered |= dep.ordered; deps[i].exec_all |= dep.exec_all; dep.ordered = TGL_REGDIST_NULL; } if (dep.unordered && deps[i].unordered && deps[i].id == dep.id) { deps[i].unordered |= dep.unordered; deps[i].exec_all |= dep.exec_all; dep.unordered = TGL_SBID_NULL; } } if (is_valid(dep)) deps.push_back(dep); } } tgl_swsb ordered_dependency_swsb(const dependency_list &deps, const ordered_address &jp, bool exec_all) { tgl_pipe p = TGL_PIPE_NONE; unsigned min_dist = ~0u; for (unsigned i = 0; i < deps.size(); i++) { if (deps[i].ordered && exec_all >= deps[i].exec_all) { for (unsigned q = 0; q < IDX(TGL_PIPE_ALL); q++) { const unsigned dist = jp.jp[q] - int64_t(deps[i].jp.jp[q]); const unsigned max_dist = (q == IDX(TGL_PIPE_LONG) ? 14 : 10); assert(jp.jp[q] > deps[i].jp.jp[q]); if (dist <= max_dist) { p = (p && IDX(p) != q ? TGL_PIPE_ALL : tgl_pipe(TGL_PIPE_FLOAT + q)); min_dist = MIN3(min_dist, dist, 7); } } } } return { p ? min_dist : 0, p }; } bool find_ordered_dependency(const dependency_list &deps, const ordered_address &jp, bool exec_all) { return ordered_dependency_swsb(deps, jp, exec_all).regdist; } tgl_sbid_mode find_unordered_dependency(const dependency_list &deps, tgl_sbid_mode unordered, bool exec_all) { if (unordered) { for (unsigned i = 0; i < deps.size(); i++) { if ((unordered & deps[i].unordered) && exec_all >= deps[i].exec_all) return deps[i].unordered; } } return TGL_SBID_NULL; } tgl_sbid_mode baked_unordered_dependency_mode(const struct intel_device_info *devinfo, const fs_inst *inst, const dependency_list &deps, const ordered_address &jp) { const bool exec_all = inst->force_writemask_all; const bool has_ordered = find_ordered_dependency(deps, jp, exec_all); const tgl_pipe ordered_pipe = ordered_dependency_swsb(deps, jp, exec_all).pipe; if (find_unordered_dependency(deps, TGL_SBID_SET, exec_all)) return find_unordered_dependency(deps, TGL_SBID_SET, exec_all); else if (has_ordered && is_unordered(inst)) return TGL_SBID_NULL; else if (find_unordered_dependency(deps, TGL_SBID_DST, exec_all) && (!has_ordered || ordered_pipe == inferred_sync_pipe(devinfo, inst))) return find_unordered_dependency(deps, TGL_SBID_DST, exec_all); else if (!has_ordered) return find_unordered_dependency(deps, TGL_SBID_SRC, exec_all); else return TGL_SBID_NULL; } bool baked_ordered_dependency_mode(const struct intel_device_info *devinfo, const fs_inst *inst, const dependency_list &deps, const ordered_address &jp) { const bool exec_all = inst->force_writemask_all; const bool has_ordered = find_ordered_dependency(deps, jp, exec_all); const tgl_pipe ordered_pipe = ordered_dependency_swsb(deps, jp, exec_all).pipe; const tgl_sbid_mode unordered_mode = baked_unordered_dependency_mode(devinfo, inst, deps, jp); if (!has_ordered) return false; else if (!unordered_mode) return true; else return ordered_pipe == inferred_sync_pipe(devinfo, inst) && unordered_mode == (is_unordered(inst) ? TGL_SBID_SET : TGL_SBID_DST); } void update_inst_scoreboard(const fs_visitor *shader, const ordered_address *jps, const fs_inst *inst, unsigned ip, scoreboard &sb) { const bool exec_all = inst->force_writemask_all; const struct intel_device_info *devinfo = shader->devinfo; const tgl_pipe p = inferred_exec_pipe(devinfo, inst); const ordered_address jp = p ? ordered_address(p, jps[ip].jp[IDX(p)]) : ordered_address(); const bool is_ordered = ordered_unit(devinfo, inst, IDX(TGL_PIPE_ALL)); for (unsigned i = 0; i < inst->sources; i++) { const dependency rd_dep = (inst->is_payload(i) || inst->is_math()) ? dependency(TGL_SBID_SRC, ip, exec_all) : is_ordered ? dependency(TGL_REGDIST_SRC, jp, exec_all) : dependency::done; for (unsigned j = 0; j < regs_read(inst, i); j++) { const fs_reg r = byte_offset(inst->src[i], REG_SIZE * j); sb.set(r, shadow(sb.get(r), rd_dep)); } } if (inst->reads_accumulator_implicitly()) sb.set(brw_acc_reg(8), dependency(TGL_REGDIST_SRC, jp, exec_all)); if (is_send(inst) && inst->base_mrf != -1) { const dependency rd_dep = dependency(TGL_SBID_SRC, ip, exec_all); for (unsigned j = 0; j < inst->mlen; j++) sb.set(brw_uvec_mrf(8, inst->base_mrf + j, 0), rd_dep); } const dependency wr_dep = is_unordered(inst) ? dependency(TGL_SBID_DST, ip, exec_all) : is_ordered ? dependency(TGL_REGDIST_DST, jp, exec_all) : dependency(); if (inst->writes_accumulator_implicitly(devinfo)) sb.set(brw_acc_reg(8), wr_dep); if (is_valid(wr_dep) && inst->dst.file != BAD_FILE && !inst->dst.is_null()) assign() argument
|
| /third_party/pulseaudio/src/modules/rtp/ |
| H A D | rtsp_client.c | 80 char *transport; member
554 int pa_rtsp_setup(pa_rtsp_client *c, const char *transport) { in pa_rtsp_setup() argument
|
| /foundation/CastEngine/castengine_wifi_display/services/impl/wfd/ |
| H A D | wfd_message.cpp | 506 auto transport = GetToken(RTSP_TOKEN_TRANSPORT); in GetClientPort() local
524 auto transport = GetToken(RTSP_TOKEN_TRANSPORT); in GetServerPort() local
|