/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/l2cap/ |
H A D | l2cap_core.c | 90 if (chan != NULL) { in L2capResponseTimeout() 234 if ((chan->lcfg.fcs == 0x01) || (chan->rcfg.fcs == 0x01)) { in L2capChannelConnected() 677 if (chan->erfc.retryCount == chan->lcfg.rfc.maxTransmit) { in L2capErfcMonitorTimeout() 707 …AlarmSet(chan->erfc.monitorTimer, chan->lcfg.rfc.monitorTimeout, L2capErfcMonitorTimeoutCallback, … in L2capErfcStartMonitorTimer() 758 chan); in L2capErfcStartRetransmissionTimer() 1461 if (chan == NULL) { in L2capProcessConfigurationReq() 1530 if (chan == NULL) { in L2capProcessConfigurationRsp() 1602 chan->rcid = cid; in L2capProcessConnectionReq() 1616 chan->lcid, in L2capProcessConnectionReq() 1661 chan->rcid = rcid; in L2capProcessConnectionRsp() [all …]
|
H A D | l2cap.c | 32 L2capChannel *chan = NULL; in L2CAP_ConnectReq() local 56 *lcid = chan->lcid; in L2CAP_ConnectReq() 84 L2capChannel *chan = NULL; in L2CAP_ConnectRsp() local 99 if (chan == NULL) { in L2CAP_ConnectRsp() 136 if (chan == NULL) { in L2CAP_ConfigReq() 205 if (chan == NULL) { in L2CAP_ConfigRsp() 214 chan->lcfg.rfc.txWindowSize = chan->rcfg.rfc.rxWindowSize; in L2CAP_ConfigRsp() 249 if (chan == NULL) { in L2CAP_DisconnectionReq() 273 if (chan == NULL) { in L2CAP_DisconnectionRsp() 298 if (chan == NULL) { in L2CAP_LocalBusy() [all …]
|
H A D | l2cap_le.c | 213 return chan; in L2capLeGetChannel4() 257 if (chan == NULL) { in L2capLeNewChannel() 262 chan->lpsm = lpsm; in L2capLeNewChannel() 263 chan->rpsm = rpsm; in L2capLeNewChannel() 270 return chan; in L2capLeNewChannel() 298 L2capFree(chan); in L2capLeDestroyChannel() 728 chan->rcid = rcid; in L2capLeProcessCreditBasedConnectionReq() 744 chan->lcid, in L2capLeProcessCreditBasedConnectionReq() 786 chan->rcid = rcid; in L2capLeProcessCreditBasedConnectionRsp() 787 lcid = chan->lcid; in L2capLeProcessCreditBasedConnectionRsp() [all …]
|
H A D | l2cap_inst.c | 129 L2capChannel *chan = NULL; in L2capGetChannel() local 136 return chan; in L2capGetChannel() 154 if ((*chan) != NULL) { in L2capGetChannel2() 223 L2capChannel *chan = NULL; in L2capNewChannel() local 226 if (chan == NULL) { in L2capNewChannel() 243 chan->lpsm = lpsm; in L2capNewChannel() 244 chan->rpsm = rpsm; in L2capNewChannel() 246 chan->cfgState = 0; in L2capNewChannel() 249 chan->part.length = 0; in L2capNewChannel() 255 return chan; in L2capNewChannel() [all …]
|
H A D | l2cap_core.h | 72 int L2capSendConnectionReq(L2capConnection *conn, L2capChannel *chan); 73 int L2capSendConnectionRsp(L2capConnection *conn, L2capChannel *chan, uint8_t ident, uint16_t resul… 74 int L2capSendConfigurationReq(L2capConnection *conn, const L2capChannel *chan); 76 …const L2capConnection *conn, L2capChannel *chan, uint8_t ident, uint16_t result, const L2capConfig… 77 int L2capSendDisconnectionReq(L2capConnection *conn, L2capChannel *chan); 78 int L2capSendDisconnectionRsp(const L2capConnection *conn, const L2capChannel *chan, uint8_t ident); 82 int L2capSendSFrame(const L2capConnection *conn, L2capChannel *chan, uint8_t pBit, uint8_t fBit, ui… 83 int L2capSendIFrame(L2capConnection *conn, L2capChannel *chan, Packet *pkt); 85 void L2capErfcStartRetransmissionTimer(L2capChannel *chan); 86 void L2capErfcStartMonitorTimer(L2capChannel *chan);
|
H A D | l2cap_inst.h | 182 L2capConnection *L2capGetConnection3(const L2capChannel *chan); 185 void L2capGetChannel2(uint16_t lcid, L2capConnection **conn, L2capChannel **chan); 186 …d L2capGetChannel3(uint16_t aclHandle, uint16_t lcid, L2capConnection **conn, L2capChannel **chan); 189 void L2capDestroyChannel(L2capChannel *chan); 190 void L2capDeleteChannel(L2capConnection *conn, L2capChannel *chan, uint16_t removeAcl);
|
/ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/proxy_channel/ |
H A D | trans_proxy_manager_test.cpp | 328 chan->authId = 10; 329 chan->connId = 10; 330 chan->myId = 10; 331 chan->peerId = 10; 332 chan->reqId = 10; 334 chan->seq = 10; 341 ret = TransProxyCreateChanInfo(chan, chan->channelId, &appInfo); 536 chan->reqId = 20; 538 chan->seq = 20; 541 ret = TransProxyCreateChanInfo(chan, chan->channelId, &appInfo); [all …]
|
H A D | softbus_proxychannel_manager_test.cpp | 162 if (chan == NULL) { in BuildProxyChannelInfo() 167 chan->myId = channelId; in BuildProxyChannelInfo() 169 chan->reqId = channelId; in BuildProxyChannelInfo() 171 chan->seq = channelId; in BuildProxyChannelInfo() 173 chan->status = status; in BuildProxyChannelInfo() 174 return chan; in BuildProxyChannelInfo() 183 int32_t ret = TransProxyCreateChanInfo(chan, chan->channelId, &appInfo); in TestTransProxyAddAuthChannel() 193 int32_t ret = TransProxyCreateChanInfo(chan, chan->channelId, &appInfo); in TestTransProxyAddNormalChannel() 452 ret = TransProxyCreateChanInfo(chan, chan->channelId, &appInfo); 820 int32_t ret = TransProxyCreateChanInfo(chan, chan->channelId, &appInfo); [all …]
|
H A D | trans_proxy_channel_test.cpp | 129 if (chan == NULL) { in TestAddTestProxyChannel() 133 chan->myId = m_testProxyChannelId; in TestAddTestProxyChannel() 134 chan->channelId = m_testProxyChannelId; in TestAddTestProxyChannel() 135 chan->authHandle.authId = authId; in TestAddTestProxyChannel() 136 chan->appInfo.appType = APP_TYPE_NORMAL; in TestAddTestProxyChannel() 140 SoftBusFree(chan); in TestAddTestProxyChannel() 161 chan->myId = m_testProxyChannelId; 162 chan->channelId = m_testProxyChannelId; 183 chan->myId = m_testProxyChannelId; 184 chan->channelId = m_testProxyChannelId; [all …]
|
H A D | trans_proxy_message_test.cpp | 97 chan->authId = channelId; in TestMessageAddProxyChannel() 98 chan->connId = channelId; in TestMessageAddProxyChannel() 99 chan->myId = channelId; in TestMessageAddProxyChannel() 100 chan->peerId = channelId; in TestMessageAddProxyChannel() 101 chan->reqId = channelId; in TestMessageAddProxyChannel() 103 chan->seq = channelId; in TestMessageAddProxyChannel() 105 chan->status = status; in TestMessageAddProxyChannel() 107 int32_t ret = TransProxyCreateChanInfo(chan, chan->channelId, &appInfo); in TestMessageAddProxyChannel() 173 ProxyChannelInfo chan; variable 180 chan.channelId = -1; [all …]
|
H A D | softbus_proxychannel_message_test.cpp | 171 chan->connId = channelId; in TestMessageAddProxyChannel() 172 chan->myId = channelId; in TestMessageAddProxyChannel() 173 chan->peerId = channelId; in TestMessageAddProxyChannel() 174 chan->reqId = channelId; in TestMessageAddProxyChannel() 176 chan->seq = channelId; in TestMessageAddProxyChannel() 178 chan->status = status; in TestMessageAddProxyChannel() 180 int32_t ret = TransProxyCreateChanInfo(chan, chan->channelId, &appInfo); in TestMessageAddProxyChannel() 182 SoftBusFree(chan); in TestMessageAddProxyChannel() 248 ProxyChannelInfo chan; variable 255 chan.channelId = -1; [all …]
|
H A D | softbus_proxy_session_test.cpp | 120 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); in TestAddProxyChannel() local 121 ASSERT_TRUE(NULL != chan); in TestAddProxyChannel() 122 chan->authHandle.authId = channelId; in TestAddProxyChannel() 123 chan->connId = channelId; in TestAddProxyChannel() 124 chan->myId = channelId; in TestAddProxyChannel() 125 chan->peerId = channelId; in TestAddProxyChannel() 126 chan->reqId = channelId; in TestAddProxyChannel() 127 chan->channelId = channelId; in TestAddProxyChannel() 128 chan->seq = channelId; in TestAddProxyChannel() 130 chan->status = status; in TestAddProxyChannel() [all …]
|
H A D | trans_proxy_session_test.cpp | 137 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); in TestAddProxyChannel() local 138 ASSERT_TRUE(NULL != chan); in TestAddProxyChannel() 139 chan->authId = channelId; in TestAddProxyChannel() 140 chan->connId = channelId; in TestAddProxyChannel() 141 chan->myId = channelId; in TestAddProxyChannel() 142 chan->peerId = channelId; in TestAddProxyChannel() 143 chan->reqId = channelId; in TestAddProxyChannel() 144 chan->channelId = channelId; in TestAddProxyChannel() 145 chan->seq = channelId; in TestAddProxyChannel() 147 chan->status = status; in TestAddProxyChannel() [all …]
|
H A D | softbus_trans_proxy_transceiver_test.cpp | 292 ProxyChannelInfo chan; variable 298 chan.isServer = false; 299 int32_t ret = TransProxyConnExistProc(&chan, chanNewId, &connInfo); 502 ProxyConnInfo chan; variable 503 int32_t ret = TransAddConnItem(&chan); 693 const char *chan = "testchan"; variable 695 0, const_cast<char *>(chan)); 725 ProxyChannelInfo chan; variable 730 msg->obj = reinterpret_cast<void *>(&chan);
|
/ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/ |
H A D | softbus_proxychannel_transceiver.c | 206 OnProxyChannelClosed(chan->channelId, &(chan->appInfo)); in TransProxyLoopMsgHandler() 211 TransProxyKeepalive(chan->connId, chan); in TransProxyLoopMsgHandler() 268 if (chan != NULL) { in TransProxyPostResetPeerMsgToLoop() 305 if (chan == NULL) { in TransProxyPostKeepAliveMsgToLoop() 312 if (chan != NULL) { in TransProxyPostKeepAliveMsgToLoop() 322 if (chan == NULL) { in TransProxyPostOpenFailMsgToLoop() 339 if (chan == NULL) { in TransProxyPostOpenClosedMsgToLoop() 440 if (chan == NULL) { in TransAddConnItem() 665 if (chan == NULL) { in TransProxyConnExistProc() 801 if (chan == NULL) { in TransProxyOpenConnChannel() [all …]
|
H A D | softbus_proxychannel_manager.c | 947 if (chan->type == CONNECT_BLE || chan->type == CONNECT_BLE_DIRECT) { in ConstructProxyChannelInfo() 1104 if (chan == NULL) { in ReleaseChannelInfo() 1110 SoftBusFree(chan); in ReleaseChannelInfo() 1158 OnProxyChannelClosed(chan->channelId, &(chan->appInfo)); in TransProxyProcessHandshake() 1490 int32_t ret = GenerateRandomStr(chan->identity, sizeof(chan->identity)); in TransProxyCreateChanInfo() 1861 …(void)memset_s(chan->appInfo.sessionKey, sizeof(chan->appInfo.sessionKey), 0, sizeof(chan->appInfo… in TransProxyGetNameByChanId() 1878 SoftBusFree(chan); in TransProxyGetNameByChanId() 2081 chan.channelId, chan.connId, ret); in TransProxyGetConnOptionByChanId() 2088 chan.channelId, chan.connId, ret); in TransProxyGetConnOptionByChanId() 2098 chan.channelId, chan.connId, ret); in TransProxyGetConnOptionByChanId() [all …]
|
H A D | softbus_proxychannel_control.c | 156 int32_t TransProxyAckHandshake(uint32_t connId, ProxyChannelInfo *chan, int32_t retCode) in TransProxyAckHandshake() argument 158 if (chan == NULL) { in TransProxyAckHandshake() 167 if (chan->appInfo.appType != APP_TYPE_AUTH) { in TransProxyAckHandshake() 170 msgHead.myId = chan->myId; in TransProxyAckHandshake() 171 msgHead.peerId = chan->peerId; in TransProxyAckHandshake() 176 retCode, chan->myId, chan->peerId); in TransProxyAckHandshake() 180 chan->myId, chan->peerId); in TransProxyAckHandshake() 181 payLoad = TransProxyPackHandshakeAckMsg(chan); in TransProxyAckHandshake() 189 if (TransProxyPackMessage(&msgHead, chan->authHandle, &dataInfo) != SOFTBUS_OK) { in TransProxyAckHandshake() 196 CONN_HIGH, chan->appInfo.myData.pid); in TransProxyAckHandshake()
|
H A D | softbus_proxychannel_listener.c | 188 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); in TransProxyGetChannelIsServer() local 189 if (chan == NULL) { in TransProxyGetChannelIsServer() 193 if (TransProxyGetChanByChanId(channelId, chan) != SOFTBUS_OK) { in TransProxyGetChannelIsServer() 194 SoftBusFree(chan); in TransProxyGetChannelIsServer() 197 *isServer = chan->isServer; in TransProxyGetChannelIsServer() 198 SoftBusFree(chan); in TransProxyGetChannelIsServer()
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/ |
H A D | mod.rs | 36 chan: C, field 41 fn new(chan: C) -> Channel<C> { in new() 43 chan, in new() 49 pub(crate) fn channel<C: Container>(chan: C) -> (Tx<C>, Rx<C>) { in channel() 50 let channel = Arc::new(Channel::new(chan)); in channel() 78 self.inner.chan.close(); in close() 87 &self.inner.chan in deref() 105 &self.inner.chan in deref()
|
/ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/include/ |
H A D | softbus_proxychannel_transceiver.h | 38 void TransProxyPostResetPeerMsgToLoop(const ProxyChannelInfo *chan); 40 void TransProxyPostDisConnectMsgToLoop(uint32_t connId, bool isServer, const ProxyChannelInfo *chan… 41 void TransProxyPostOpenClosedMsgToLoop(const ProxyChannelInfo *chan); 42 void TransProxyPostOpenFailMsgToLoop(const ProxyChannelInfo *chan, int32_t errCode); 43 void TransProxyPostKeepAliveMsgToLoop(const ProxyChannelInfo *chan);
|
H A D | softbus_proxychannel_manager.h | 47 int32_t TransProxyGetChanByChanId(int32_t chanId, ProxyChannelInfo *chan); 48 int32_t TransProxyGetChanByReqId(int32_t reqId, ProxyChannelInfo *chan); 57 int32_t TransProxyCreateChanInfo(ProxyChannelInfo *chan, int32_t channelId, const AppInfo *appInfo);
|
/ohos5.0/drivers/hdf_core/framework/support/platform/src/dma/ |
H A D | dmac_core.c | 249 int32_t chan; in DmacRequestChannel() local 257 chan = DmacAllocateChannel(cntlr); in DmacRequestChannel() 258 if (chan < 0) { in DmacRequestChannel() 262 chanInfo = &(cntlr->channelList[chan]); in DmacRequestChannel() 263 chanInfo->channel = (unsigned int)chan; in DmacRequestChannel() 267 DmacFreeChannel(cntlr, chan); in DmacRequestChannel() 280 if (chan->dummyPage == NULL) { in DmacGetDummyBuf() 281 chan->dummyPage = OsalMemCalloc(sizeof(cntlr->maxTransSize)); in DmacGetDummyBuf() 284 return (chan->dummyPage == NULL) ? 0 : (uintptr_t)LOS_PaddrQuery(chan->dummyPage); in DmacGetDummyBuf() 517 uintptr_t DmaGetCurrChanDestAddr(struct DmaCntlr *cntlr, uint16_t chan) in DmaGetCurrChanDestAddr() argument [all …]
|
/ohos5.0/drivers/hdf_core/framework/test/unittest/platform/virtual/ |
H A D | adc_linux_virtual_iio_driver.c | 41 static int AdcReadChannelData(const struct iio_dev *indioDev, struct iio_chan_spec const *chan, int… in AdcReadChannelData() argument 48 (void)chan; in AdcReadChannelData() 57 static int AdcIioReadRaw(struct iio_dev *indioDev, struct iio_chan_spec const *chan, int *val, int … in AdcIioReadRaw() argument 63 if (indioDev == NULL || chan == NULL || val == NULL || val2 == NULL) { in AdcIioReadRaw() 77 ret = AdcReadChannelData(indioDev, chan, val); in AdcIioReadRaw()
|
/ohos5.0/drivers/hdf_core/framework/support/platform/include/dma/ |
H A D | dmac_core.h | 149 int (*dmacGetChanStatus)(struct DmaCntlr *cntlr, uint16_t chan); 150 uintptr_t (*dmacGetCurrDestAddr)(struct DmaCntlr *cntlr, uint16_t chan); 165 uintptr_t DmaGetCurrChanDestAddr(struct DmaCntlr *cntlr, uint16_t chan); 198 static inline uintptr_t DmaGetCurrChanDestAddr(struct DmaCntlr *cntlr, uint16_t chan) in DmaGetCurrChanDestAddr() argument 201 (void)chan; in DmaGetCurrChanDestAddr()
|
/ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/fuzztest/softbusproxychannelmanager_fuzzer/ |
H A D | softbusproxychannelmanager_fuzzer.cpp | 155 ProxyChannelInfo chan; in TransProxyGetChanByChanIdTest() local 157 (void)TransProxyGetChanByChanId(chanId, &chan); in TransProxyGetChanByChanIdTest() 163 ProxyChannelInfo chan; in TransProxyGetChanByReqIdTest() local 165 (void)TransProxyGetChanByReqId(reqId, &chan); in TransProxyGetChanByReqIdTest() 201 ProxyChannelInfo chan; in TransProxyGetSendMsgChanInfoTest() local 203 (void)TransProxyGetSendMsgChanInfo(channelId, &chan); in TransProxyGetSendMsgChanInfoTest()
|