| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | mpsc_test.rs | 35 assert!(tx.send(1).is_ok()); in sdv_unbounded_send_recv_test()
36 assert!(tx.send(2).is_ok()); in sdv_unbounded_send_recv_test()
37 drop(tx); in sdv_unbounded_send_recv_test()
56 drop(tx); in sdv_unbounded_send_recv_drop_test()
72 drop(tx); in sdv_unbounded_send_try_recv_test()
154 drop(tx); in sdv_bounded_try_send_try_recv_test()
195 assert!(tx.is_closed()); in sdv_mpsc_is_closed()
201 assert!(tx.is_closed()); in sdv_mpsc_is_closed()
218 assert!(tx.is_same(&tx)); in sdv_mpsc_is_same()
224 assert!(tx.is_same(&tx)); in sdv_mpsc_is_same()
[all …]
|
| /ohos5.0/base/request/request/services/src/service/client/ |
| H A D | manager.rs | 29 tx: UnboundedSender<ClientEvent>, field
34 Self { tx } in new()
38 if self.tx.send(event).is_err() { in send_event()
62 let (tx, rx) = unbounded_channel(); in init()
69 ClientManagerEntry::new(tx) in init()
83 ClientEvent::OpenChannel(pid, tx) => self.handle_open_channel(pid, tx), in run()
87 ClientEvent::Unsubscribe(tid, tx) => self.handle_unsubscribe(tid, tx), in run()
89 ClientEvent::Terminate(pid, tx) => self.handle_process_terminated(pid, tx), in run()
135 let _ = tx.send(Ok(*fd)); in handle_open_channel()
155 tx: Sender<ErrorCode>, in handle_subscribe()
[all …]
|
| H A D | mod.rs | 53 let (tx, rx) = channel::<Result<i32, ErrorCode>>(); in open_channel()
54 let event = ClientEvent::OpenChannel(pid, tx); in open_channel()
69 let (tx, rx) = channel::<ErrorCode>(); in subscribe()
70 let event = ClientEvent::Subscribe(tid, pid, uid, token_id, tx); in subscribe()
85 let (tx, rx) = channel::<ErrorCode>(); in unsubscribe()
86 let event = ClientEvent::Unsubscribe(tid, tx); in unsubscribe()
106 let (tx, rx) = channel::<ErrorCode>(); in notify_process_terminate()
107 let event = ClientEvent::Terminate(pid, tx); in notify_process_terminate()
150 let (tx, rx) = unbounded_channel(); in constructor()
167 Some((tx, fd)) in constructor()
|
| /ohos5.0/foundation/multimedia/image_framework/frameworks/innerkitsimpl/test/unittest/ |
| H A D | matrix_test.cpp | 40 float tx = 1; variable
57 float tx = 0; variable
74 float tx = 1; variable
91 float tx = 1; variable
108 float tx = 0; variable
125 float tx = 1; variable
159 float tx = 1; variable
177 float tx = 1; variable
230 float tx = 0; variable
249 float tx = 1; variable
[all …]
|
| /ohos5.0/base/request/request/services/src/manage/ |
| H A D | task_manager.rs | 76 let (tx, rx) = unbounded_channel(); in init()
77 let tx = TaskManagerTx::new(tx); in init() localVariable
86 network_manager.tx = Some(tx.clone()); in init()
120 tx in init()
124 tx: TaskManagerTx, in new()
200 ServiceEvent::DumpAll(tx) => { in handle_service_event()
353 Self { tx } in new()
357 if self.tx.send(event).is_err() { in send_event()
388 let (tx, rx) = oneshot::channel(); in show()
395 let (tx, rx) = oneshot::channel(); in query()
[all …]
|
| H A D | network.rs | 50 let tx = network_manager.tx.clone(); in register_network_change() localVariable
54 match tx { in register_network_change()
55 Some(tx) => { in register_network_change()
60 Box::new(NetworkTaskManagerTx { inner: tx.clone() }), in register_network_change()
|
| H A D | query.rs | 44 let (info, tx) = match event { in handle_query_event()
45 QueryEvent::Show(task_id, uid, tx) => { in handle_query_event()
47 (info, tx) in handle_query_event()
49 QueryEvent::Query(task_id, action, tx) => { in handle_query_event()
51 (info, tx) in handle_query_event()
53 QueryEvent::Touch(task_id, uid, token, tx) => { in handle_query_event()
55 (info, tx) in handle_query_event()
58 let _ = tx.send(info); in handle_query_event()
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/queue/ |
| H A D | keeper.rs | 27 tx: UnboundedSender<TaskManagerEvent>, field
37 pub(crate) fn new(tx: TaskManagerTx) -> Self { in new()
39 let tx = &tx.tx; in new() localVariable
40 let handle = count_down(tx.clone()); in new()
42 tx: tx.clone(), in new()
66 tx: self.tx.clone(), in clone()
80 inner.handle = Some(count_down(self.tx.clone())); in drop()
85 fn count_down(tx: UnboundedSender<TaskManagerEvent>) -> JoinHandle<()> { in count_down()
86 runtime_spawn(unload_sa(tx)) in count_down()
89 async fn unload_sa(tx: UnboundedSender<TaskManagerEvent>) { in unload_sa()
[all …]
|
| H A D | running_task.rs | 30 tx: TaskManagerTx, field
36 pub(crate) fn new(task: Arc<RequestTask>, tx: TaskManagerTx, keeper: SAKeeper) -> Self { in new()
39 tx, in new()
73 self.tx in drop()
81 self.tx in drop()
89 self.tx.send_event(TaskManagerEvent::Task(TaskEvent::Failed( in drop()
98 self.tx in drop()
|
| H A D | mod.rs | 47 tx: TaskManagerTx, field
56 tx: TaskManagerTx, in new()
63 keeper: SAKeeper::new(tx.clone()), in new()
64 tx, in new()
89 let running_task = RunningTask::new(task.clone(), self.tx.clone(), self.keeper.clone()); in try_restart()
191 self.tx.send_event(TaskManagerEvent::Task(TaskEvent::Failed( in reschedule_inner()
212 let running_task = RunningTask::new(task.clone(), self.tx.clone(), self.keeper.clone()); in reschedule_inner()
|
| /ohos5.0/base/request/request/services/src/service/run_count/ |
| H A D | manager.rs | 29 tx: UnboundedSender<RunCountEvent>, field
34 Self { tx } in new()
38 if self.tx.send(event).is_err() { in send_event()
53 let (tx, rx) = oneshot::channel::<ErrorCode>(); in subscribe_run_count()
82 let (tx, rx) = unbounded_channel(); in init()
89 RunCountManagerEntry::new(tx) in init()
104 RunCountEvent::Subscribe(pid, obj, tx) => self.subscribe_run_count(pid, obj, tx), in run()
105 RunCountEvent::Unsubscribe(pid, tx) => self.unsubscribe_run_count(pid, tx), in run()
121 let _ = tx.send(ErrorCode::ErrOk); in subscribe_run_count()
126 let _ = tx.send(ErrorCode::ErrOk); in unsubscribe_run_count()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | watch.rs | 54 let tx = Sender { in channel() localVariable
61 (tx, rx) in channel()
592 let (tx, mut rx) = watch::channel("hello"); in send_try_notified()
594 assert!(tx.send("world").is_ok()); in send_try_notified()
598 drop(tx); in send_try_notified()
613 let (tx, mut rx) = watch::channel("hello"); in send_notified_await()
614 assert!(tx.send("world").is_ok()); in send_notified_await()
615 drop(tx); in send_notified_await()
636 assert!(tx.send("world").is_ok()); in send_borrow_notify()
654 let (tx, rx) = watch::channel("hello"); in receiver_count()
[all …]
|
| H A D | oneshot.rs | 86 let tx = Sender { in channel() localVariable
90 (tx, rx) in channel()
477 let (tx, mut rx) = oneshot::channel(); in send_try_recv()
479 tx.send("hello").unwrap(); in send_try_recv()
494 let (tx, rx) = oneshot::channel(); in send_recv_await()
495 if tx.send(6).is_err() { in send_recv_await()
517 let (tx, mut rx) = oneshot::channel(); in close_rx()
518 assert!(!tx.is_closed()); in close_rx()
521 assert!(tx.is_closed()); in close_rx()
524 let (tx, mut rx) = oneshot::channel(); in close_rx()
[all …]
|
| /ohos5.0/base/request/request/services/src/manage/events/ |
| H A D | mod.rs | 49 let (tx, rx) = channel::<Result<u32, ErrorCode>>(); in construct()
53 tx, in construct()
60 let (tx, rx) = channel::<ErrorCode>(); in pause()
68 let (tx, rx) = channel::<ErrorCode>(); in start()
76 let (tx, rx) = channel::<ErrorCode>(); in stop()
84 let (tx, rx) = channel::<ErrorCode>(); in remove()
92 let (tx, rx) = channel::<ErrorCode>(); in resume()
100 let (tx, rx) = channel::<DumpAllInfo>(); in dump_all()
105 let (tx, rx) = channel::<Option<DumpOneInfo>>(); in dump_one()
107 Self::Service(ServiceEvent::DumpOne(task_id, tx)), in dump_one()
[all …]
|
| /ohos5.0/foundation/graphic/graphic_utils_lite/interfaces/kits/gfx_utils/diagram/spancolorfill/ |
| H A D | fill_interpolator.h | 99 float tx; in Begin() local
102 tx = x; in Begin()
105 transType_->Transform(&tx, &ty); in Begin()
106 int32_t x1 = MATH_ROUND32(tx * SUBPIXEL_SCALE); in Begin()
109 tx = x + len; in Begin()
111 transType_->Transform(&tx, &ty); in Begin()
112 int32_t x2 = MATH_ROUND32(tx * SUBPIXEL_SCALE); in Begin()
|
| /ohos5.0/drivers/hdf_core/framework/test/unittest/platform/virtual/ |
| H A D | spi_virtual.c | 127 static bool VirtualSpiWriteFifo(struct VirtualSpi *virtual, const uint8_t *tx, uint32_t count) in VirtualSpiWriteFifo() argument
138 if (tx != NULL) { in VirtualSpiWriteFifo()
139 value = (bytes == ONE_BYTE) ? *tx : *((uint16_t *)tx); in VirtualSpiWriteFifo()
140 tx += bytes; in VirtualSpiWriteFifo()
182 const uint8_t *tx = msg->wbuf; in VirtualSpiTxRx() local
186 if (tx == NULL && rx == NULL) { in VirtualSpiTxRx()
192 if (!VirtualSpiWriteFifo(virtual, tx, tmpLen)) { in VirtualSpiTxRx()
196 tx = (tx == NULL) ? NULL : (tx + tmpLen); in VirtualSpiTxRx()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | async_pool.rs | 765 let (tx, rx) = channel(); in ut_executor_mng_info_cancel()
767 let (flag_clone, tx) = (flag.clone(), tx); in ut_executor_mng_info_cancel()
774 tx.send(()).unwrap() in ut_executor_mng_info_cancel()
796 let (flag_clone, tx) = (flag.clone(), tx); in ut_executor_mng_info_wake_up_all()
804 tx.send(()).unwrap() in ut_executor_mng_info_wake_up_all()
835 let (flag_clone, tx) = (flag.clone(), tx); in ut_executor_mng_info_wake_up_rand_one()
841 tx.send(()).unwrap() in ut_executor_mng_info_wake_up_rand_one()
871 let (flag_clone, tx) = (flag.clone(), tx); in ut_executor_mng_info_wake_up_if_one_task_left()
877 tx.send(()).unwrap() in ut_executor_mng_info_wake_up_if_one_task_left()
915 let (flag_clone, tx) = (flag.clone(), tx); in ut_executor_mng_info_from_woken_to_sleep()
[all …]
|
| /ohos5.0/foundation/multimedia/image_framework/frameworks/innerkitsimpl/converter/src/ |
| H A D | matrix.cpp | 35 Matrix &Matrix::SetTranslate(const float tx, const float ty) in SetTranslate() argument
37 *this = Matrix(1, 0, tx, 0, 1, ty, 0, 1, 1, (tx == 0 || ty == 0) ? IDENTITY : TRANSLATE); in SetTranslate()
119 void Matrix::SetTranslateAndScale(const float tx, const float ty, const float sx, const float sy) in SetTranslateAndScale() argument
123 fMat_[IMAGE_TRANSX] = tx; in SetTranslateAndScale()
135 if (tx != 0 || ty != 0) { in SetTranslateAndScale()
219 void Matrix::TransXY(const Matrix &m, const float tx, const float ty, Point &pt) in TransXY() argument
222 pt.x = tx + m.fMat_[IMAGE_TRANSX]; in TransXY()
|
| /ohos5.0/foundation/multimedia/image_framework/frameworks/innerkitsimpl/converter/include/ |
| H A D | matrix.h | 108 …constexpr Matrix(float sx, float kx, float tx, float ky, float sy, float ty, float p0, float p1, f… in Matrix() argument
110 : fMat_ { sx, kx, tx, ky, sy, ty, p0, p1, p2 }, operType_(operType) {} in Matrix()
121 Matrix &SetTranslate(const float tx, const float ty);
135 void SetTranslateAndScale(const float tx, const float ty, const float sx, const float sy);
141 static void TransXY(const Matrix &m, const float tx, const float sy, Point &pt);
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/core/components/shape/ |
| H A D | rosen_render_shape_container.cpp | 58 double tx = GetLayoutSize().Width() * 0.5 - (viewBoxWidth * 0.5 + viewBoxLeft) * scale; in PerformLayout() local
67 rsNode->SetTranslate({ tx, ty }); in PerformLayout()
93 double tx = GetLayoutSize().Width() * 0.5 - (viewBoxWidth * 0.5 + viewBoxLeft) * scale; in Paint() local
96 skOffCanvas_->translate(tx, ty); in Paint()
127 double tx = GetLayoutSize().Width() * 0.5 - (viewBoxWidth * 0.5 + viewBoxLeft) * scale; in Paint() local
130 tmpCanvas->Translate(tx, ty); in Paint()
219 double tx = GetLayoutSize().Width() * 0.5 - (viewBoxWidth * 0.5 + viewBoxLeft) * scale; in BitmapMesh() local
223 skOffCanvas_->translate(tx, ty); in BitmapMesh()
226 offCanvas_->Translate(tx, ty); in BitmapMesh()
|
| /ohos5.0/base/msdp/device_status/tools/vdev/src/ |
| H A D | virtual_mouse.cpp | 187 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()
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/l2cap/ |
| H A D | l2cap_core.c | 533 L2capErfcTxPacket *tx = NULL; in L2capProcessRxReqSeq() local
577 PacketFree(tx->pkt); in L2capProcessRxReqSeq()
578 L2capFree(tx); in L2capProcessRxReqSeq()
589 L2capErfcTxPacket *tx = NULL; in L2capErfcTxOneFrame() local
765 L2capErfcTxPacket *tx = NULL; in L2capErfcDoTx() local
783 L2capAddCrc(tx->pkt); in L2capErfcDoTx()
786 tx->retryCount += 1; in L2capErfcDoTx()
813 L2capErfcTxPacket *tx = NULL; in L2capErfcTx() local
924 if (tx == NULL) { in L2capAddNewPacket()
927 tx->pkt = pkt; in L2capAddNewPacket()
[all …]
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/test/2d_graphics/fuzztest/draw/rsxform_fuzzer/ |
| H A D | rs_xform_fuzzer.cpp | 38 scalar tx = GetObject<scalar>(); in RsXformFuzzTest() local
40 RSXform::Make(cos, sin, tx, ty); in RsXformFuzzTest()
|
| /ohos5.0/foundation/graphic/graphic_surface/surface/src/ |
| H A D | surface_utils.cpp | 166 float tx = 0.f; in ComputeTransformMatrix() local
177 tx = (float(crop.x) / bufferWidth); in ComputeTransformMatrix()
187 …std::array<float, MATRIX_ARRAY_SIZE> cropMatrix = {sx, 0, 0, 0, 0, sy, 0, 0, 0, 0, 1, 0, tx, ty, 0… in ComputeTransformMatrix()
254 float tx = 0.f; in ComputeTransformMatrixV2() local
275 tx = (float(crop.x) / bufferWidth); in ComputeTransformMatrixV2()
285 …std::array<float, MATRIX_ARRAY_SIZE> cropMatrix = {sx, 0, 0, 0, 0, sy, 0, 0, 0, 0, 1, 0, tx, ty, 0… in ComputeTransformMatrixV2()
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/include/text/ |
| H A D | rs_xform.h | 29 static RSXform Make(scalar cos, scalar sin, scalar tx, scalar ty) in Make()
31 RSXform xform = { cos, sin, tx, ty }; in Make()
|