| /external/tensorflow/tensorflow/contrib/verbs/ |
| patch_notes_verbs_with_0_copies.md | 14 2. Non DMAble tensors (CanMemCopy == false) will be serialized to proto on the sender side, RDMA written to a registered buffer on the receiver side, and then deserialized by the receiver.
15 3. Tensors which are located on a non-RDMA-compatible GPU, will be RDMA written to a registered CPU proxy buffer on the receiver side, and then copied to GPU by the receiver.
27 2. The address of the destination Tensor needs to be sent to the sender side for writing, meaning that the result/proxy tensor should be pre-allocated on the receiver side, prior to sending the tensor request. In order to do that, we need to know its meta-data, i.e. shape and data-type for DMAble tensors, and proto-size for serialized tensors. Unfortunately, this information is only available on the sender side which complicates manners. In order to avoid sending extra messages for querying the meta-data on each step, we store a local meta-data cache per tensor. Based on the assumption that the meta-data of a tensor rarely changes between steps, we expect that on most times the cache will only be updated once. When the sender receives a request for a tensor, if it is the first time this tensor is requested, or in the rare case that the meta-data did change, the sender will first send a meta-data response, on which the receiver will update the local cache, and reallocate the result/proxy tensors if required. When the receiver sends the tensor request, it will contain also the meta-data currently stored in its local cache, so the sender can compare it to see if there was a change.
56 * **RDMA_MESSAGE_TENSOR_REQUEST** - (receiver ==> sender) The original tensor request.
62 * is_dead/data_type/tensor_shape/tensor_bytes - The current meta-data as stored in the receiver local cache. The sender will use that information to know if the receiver's cache requires updating
[all...] |
| /external/webrtc/talk/media/webrtc/ |
| fakewebrtccall.cc | 382 webrtc::PacketReceiver* FakeCall::Receiver() {
398 for (auto receiver : video_receive_streams_) {
399 if (receiver->GetConfig().rtp.remote_ssrc == ssrc)
405 for (auto receiver : audio_receive_streams_) {
406 if (receiver->GetConfig().rtp.remote_ssrc == ssrc) {
407 receiver->IncrementReceivedPackets();
|
| /frameworks/base/services/core/java/com/android/server/connectivity/ |
| Tethering.java | 368 public void startTethering(int type, ResultReceiver receiver, boolean showProvisioningUi) {
370 enableTetheringInternal(type, true, receiver);
375 runUiTetherProvisioningAndEnable(type, receiver);
377 runSilentTetherProvisioningAndEnable(type, receiver);
431 private void enableTetheringInternal(int type, boolean enable, ResultReceiver receiver) {
440 sendTetherResult(receiver, result);
447 sendTetherResult(receiver, result);
450 setBluetoothTethering(enable, receiver);
454 sendTetherResult(receiver, TETHER_ERROR_UNKNOWN_IFACE);
458 private void sendTetherResult(ResultReceiver receiver, int result)
[all...] |
| /frameworks/support/media/src/main/java/androidx/media/ |
| MediaBrowserServiceCompat.java | [all...] |
| /art/runtime/interpreter/ |
| unstarted_runtime.cc | 718 Handle<mirror::Object> receiver = hs.NewHandle(c->AllocObject(self)); local
719 if (receiver == nullptr) {
730 soa.AddLocalReference<jobject>(receiver.Get()));
738 result->SetL(receiver.Get());
[all...] |
| interpreter_common.h | 135 ObjPtr<mirror::Object> receiver = (type == kStatic) local
140 method_idx, &receiver, sf_method, self);
153 jit->InvokeVirtualOrInterface(receiver, sf_method, shadow_frame.GetDexPC(), called_method);
179 ObjPtr<mirror::Object> receiver = local
183 method_idx, &receiver, sf_method, self);
196 jit->InvokeVirtualOrInterface(receiver, sf_method, shadow_frame.GetDexPC(), called_method);
203 self, receiver.Ptr(), sf_method, shadow_frame.GetDexPC(), called_method);
261 ObjPtr<mirror::Object> const receiver = shadow_frame.GetVRegReference(vregC); local
262 if (UNLIKELY(receiver == nullptr)) {
269 CHECK(receiver->GetClass()->ShouldHaveEmbeddedVTable())
[all...] |
| /frameworks/base/core/tests/coretests/src/android/app/ |
| DownloadManagerBaseTest.java | 466 * @return A new receiver that records and can be queried on how many downloads have completed.
469 MultipleDownloadsCompletedReceiver receiver = new MultipleDownloadsCompletedReceiver(); local
470 mContext.registerReceiver(receiver, new IntentFilter(
472 return receiver;
520 WiFiChangedReceiver receiver = new WiFiChangedReceiver(mContext); local
521 mContext.registerReceiver(receiver, new IntentFilter(
524 synchronized (receiver) {
528 while (receiver.getWiFiIsOn() != enable && !timedOut) {
530 receiver.wait(DEFAULT_WAIT_POLL_TIME);
544 assertEquals(enable, receiver.getWiFiIsOn())
[all...] |
| /prebuilts/sdk/current/extras/app-toolkit/m2repository/android/arch/paging/common/28.0.0/ |
| common-28.0.0.jar | |
| /cts/tests/tests/net/src/android/net/cts/ |
| ConnectivityManagerTest.java | 480 fail("Broadcast receiver or NetworkCallback wait was interrupted.");
503 ConnectivityActionReceiver receiver = new ConnectivityActionReceiver( local
505 mContext.registerReceiver(receiver, filter);
522 receiver.waitForState());
524 fail("Broadcast receiver or NetworkCallback wait was interrupted.");
528 mContext.unregisterReceiver(receiver);
609 ConnectivityReceiver receiver = new ConnectivityReceiver(); local
612 mContext.registerReceiver(receiver, filter);
676 ConnectivityActionReceiver receiver = new ConnectivityActionReceiver( local
680 mContext.registerReceiver(receiver, filter)
731 ConnectivityActionReceiver receiver = new ConnectivityActionReceiver( local
[all...] |
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/ |
| ShadowApplication.java | 389 final BroadcastReceiver receiver = wrapper.broadcastReceiver; local
390 final ShadowBroadcastReceiver shReceiver = Shadows.shadowOf(receiver);
395 receiver.setPendingResult(ShadowBroadcastPendingResult.create(0, null, null, false));
530 public Intent registerReceiver(BroadcastReceiver receiver, IntentFilter filter) {
531 return registerReceiverWithContext(receiver, filter, null, null, realApplication);
535 public Intent registerReceiver(BroadcastReceiver receiver, IntentFilter filter, String broadcastPermission, Handler scheduler) {
536 return registerReceiverWithContext(receiver, filter, broadcastPermission, scheduler, realApplication);
539 Intent registerReceiverWithContext(BroadcastReceiver receiver, IntentFilter filter, String broadcastPermission, Handler scheduler, Context context) {
540 if (receiver != null) {
541 registeredReceivers.add(new Wrapper(receiver, filter, context, broadcastPermission, scheduler))
[all...] |
| /prebuilts/go/darwin-x86/test/ |
| method.go | 261 func (C) f() {} // value receiver, direct field of A
262 func (*C) g() {} // pointer receiver
266 func (D) h() {} // value receiver, indirect field of A
267 func (*D) i() {} // pointer receiver
277 // Addressable value receiver.
286 // Non-addressable value receiver.
295 // Pointer receiver.
|
| /prebuilts/go/linux-x86/test/ |
| method.go | 261 func (C) f() {} // value receiver, direct field of A
262 func (*C) g() {} // pointer receiver
266 func (D) h() {} // value receiver, indirect field of A
267 func (*D) i() {} // pointer receiver
277 // Addressable value receiver.
286 // Non-addressable value receiver.
295 // Pointer receiver.
|
| /external/v8/src/wasm/ |
| wasm-js.cc | 512 "Receiver is not a WebAssembly.Table")) {
515 auto receiver = local
518 v8::Number::New(isolate, receiver->current_length()));
531 "Receiver is not a WebAssembly.Table")) {
535 auto receiver = local
537 i::Handle<i::FixedArray> old_array(receiver->functions(), i_isolate);
545 int64_t max_size64 = receiver->maximum_length();
558 i::WasmTableObject::Grow(i_isolate, receiver,
567 receiver->set_functions(*new_array);
585 "Receiver is not a WebAssembly.Table"))
589 auto receiver = local
630 auto receiver = local
671 i::Handle<i::WasmMemoryObject> receiver = local
711 i::Handle<i::WasmMemoryObject> receiver = local
[all...] |
| /cts/hostsidetests/appsecurity/test-apps/IsolatedSplitApp/src/com/android/cts/isolatedsplitapp/ |
| SplitAppTest.java | 145 final ExtrasResultReceiver receiver = sendOrderedBroadcast(context); local
146 final Bundle results = receiver.get();
195 final ExtrasResultReceiver receiver = sendOrderedBroadcast(context); local
196 final Bundle results = receiver.get();
238 final ExtrasResultReceiver receiver = sendOrderedBroadcast(context); local
239 final Bundle results = receiver.get();
|
| /cts/hostsidetests/incident/apps/batterystatsapp/src/com/android/server/cts/device/batterystats/ |
| BatteryStatsBgVsFgActions.java | 331 /** Register receiver to determine when given action is complete. */
334 BroadcastReceiver receiver = new BroadcastReceiver() { local
340 // run Broadcast receiver in a different thread since the foreground activity will wait.
345 ctx.registerReceiver(receiver, intentFilter, null, handler);
346 return receiver;
350 * Uses the receiver to wait until the action is complete. ctx and receiver may be null if no
351 * receiver is needed to be unregistered.
354 int maxWaitTimeMs, CountDownLatch latch, BroadcastReceiver receiver) {
367 if (ctx != null && receiver != null)
[all...] |
| /external/v8/tools/clang/blink_gc_plugin/ |
| DiagnosticsReporter.cpp | 446 RecordInfo* receiver) {
447 ReportMissingDispatch(dispatch, receiver, diag_missing_trace_dispatch_);
452 RecordInfo* receiver) {
453 ReportMissingDispatch(dispatch, receiver, diag_missing_finalize_dispatch_);
458 RecordInfo* receiver,
460 ReportDiagnostic(dispatch->getLocStart(), error) << receiver->record();
|
| /frameworks/base/core/tests/hosttests/test-apps/DownloadManagerTestApp/src/com/android/frameworks/downloadmanagertests/ |
| DownloadManagerBaseTest.java | 113 * Broadcast receiver to listen for broadcast from DownloadManager indicating that downloads
158 * @return Handler for the receiver thread.
263 * @return A new receiver that records and can be queried on how many downloads have completed.
292 WiFiChangedReceiver receiver = new WiFiChangedReceiver(mContext); local
293 mContext.registerReceiver(receiver, new IntentFilter(
296 synchronized (receiver) {
300 while (receiver.getWiFiIsOn() != enable && !timedOut) {
302 receiver.wait(DEFAULT_WAIT_POLL_TIME);
316 assertEquals(enable, receiver.getWiFiIsOn());
|
| /cts/tests/tests/content/src/android/content/cts/ |
| ContextWrapperTest.java | 119 for (BroadcastReceiver receiver : mRegisteredReceiverList) {
120 mContextWrapper.unregisterReceiver(receiver);
126 private void registerBroadcastReceiver(BroadcastReceiver receiver, IntentFilter filter) {
127 mContextWrapper.registerReceiver(receiver, filter);
129 mRegisteredReceiverList.add(receiver);
195 assertTrue("Receiver didn't make any response.", broadcastReceiver.hadReceivedBroadCast());
237 // Send wanted intent(action = MOCK_ACTION1), but the receiver is unregistered.
530 assertTrue("Receiver didn't make any response.", stickyReceiver.hadReceivedBroadCast());
703 final ResultReceiver receiver = new ResultReceiver(); local
705 registerBroadcastReceiver(receiver, new IntentFilter(ResultReceiver.MOCK_ACTION))
718 final ResultReceiver receiver = new ResultReceiver(); local
[all...] |
| /cts/hostsidetests/appsecurity/test-apps/ClassLoaderSplitApp/src/com/android/cts/classloadersplitapp/ |
| SplitAppTest.java | 116 final ExtrasResultReceiver receiver = sendOrderedBroadcast(context); local
117 final Bundle results = receiver.get();
|
| /external/v8/src/debug/ |
| debug-evaluate.cc | 42 Handle<JSObject> receiver(context->global_proxy());
44 return Evaluate(isolate, outer_info, context, receiver, source, false);
77 Handle<JSObject> receiver(context->global_proxy());
79 Evaluate(isolate, context_builder.outer_info(), context, receiver, source,
89 Handle<Context> context, Handle<Object> receiver, Handle<String> source,
103 isolate, result, Execution::Call(isolate, eval_fun, receiver, 0, NULL),
254 !frame_->receiver()->IsTheHole(isolate_)) {
255 recv = handle(frame_->receiver(), isolate_);
|
| /external/v8/src/ |
| execution.h | 24 // Call a function, the caller supplies a receiver and an array
27 // When the function called is not in strict mode, receiver is
31 Isolate* isolate, Handle<Object> callable, Handle<Object> receiver,
53 Handle<Object> receiver, int argc,
|
| string-stream.h | 146 void PrintPrototype(JSFunction* fun, Object* receiver);
149 void PrintFunction(Object* function, Object* receiver, Code** code);
|
| /frameworks/av/packages/MediaComponents/src/com/android/media/ |
| IMediaController2.aidl | 54 void onCustomCommand(in Bundle command, in Bundle args, in ResultReceiver receiver);
|
| /frameworks/base/core/java/android/view/ |
| IWindow.aidl | 46 * command. Any response from the receiver must be sent through the
100 void requestAppKeyboardShortcuts(IResultReceiver receiver, int deviceId);
|
| /frameworks/base/core/java/com/android/internal/statusbar/ |
| IStatusBar.aidl | 144 void showFingerprintDialog(in Bundle bundle, IBiometricPromptReceiver receiver);
|
