Home
last modified time | relevance | path

Searched refs:chan (Results 1 – 25 of 33) sorted by relevance

12

/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/l2cap/
H A Dl2cap_core.c90 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 Dl2cap.c32 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 Dl2cap_le.c213 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 Dl2cap_inst.c129 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 Dl2cap_core.h72 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 Dl2cap_inst.h182 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 Dtrans_proxy_manager_test.cpp328 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 Dsoftbus_proxychannel_manager_test.cpp162 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 Dtrans_proxy_channel_test.cpp129 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 Dtrans_proxy_message_test.cpp97 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 Dsoftbus_proxychannel_message_test.cpp171 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 Dsoftbus_proxy_session_test.cpp120 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 Dtrans_proxy_session_test.cpp137 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 Dsoftbus_trans_proxy_transceiver_test.cpp292 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 Dsoftbus_proxychannel_transceiver.c206 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 Dsoftbus_proxychannel_manager.c947 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 Dsoftbus_proxychannel_control.c156 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 Dsoftbus_proxychannel_listener.c188 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 Dmod.rs36 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 Dsoftbus_proxychannel_transceiver.h38 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 Dsoftbus_proxychannel_manager.h47 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 Ddmac_core.c249 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 Dadc_linux_virtual_iio_driver.c41 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 Ddmac_core.h149 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 Dsoftbusproxychannelmanager_fuzzer.cpp155 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()

12