OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:EventLoop
(Results
1 - 11
of
11
) sorted by null
/device/google/cuttlefish_common/guest/commands/vsoc_input_service/
vsoc_input_service.cpp
40
void
EventLoop
(std::shared_ptr<VirtualDeviceBase> device,
89
EventLoop
(
96
EventLoop
(virtual_keyboard_, [](InputEvent* event_buffer, int max_events) {
102
EventLoop
(virtual_power_button_,
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
NettyHandlerTestBase.java
48
import io.netty.channel.
EventLoop
;
128
EventLoop
eventLoop
;
135
public
EventLoop
eventLoop
() {
136
if (
eventLoop
== null) {
139
return
eventLoop
;
143
EventLoop
realEventLoop = super.
eventLoop
();
147
eventLoop
= mock(EventLoop.class, delegatesTo(realEventLoop))
[
all
...]
WriteQueueTest.java
32
import io.netty.channel.
EventLoop
;
72
EventLoop
eventLoop
= Mockito.mock(
EventLoop
.class);
80
}).when(
eventLoop
).execute(any(Runnable.class));
81
when(
eventLoop
.inEventLoop()).thenReturn(true);
82
when(channel.
eventLoop
()).thenReturn(
eventLoop
);
NettyStreamTestBase.java
41
import io.netty.channel.
EventLoop
;
71
protected
EventLoop
eventLoop
;
93
when(channel.
eventLoop
()).thenReturn(
eventLoop
);
102
when(
eventLoop
.inEventLoop()).thenReturn(true);
112
}).when(
eventLoop
).execute(any(Runnable.class));
NettyClientHandlerTest.java
75
import io.netty.channel.
EventLoop
;
171
channel().
eventLoop
(),
515
channel().
eventLoop
(),
524
channel().
eventLoop
(),
760
EventLoop
eventLoop
,
763
super(handler,
eventLoop
, maxMessageSize, StatsTraceContext.NOOP, transportTracer);
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
NettyServerStream.java
33
import io.netty.channel.
EventLoop
;
93
if (channel.
eventLoop
().inEventLoop()) {
97
channel.
eventLoop
().execute(new Runnable() {
159
private final
EventLoop
eventLoop
;
163
EventLoop
eventLoop
,
171
this.
eventLoop
=
eventLoop
;
176
if (
eventLoop
.inEventLoop())
[
all
...]
NettyClientStream.java
41
import io.netty.channel.
EventLoop
;
190
if (channel.
eventLoop
().inEventLoop()) {
194
channel.
eventLoop
().execute(new Runnable() {
213
private final
EventLoop
eventLoop
;
219
EventLoop
eventLoop
,
225
this.
eventLoop
= checkNotNull(
eventLoop
, "
eventLoop
");
[
all
...]
NettyClientTransport.java
48
import io.netty.channel.
EventLoop
;
161
channel.
eventLoop
(),
185
EventLoop
eventLoop
= group.next();
188
new ClientKeepAlivePinger(this),
eventLoop
, keepAliveTimeNanos, keepAliveTimeoutNanos,
207
b.group(
eventLoop
);
326
if (channel.
eventLoop
().inEventLoop()) {
332
channel.
eventLoop
().submit(
352
assert ch.
eventLoop
().inEventLoop();
/external/python/cpython3/Lib/test/test_asyncio/
test_selector_events.py
120
class
EventLoop
(BaseSelectorEventLoop):
126
self.loop =
EventLoop
(self.selector)
[
all
...]
test_base_events.py
797
class
EventLoop
(base_events.BaseEventLoop):
801
loop =
EventLoop
()
[
all
...]
/external/kotlinc/lib/
kotlin-main-kts.jar
Completed in 1649 milliseconds