Home
last modified time | relevance | path

Searched refs:qos (Results 1 - 25 of 34) sorted by relevance

12

/base/telephony/call_manager/services/distributed_call/src/transmission/
H A Dclient_session.cpp39 QosTV qos[] = { in Connect() local
40 { .qos = QOS_TYPE_MIN_BW, .value = QOS_MIN_BW }, in Connect()
41 { .qos = QOS_TYPE_MAX_LATENCY, .value = QOS_MAX_LATENCY } in Connect()
43 int32_t ret = BindAsync(socket, qos, sizeof(qos) / sizeof(qos[0]), &listener_); in Connect()
H A Dserver_session.cpp53 QosTV qos[] = { in Create() local
54 { .qos = QOS_TYPE_MIN_BW, .value = QOS_MIN_BW }, in Create()
55 { .qos = QOS_TYPE_MAX_LATENCY, .value = QOS_MAX_LATENCY } in Create()
57 int32_t ret = Listen(socket, qos, sizeof(qos) / sizeof(qos[0]), &listener_); in Create()
/base/request/request/services/src/manage/scheduler/
H A Dmod.rs14 mod qos; modules
20 use qos::Qos;
48 // 待运行的任务优先级队列（scheduler.qos），
62 qos: Qos,
87 qos: Qos::new(),
160 self.qos.start_task(uid, qos_info); in start_inner()
173 if self.qos.remove_task(uid, task_id) {
188 if self.qos.remove_task(uid, task_id) {
198 if self.qos.remove_task(uid, task_id) {
209 if self.qos
[all...]
/base/security/access_token/services/tokensyncmanager/test/mock/include/
H A Dsocket.h155 QosType qos; /**< Qos type {@link QosType} */ member
329 * @param qos[] Indicates the QoS status that we can provide.
333 void (*OnQos)(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount);
354 * @param qos Indicates the QoS requirements for socket. The value cannot be empty.
361 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener);
370 * @param qos Indicates the QoS requirements for socket. The value cannot be empty.
380 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener);
/base/security/device_security_level/test/dslm_unit_test/
H A Ddslm_msg_interface_mock.h48 virtual int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) = 0;
50 virtual int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) = 0;
72 (int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener), (override));
73 MOCK_METHOD(int32_t, Bind, (int32_t socket, const QosTV qos[], uint32_t qosCount,
H A Ddslm_msg_interface_mock.cpp155 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind() argument
158 return interface->Bind(socket, qos, qosCount, listener); in Bind()
170 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen() argument
173 return interface->Listen(socket, qos, qosCount, listener); in Listen()
/base/security/device_security_level/test/dslm_fuzz_test/mock/
H A Dmock.cpp29 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen() argument
/base/hiviewdfx/hiview/plugins/eventlogger/
H A Dactive_key_event.cpp116 ffrt::submit(initSubscribePower, {}, {}, ffrt::task_attr().name("initSubscribePower").qos(ffrt::qos_default)); in Init()
118 ffrt::task_attr().name("initSubscribeOnlyPower").qos(ffrt::qos_default)); in Init()
189 ffrt::submit(hitraceCapture, {}, {}, ffrt::task_attr().name("HitraceCapture").qos(ffrt::qos_user_initiated)); in CombinationKeyHandle()
209 ffrt::task_attr().name("ActiveKeyEvent").qos(ffrt::qos_user_initiated)); in CombinationKeyCallback()
/base/security/access_token/services/tokensyncmanager/include/remote/
H A Dsoft_bus_socket_listener.h35 static void OnQos(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) {}; in OnQos() argument
/base/useriam/user_auth_framework/services/remote_connect/inc/
H A Dsoft_bus_socket_listener.h37 static void OnQos(int32_t socketId, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) {}; in OnQos() argument
H A Dsoft_bus_client_socket.h38 void OnQos(int32_t socketId, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) override;
H A Dsoft_bus_server_socket.h36 void OnQos(int32_t socketId, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) override;
H A Dsoft_bus_manager.h56 void OnQos(int32_t socketId, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) {}; in OnQos() argument
H A Dsoft_bus_base_socket.h67 virtual void OnQos(int32_t socketId, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) = 0;
/base/hiviewdfx/hiview/plugins/event_store/event_export/
H A Devent_export_engine.cpp75 }, {}, {}, ffrt::task_attr().name("dft_export_init").qos(ffrt::qos_default)); in Start()
78 }, { initTaskHandle }, {}, ffrt::task_attr().name("dft_export_start").qos(ffrt::qos_default)); in Start()
114 ffrt::submit(task, {}, {}, ffrt::task_attr().name("dft_event_export").qos(ffrt::qos_default)); in InitAndRunTasks()
/base/security/access_token/services/tokensyncmanager/src/remote/
H A Dsoft_bus_manager.cpp189 // set service qos, no need to regist OnQos now, regist it in ServiceSocketInit()
191 { .qos = QOS_TYPE_MIN_BW, .value = MIN_BW }, in ServiceSocketInit()
192 { .qos = QOS_TYPE_MAX_LATENCY, .value = MAX_LATENCY }, in ServiceSocketInit()
193 { .qos = QOS_TYPE_MIN_LATENCY, .value = MIN_LATENCY }, in ServiceSocketInit()
403 { .qos = QOS_TYPE_MIN_BW, .value = MIN_BW }, in BindService()
404 { .qos = QOS_TYPE_MAX_LATENCY, .value = MAX_LATENCY }, in BindService()
405 { .qos = QOS_TYPE_MIN_LATENCY, .value = MIN_LATENCY }, in BindService()
/base/request/request/services/src/manage/scheduler/queue/
H A Dmod.rs32 use crate::manage::scheduler::qos::{QosChanges, QosDirection};
121 pub(crate) fn reschedule(&mut self, qos: QosChanges, qos_remove_queue: &mut Vec<(u64, u32)>) {
122 if let Some(vec) = qos.download {
125 if let Some(vec) = qos.upload {
/base/security/device_security_level/baselib/msglib/src/standard/
H A Dmessenger_device_socket_manager.c398 {.qos = QOS_TYPE_MIN_BW, .value = 8 * 1024}, in ProcessCreateServer()
399 {.qos = QOS_TYPE_MAX_LATENCY, .value = 10000}, in ProcessCreateServer()
400 {.qos = QOS_TYPE_MIN_LATENCY, .value = 2000}, in ProcessCreateServer()
591 {.qos = QOS_TYPE_MIN_BW, .value = 8 * 1024}, in BindSync()
592 {.qos = QOS_TYPE_MAX_LATENCY, .value = 10000}, in BindSync()
593 {.qos = QOS_TYPE_MIN_LATENCY, .value = 2000}, in BindSync()
594 {.qos = QOS_TYPE_MAX_IDLE_TIMEOUT, .value = 30000}, in BindSync()
/base/useriam/user_auth_framework/services/remote_connect/src/
H A Dsoft_bus_manager.cpp242 { .qos = QOS_TYPE_MIN_BW, .value = MIN_BW }, in ServiceSocketListen()
243 { .qos = QOS_TYPE_MAX_LATENCY, .value = MAX_LATENCY }, in ServiceSocketListen()
244 { .qos = QOS_TYPE_MIN_LATENCY, .value = MIN_LATENCY }, in ServiceSocketListen()
245 { .qos = QOS_TYPE_MAX_WAIT_TIMEOUT, .value = MAX_TIMEOUT }, in ServiceSocketListen()
398 { .qos = QOS_TYPE_MIN_BW, .value = MIN_BW }, in ClientSocketBind()
399 { .qos = QOS_TYPE_MAX_LATENCY, .value = MAX_LATENCY }, in ClientSocketBind()
400 { .qos = QOS_TYPE_MIN_LATENCY, .value = MIN_LATENCY }, in ClientSocketBind()
H A Dsoft_bus_client_socket.cpp58 void ClientSocket::OnQos(int32_t socketId, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) in OnQos() argument
/base/security/access_token/services/accesstokenmanager/main/cpp/src/callback/
H A Dcallback_manager.cpp157 ffrt::submit(callbackSingle, {}, {}, ffrt::task_attr().qos(ffrt::qos_default)); in ExecuteAllCallback()
216 ffrt::task_attr().qos(ffrt::qos_default).name(taskName.c_str())); in ExecuteCallbackAsync()
/base/hiviewdfx/hiview/base/event_store/store/
H A Dsys_event_repeat_guard.cpp155 }, {}, {}, ffrt::task_attr().name("repeat_guard").qos(ffrt::qos_default)); in RegisterListeningUeSwitch()
/base/request/request/services/src/manage/scheduler/state/
H A Dmod.rs20 use super::qos::RssCapacity;
H A Drecorder.rs17 use crate::manage::scheduler::qos::RssCapacity;
/base/msdp/device_status/intention/adapters/dsoftbus_adapter/src/
H A Ddsoftbus_adapter_impl.cpp375 { .qos = QOS_TYPE_MIN_BW, .value = MIN_BW }, in InitSocket()
376 { .qos = QOS_TYPE_MAX_LATENCY, .value = LATENCY }, in InitSocket()
377 { .qos = QOS_TYPE_MIN_LATENCY, .value = LATENCY }, in InitSocket()

Completed in 12 milliseconds

12