| /external/boringssl/src/tool/ |
| transport_common.h | 31 class Listener {
33 Listener() {}
34 ~Listener();
36 // Init initializes the listener to listen on |port|, which should be of the
40 // Accept sets |*out_sock| to be a socket connected to the listener.
46 Listener(const Listener &) = delete;
47 Listener &operator=(const Listener &) = delete;
|
| /external/libchrome/ipc/ |
| message_router.h | 17 // to the correct listener. Routing is based on the Message's routing ID.
23 // find a listener. If a listener is found, then the message is passed to it.
36 class COMPONENT_EXPORT(IPC) MessageRouter : public Listener, public Sender {
44 // Listener implementation:
48 // true if the message was dispatched, or false if there was no listener for
55 // Called to add a listener for a particular message routing ID.
57 bool AddRoute(int32_t routing_id, Listener* listener);
59 // Called to remove a listener for a particular message routing ID
[all...] |
| ipc_listener.h | 21 class COMPONENT_EXPORT(IPC) Listener {
55 virtual ~Listener() {}
|
| /external/tensorflow/tensorflow/stream_executor/ |
| multi_platform_manager.h | 85 // already registered. The associated listener, if not null, will be used to
134 // Interface for a listener that gets notfied at certain events.
135 class Listener {
137 virtual ~Listener() = default;
143 static port::Status RegisterListener(std::unique_ptr<Listener> listener);
155 // Registering a listener:
|
| /cts/tests/tests/media/libmediandkjni/ |
| native_media_source.h | 48 class Listener {
52 virtual ~Listener() = default;
54 virtual Status prepare(std::shared_ptr<Listener> l, std::shared_ptr<ANativeWindow> n) = 0;
64 std::shared_ptr<Listener> mBufListener;
|
| /external/google-fruit/examples/multibindings/ |
| main.cpp | 23 class Listener {
28 class Listener1 : public Listener {
33 std::cout << "Listener 1 notified" << std::endl;
52 class Listener2 : public Listener {
60 writer->write("Listener 2 notified");
69 .addMultibinding<Listener, Listener1>()
70 .addMultibinding<Listener, Listener2>();
75 std::vector<Listener*> listeners = injector.getMultibindings<Listener>();
78 for (Listener* listener : listeners)
[all...] |
| /frameworks/av/media/codec2/faultinjection/ |
| C2ComponentWrapper.h | 44 * A wrapper around the listener class inside C2Component class.
46 class Listener : public C2Component::Listener {
48 explicit Listener(const std::shared_ptr<C2Component::Listener> &listener);
49 virtual ~Listener() = default;
58 std::shared_ptr<C2Component::Listener> mListener;
65 const std::shared_ptr<C2Component::Listener> &listener,
[all...] |
| C2ComponentWrapper.cpp | 61 C2ComponentWrapper::Listener::Listener(
62 const std::shared_ptr<C2Component::Listener> &listener) : mListener(listener) {}
64 void C2ComponentWrapper::Listener::onWorkDone_nb(std::weak_ptr<C2Component> component,
69 void C2ComponentWrapper::Listener::onTripped_nb(std::weak_ptr<C2Component> component,
74 void C2ComponentWrapper::Listener::onError_nb(
83 const std::shared_ptr<C2Component::Listener> &listener, c2_blocking_t mayBlock)
[all...] |
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| ClientCall.java | 43 * <p>There is no interaction between the states on the {@link Listener Listener} and {@link
44 * ClientCall}, i.e., if {@link Listener#onClose Listener.onClose()} is called, it has no bearing on
48 * If {@link #cancel} won the race, {@link Listener#onClose Listener.onClose()} is called with
49 * {@link Status#CANCELLED CANCELLED}. Otherwise, {@link Listener#onClose Listener.onClose()} is
56 * call.start(listener, headers);
60 * // wait for listener.onMessage(
[all...] |
| NameResolver.java | 31 * {@link Listener} to receive continuous updates.
34 * {@link Listener} is responsible for eventually (after an appropriate backoff period) invoking
58 * @param listener used to receive updates on the target
61 public abstract void start(Listener listener);
64 * Stops the resolution. Updates to the Listener will stop.
130 public interface Listener {
143 * Handles an error from the resolver. The listener is responsible for eventually invoking
|
| ServerCall.java | 54 public abstract static class Listener<ReqT> {
96 * {@link Listener#onMessage(Object)}. Once {@code numMessages} have been delivered
104 * @param numMessages the requested number of messages to be delivered to the listener.
146 * <p>If no errors or cancellations are known to have occurred, then a {@link Listener#onComplete}
148 * Listener#onCancel} has been or will be called.
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| ManagedClientTransport.java | 32 * contract defined by {@link #shutdown}, {@link Listener#transportShutdown} and
33 * {@link Listener#transportTerminated}.
41 * <p>Implementations must not call {@code listener} from within {@link #start}; implementations
42 * are expected to notify listener on a separate thread or when the returned {@link Runnable} is
45 * @param listener non-{@code null} listener of transport events
51 Runnable start(Listener listener);
56 * {@link Listener#transportShutdown} callback called), or be transferred off this transport (in
71 interface Listener {
[all...] |
| ConnectivityStateManager.java | 36 private ArrayList<Listener> listeners = new ArrayList<>();
41 * Adds a listener for state change event.
50 Listener stateChangeListener = new Listener(callback, executor);
71 ArrayList<Listener> savedListeners = listeners;
73 for (Listener listener : savedListeners) {
74 listener.runInExecutor();
90 private static final class Listener {
94 Listener(Runnable callback, Executor executor)
[all...] |
| /external/python/cpython2/Lib/multiprocessing/dummy/ |
| connection.py | 35 __all__ = [ 'Client', 'Listener', 'Pipe' ]
43 class Listener(object):
|
| /external/python/cpython3/Lib/multiprocessing/dummy/ |
| connection.py | 10 __all__ = [ 'Client', 'Listener', 'Pipe' ]
18 class Listener(object):
|
| /external/volley/src/main/java/com/android/volley/ |
| Response.java | 27 public interface Listener<T> {
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| Service.java | 42 * therefore every method of the listener will be called at most once. N.B. The {@link State#FAILED}
149 * Registers a {@link Listener} to be {@linkplain Executor#execute executed} on the given
150 * executor. The listener will have the corresponding transition method called whenever the
151 * service changes state. The listener will not have previous state changes replayed, so it is
154 * <p>{@code addListener} guarantees execution ordering across calls to a given listener but not
155 * across calls to multiple listeners. Specifically, a given listener will have its callbacks
157 * one of the listener's callbacks will execute at once. However, multiple listeners' callbacks
161 * <p>RuntimeExceptions thrown by a listener will be caught and logged. Any exception thrown
165 * @param listener the listener to run when the service changes state is complet
[all...] |
| /external/llvm/include/llvm/CodeGen/ |
| MachinePassRegistry.h | 31 /// MachinePassRegistryListener - Listener to adds and removals of nodes in
90 MachinePassRegistryListener* Listener;// Listener for list adds are removes.
103 void setListener(MachinePassRegistryListener *L) { Listener = L; }
|
| /external/swiftshader/third_party/llvm-7.0/llvm/include/llvm/CodeGen/ |
| MachinePassRegistry.h | 31 /// MachinePassRegistryListener - Listener to adds and removals of nodes in
80 MachinePassRegistryListener *Listener; // Listener for list adds are removes.
92 void setListener(MachinePassRegistryListener *L) { Listener = L; }
|
| /frameworks/av/media/libmediaplayerservice/include/ |
| MediaPlayerInterface.h | 74 class Listener : public RefBase {
77 virtual ~Listener() {}
277 const sp<Listener> &listener) {
279 mListener = listener;
284 sp<Listener> listener; local
287 listener = mListener;
290 if (listener != NULL) {
291 listener->notify(msg, ext1, ext2, obj)
[all...] |
| /cts/apps/CtsVerifier/src/com/android/cts/verifier/wifi/ |
| BaseTestCase.java | 35 protected Listener mListener;
98 public void start(Listener listener) {
99 mListener = listener;
152 * Listener interface used to communicate the state and status of the test case. It should
155 public interface Listener {
162 * This function is invoked by the test to send a message to listener.
|
| /cts/apps/CtsVerifier/src/com/android/cts/verifier/wifiaware/ |
| BaseTestCase.java | 33 protected Listener mListener;
81 public void start(Listener listener) {
82 mListener = listener;
134 * Listener interface used to communicate the state and status of the test case. It should
137 public interface Listener {
144 * This function is invoked by the test to send a message to listener.
|
| /cts/tests/tests/telecom/src/android/telecom/cts/ |
| SelfManagedConnection.java | 39 public static abstract class Listener {
44 private final Listener mListener;
46 public SelfManagedConnection(boolean isIncomingCall, Listener listener) {
48 mListener = listener;
|
| /external/icu/tools/srcgen/currysrc/src/main/java/com/google/currysrc/processors/ |
| AddDefaultConstructor.java | 46 private Listener listener; field in class:AddDefaultConstructor
48 public interface Listener {
61 this.listener = (l, typeDeclaration) -> {};
64 public void setListener(Listener listener) {
65 this.listener = listener;
76 listener.onAddDefaultConstructor(typeLocator, typeDeclaration);
|
| /external/python/cpython2/Lib/multiprocessing/ |
| connection.py | 35 __all__ = [ 'Client', 'Listener', 'Pipe' ]
90 return tempfile.mktemp(prefix='listener-', dir=get_temp_dir())
117 class Listener(object):
119 Returns a listener object.
163 Returns a connection to the address of a `Listener`
347 sub_debug('listener created with address=%r', self._address)
376 sub_debug('closing listener with address=%r', address)
467 class XmlListener(Listener):
471 obj = Listener.accept(self)
|
