Home
last modified time | relevance | path

Searched refs:channel (Results 1 - 25 of 70) sorted by relevance

123

/base/sensors/medical_sensor/services/medical_sensor/src/
H A Dmedical_data_processer.cpp63 sptr<MedicalSensorBasicDataChannel> &channel, struct SensorEvent &event, uint64_t periodCount) in SendNoneFifoCacheData()
80 fifoCacheData->SetChannel(channel); in SendNoneFifoCacheData()
83 SendRawData(cacheBuf, channel, sendEvents); in SendNoneFifoCacheData()
88 if (fifoCacheData->GetChannel() != channel) { in SendNoneFifoCacheData()
98 SendRawData(cacheBuf, channel, sendEvents); in SendNoneFifoCacheData()
108 fifoCacheData->SetChannel(channel); in SendNoneFifoCacheData()
110 SendRawData(cacheBuf, channel, sendEvents); in SendNoneFifoCacheData()
115 sptr<MedicalSensorBasicDataChannel> &channel, struct SensorEvent &event, uint64_t periodCount, uint64_t fifoCount) in SendFifoCacheData()
131 fifoCacheData->SetChannel(channel); in SendFifoCacheData()
136 // find channel i in SendFifoCacheData()
62 SendNoneFifoCacheData(std::unordered_map<uint32_t, struct SensorEvent> &cacheBuf, sptr<MedicalSensorBasicDataChannel> &channel, struct SensorEvent &event, uint64_t periodCount) SendNoneFifoCacheData() argument
114 SendFifoCacheData(std::unordered_map<uint32_t, struct SensorEvent> &cacheBuf, sptr<MedicalSensorBasicDataChannel> &channel, struct SensorEvent &event, uint64_t periodCount, uint64_t fifoCount) SendFifoCacheData() argument
172 ReportData(sptr<MedicalSensorBasicDataChannel> &channel, struct SensorEvent &event) ReportData() argument
198 ReportNotContinuousData(std::unordered_map<uint32_t, struct SensorEvent> &cacheBuf, sptr<MedicalSensorBasicDataChannel> &channel, struct SensorEvent &event) ReportNotContinuousData() argument
222 CheckSendDataPermission(sptr<MedicalSensorBasicDataChannel> channel, uint32_t sensorId) CheckSendDataPermission() argument
227 SendRawData(std::unordered_map<uint32_t, struct SensorEvent> &cacheBuf, sptr<MedicalSensorBasicDataChannel> channel, std::vector<struct SensorEvent> event) SendRawData() argument
267 CacheSensorEvent( const struct SensorEvent &event, sptr<MedicalSensorBasicDataChannel> &channel) CacheSensorEvent() argument
386 SendEvents(sptr<MedicalSensorBasicDataChannel> &channel, struct SensorEvent &event) SendEvents() argument
[all...]
H A Dflush_info_record.cpp53 const sptr<MedicalSensorBasicDataChannel> &channel, bool isFirstFlush) in SetFlushInfo()
56 if (channel == nullptr) { in SetFlushInfo()
57 HiLog::Error(LABEL, "%{public}s failed, channel cannot be null", __func__); in SetFlushInfo()
60 FlushInfo flush(channel, isFirstFlush); in SetFlushInfo()
77 HiLog::Debug(LABEL, "%{public}s channel list size : %{public}u", __func__, in IsFlushChannelValid()
79 for (const auto &channel : currChannelList) { in IsFlushChannelValid()
80 if (channel == flushChannel) { in IsFlushChannelValid()
88 const sptr<MedicalSensorBasicDataChannel> &channel) in GetFlushChannelIndex()
92 if (flushInfoList[i].flushChannel == channel) { in GetFlushChannelIndex()
107 sptr<MedicalSensorBasicDataChannel> channel in FlushProcess() local
52 SetFlushInfo(uint32_t sensorId, const sptr<MedicalSensorBasicDataChannel> &channel, bool isFirstFlush) SetFlushInfo() argument
87 GetFlushChannelIndex(const std::vector<struct FlushInfo> &flushInfoList, const sptr<MedicalSensorBasicDataChannel> &channel) GetFlushChannelIndex() argument
[all...]
H A Dfifo_cache_data.cpp54 void FifoCacheData::SetChannel(const sptr<MedicalSensorBasicDataChannel> &channel) in SetChannel() argument
56 channel_ = channel; in SetChannel()
H A Dclient_info.cpp136 HiLog::Error(LABEL, "%{public}s max support channel size is %{public}u", __func__, MAX_SUPPORT_CHANNEL); in UpdateUid()
202 HiLog::Error(LABEL, "%{public}s there is no channel belong to the pid", __func__); in GetSensorChannelByPid()
219 HiLog::Debug(LABEL, "%{public}s there is no channel belong to sensorId : %{public}u", __func__, sensorId); in GetSensorChannel()
272 bool ClientInfo::UpdateSensorChannel(int32_t pid, const sptr<MedicalSensorBasicDataChannel> &channel) in UpdateSensorChannel() argument
275 if (pid <= INVALID_PID || channel == nullptr) { in UpdateSensorChannel()
276 HiLog::Error(LABEL, "%{public}s pid or channel is invalid or channel cannot be null", __func__); in UpdateSensorChannel()
283 HiLog::Error(LABEL, "%{public}s max support channel size : %{public}u", __func__, MAX_SUPPORT_CHANNEL); in UpdateSensorChannel()
286 auto ret = channelMap_.insert(std::make_pair(pid, channel)); in UpdateSensorChannel()
290 channelMap_[pid] = channel; in UpdateSensorChannel()
398 ComputeBestPeriodCount(uint32_t sensorId, sptr<MedicalSensorBasicDataChannel> &channel) ComputeBestPeriodCount() argument
424 ComputeBestFifoCount(uint32_t sensorId, sptr<MedicalSensorBasicDataChannel> &channel) ComputeBestFifoCount() argument
573 GetAppInfoByChannel(const sptr<MedicalSensorBasicDataChannel> &channel) GetAppInfoByChannel() argument
602 MedicalSensorChannelInfo channel; GetSensorChannelInfo() local
[all...]
H A Dmedical_dump.cpp61 dprintf(fd, " -c: dump the sensor data channel info\n"); in DumpHelp()
94 dprintf(fd, "MedicalSensor channel info:\n"); in DumpSensorChannel()
97 for (const auto &channel : channelInfo) { in DumpSensorChannel()
98 auto sensorId = channel.GetSensorId(); in DumpSensorChannel()
100 auto cmdList = channel.GetCmdType(); in DumpSensorChannel()
107 channel.GetUid(), channel.GetPackageName().c_str(), sensorId, sensorMap_[sensorId].c_str(), in DumpSensorChannel()
108 int32_t { channel.GetSamplingPeriodNs() }, channel.GetFifoCount(), cmds.c_str()); in DumpSensorChannel()
/base/sensors/sensor/services/src/
H A Dsensor_data_processer.cpp56 sptr<SensorBasicDataChannel> &channel, SensorData &data, in SendNoneFifoCacheData()
67 fifoCacheData->SetChannel(channel); in SendNoneFifoCacheData()
70 SendRawData(cacheBuf, channel, sendEvents); in SendNoneFifoCacheData()
83 if (fifoChannel != channel) { in SendNoneFifoCacheData()
93 SendRawData(cacheBuf, channel, sendEvents); in SendNoneFifoCacheData()
100 fifoCacheData->SetChannel(channel); in SendNoneFifoCacheData()
102 SendRawData(cacheBuf, channel, sendEvents); in SendNoneFifoCacheData()
107 sptr<SensorBasicDataChannel> &channel, SensorData &data, in SendFifoCacheData()
117 fifoCacheData->SetChannel(channel); in SendFifoCacheData()
122 // find channel i in SendFifoCacheData()
55 SendNoneFifoCacheData(std::unordered_map<int32_t, SensorData> &cacheBuf, sptr<SensorBasicDataChannel> &channel, SensorData &data, uint64_t periodCount) SendNoneFifoCacheData() argument
106 SendFifoCacheData(std::unordered_map<int32_t, SensorData> &cacheBuf, sptr<SensorBasicDataChannel> &channel, SensorData &data, uint64_t periodCount, uint64_t fifoCount) SendFifoCacheData() argument
163 ReportData(sptr<SensorBasicDataChannel> &channel, SensorData &data) ReportData() argument
183 ReportNotContinuousData(std::unordered_map<int32_t, SensorData> &cacheBuf, sptr<SensorBasicDataChannel> &channel, SensorData &data) ReportNotContinuousData() argument
204 SendRawData(std::unordered_map<int32_t, SensorData> &cacheBuf, sptr<SensorBasicDataChannel> channel, std::vector<SensorData> events) SendRawData() argument
221 CacheSensorEvent(const SensorData &data, sptr<SensorBasicDataChannel> &channel) CacheSensorEvent() argument
288 SendEvents(sptr<SensorBasicDataChannel> &channel, SensorData &data) SendEvents() argument
[all...]
H A Dflush_info_record.cpp46 ErrCode FlushInfoRecord::SetFlushInfo(int32_t sensorId, const sptr<SensorBasicDataChannel> &channel, bool isFirstFlush) in SetFlushInfo() argument
49 CHKPR(channel, INVALID_POINTER); in SetFlushInfo()
50 FlushInfo flush(channel, isFirstFlush); in SetFlushInfo()
68 for (const auto &channel : currChannelList) { in IsFlushChannelValid()
69 if (channel == flushChannel) { in IsFlushChannelValid()
77 const sptr<SensorBasicDataChannel> &channel) in GetFlushChannelIndex()
80 if (flushInfoList[i].flushChannel.promote() == channel) { in GetFlushChannelIndex()
90 sptr<SensorBasicDataChannel> channel = clientInfo_.GetSensorChannelByPid(pid); in FlushProcess() local
91 CHKPR(channel, ERROR); in FlushProcess()
92 int32_t ret = SetFlushInfo(sensorId, channel, fals in FlushProcess()
76 GetFlushChannelIndex(const std::vector<FlushInfo> &flushInfoList, const sptr<SensorBasicDataChannel> &channel) GetFlushChannelIndex() argument
[all...]
H A Dfifo_cache_data.cpp54 void FifoCacheData::SetChannel(const sptr<SensorBasicDataChannel> &channel) in SetChannel() argument
56 channel_ = channel; in SetChannel()
H A Dclient_info.cpp140 SEN_HILOGE("Max support channel size is %{public}d", MAX_SUPPORT_CHANNEL); in UpdateAppThreadInfo()
199 SEN_HILOGE("There is no channel belong to the pid"); in GetSensorChannelByPid()
214 SEN_HILOGD("There is no channel belong to sensorId:%{public}d", sensorId); in GetSensorChannel()
270 bool ClientInfo::UpdateSensorChannel(int32_t pid, const sptr<SensorBasicDataChannel> &channel) in UpdateSensorChannel() argument
273 CHKPR(channel, false); in UpdateSensorChannel()
282 SEN_HILOGE("Max support channel size:%{public}d", MAX_SUPPORT_CHANNEL); in UpdateSensorChannel()
285 auto ret = channelMap_.insert(std::make_pair(pid, channel)); in UpdateSensorChannel()
289 channelMap_[pid] = channel; in UpdateSensorChannel()
358 SEN_HILOGD("There is no channel belong to pid, no need to destroy"); in DestroySensorChannel()
373 SEN_HILOGE("sensorId or channel i in GetCurPidSensorInfo()
392 ComputeBestPeriodCount(int32_t sensorId, sptr<SensorBasicDataChannel> &channel) ComputeBestPeriodCount() argument
417 ComputeBestFifoCount(int32_t sensorId, sptr<SensorBasicDataChannel> &channel) ComputeBestFifoCount() argument
554 GetAppInfoByChannel(const sptr<SensorBasicDataChannel> &channel) GetAppInfoByChannel() argument
593 SensorChannelInfo channel; GetSensorChannelInfo() local
[all...]
/base/sensors/medical_sensor/services/medical_sensor/include/
H A Dmedical_sensor_data_processer.h41 int32_t SendEvents(sptr<MedicalSensorBasicDataChannel> &channel, struct SensorEvent &event);
43 int32_t CacheSensorEvent(const struct SensorEvent &event, sptr<MedicalSensorBasicDataChannel> &channel);
47 void ReportData(sptr<MedicalSensorBasicDataChannel> &channel, struct SensorEvent &event);
49 sptr<MedicalSensorBasicDataChannel> &channel, struct SensorEvent &event);
51 sptr<MedicalSensorBasicDataChannel> &channel, struct SensorEvent &event,
54 sptr<MedicalSensorBasicDataChannel> &channel, struct SensorEvent &event,
57 sptr<MedicalSensorBasicDataChannel> channel,
60 bool CheckSendDataPermission(sptr<MedicalSensorBasicDataChannel> channel, uint32_t sensorId);
H A Dflush_info_record.h38 FlushInfo(const sptr<MedicalSensorBasicDataChannel> &channel, bool enableFlush) in FlushInfo()
39 : flushChannel(channel), flushFromEnable(enableFlush) {}; in FlushInfo()
52 ErrCode SetFlushInfo(uint32_t sensorId, const sptr<MedicalSensorBasicDataChannel> &channel, bool isFirstFlush);
56 const sptr<MedicalSensorBasicDataChannel> &channel);
63 // sensorId, channel pointer for pending flush.
/base/sensors/sensor/services/include/
H A Dsensor_data_processer.h41 int32_t SendEvents(sptr<SensorBasicDataChannel> &channel, SensorData &data);
43 int32_t CacheSensorEvent(const SensorData &data, sptr<SensorBasicDataChannel> &channel);
47 void ReportData(sptr<SensorBasicDataChannel> &channel, SensorData &data);
49 sptr<SensorBasicDataChannel> &channel, SensorData &data);
51 sptr<SensorBasicDataChannel> &channel, SensorData &data, uint64_t periodCount);
53 sptr<SensorBasicDataChannel> &channel, SensorData &data, uint64_t periodCount,
55 void SendRawData(std::unordered_map<int32_t, SensorData> &cacheBuf, sptr<SensorBasicDataChannel> channel,
H A Dflush_info_record.h40 FlushInfo(const sptr<SensorBasicDataChannel> &channel, bool enableFlush) in FlushInfo()
41 : flushChannel(channel), flushFromEnable(enableFlush){}; in FlushInfo()
53 ErrCode SetFlushInfo(int32_t sensorId, const sptr<SensorBasicDataChannel> &channel, bool isFirstFlush);
57 const sptr<SensorBasicDataChannel> &channel);
63 // sensorId, channel pointer for pending flush.
/base/inputmethod/imf/frameworks/native/inputmethod_ability/src/
H A Dinput_method_ability.cpp205 if (clientInfo.channel == nullptr) { in StartInput()
211 SetInputDataChannel(clientInfo.channel); in StartInput()
266 void InputMethodAbility::ClearDataChannel(const sptr<IRemoteObject> &channel) in ClearDataChannel() argument
269 if (dataChannelObject_ == nullptr || channel == nullptr) { in ClearDataChannel()
273 if (dataChannelObject_.GetRefPtr() == channel.GetRefPtr()) { in ClearDataChannel()
440 auto channel = GetInputDataChannelProxy(); in ShowKeyboardImplWithoutLock() local
441 if (channel != nullptr) { in ShowKeyboardImplWithoutLock()
442 channel->SendKeyboardStatus(KeyboardStatus::SHOW); in ShowKeyboardImplWithoutLock()
451 auto channel = GetInputDataChannelProxy(); in NotifyPanelStatusInfo() local
452 NotifyPanelStatusInfo(info, channel); in NotifyPanelStatusInfo()
523 auto channel = GetInputDataChannelProxy(); InsertText() local
535 auto channel = GetInputDataChannelProxy(); DeleteForward() local
546 auto channel = GetInputDataChannelProxy(); DeleteBackward() local
556 auto channel = GetInputDataChannelProxy(); SendFunctionKey() local
582 auto channel = GetInputDataChannelProxy(); SendExtendAction() local
594 auto channel = GetInputDataChannelProxy(); GetTextBeforeCursor() local
606 auto channel = GetInputDataChannelProxy(); GetTextAfterCursor() local
617 auto channel = GetInputDataChannelProxy(); MoveCursor() local
654 auto channel = GetInputDataChannelProxy(); GetEnterKeyType() local
665 auto channel = GetInputDataChannelProxy(); GetInputPattern() local
676 auto channel = GetInputDataChannelProxy(); GetTextIndexAtCursor() local
687 auto channel = GetInputDataChannelProxy(); GetTextConfig() local
781 OnConnectSystemCmd(const sptr<IRemoteObject> &channel, sptr<IRemoteObject> &agent) OnConnectSystemCmd() argument
921 auto channel = GetInputDataChannelProxy(); NotifyPanelStatus() local
976 auto channel = GetInputDataChannelProxy(); HideKeyboard() local
1100 OnClientInactive(const sptr<IRemoteObject> &channel) OnClientInactive() argument
1136 auto channel = GetInputDataChannelProxy(); NotifyKeyboardHeight() local
1167 auto channel = GetInputDataChannelProxy(); SendPrivateCommand() local
1216 auto channel = GetInputDataChannelProxy(); GetCallingWindowInfo() local
[all...]
H A Dinput_method_core_proxy.cpp45 return ITypesUtil::Marshal(data, isBindFromClient, clientInfo, clientInfo.channel); in StartInput()
62 int32_t InputMethodCoreProxy::OnConnectSystemCmd(const sptr<IRemoteObject> &channel, sptr<IRemoteObject> &agent)
65 ON_CONNECT_SYSTEM_CMD, [channel](MessageParcel &data) { return data.WriteRemoteObject(channel); },
90 int32_t InputMethodCoreProxy::StopInput(const sptr<IRemoteObject> &channel)
92 return SendRequest(STOP_INPUT, [&channel](MessageParcel &data) { return ITypesUtil::Marshal(data, channel); });
110 void InputMethodCoreProxy::OnClientInactive(const sptr<IRemoteObject> &channel)
113 ON_CLIENT_INACTIVE, [&channel](MessageParcel &data) { return ITypesUtil::Marshal(data, channel); }, nullpt
[all...]
H A Dinput_method_core_stub.cpp109 sptr<IRemoteObject> channel = nullptr; in StartInputOnRemote() local
110 if (!ITypesUtil::Unmarshal(data, isBindFromClient, clientInfo, clientInfo.channel)) { in StartInputOnRemote()
129 int32_t InputMethodCoreStub::OnConnectSystemCmd(const sptr<IRemoteObject> &channel, sptr<IRemoteObject> &agent) in OnConnectSystemCmd() argument
173 sptr<IRemoteObject> channel = nullptr; in StopInputOnRemote() local
174 if (!ITypesUtil::Unmarshal(data, channel)) { in StopInputOnRemote()
179 auto task = std::make_shared<TaskImsaStopInput>(channel); in StopInputOnRemote()
233 sptr<IRemoteObject> channel = nullptr; in OnClientInactiveOnRemote() local
234 if (!ITypesUtil::Unmarshal(data, channel)) { in OnClientInactiveOnRemote()
239 auto task = std::make_shared<TaskImsaOnClientInactive>(channel); in OnClientInactiveOnRemote()
266 int32_t InputMethodCoreStub::StopInput(const sptr<IRemoteObject> &channel) in StopInput() argument
281 OnClientInactive(const sptr<IRemoteObject> &channel) OnClientInactive() argument
[all...]
/base/security/access_token/services/tokensyncmanager/src/remote/
H A Dsoft_bus_socket_listener.cpp105 // channel create in SoftBusDeviceConnectionListener::OnDeviceOnline->RemoteCommandManager::NotifyDeviceOnline in OnClientBytes()
106 auto channel = RemoteCommandManager::GetInstance().GetExecutorChannel(networkId); in OnClientBytes() local
107 if (channel == nullptr) { in OnClientBytes()
111 channel->HandleDataReceived(socket, static_cast<unsigned char *>(const_cast<void *>(data)), dataLen); in OnClientBytes()
126 // channel create in SoftBusDeviceConnectionListener::OnDeviceOnline->RemoteCommandManager::NotifyDeviceOnline in OnServiceBytes()
127 auto channel = RemoteCommandManager::GetInstance().GetExecutorChannel(networkId); in OnServiceBytes() local
128 if (channel == nullptr) { in OnServiceBytes()
132 channel->HandleDataReceived(socket, static_cast<unsigned char *>(const_cast<void *>(data)), dataLen); in OnServiceBytes()
/base/sensors/sensor/vibration_convert/core/native/src/
H A Dgenerate_vibration_json_file.cpp56 Json::Value channel; in GenerateJsonFile() local
57 channel["Parameters"]["Index"] = 1; in GenerateJsonFile()
58 channel["Pattern"] = pattern; in GenerateJsonFile()
60 channels.append(channel); in GenerateJsonFile()
/base/telephony/core_service/utils/codec/include/
H A Dapdu_command.h46 uint32_t channel = 0; member
51 ApduCommand(int32_t channelId, const ApduData &apduData) : channel(channelId), data(apduData) {} in ApduCommand()
/base/inputmethod/imf/frameworks/native/inputmethod_ability/include/
H A Di_input_method_core.h57 virtual int32_t StopInput(const sptr<IRemoteObject> &channel) = 0;
66 virtual int32_t OnConnectSystemCmd(const sptr<IRemoteObject> &channel, sptr<IRemoteObject> &agent) = 0;
67 virtual void OnClientInactive(const sptr<IRemoteObject> &channel) = 0;
H A Dinput_method_core_proxy.h37 int32_t StopInput(const sptr<IRemoteObject> &channel) override;
46 int32_t OnConnectSystemCmd(const sptr<IRemoteObject> &channel, sptr<IRemoteObject> &agent) override;
47 void OnClientInactive(const sptr<IRemoteObject> &channel) override;
/base/inputmethod/imf/frameworks/native/inputmethod_ability/include/tasks/
H A Dtask_imsa.h44 explicit TaskImsaStopInput(sptr<IRemoteObject> channel) : Task(TASK_TYPE_IMSA_STOP_INPUT) in TaskImsaStopInput() argument
47 InputMethodAbility::GetInstance()->StopInput(channel); in TaskImsaStopInput()
80 explicit TaskImsaOnClientInactive(sptr<IRemoteObject> channel) : Task(TASK_TYPE_IMSA_CLIENT_INACTIVE) in TaskImsaOnClientInactive() argument
83 InputMethodAbility::GetInstance()->OnClientInactive(channel); in TaskImsaOnClientInactive()
92 explicit TaskImsaInitInputCtrlChannel(sptr<IRemoteObject> channel) : Task(TASK_TYPE_IMSA_INIT_INPUT_CTRL_CHANNEL) in TaskImsaInitInputCtrlChannel() argument
95 InputMethodAbility::GetInstance()->OnInitInputControlChannel(channel); in TaskImsaInitInputCtrlChannel()
/base/msdp/device_status/intention/common/channel/include/
H A Dchannel.h83 Sender(std::shared_ptr<Channel<Event>> channel) in Sender() argument
84 : channel_(channel) in Sender()
152 Receiver(std::shared_ptr<Channel<Event>> channel) in Receiver() argument
153 : channel_(channel) in Receiver()
183 std::shared_ptr<Channel<Event>> channel = std::make_shared<Channel<Event>>(); in OpenChannel() local
184 return std::make_pair(Channel<Event>::Sender(channel), Channel<Event>::Receiver(channel)); in OpenChannel()
/base/sensors/sensor/frameworks/native/src/
H A Dfd_listener.cpp33 void FdListener::SetChannel(SensorDataChannel *channel) in SetChannel() argument
35 channel_ = channel; in SetChannel()
/base/web/webview/test/fuzztest/ohos_adapter/audio_adapter/audiorendereradapter_fuzzer/
H A Daudiorenderadapter_fuzzer.cpp38 AudioAdapterChannel channel = AudioAdapterChannel::STEREO; in AudioRendererAdapterFuzzTest() local
59 audioRendererAdapterImpl.GetAudioChannel(channel); in AudioRendererAdapterFuzzTest()

Completed in 12 milliseconds

123