Home
last modified time | relevance | path

Searched refs:tx (Results 1 - 15 of 15) sorted by relevance

/base/request/request/services/src/service/client/
H A Dmanager.rs29 tx: UnboundedSender<ClientEvent>,
33 pub(crate) fn new(tx: UnboundedSender<ClientEvent>) -> Self {
34 Self { tx }
38 if self.tx.send(event).is_err() {
62 let (tx, rx) = unbounded_channel();
69 ClientManagerEntry::new(tx)
83 ClientEvent::OpenChannel(pid, tx) => self.handle_open_channel(pid, tx),
84 ClientEvent::Subscribe(tid, pid, uid, token_id, tx) => {
85 self.handle_subscribe(tid, pid, uid, token_id, tx)
[all...]
H A Dmod.rs53 let (tx, rx) = channel::<Result<i32, ErrorCode>>();
54 let event = ClientEvent::OpenChannel(pid, tx);
69 let (tx, rx) = channel::<ErrorCode>();
70 let event = ClientEvent::Subscribe(tid, pid, uid, token_id, tx);
85 let (tx, rx) = channel::<ErrorCode>();
86 let event = ClientEvent::Unsubscribe(tid, tx);
106 let (tx, rx) = channel::<ErrorCode>();
107 let event = ClientEvent::Terminate(pid, tx);
150 let (tx, rx) = unbounded_channel();
167 Some((tx, f
[all...]
/base/request/request/services/src/manage/scheduler/queue/
H A Dkeeper.rs27 tx: UnboundedSender<TaskManagerEvent>,
37 pub(crate) fn new(tx: TaskManagerTx) -> Self {
39 let tx = &tx.tx;
40 let handle = count_down(tx.clone());
42 tx: tx.clone(),
66 tx: self.tx in clone()
[all...]
H A Drunning_task.rs31 tx: TaskManagerTx,
37 pub(crate) fn new(task: Arc<RequestTask>, tx: TaskManagerTx, keeper: SAKeeper) -> Self {
40 tx,
74 self.tx in drop()
82 self.tx in drop()
90 self.tx.send_event(TaskManagerEvent::Task(TaskEvent::Failed( in drop()
99 self.tx in drop()
H A Dmod.rs48 tx: TaskManagerTx,
58 tx: TaskManagerTx,
66 keeper: SAKeeper::new(tx.clone()),
67 tx,
93 let running_task = RunningTask::new(task.clone(), self.tx.clone(), self.keeper.clone());
179 self.tx.send_event(TaskManagerEvent::Task(TaskEvent::Failed(
200 let running_task = RunningTask::new(task.clone(), self.tx.clone(), self.keeper.clone());
/base/request/request/services/src/service/run_count/
H A Dmanager.rs29 tx: UnboundedSender<RunCountEvent>,
33 pub(crate) fn new(tx: UnboundedSender<RunCountEvent>) -> Self {
34 Self { tx }
38 if self.tx.send(event).is_err() {
53 let (tx, rx) = oneshot::channel::<ErrorCode>();
54 let event = RunCountEvent::Subscribe(pid, obj, tx);
60 let (tx, rx) = oneshot::channel::<ErrorCode>();
61 let event = RunCountEvent::Unsubscribe(pid, tx);
82 let (tx, rx) = unbounded_channel();
89 RunCountManagerEntry::new(tx)
[all...]
/base/request/request/services/src/manage/
H A Dtask_manager.rs77 let (tx, rx) = unbounded_channel();
78 let tx = TaskManagerTx::new(tx);
82 registry_account_subscribe(tx.clone());
85 let network = register_network_change(tx.clone());
86 subscribe_notification_bar(tx.clone());
94 AppUninstallSubscriber::new(tx.clone()),
99 let task_manager = Self::new(tx.clone(), rx, runcount_manager, client_manager, network);
114 runtime_spawn(restore_all_tasks(tx.clone()));
116 runtime_spawn(clear_timeout_tasks(tx
[all...]
H A Dquery.rs44 let (info, tx) = match event {
45 QueryEvent::Show(task_id, uid, tx) => {
47 (info, tx)
49 QueryEvent::Query(task_id, action, tx) => {
51 (info, tx)
53 QueryEvent::Touch(task_id, uid, token, tx) => {
55 (info, tx)
58 let _ = tx.send(info);
H A Dmod.rs55 let (tx, rx) = unbounded_channel(); in task_manager()
56 let task_manager_tx = TaskManagerTx::new(tx); in task_manager()
68 let (tx, _rx) = unbounded_channel(); in task_manager()
69 let run_count = RunCountManagerEntry::new(tx); in task_manager()
70 let (tx, _rx) = unbounded_channel(); in task_manager()
71 let client = ClientManagerEntry::new(tx); in task_manager()
H A Daccount.rs284 let (tx, mut rx) = mpsc::unbounded_channel(); in ut_account_check_oh()
285 let task_manager = TaskManagerTx { tx }; in ut_account_check_oh()
302 let (tx, mut rx) = mpsc::unbounded_channel(); in ut_account_update()
303 let task_manager = TaskManagerTx { tx }; in ut_account_update()
H A Dnotifier.rs107 let (tx, rx) = unbounded_channel(); in init_manager()
108 let task_manager_tx = TaskManagerTx::new(tx); in init_manager()
120 let (tx, _rx) = unbounded_channel(); in init_manager()
121 let run_count = RunCountManagerEntry::new(tx); in init_manager()
122 let (tx, client_rx) = unbounded_channel(); in init_manager()
123 let client = ClientManagerEntry::new(tx); in init_manager()
/base/request/request/services/src/manage/events/
H A Dmod.rs49 let (tx, rx) = channel::<Result<u32, ErrorCode>>();
53 tx,
60 let (tx, rx) = channel::<ErrorCode>();
62 Self::Service(ServiceEvent::Pause(uid, task_id, tx)),
68 let (tx, rx) = channel::<ErrorCode>();
70 Self::Service(ServiceEvent::Start(uid, task_id, tx)),
76 let (tx, rx) = channel::<ErrorCode>();
78 Self::Service(ServiceEvent::Stop(uid, task_id, tx)),
84 let (tx, rx) = channel::<ErrorCode>();
86 Self::Service(ServiceEvent::Remove(uid, task_id, tx)),
[all...]
/base/msdp/device_status/tools/vdev/src/
H A Dvirtual_mouse.cpp187 double tx = round(step * static_cast<double>(dx) / delta); in Move() local
190 if ((std::abs(tx) >= STEP_UNIT) && (std::abs(tx) <= MAXIMUM_STEP_LENGTH)) { in Move()
191 SendEvent(EV_REL, REL_X, static_cast<int32_t>(tx)); in Move()
196 if (((std::abs(tx) >= STEP_UNIT) && (std::abs(tx) <= MAXIMUM_STEP_LENGTH)) || in Move()
H A Dvirtual_touchscreen_builder.cpp134 std::cout << " -D <SLOT> <sx> <sy> <tx> <ty> Drag the touch <SLOT> to (tx, ty)" << std::endl; in ShowUsage()
370 int32_t tx = std::atoi(argv[optind + TX_OFFSET]); in ReadDragToAction() local
373 std::cout << "[touchscreen] drag-to: [" << slot << ", (" << tx << "," << ty << ")]" << std::endl; in ReadDragToAction()
377 vTouch->MoveTo(slot, tx, ty); in ReadDragToAction()
/base/request/request/services/src/manage/scheduler/
H A Dmod.rs72 tx: TaskManagerTx,
77 let mut state_handler = state::Handler::new(network.clone(), tx.clone());
89 tx.clone(),
97 task_manager: tx,

Completed in 7 milliseconds