| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/rfcomm/ |
| H A D | rfcomm_channel_fsm.c | 381 return RfcommSendUihRpn(channel->session, channel->dlci, false, &channel->portConfig); in RfcommRecvRpnCmd()
402 return RfcommSendUihRpn(channel->session, channel->dlci, false, &portConfig); in RfcommRecvRpnReq()
440 channel->localMtu = (channel->localMtu < info.pn.mtu) ? channel->localMtu : info.pn.mtu; in RfcommRecvPnReq()
441 channel->peerMtu = channel->localMtu; in RfcommRecvPnReq()
507 channel->localMtu = (channel->localMtu < info.pn.mtu) ? channel->localMtu : info.pn.mtu; in RfcommRecvPnRsp()
508 channel->peerMtu = channel->localMtu; in RfcommRecvPnRsp()
936 return RfcommSendDm(channel->session, channel->dlci, false); in RfcommRecvRevData()
999 newCredits = channel->localCreditMax - channel->localCredit; in RfcommWriteData()
1052 int ret = RfcommSendUihRpn(channel->session, channel->dlci, true, NULL); in RfcommSendRpnReq()
1085 int ret = RfcommSendUihRls(channel->session, channel->dlci, true, status); in RfcommSendRlsReq()
[all …]
|
| H A D | rfcomm_channel.c | 256 if (channel == NULL) { in RfcommCreateChannel()
283 return channel; in RfcommCreateChannel()
323 return channel; in RfcommCreateChannelOfServer()
353 free(channel); in RfcommRemoveChannel()
462 channel->callBack(channel->handle, event, eventData, channel->context); in RfcommNotifyEvtToUpper()
489 if ((channel->session == session) && (channel->dlci == dlci)) { in RfcommGetChannelByDlci()
807 if ((channel->scn == scn) && (channel->isServer)) { in RfcommRemoveChannelCallback()
893 RfcommSendUihData(channel->session, channel->dlci, credits, NULL); in RfcommSendCredits()
915 uint8_t newCredits = channel->localCreditMax - channel->localCredit; in RfcommSetFlcToPeer()
932 RfcommSendUihMsc(channel->session, channel->dlci, true, &modemStatus); in RfcommSetFlcToPeer()
[all …]
|
| H A D | rfcomm.c | 149 if (channel != NULL) { in RfcommConnectChannel()
166 if (channel == NULL) { in RfcommConnectChannel()
228 if (channel == NULL) { in RfcommAcceptConnection()
250 if (channel == NULL) { in RfcommRejectConnection()
270 if (channel == NULL) { in RfcommDisconnectChannel()
318 if (channel == NULL) { in RfcommSetPortConfig()
338 if (channel == NULL) { in RfcommReqPortConfig()
359 if (channel == NULL) { in RfcommSendRemoteLineStatus()
380 if (channel == NULL) { in RfcommSetModemStatus()
401 if (channel == NULL) { in RfcommGetPortState()
[all …]
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/gavdp/a2dp_codec/sbclib/src/ |
| H A D | sbc_frame.cpp | 123 for (int channel = 0; channel < frame.channels_; channel++) { in SbcCalculateBitsNormal() local
221 for (int channel = 0; channel < CHANNEL_TWO; channel++) { in SbcCalculateBitsMaxStereo() local
230 for (int channel = 0; channel < CHANNEL_TWO; channel++) { in SbcCalculateBitsMaxStereo() local
258 for (int channel = 0; channel < CHANNEL_TWO; channel++) { in SbcCalculateBitsSliceStereo() local
280 for (int channel = 0; channel < CHANNEL_TWO; channel++) { in SbcCalculateBitsInnerStereo() local
394 for (int channel = 0; channel < frame.channels_; channel++) { in UnpackFrameStream() local
413 for (uint8_t channel = 0; channel < frame.channels_; channel++) { in UnpackFrameStream() local
420 for (uint8_t channel = 0; channel < frame.channels_; channel++) { in UnpackFrameStream() local
562 for (int channel = 0; channel < frame.channels_; channel++) { in SbcCaculateLevelsAndSampleDelta() local
592 for (int channel = 0; channel < channels; channel++) { in PackFrameInternal() local
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/common/src/ |
| H A D | client_trans_udp_manager.c | 42 if (channel == NULL) { in ClientTransAddUdpChannel()
101 if (channel == NULL) { in TransGetUdpChannel()
154 UdpChannel channel; in OnUdpChannelOpened() local
269 channel->channelId, channel->businessType); in TransOnUdpChannelOpened()
323 UdpChannel channel; in TransOnUdpChannelOpenFailed() local
432 UdpChannel channel; in CloseUdpChannel() local
458 UdpChannel channel; in TransOnUdpChannelQosEvent() local
491 UdpChannel channel; in TransUdpChannelSendStream() local
506 UdpChannel channel; in TransUdpChannelSetStreamMultiLayer() local
580 UdpChannel channel; in OnRawStreamEncryptOptGet() local
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/common/ |
| H A D | client_trans_udp_manager_test.cpp | 102 ChannelInfo channel; in InitChannelInfo() local
108 channel.fd = TEST_DATA_TYPE; in InitChannelInfo()
109 channel.isServer = true; in InitChannelInfo()
110 channel.isEnabled = true; in InitChannelInfo()
113 channel.groupId = strTmp; in InitChannelInfo()
114 channel.sessionKey = strTmp; in InitChannelInfo()
115 channel.keyLen = sizeof(channel.sessionKey); in InitChannelInfo()
118 channel.myIp = strTmp; in InitChannelInfo()
120 channel.isUdpFile = true; in InitChannelInfo()
122 channel.peerIp = strTmp; in InitChannelInfo()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/sdk/frame/small/src/ |
| H A D | trans_client_stub.c | 28 ChannelInfo channel = {0}; in ClientOnChannelOpened() local
32 ReadBool(data, &(channel.isServer)); in ClientOnChannelOpened()
33 ReadBool(data, &(channel.isEnabled)); in ClientOnChannelOpened()
34 ReadBool(data, &(channel.isEncrypt)); in ClientOnChannelOpened()
35 ReadInt32(data, &(channel.peerUid)); in ClientOnChannelOpened()
36 ReadInt32(data, &(channel.peerPid)); in ClientOnChannelOpened()
38 ReadUint32(data, &(channel.keyLen)); in ClientOnChannelOpened()
39 channel.sessionKey = (char *)ReadBuffer(data, channel.keyLen); in ClientOnChannelOpened()
42 if (channel.groupId == NULL || channel.sessionKey == NULL || channel.peerSessionName == NULL || in ClientOnChannelOpened()
43 channel.peerDeviceId == NULL) { in ClientOnChannelOpened()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| H A D | mod.rs | 55 channel: Tx<Array<T>>, field
61 channel: self.channel.clone(), in clone()
89 channel: Rx<Array<T>>, field
247 self.channel.is_close() in is_closed()
261 self.channel.is_same(&other.channel) in is_same()
274 self.channel.capacity() in capacity()
289 self.channel.len() in len()
310 self.channel.close(); in drop()
331 self.channel.len() in len()
515 self.channel.close(); in close()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/ |
| H A D | mod.rs | 50 channel: Tx<Queue<T>>, field
56 channel: self.channel.clone(), in clone()
80 channel: Rx<Queue<T>>, field
123 self.channel.send(value) in send()
142 self.channel.is_close() in is_closed()
156 self.channel.is_same(&other.channel) in is_same()
171 self.channel.len() in len()
192 self.channel.close(); in drop()
213 self.channel.len() in len()
392 self.channel.close(); in close()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | watch.rs | 55 channel: channel.clone(), in channel()
58 channel, in channel()
85 channel: Arc<Channel<T>>, field
114 self.channel.state.version_update(); in send()
116 self.channel.waker_list.notify_all(); in send()
145 channel: self.channel.clone(), in subscribe()
166 self.channel.rx_cnt.load(Acquire) in receiver_count()
172 self.channel.close(); in drop()
275 channel: Arc<Channel<T>>, field
493 Arc::ptr_eq(&self.channel, &other.channel) in is_same()
[all …]
|
| H A D | oneshot.rs | 84 pub fn channel<T>() -> (Sender<T>, Receiver<T>) { in channel() function
85 let channel = Arc::new(Channel::new()); in channel() localVariable
87 channel: channel.clone(), in channel()
89 let rx = Receiver { channel }; in channel()
137 channel: Arc<Channel<T>>, field
172 .channel in send()
218 self.channel.waker.wake(); in drop()
271 channel: Arc<Channel<T>>, field
330 .channel in try_recv()
377 .channel in close()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/sdk/transmission/trans_channel/tcp_direct/src/ |
| H A D | client_trans_tcp_direct_manager.c | 175 if (channel == NULL) { in TransGetNewTcpChannel()
184 item->channelId = channel->channelId; in TransGetNewTcpChannel()
185 item->detail.fd = channel->fd; in TransGetNewTcpChannel()
269 if (channel->isServer && isSocket) { in ClientTransTdcHandleListener()
332 ret = TransAddDataBufNode(channel->channelId, channel->fd); in ClientTransTdcOnChannelOpened()
334 …(TRANS_SDK, "add node fail. channelId=%{public}d, fd=%{public}d", channel->channelId, channel->fd); in ClientTransTdcOnChannelOpened()
419 TcpDirectChannelInfo channel; in TransTdcGetSessionKey() local
437 TcpDirectChannelInfo channel; in TransTdcGetHandle() local
442 *handle = channel.detail.fd; in TransTdcGetHandle()
448 TcpDirectChannelInfo channel; in TransDisableSessionListener() local
[all …]
|
| /ohos5.0/foundation/multimedia/audio_framework/services/audio_service/common/src/ |
| H A D | volume_tools.cpp | 49 if (vols.channel > CHANNEL_16 || vols.channel < MONO) { in IsVolumeValid()
75 …if (!IsVolumeValid(volStart) || !IsVolumeValid(volEnd) || channel > CHANNEL_16 || channel < MONO) { in GetChannelVolumes()
77 volEnd, channel); in GetChannelVolumes()
80 for (size_t i = 0; i < channel; i++) { in GetChannelVolumes()
84 vols.channel = channel; in GetChannelVolumes()
91 …if (!IsVolumeValid(volStart) || !IsVolumeValid(volEnd) || channel > CHANNEL_16 || channel < MONO) { in GetChannelVolumes()
93 volEnd, channel); in GetChannelVolumes()
100 vols.channel = channel; in GetChannelVolumes()
283 raw8 += (split - 1) * channel; in CountU8Volume()
327 raw16 += (split - 1) * channel; in CountS16Volume()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/manager/src/ |
| H A D | trans_channel_callback.c | 61 const ChannelInfo *channel) in TransServerOnChannelOpened() argument
67 if (channel->isEncrypt) { in TransServerOnChannelOpened()
75 …TransGetRemoteDeviceVersion(channel->peerDeviceId, channel->isEncrypt ? CATEGORY_NETWORK_ID : CATE… in TransServerOnChannelOpened()
77 int64_t timeStart = channel->timeStart; in TransServerOnChannelOpened()
82 .linkType = channel->connectType, in TransServerOnChannelOpened()
83 .channelId = channel->channelId, in TransServerOnChannelOpened()
91 .peerUdid = channel->isEncrypt ? peerUdid : channel->peerDeviceId in TransServerOnChannelOpened()
94 if (!channel->isServer) { in TransServerOnChannelOpened()
96 TransGetSocketChannelStateByChannel(channel->channelId, channel->channelType, &state); in TransServerOnChannelOpened()
107 channel->channelId, channel->channelType, CORE_SESSION_STATE_CHANNEL_OPENED); in TransServerOnChannelOpened()
[all …]
|
| /ohos5.0/base/sensors/sensor/services/src/ |
| H A D | sensor_data_processer.cpp | 66 fifoCacheData->SetChannel(channel); in SendNoneFifoCacheData()
82 if (fifoChannel != channel) { in SendNoneFifoCacheData()
99 fifoCacheData->SetChannel(channel); in SendNoneFifoCacheData()
132 if (fifoChannel != channel) { in SendFifoCacheData()
164 CHKPV(channel); in ReportData()
213 CHKPV(channel); in SendRawData()
229 CHKPR(channel, INVALID_POINTER); in CacheSensorEvent()
271 for (auto &channel : channelList) { in EventFilter() local
305 CHKPR(channel, INVALID_POINTER); in SendEvents()
309 ReportData(channel, data); in SendEvents()
[all …]
|
| /ohos5.0/base/sensors/medical_sensor/services/medical_sensor/src/ |
| H A D | medical_data_processer.cpp | 80 fifoCacheData->SetChannel(channel); in SendNoneFifoCacheData()
108 fifoCacheData->SetChannel(channel); in SendNoneFifoCacheData()
131 fifoCacheData->SetChannel(channel); in SendFifoCacheData()
167 fifoCacheData->SetChannel(channel); in SendFifoCacheData()
174 if (channel == nullptr) { in ReportData()
270 if (channel == nullptr) { in CacheSensorEvent()
325 for (auto &channel : flushVec) { in EventFilter() local
341 for (auto &channel : channelList) { in EventFilter() local
388 if (channel == nullptr) { in SendEvents()
395 ReportData(channel, event); in SendEvents()
[all …]
|
| /ohos5.0/foundation/multimedia/av_codec/test/moduletest/audio_decoder/Avbuffer/src/ |
| H A D | param_check_test.cpp | 167 channel = 1;
175 channel = 8;
183 channel = 0;
191 channel = 9;
341 channel = 1;
349 channel = 8;
357 channel = 0;
365 channel = 9;
491 channel = 1;
499 channel = 2;
[all …]
|
| /ohos5.0/foundation/multimedia/audio_framework/frameworks/native/audioutils/src/ |
| H A D | audio_channel_blend.cpp | 32 AudioBlend::AudioBlend(ChannelBlendMode blendMode, uint8_t format, uint8_t channel) in AudioBlend() argument
33 :blendMode_(blendMode), format_(format), channels_(channel) in AudioBlend()
37 void AudioBlend::SetParams(ChannelBlendMode blendMode, uint8_t format, uint8_t channel) in SetParams() argument
43 channels_ = channel; in SetParams()
109 void AudioBlend::ProcessBlendLRModeWithFormat(T *buffer, size_t count, AudioChannel channel) in ProcessBlendLRModeWithFormat() argument
112 switch (channel) { in ProcessBlendLRModeWithFormat()
132 buffer += (int8_t)channel; in ProcessBlendLRModeWithFormat()
140 switch (channel) { in ProcessAllLeftModeWithFormat()
160 buffer += (int8_t)channel; in ProcessAllLeftModeWithFormat()
168 switch (channel) { in ProcessAllRightModeWithFormat()
[all …]
|
| /ohos5.0/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_common/ |
| H A D | wifi_channel_helper.cpp | 108 if (channel == INVALID_FREQ_OR_CHANNEL) { in UpdateValidChannels()
115 if (channel == INVALID_FREQ_OR_CHANNEL) { in UpdateValidChannels()
231 int channel; in TransformFrequencyIntoChannel() local
234 if (channel == -1) { in TransformFrequencyIntoChannel()
238 chanVector.push_back(channel); in TransformFrequencyIntoChannel()
257 if (channel >= CHANNEL_2G_MIN && channel <= CHANNEL_2G_MAX) { in TransformChannelToFrequency()
260 if (CHANNEL_5G_MIN <= channel && channel <= CHANNEL_5G_MAX) { in TransformChannelToFrequency()
278 if (channel <= CHANNEL_2G_MAX) { in TransformChannelToBand()
280 } else if (channel <= CHANNEL_5G_MAX) { in TransformChannelToBand()
298 return channel >= CHANNEL_2G_MIN && channel <= CHANNEL_2G_MAX; in IsValid24GChannel()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/src/ |
| H A D | client_trans_stream.c | 153 int32_t TransOnstreamChannelOpened(const ChannelInfo *channel, int32_t *streamPort) in TransOnstreamChannelOpened() argument
156 if (channel == NULL || streamPort == NULL) { in TransOnstreamChannelOpened()
160 StreamType streamType = (StreamType)channel->streamType; in TransOnstreamChannelOpened()
171 if (channel->isServer) { in TransOnstreamChannelOpened()
177 ret = OnStreamUdpChannelOpened(channel->channelId); in TransOnstreamChannelOpened()
183 VtpStreamOpenParam p1 = { "DSOFTBUS_STREAM", channel->myIp, in TransOnstreamChannelOpened()
184 … NULL, -1, streamType, (uint8_t*)channel->sessionKey, channel->keyLen, isEncryptedRawStream}; in TransOnstreamChannelOpened()
194 VtpStreamOpenParam p1 = { "DSOFTBUS_STREAM", channel->myIp, channel->peerIp, in TransOnstreamChannelOpened()
195 …channel->peerPort, streamType, (uint8_t *)channel->sessionKey, channel->keyLen, isEncryptedRawStre… in TransOnstreamChannelOpened()
197 int32_t ret = StartVtpStreamChannelClient(channel->channelId, &p1, &g_streamCallcb); in TransOnstreamChannelOpened()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/file/ |
| H A D | trans_sdk_file_test.cpp | 47 if (channel == NULL) { in TransAddChannelTest()
50 channel->channelId = 1; in TransAddChannelTest()
51 channel->dfileId = -1; in TransAddChannelTest()
52 channel->channelId = 1; in TransAddChannelTest()
53 channel->businessType = 1; in TransAddChannelTest()
54 channel->isEnable = true; in TransAddChannelTest()
55 channel->routeType = 1; in TransAddChannelTest()
57 channel->info.peerUid = 0; in TransAddChannelTest()
63 return channel; in TransAddChannelTest()
188 channel->channelId = 1; in GenerateAndAddUdpChannel()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/udp_negotiation/ |
| H A D | trans_udp_nego_test.cpp | 322 ASSERT_TRUE(channel != nullptr);
371 ASSERT_TRUE(channel != nullptr);
395 UdpChannelInfo channel; variable
418 ASSERT_TRUE(channel != nullptr);
422 StartExchangeUdpInfo(channel, authHandle, channel->seq);
517 ASSERT_TRUE(channel != nullptr);
537 ASSERT_TRUE(channel != nullptr);
743 SoftBusFree(channel);
763 SoftBusFree(channel);
793 SoftBusFree(channel);
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/udp_negotiation/src/ |
| H A D | trans_udp_negotiation.c | 589 (void)memset_s(&channel, sizeof(channel), 0, sizeof(channel)); in TransOnExchangeUdpInfoReply()
614 …(void)memset_s(channel.info.sessionKey, sizeof(channel.info.sessionKey), 0, sizeof(channel.info.se… in TransOnExchangeUdpInfoReply()
809 ret = StartExchangeUdpInfo(channel, authHandle, channel->seq); in UdpOnAuthConnOpened()
821 SoftBusFree(channel); in UdpOnAuthConnOpened()
831 SoftBusFree(channel); in UdpOnAuthConnOpened()
865 SoftBusFree(channel); in UdpOnAuthConnOpenFailed()
885 SoftBusFree(channel); in TransCloseUdpChannelByRequestId()
896 …(void)memset_s(channel.info.sessionKey, sizeof(channel.info.sessionKey), 0, sizeof(channel.info.se… in CheckAuthConnStatus()
1107 (void)memset_s(&channel, sizeof(channel), 0, sizeof(channel)); in TransCloseUdpChannel()
1113 …(void)memset_s(channel.info.sessionKey, sizeof(channel.info.sessionKey), 0, sizeof(channel.info.se… in TransCloseUdpChannel()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/tcp_direct/ |
| H A D | trans_sdk_tcp_direct_test.cpp | 172 ASSERT_TRUE(channel != nullptr);
182 SoftBusFree(channel);
195 ASSERT_TRUE(channel != nullptr);
209 SoftBusFree(channel);
238 SoftBusFree(channel);
267 SoftBusFree(channel);
336 SoftBusFree(channel);
368 SoftBusFree(channel);
400 SoftBusFree(channel);
595 SoftBusFree(channel);
[all …]
|
| /ohos5.0/foundation/multimedia/av_codec/test/moduletest/audio_encoder/Avbuffer/src/ |
| H A D | param_check_test.cpp | 121 channel = 1;
130 channel = 2;
139 channel = 0;
148 channel = 3;
368 int32_t channel = 1; variable
378 channel = 1;
387 channel = 0;
396 channel = 2;
414 int32_t channel = 1; variable
460 int32_t channel = 1; variable
[all …]
|