| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | ActorLazyTest.kt | 15 val actor = actor<String>(start = CoroutineStart.LAZY) { in <lambda>() constant
18 actor as Job // type assertion in <lambda>()
19 assertFalse(actor.isActive) in <lambda>()
20 assertFalse(actor.isCompleted) in <lambda>()
21 assertFalse(actor.isClosedForSend) in <lambda>()
23 yield() // to actor code --> nothing happens (not started!) in <lambda>()
24 assertFalse(actor.isActive) in <lambda>()
25 assertFalse(actor.isCompleted) in <lambda>()
26 assertFalse(actor.isClosedForSend) in <lambda>()
28 // start actor explicitly in <lambda>()
[all …]
|
| D | ActorTest.kt | 26 val actor = actor<String>(capacity = capacity) { in <lambda>() constant
29 actor as Job // type assertion in <lambda>()
30 assertTrue(actor.isActive) in <lambda>()
31 assertFalse(actor.isCompleted) in <lambda>()
32 assertFalse(actor.isClosedForSend) in <lambda>()
34 yield() // to actor code in <lambda>()
35 assertFalse(actor.isActive) in <lambda>()
36 assertTrue(actor.isCompleted) in <lambda>()
37 assertTrue(actor.isClosedForSend) in <lambda>()
44 val actor = actor<String>(capacity = capacity) { in <lambda>() constant
[all …]
|
| D | DoubleChannelCloseStressTest.kt | 16 … val actor = GlobalScope.actor<Int>(CoroutineName("actor"), start = CoroutineStart.LAZY) { in testDoubleCloseStress() constant
21 actor.send(1) in testDoubleCloseStress()
27 actor.close() in testDoubleCloseStress()
|
| D | ProduceConsumeJvmTest.kt | 49 val actor = actor<Int>(capacity = capacity) { in <lambda>() constant
57 actor.send(i) in <lambda>()
59 actor.close() in <lambda>()
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/simulator/ |
| D | simulator.h | 14 #include "quiche/quic/test_tools/simulator/actor.h"
31 // Schedule the specified actor. This method will ensure that |actor| is
33 // before the Actor is called, Act() is called exactly once, at the earliest
34 // time requested, and the Actor has to reschedule itself manually for the
36 void Schedule(Actor* actor, QuicTime new_time);
38 // Remove the specified actor from the schedule.
39 void Unschedule(Actor* actor);
69 friend class Actor;
98 // Register an actor with the simulator. Invoked by Actor constructor.
99 void AddActor(Actor* actor);
[all …]
|
| D | actor.h | 18 // Actor is the base class for all participants of the simulation which can
19 // schedule events to be triggered at the specified time. Every actor has a
22 // The Actor object is scheduled as follows:
23 // 1. Every Actor object appears at most once in the event queue, for one
25 // 2. Actor is scheduled by calling Schedule() method.
28 // 4. Before Act() is called, the Actor is removed from the event queue. Act()
30 class Actor {
32 Actor(Simulator* simulator, std::string name);
33 virtual ~Actor();
35 // Trigger all the events the actor can potentially handle at this point.
[all …]
|
| D | simulator.cc | 25 // Ensure that Actor under run_for_alarm_ is removed before Simulator data in ~Simulator()
41 void Simulator::AddActor(Actor* actor) { in AddActor() argument
43 scheduled_times_.insert(std::make_pair(actor, QuicTime::Infinite())); in AddActor()
44 auto emplace_names_result = actor_names_.insert(actor->name()); in AddActor()
51 void Simulator::RemoveActor(Actor* actor) { in RemoveActor() argument
52 auto scheduled_time_it = scheduled_times_.find(actor); in RemoveActor()
53 auto actor_names_it = actor_names_.find(actor->name()); in RemoveActor()
59 Unschedule(actor); in RemoveActor()
66 void Simulator::Schedule(Actor* actor, QuicTime new_time) { in Schedule() argument
67 auto scheduled_time_it = scheduled_times_.find(actor); in Schedule()
[all …]
|
| D | actor.cc | 5 #include "quiche/quic/test_tools/simulator/actor.h"
12 Actor::Actor(Simulator* simulator, std::string name) in Actor() function in quic::simulator::Actor
19 Actor::~Actor() { simulator_->RemoveActor(this); } in ~Actor()
21 void Actor::Schedule(QuicTime next_tick) { in Schedule()
25 void Actor::Unschedule() { simulator_->Unschedule(this); } in Unschedule()
|
| D | README.md | 11 events has to subclass Actor. Subclassing Actor involves:
13 1. Calling the `Actor::Actor(Simulator*, std::string)` constructor to establish
18 3. Implementing `Act()` method with the relevant logic. The actor will be
25 class LogClock : public Actor {
27 LogClock(Simulator* simulator, std::string name) : Actor(simulator, name) {
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/channels/ |
| D | Actor.kt | 14 * Scope for [actor][GlobalScope.actor] coroutine builder.
62 * A typical usage of the actor builder looks like this:
65 * val c = actor {
66 * // initialize actor's state
71 * // send messages to the actor
74 * // stop the actor when it is no longer needed
80 …* When the inbox channel of the actor is [closed][SendChannel.close] it sends a special "close tok…
81 …* The actor still processes all the messages that were already sent and then "`for (msg in channel…
82 * and the actor completes.
84 …* If the actor needs to be aborted without processing all the messages that were already sent to i…
[all …]
|
| /external/tcpdump/tests/ |
| D | lacp-ev.out | 2 Actor Information TLV (0x01), length 20
12 Actor Information TLV (0x01), length 20
22 Actor Information TLV (0x01), length 20
32 Actor Information TLV (0x01), length 20
42 Actor Information TLV (0x01), length 20
52 Actor Information TLV (0x01), length 20
62 Actor Information TLV (0x01), length 20
72 Actor Information TLV (0x01), length 20
82 Actor Information TLV (0x01), length 20
92 Actor Information TLV (0x01), length 20
[all …]
|
| /external/python/google-api-python-client/docs/dyn/ |
| D | cloudsupport_v2beta.cases.html | 142 …"displayName": "A String", # The name to display for the actor. If not provide…
143 …"email": "A String", # The email address of the actor. If not provided, it is …
144 …uot;googleSupport": True or False, # Output only. Whether the actor is a Google support actor.
178 …"displayName": "A String", # The name to display for the actor. If not provide…
179 …"email": "A String", # The email address of the actor. If not provided, it is …
180 …uot;googleSupport": True or False, # Output only. Whether the actor is a Google support actor.
212 …"displayName": "A String", # The name to display for the actor. If not provide…
213 …"email": "A String", # The email address of the actor. If not provided, it is …
214 …uot;googleSupport": True or False, # Output only. Whether the actor is a Google support actor.
243 …"actor": { # An object containing information about the effective user and authenticated…
[all …]
|
| D | cloudsupport_v2beta.cases.comments.html | 108 …"displayName": "A String", # The name to display for the actor. If not provide…
109 …"email": "A String", # The email address of the actor. If not provided, it is …
110 …uot;googleSupport": True or False, # Output only. Whether the actor is a Google support actor.
129 …"displayName": "A String", # The name to display for the actor. If not provide…
130 …"email": "A String", # The email address of the actor. If not provided, it is …
131 …uot;googleSupport": True or False, # Output only. Whether the actor is a Google support actor.
161 …"displayName": "A String", # The name to display for the actor. If not provide…
162 …"email": "A String", # The email address of the actor. If not provided, it is …
163 …uot;googleSupport": True or False, # Output only. Whether the actor is a Google support actor.
|
| D | cloudsupport_v2beta.attachments.html | 102 …"displayName": "A String", # The name to display for the actor. If not provide…
103 …"email": "A String", # The email address of the actor. If not provided, it is …
104 …uot;googleSupport": True or False, # Output only. Whether the actor is a Google support actor.
125 …"displayName": "A String", # The name to display for the actor. If not provide…
126 …"email": "A String", # The email address of the actor. If not provided, it is …
127 …uot;googleSupport": True or False, # Output only. Whether the actor is a Google support actor.
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/ |
| D | example-sync-07.kt | 32 // This function launches a new counter actor
33 fun CoroutineScope.counterActor() = actor<CounterMsg> { in <lambda>()
34 var counter = 0 // actor state in <lambda>()
44 val counter = counterActor() // create the actor in <lambda>()
50 // send a message to get a counter value from an actor in <lambda>()
54 counter.close() // shutdown the actor in <lambda>()
|
| /external/kotlinx.coroutines/ui/ |
| D | coroutines-guide-ui.md | 219 <!--- INCLUDE .*/example-ui-actor-([0-9]+).kt -->
234 > You can get the full code [here](kotlinx-coroutines-javafx/test/guide/example-ui-actor-01.kt).
260 or otherwise ignore a cancellation signal. A better solution is to use an [actor] for tasks that sh…
265 // launch one actor to handle all events on this node
266 val eventActor = GlobalScope.actor<MouseEvent>(Dispatchers.Main) {
269 // install a listener to offer events to this actor
276 > You can get the full code [here](kotlinx-coroutines-javafx/test/guide/example-ui-actor-02.kt).
278 The key idea that underlies an integration of an actor coroutine and a regular event handler is tha…
279 …rySend] function on [SendChannel] that does not wait. It sends an element to the actor immediately,
283 animation is running. This happens because the actor is busy with an animation and does not receive…
[all …]
|
| /external/jackson-databind/src/test/java/com/fasterxml/jackson/databind/deser/filter/ |
| D | ProblemHandlerLocation1440Test.java | 80 public ActivityEntity actor; field in ProblemHandlerLocation1440Test.Activity
86 …public Activity(@JsonProperty("actor") final ActivityEntity actor, @JsonProperty("object") final A… in Activity() argument
87 this.actor = actor; in Activity()
120 "{'actor': {'id': 'actor_id','type': 'actor_type'," in testIncorrectContext()
136 assertEquals("actor.invalid_1#invalid_1", probs.get(0)); in testIncorrectContext()
|
| /external/cronet/net/url_request/ |
| D | url_request_throttler_simulation_unittest.cc | 68 // - Phase 1 advances every actor's time to a new absolute time.
69 // - Phase 2 asks each actor to perform their action.
72 class Actor { class in net::__anonfeb591090111::DiscreteTimeSimulation
74 virtual ~Actor() = default;
84 // Adds an |actor| to the simulation. The client of the simulation maintains
85 // ownership of |actor| and must ensure its lifetime exceeds that of the
88 void AddActor(Actor* actor) { in AddActor() argument
89 actors_.push_back(actor); in AddActor()
101 for (auto* actor : actors_) { in RunSimulation() local
102 actor->AdvanceTime(now); in RunSimulation()
[all …]
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/akka/ |
| D | PingPongAkkaBenchmark.kt | 7 import akka.actor.*
39 var dispatcher: String = "akka.actor.default-dispatcher"
44 akka.actor.single-thread-dispatcher { in setup()
75 .withDispatcher("akka.actor.$dispatcher")) in runPingPongs()
77 .withDispatcher("akka.actor.$dispatcher")) in runPingPongs()
|
| D | StatefulActorAkkaBenchmark.kt | 7 import akka.actor.*
47 var dispatcher: String = "akka.actor.default-dispatcher"
53 akka.actor.single-thread-dispatcher { in setup()
112 .withDispatcher("akka.actor.$dispatcher")) in createRequestorActors()
121 .withDispatcher("akka.actor.$dispatcher")) in createComputationActors()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/ |
| D | ConcurrentStatefulActorBenchmark.kt | 18 …* Benchmark: single actor fans out requests to all (#cores count) computation actors and then ping…
19 …* Fair benchmark expects that every computation actor will receive exactly N messages, unfair expe…
89 actor<Letter>(capacity = 1024) { in requestorActorUnfair()
101 return@actor in requestorActorUnfair()
115 actor<Letter>(capacity = 1024) { in requestorActorFair()
129 return@actor in requestorActorFair()
|
| /external/angle/doc/img/ |
| D | StateNotificationExample.svg | 11 …actor"><rect x="10" y="20" width="46.953125" height="38.84375" stroke="#000000" fill="#ffffff" sty…
|
| /external/python/google-api-python-client/tests/data/ |
| D | plus.json | 106 "actor": { object
112 "description": "The name of the actor, suitable for display."
116 "description": "The ID of the actor's person resource."
120 "description": "The image representation of the actor.",
124 …"description": "The URL of the actor's profile photo. To re-size the image and crop it to a square…
130 "description": "The link to the actor's Google profile."
163 "actor": { object
165 …mple, when a person reshares an activity), this property specifies the original activity's actor.",
169 "description": "The original actor's name, suitable for display."
173 "description": "ID of the original actor."
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | FailFastOnStartTest.kt | 65 actor<Int>(Dispatchers.Main) { fail() } in <lambda>()
70 val actor = actor<Int>(Dispatchers.Main, start = CoroutineStart.LAZY) { fail() } in <lambda>() constant
71 actor.send(1) in <lambda>()
|
| /external/rust/crates/tokio/tests/ |
| D | sync_mpsc_weak.rs | 138 let actor = MyActor::new(receiver, sender.clone().downgrade()); in actor_weak_sender() localVariable
140 (Self { sender }, actor) in actor_weak_sender()
151 recv.await.expect("Actor task has been killed") in actor_weak_sender()
155 let (handle, mut actor) = MyActorHandle::new(); in actor_weak_sender()
157 let actor_handle = tokio::spawn(async move { actor.run().await }); in actor_weak_sender()
399 let actor = MyActor::new(receiver, sender.clone().downgrade()); in actor_weak_unbounded_sender() localVariable
401 (Self { sender }, actor) in actor_weak_unbounded_sender()
412 recv.await.expect("Actor task has been killed") in actor_weak_unbounded_sender()
416 let (handle, mut actor) = MyActorHandle::new(); in actor_weak_unbounded_sender()
418 let actor_handle = tokio::spawn(async move { actor.run().await }); in actor_weak_unbounded_sender()
|
