| /external/libchrome/ipc/ |
| ipc_fuzzing_tests.cc | 146 void Init(IPC::Sender* s) {
150 IPC::Sender* other_;
297 sender()->Send(msg);
301 sender()->Send(msg);
322 sender()->Send(msg);
326 sender()->Send(msg);
351 sender()->Send(msg);
357 sender()->Send(msg);
|
| ipc_cpu_perftest.cc | 100 void Init(Sender* sender) {
102 sender_ = sender;
193 Sender* sender_ = nullptr;
|
| ipc_channel_proxy.h | 76 class COMPONENT_EXPORT(IPC) ChannelProxy : public Sender {
|
| ipc_logging.cc | 110 void Logging::SetIPCSender(IPC::Sender* sender) {
111 sender_ = sender;
|
| ipc_channel_proxy_unittest.cc | 269 sender()->Send(new WorkerMsg_Quit);
279 IPC::Sender* sender() { return channel_proxy_.get(); } function in class:__anon27700::IPCChannelProxyTest
298 sender()->Send(new TestMsg_Bounce);
299 sender()->Send(new AutomationMsg_Bounce);
302 sender()->Send(new WorkerMsg_Bounce);
324 sender()->Send(new TestMsg_Bounce);
327 sender()->Send(new AutomationMsg_Bounce);
353 sender()->Send(new TestMsg_Bounce);
354 sender()->Send(new AutomationMsg_Bounce)
[all...] |
| ipc_mojo_perftest.cc | 49 void Init(Sender* sender) {
51 sender_ = sender;
115 Sender* sender_;
|
| ipc_sync_channel_unittest.cc | 42 class Worker : public Listener, public Sender {
[all...] |
| /external/syzkaller/dashboard/app/ |
| jobs_test.go | 38 sender := (<-c.emailSink).Sender
39 c.incomingEmail(sender, "#syz upstream\n")
42 sender = (<-c.emailSink).Sender
43 _, extBugID, err := email.RemoveAddrContext(sender)
48 c.incomingEmail(sender, "bla-bla-bla", EmailOptFrom("maintainer@kernel.org"),
51 c.incomingEmail(sender, "#syz test: git://git.git/git.git kernel-branch\n"+patch,
66 c.incomingEmail(sender, "#syz test: repo",
71 c.incomingEmail(sender, "#syz test: repo branch commit"
[all...] |
| reporting_email.go | 421 Sender: from,
446 Sender: from,
|
| util_test.go | 315 from := "default@sender.com"
327 email := fmt.Sprintf(`Sender: %v
|
| /device/linaro/bootloader/edk2/MdeModulePkg/Library/DxeIpIoLib/ |
| DxeIpIoLib.c | 606 @param[in] Sender Pointer to the IP sender.
620 IN IP_IO_IP_PROTOCOL Sender,
747 SndEntry->Ip = Sender;
[all...] |
| /external/zlib/src/contrib/delphi/ |
| ZLib.pas | 53 procedure Progress(Sender: TObject); dynamic;
398 procedure TCustomZLibStream.Progress(Sender: TObject);
400 if Assigned(FOnProgress) then FOnProgress(Sender);
|
| /external/webrtc/webrtc/base/ |
| virtualsocket_unittest.cc | 29 struct Sender : public MessageHandler {
30 Sender(Thread* th, AsyncSocket* s, uint32_t rt)
671 Sender sender(pthMain, send_socket, 80 * 1024);
675 sender.done = true;
712 Sender sender(pthMain, send_socket, 100 * 2 * 1024);
716 sender.done = receiver.done = true;
[all...] |
| /device/linaro/bootloader/edk2/MdeModulePkg/Universal/Network/Udp4Dxe/ |
| Udp4Impl.c | 62 @param[in] Sender Specify a pointer of EFI_IP4_PROTOCOL for sending.
71 IN IP_IO_IP_PROTOCOL Sender,
997 @param[in] Sender Specify a pointer of EFI_IP4_PROTOCOL for sending.
1006 IN IP_IO_IP_PROTOCOL Sender,
[all...] |
| /device/linaro/bootloader/edk2/NetworkPkg/Udp6Dxe/ |
| Udp6Impl.c | 62 @param[in] Sender Specify a EFI_IP6_PROTOCOL for sending.
71 IN IP_IO_IP_PROTOCOL Sender,
981 @param[in] Sender Specify a EFI_IP6_PROTOCOL for sending.
990 IN IP_IO_IP_PROTOCOL Sender,
[all...] |
| /external/webrtc/webrtc/modules/rtp_rtcp/source/ |
| rtcp_sender.cc | 376 If the participant is a sender (we_sent true), the constant C is
433 // This is only saved when we are the sender
619 // * If the sender is an owner of the TMMBN -> send TMMBR
[all...] |
| /external/tensorflow/tensorflow/contrib/verbs/ |
| README.md | 35 2. Non DMAable tensors (CanMemCopy == false) will be serialized to a TensorProto on the sender side, RDMA written to a registered buffer on the receiver side, and then deserialized by the receiver.
42 * **Sender** - The node which sends the tensor.
55 The tensor transfer process is initiated when the receiver requests a tensor. In code it is done by calling **Rendezvous::Recv()** or **Rendezvous::RecvAsync()**. The TensorFlow base implementation handles the case where the requested tensor is located on the same node. The more interesting case where the requested tensor is located on a remote node (receiver != sender) is to be handled in a derivation of the pure virtual **BaseRemoteRendezvous::RecvFromRemoteAsync()**. TensorFlow provides a default GRPC based implementation which comes in the vanilla version but suffers in scalability when running large models. Our RDMA based implementation presumes to be more scalable. HKUST's contrib GDR implementation is more scalable than GRPC, and less scalable than ours, only because we did our evolution based on it.
60 2. Send a **RDMA_MESSAGE_TENSOR_REQUEST** to the sender, containing the address of the destination tensor (result/proxy) for RDMA write.
62 In order to allocate the result and proxy tensors, we need to know the tensor's meta-data, i.e. shape and data-type for DMAable 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 at each step, we store a local meta-data cache per tensor, which will only be update upon changes. 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. The sender is responsible to detect changes in the meta-data, and update the receiver. In order for the sender to know that the meta-data had changed, each **RDMA_MESSAGE_TENSOR_REQUEST** will contain the meta-data that the receiver had grabbed from the local cache. The sender will then compare the meta-data from the message to the tensor's new meta-data.
64 When the sender receives an **RDMA_MESSAGE_TENSOR_REQUEST**, it will create a new **RdmaTensorResponse** object for the given request message, store it in a list of pending responses, and will invoke its **Start()** method. The **Start()** method does the following:
82 When the sender receives a **RDMA_MESSAGE_TENSOR_RE_REQUEST**, it will locate the relevant **RdmaTensorResponse** (…)
[all...] |
| /external/syzkaller/pkg/email/ |
| parser_test.go | 530 {`Sender: syzkaller-bugs@googlegroups.com
|
| /external/syzkaller/vendor/golang.org/x/net/http2/ |
| server.go | [all...] |
