| /external/boringssl/src/decrepit/evp/ |
| D | evp_do_all.c | 18 void EVP_CIPHER_do_all_sorted(void (*callback)(const EVP_CIPHER *cipher, in EVP_CIPHER_do_all_sorted()
22 callback(EVP_aes_128_cbc(), "AES-128-CBC", NULL, arg); in EVP_CIPHER_do_all_sorted()
23 callback(EVP_aes_192_cbc(), "AES-192-CBC", NULL, arg); in EVP_CIPHER_do_all_sorted()
24 callback(EVP_aes_256_cbc(), "AES-256-CBC", NULL, arg); in EVP_CIPHER_do_all_sorted()
25 callback(EVP_aes_128_ctr(), "AES-128-CTR", NULL, arg); in EVP_CIPHER_do_all_sorted()
26 callback(EVP_aes_192_ctr(), "AES-192-CTR", NULL, arg); in EVP_CIPHER_do_all_sorted()
27 callback(EVP_aes_256_ctr(), "AES-256-CTR", NULL, arg); in EVP_CIPHER_do_all_sorted()
28 callback(EVP_aes_128_ecb(), "AES-128-ECB", NULL, arg); in EVP_CIPHER_do_all_sorted()
29 callback(EVP_aes_192_ecb(), "AES-192-ECB", NULL, arg); in EVP_CIPHER_do_all_sorted()
30 callback(EVP_aes_256_ecb(), "AES-256-ECB", NULL, arg); in EVP_CIPHER_do_all_sorted()
[all …]
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | queue_op.cc | 53 void QueueOpKernel::ComputeAsync(OpKernelContext* ctx, DoneCallback callback) { in ComputeAsync() argument
57 ctx, LookupResource(ctx, HandleFromInput(ctx, 0), &queue), callback); in ComputeAsync()
60 callback); in ComputeAsync()
62 ComputeAsync(ctx, queue, [callback, queue]() { in ComputeAsync()
64 callback(); in ComputeAsync()
89 DoneCallback callback) { in ComputeAsync() argument
99 OP_REQUIRES_OK_ASYNC(ctx, ctx->MatchSignature(expected_inputs, {}), callback); in ComputeAsync()
104 callback); in ComputeAsync()
109 OP_REQUIRES_OK_ASYNC(ctx, queue->ValidateTuple(tuple), callback); in ComputeAsync()
110 queue->TryEnqueue(tuple, ctx, callback); in ComputeAsync()
[all …]
|
| D | barrier_ops.cc | 91 const DoneCallback& callback) { in TryInsertMany() argument
98 callback); in TryInsertMany()
122 callback); in TryInsertMany()
136 callback); in TryInsertMany()
148 callback); in TryInsertMany()
152 callback(); in TryInsertMany()
170 callback); in TryInsertMany()
183 [this, ctx, callback]() { in TryInsertMany()
185 callback(); in TryInsertMany()
192 CloseQueueLocked(ctx, false, callback); in TryInsertMany()
[all …]
|
| D | fifo_queue.cc | 51 DoneCallback callback) { in TryEnqueue() argument
61 1, callback, ctx, cm, token, in TryEnqueue()
83 callback(); in TryEnqueue()
103 DoneCallback callback) { in TryEnqueueMany() argument
106 callback(); in TryEnqueueMany()
119 batch_size, callback, ctx, cm, token, in TryEnqueueMany()
151 callback(); in TryEnqueueMany()
155 void FIFOQueue::TryDequeue(OpKernelContext* ctx, CallbackWithTuple callback) { in TryDequeue() argument
166 1, [callback]() { callback(Tuple()); }, ctx, cm, token, in TryDequeue()
167 [callback, this](Attempt* attempt) EXCLUSIVE_LOCKS_REQUIRED(mu_) { in TryDequeue()
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/ |
| D | FakeNativeCall.cs | 104 …public void StartUnary(IUnaryResponseClientCallback callback, byte[] payload, WriteFlags writeFlag… in StartUnary() argument
107 UnaryResponseClientCallback = callback; in StartUnary()
116 …public void StartClientStreaming(IUnaryResponseClientCallback callback, MetadataArraySafeHandle me… in StartClientStreaming() argument
119 UnaryResponseClientCallback = callback; in StartClientStreaming()
122 …public void StartServerStreaming(IReceivedStatusOnClientCallback callback, byte[] payload, WriteFl… in StartServerStreaming() argument
125 ReceivedStatusOnClientCallback = callback; in StartServerStreaming()
128 …public void StartDuplexStreaming(IReceivedStatusOnClientCallback callback, MetadataArraySafeHandle… in StartDuplexStreaming() argument
131 ReceivedStatusOnClientCallback = callback; in StartDuplexStreaming()
134 public void StartReceiveMessage(IReceivedMessageCallback callback) in StartReceiveMessage() argument
136 ReceivedMessageCallback = callback; in StartReceiveMessage()
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | DispatcherTest.java | 18 RecordingCallback callback = new RecordingCallback(); field in DispatcherTest
44 client.newCall(newRequest("http://a/1")).enqueue(callback); in enqueuedJobsRunImmediately()
50 client.newCall(newRequest("http://a/1")).enqueue(callback); in maxRequestsEnforced()
51 client.newCall(newRequest("http://a/2")).enqueue(callback); in maxRequestsEnforced()
52 client.newCall(newRequest("http://b/1")).enqueue(callback); in maxRequestsEnforced()
53 client.newCall(newRequest("http://b/2")).enqueue(callback); in maxRequestsEnforced()
59 client.newCall(newRequest("http://a/1")).enqueue(callback); in maxPerHostEnforced()
60 client.newCall(newRequest("http://a/2")).enqueue(callback); in maxPerHostEnforced()
61 client.newCall(newRequest("http://a/3")).enqueue(callback); in maxPerHostEnforced()
67 client.newCall(newRequest("http://a/1")).enqueue(callback); in increasingMaxRequestsPromotesJobsImmediately()
[all …]
|
| /external/autotest/frontend/client/src/autotest/moblab/rpc/ |
| D | MoblabRpcHelper.java | 30 public static void fetchConfigData(final SimpleCallback callback) { in fetchConfigData() argument
34 if (callback != null) in fetchConfigData()
35 callback.doCallback(result); in fetchConfigData()
43 public static void fetchConfigData(final JsonRpcCallback callback) { in fetchConfigData() argument
45 rpcProxy.rpcCall("get_config_values", null, callback); in fetchConfigData()
51 public static void submitConfigData(JSONObject configValues, JsonRpcCallback callback) { in submitConfigData() argument
55 rpcProxy.rpcCall("update_config_handler", params, callback); in submitConfigData()
61 public static void resetConfigData(final JsonRpcCallback callback) { in resetConfigData() argument
63 rpcProxy.rpcCall("reset_config_settings", null, callback); in resetConfigData()
69 public static void rebootMoblab(final JsonRpcCallback callback) { in rebootMoblab() argument
[all …]
|
| /external/libchrome/base/ |
| D | cancelable_callback_unittest.cc | 46 base::Closure callback = cancelable.callback(); in TEST() local
47 callback.Run(); in TEST()
50 callback.Run(); in TEST()
54 callback.Run(); in TEST()
67 base::Closure callback1 = cancelable.callback(); in TEST()
68 base::Closure callback2 = cancelable.callback(); in TEST()
81 base::Closure callback3 = cancelable.callback(); in TEST()
89 base::Closure callback; in TEST() local
95 callback = cancelable.callback(); in TEST()
96 callback.Run(); in TEST()
[all …]
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowRemoteCallbackList.java | 19 final E callback; field in ShadowRemoteCallbackList.Callback
22 Callback(E callback, Object cookie) { in Callback() argument
23 this.callback = callback; in Callback()
29 callbacks.remove(callback.asBinder()); in binderDied()
31 onCallbackDied(callback, cookie); in binderDied()
36 protected boolean register(E callback) { in register() argument
37 return register(callback, null); in register()
41 protected boolean register(E callback, Object cookie) { in register() argument
46 IBinder binder = callback.asBinder(); in register()
48 Callback cb = new Callback(callback, cookie); in register()
[all …]
|
| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowCameraTest.java | 113 TestPreviewCallback callback = new TestPreviewCallback(); in testSetPreviewCallbacks() local
114 assertThat(callback.camera).isNull(); in testSetPreviewCallbacks()
115 assertThat(callback.data).isNull(); in testSetPreviewCallbacks()
117 camera.setPreviewCallback(callback); in testSetPreviewCallbacks()
120 assertThat(callback.camera).isSameAs(camera); in testSetPreviewCallbacks()
121 assertThat(callback.data).isEqualTo("foobar".getBytes(UTF_8)); in testSetPreviewCallbacks()
126 TestPreviewCallback callback = new TestPreviewCallback(); in testSetOneShotPreviewCallbacks() local
127 assertThat(callback.camera).isNull(); in testSetOneShotPreviewCallbacks()
128 assertThat(callback.data).isNull(); in testSetOneShotPreviewCallbacks()
130 camera.setOneShotPreviewCallback(callback); in testSetOneShotPreviewCallbacks()
[all …]
|
| /external/python/cpython3/Lib/test/test_importlib/import_/ |
| D | test_relative_imports.py | 59 def relative_import_test(self, create, globals_, callback): argument
73 callback(global_)
80 def callback(global_): function
86 self.relative_import_test(create, globals_, callback)
92 def callback(global_): function
98 self.relative_import_test(create, globals_, callback)
105 def callback(global_): function
112 self.relative_import_test(create, globals_, callback)
118 def callback(global_): function
122 self.relative_import_test(create, globals_, callback)
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | FutureCallbackTest.java | 40 MockCallback callback = new MockCallback("foo"); in testSameThreadSuccess() local
41 Futures.addCallback(f, callback); in testSameThreadSuccess()
48 MockCallback callback = new MockCallback("foo"); in testExecutorSuccess() local
49 Futures.addCallback(f, callback, ex); in testExecutorSuccess()
58 MockCallback callback = new MockCallback(e); in testSameThreadExecutionException() local
59 Futures.addCallback(f, callback); in testSameThreadExecutionException()
65 FutureCallback<String> callback = in testCancel() local
80 Futures.addCallback(f, callback); in testCancel()
87 MockCallback callback = new MockCallback(error); in testThrowErrorFromGet() local
88 Futures.addCallback(f, callback); in testThrowErrorFromGet()
[all …]
|
| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| D | sync_method_unittest.cc | 83 void PingImpl(const base::Callback<void()>& callback) { in PingImpl() argument
85 callback.Run(); in PingImpl()
88 ping_handler_.Run(callback); in PingImpl()
90 void EchoImpl(int32_t value, const base::Callback<void(int32_t)>& callback) { in EchoImpl() argument
92 callback.Run(value); in EchoImpl()
95 echo_handler_.Run(value, callback); in EchoImpl()
98 const base::Callback<void(int32_t)>& callback) { in AsyncEchoImpl() argument
100 callback.Run(value); in AsyncEchoImpl()
103 async_echo_handler_.Run(value, callback); in AsyncEchoImpl()
128 void Ping(const PingCallback& callback) override { PingImpl(callback); } in Ping() argument
[all …]
|
| D | pickle_unittest.cc | 27 void DoExpectResult(int foo, int bar, const base::Closure& callback, T actual) { in DoExpectResult() argument
30 callback.Run(); in DoExpectResult()
35 const base::Closure& callback) { in ExpectResult() argument
36 return base::Bind(&DoExpectResult<T>, t.foo(), t.bar(), callback); in ExpectResult()
50 void DoExpectEnumResult(T expected, const base::Closure& callback, T actual) { in DoExpectEnumResult() argument
52 callback.Run(); in DoExpectEnumResult()
56 base::Callback<void(T)> ExpectEnumResult(T t, const base::Closure& callback) { in ExpectEnumResult() argument
57 return base::Bind(&DoExpectEnumResult<T>, t, callback); in ExpectEnumResult()
71 void ExpectError(InterfacePtr<T>* proxy, const base::Closure& callback) { in ExpectError() argument
72 proxy->set_connection_error_handler(callback); in ExpectError()
[all …]
|
| /external/autotest/client/site_tests/network_FirewallHolePunch/src/tcpserver/ |
| D | tcp-server.js | 70 TcpServer.getNetworkAddresses=function(callback) { argument
71 chrome.system.network.getNetworkInterfaces(callback);
84 TcpServer.prototype.listen = function(callback) { argument
86 this.callbacks.connect = callback;
211 TcpConnection.prototype.requestSocketInfo = function(callback) { argument
213 this._onSocketInfo.bind(this, callback));
221 TcpConnection.prototype.startListening = function(callback) { argument
222 this.callbacks.recv = callback;
238 TcpConnection.prototype.addDataReceivedListener = function(callback) { argument
241 this.startListening(callback);
[all …]
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientStreamTest.java | 107 SetStreamFactoryRunnable callback = new SetStreamFactoryRunnable(factory); in setUp() local
115 callback, in setUp()
123 callback.setStream(clientStream); in setUp()
155 BidirectionalStream.Callback callback = callbackCaptor.getValue(); in write() local
172 callback.onStreamReady(cronetStream); in write()
180 callback.onWriteCompleted(cronetStream, null, fakeBuffer, false); in write()
181 callback.onWriteCompleted(cronetStream, null, fakeBuffer, false); in write()
182 callback.onWriteCompleted(cronetStream, null, fakeBuffer, false); in write()
183 callback.onWriteCompleted(cronetStream, null, fakeBuffer, false); in write()
184 callback.onWriteCompleted(cronetStream, null, fakeBuffer, false); in write()
[all …]
|
| /external/autotest/client/deps/lansim/src/py/ |
| D | simulator.py | 65 def add_match(self, rule, callback): argument
84 if not callable(callback):
88 self._rules.append((rule, callback))
91 self._rules.append((lambda p: self._dict_rule(rule, p), callback))
96 def add_timeout(self, timeout, callback): argument
107 if not callable(callback):
112 self._events[timestamp] = [callback]
114 self._events[timestamp].append(callback)
117 def remove_timeout(self, callback): argument
131 ev_list.remove(callback)
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | CallSafeHandle.cs | 69 …public void StartUnary(IUnaryResponseClientCallback callback, byte[] payload, WriteFlags writeFlag… in StartUnary() argument
73 …mpletionRegistry.RegisterBatchCompletion(CompletionHandler_IUnaryResponseClientCallback, callback); in StartUnary()
85 …public void StartClientStreaming(IUnaryResponseClientCallback callback, MetadataArraySafeHandle me… in StartClientStreaming() argument
89 …mpletionRegistry.RegisterBatchCompletion(CompletionHandler_IUnaryResponseClientCallback, callback); in StartClientStreaming()
94 …public void StartServerStreaming(IReceivedStatusOnClientCallback callback, byte[] payload, WriteFl… in StartServerStreaming() argument
98 …etionRegistry.RegisterBatchCompletion(CompletionHandler_IReceivedStatusOnClientCallback, callback); in StartServerStreaming()
103 …public void StartDuplexStreaming(IReceivedStatusOnClientCallback callback, MetadataArraySafeHandle… in StartDuplexStreaming() argument
107 …etionRegistry.RegisterBatchCompletion(CompletionHandler_IReceivedStatusOnClientCallback, callback); in StartDuplexStreaming()
112 …public void StartSendMessage(ISendCompletionCallback callback, byte[] payload, WriteFlags writeFla… in StartSendMessage() argument
116 …ue.CompletionRegistry.RegisterBatchCompletion(CompletionHandler_ISendCompletionCallback, callback); in StartSendMessage()
[all …]
|
| D | INativeCall.cs | 70 …void StartUnary(IUnaryResponseClientCallback callback, byte[] payload, WriteFlags writeFlags, Meta… in StartUnary() argument
74 …void StartClientStreaming(IUnaryResponseClientCallback callback, MetadataArraySafeHandle metadataA… in StartClientStreaming() argument
76 …void StartServerStreaming(IReceivedStatusOnClientCallback callback, byte[] payload, WriteFlags wri… in StartServerStreaming() argument
78 …void StartDuplexStreaming(IReceivedStatusOnClientCallback callback, MetadataArraySafeHandle metada… in StartDuplexStreaming() argument
80 void StartReceiveMessage(IReceivedMessageCallback callback); in StartReceiveMessage() argument
82 void StartReceiveInitialMetadata(IReceivedResponseHeadersCallback callback); in StartReceiveInitialMetadata() argument
84 …void StartSendInitialMetadata(ISendCompletionCallback callback, MetadataArraySafeHandle metadataAr… in StartSendInitialMetadata() argument
86 …void StartSendMessage(ISendCompletionCallback callback, byte[] payload, WriteFlags writeFlags, boo… in StartSendMessage() argument
88 void StartSendCloseFromClient(ISendCompletionCallback callback); in StartSendCloseFromClient() argument
90 …void StartSendStatusFromServer(ISendStatusFromServerCompletionCallback callback, Status status, Me… in StartSendStatusFromServer() argument
[all …]
|
| /external/webrtc/webrtc/tools/rtcbot/ |
| D | botmanager.js | 39 createBot_: function (name, botType, callback) { argument
42 return new BrowserBot(name, callback);
45 callback);
52 spawnNewBot: function (name, botType, callback) { argument
54 var bot = this.createBot_(name, botType, callback);
83 var callback = this.pendingConnections_.shift();
84 callback(new WebSocketStream(ws));
99 Bot = function (name, callback) { argument
101 this.onbotready_ = callback;
128 BrowserBot = function (name, callback) { argument
[all …]
|
| /external/libbrillo/brillo/dbus/ |
| D | dbus_param_reader_unittest.cc | 23 auto callback = [&called]() { called = true; }; in TEST() local
24 EXPECT_TRUE(DBusParamReader<false>::Invoke(callback, &reader, nullptr)); in TEST()
34 auto callback = [&called](int param1) { in TEST() local
39 (DBusParamReader<false, int>::Invoke(callback, &reader, nullptr))); in TEST()
52 auto callback = [&called](bool p1, int p2, const VariantDictionary& p3) { in TEST() local
60 callback, &reader, nullptr))); in TEST()
73 auto callback = [&called](bool param1, int param2) { in TEST() local
80 (DBusParamReader<false, bool, int>::Invoke(callback, &reader, &error))); in TEST()
93 auto callback = [&called](bool param1, int param2) { in TEST() local
100 (DBusParamReader<false, bool, int>::Invoke(callback, &reader, &error))); in TEST()
[all …]
|
| /external/autotest/frontend/client/src/autotest/common/ |
| D | XhrJsonRpcProxy.java | 28 protected void sendRequest(JSONObject request, final JsonRpcCallback callback) { in sendRequest() argument
30 requestBuilder.sendRequest(request.toString(), new RpcHandler(callback)); in sendRequest()
34 callback.onError(null); in sendRequest()
42 private JsonRpcCallback callback; field in XhrJsonRpcProxy.RpcHandler
44 public RpcHandler(JsonRpcCallback callback) { in RpcHandler() argument
45 this.callback = callback; in RpcHandler()
51 callback.onError(null); in onError()
63 callback.onError(null); in onResponseReceived()
67 handleResponseText(responseText, callback); in onResponseReceived()
71 private static void handleResponseText(String responseText, JsonRpcCallback callback) { in handleResponseText() argument
[all …]
|
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/ |
| D | WebSocketReaderTest.java | 40 private final WebSocketRecorder callback = new WebSocketRecorder(); field in WebSocketReaderTest
44 private final WebSocketReader serverReader = new WebSocketReader(false, data, callback);
45 private final WebSocketReader clientReader = new WebSocketReader(true, data, callback);
48 callback.assertExhausted(); in tearDown()
120 callback.assertTextMessage("Hello"); in clientSimpleHello()
126 callback.assertTextMessage("Hello"); in serverSimpleHello()
132 callback.assertTextMessage("Hello"); in clientFramePayloadShort()
138 callback.assertTextMessage("Hello"); in clientFramePayloadLong()
155 callback.setNextMessageDelegate(new MessageDelegate() { in serverHelloTwoChunks()
173 callback.assertTextMessage("Hello"); in clientTwoFrameHello()
[all …]
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _channel_connectivity_test.py | 61 callback = _Callback()
64 channel.subscribe(callback.update, try_to_connect=False)
65 first_connectivities = callback.block_until_connectivities_satisfy(bool)
66 channel.subscribe(callback.update, try_to_connect=True)
67 second_connectivities = callback.block_until_connectivities_satisfy(
71 third_connectivities = callback.connectivities()
72 channel.unsubscribe(callback.update)
73 fourth_connectivities = callback.connectivities()
74 channel.unsubscribe(callback.update)
75 fifth_connectivities = callback.connectivities()
[all …]
|
| /external/libchrome/ui/gfx/geometry/mojo/ |
| D | geometry_struct_traits_unittest.cc | 31 void EchoPoint(const Point& p, EchoPointCallback callback) override { in EchoPoint() argument
32 std::move(callback).Run(p); in EchoPoint()
35 void EchoPointF(const PointF& p, EchoPointFCallback callback) override { in EchoPointF() argument
36 std::move(callback).Run(p); in EchoPointF()
39 void EchoSize(const Size& s, EchoSizeCallback callback) override { in EchoSize() argument
40 std::move(callback).Run(s); in EchoSize()
43 void EchoSizeF(const SizeF& s, EchoSizeFCallback callback) override { in EchoSizeF() argument
44 std::move(callback).Run(s); in EchoSizeF()
47 void EchoRect(const Rect& r, EchoRectCallback callback) override { in EchoRect() argument
48 std::move(callback).Run(r); in EchoRect()
[all …]
|