Remote promise and remote future for downstream components to update upstream states

Patent metadata

Field	Value
Publication number	US-12086095-B2
Application number	US-202217862234-A
Country	US
Kind code	B2
Filing date	Jul 11, 2022
Priority date	May 27, 2022
Publication date	Sep 10, 2024
Grant date	Sep 10, 2024

Abstract

Technologies for enabling downstream components to update upstream states in streaming pipelines are described. One method of a first computing device receives a remote promise object assigned to a first serialized object from a second computing device in the data center over a network fabric. The remote promise object uniquely identifies a first contiguous block of the first serialized object stored in a memory associated with the second computing device. The method obtains contents of the first contiguous block and sends contents of a second serialized object back to the second computing device to release the remote promise object.

First claim

What is claimed is:

1. A method comprising:
receiving, by a first computing device in a data center, a remote promise object assigned to a first serialized object from a second computing device in the data center over a network fabric, wherein the remote promise object uniquely identifies a first contiguous block of the first serialized object stored in a memory associated with the second computing device, wherein the remote promise object is released when a second serialized object is provided back to the second computing device;
obtaining contents of the first contiguous block from the memory associated with the second computing device for storage at a memory associated with the first computing device;
sending contents of a second contiguous block of the second serialized object stored in the memory associated with the first computing device to the memory associated with the second computing device; and
sending a message to the second computing device to release the remote promise object responsive to the second serialized object being provided back to the second computing device, wherein the remote promise object comprises a starting address of the first contiguous block, a size of the first contiguous block, a value of a reference count token representing a share of ownership of the first serialized object, a physical machine identifier corresponding to the memory associated with the second computing device, and a remote direct memory access (RDMA) access key.

2. The method of claim 1 , wherein sending the message to the second computing device causes the second computing device to update the value of the reference count token, and wherein the first serialized object is released from the memory associated with the first computing device responsive to the value of the reference count token satisfying a threshold value.

3. The method of claim 1 , wherein a size of the remote promise object is less than the size of the first contiguous block.

4. The method of claim 1 , wherein:
obtaining the contents of the first contiguous block comprises performing, using the remote promise object, an RDMA GET operation to obtain the contents of the first contiguous block from the memory associated with the second computing device for transfer to the memory associated with the first computing device over the network fabric; and
sending the contents of the second contiguous block comprises performing an RDMA put operation to send the contents of the second serialized object from the memory associated with the first computing device to the memory associated with the second computing device over the network fabric.

5. The method of claim 1 , further comprising:
generating a second remote promise object, wherein the second remote promise object is an object that uniquely identifies a third contiguous block of a third serialized object stored in the memory associated with the first computing device, wherein the second remote promise object is released when a fourth serialized object is provided back to the first computing device;
sending the second remote promise object to another computing device in the data center over the network fabric; and
receiving a second message from the other computing device to release the second remote promise object responsive to the fourth serialized object being provided back to the first computing device.

6. The method of claim 5 , wherein the second remote promise object is an object that uniquely identifies a starting address of the third contiguous block, a size of the third contiguous block, a physical machine corresponding to the memory associated with the second computing device, a remote direct memory access (RDMA) access key, and a value of a reference count token representing one or more shares of ownership of the third serialized object, wherein the method further comprises:
updating the value of the reference count token responsive to receiving the second message; and
releasing the remote promise object from the memory associated with the first computing device, responsive to the value of the reference count token satisfying a threshold value.

7. A computing system comprising:
a first computing device; and
a first memory coupled to the first computing device, wherein the first computing device is to:
receive, by a first computing device in a data center, a remote promise object assigned to a first serialized object from a second computing device in the data center over a network fabric, wherein the remote promise object is an object that uniquely identifies a first contiguous block of the first serialized object stored in a second memory associated with the second computing device, wherein the remote promise object is released when a second serialized object is provided back to the second computing device;
obtain contents of the first contiguous block from the second memory for storage at the first memory associated with the first computing device;
send contents of a second contiguous block of the second serialized object stored in the first memory to the second memory; and
send a message to the second computing device to release the remote promise object responsive to the second serialized object being provided back to the second computing device, wherein the remote promise object comprises a starting address of the first contiguous block, a size of the first contiguous block, a value of a reference count token representing a share of ownership of the first serialized object, a physical machine identifier corresponding to the second memory, and a remote direct memory access (RDMA) access key.

8. The computing system of claim 7 , wherein the message being sent to the second computing device causes the second computing device to update the value of the reference count token, and wherein the first serialized object is released from the first memory responsive to the value of the reference count token satisfying a threshold value.

9. The computing system of claim 7 , wherein a size of the remote promise object is less than the size of the first contiguous block.

10. The computing system of claim 7 , wherein:
the first computing device is to obtain the contents of the first contiguous block by performing, using the remote promise object, an RDMA GET operation to obtain the contents of the first contiguous block from the second memory for transfer to the first memory over the network fabric; and
the first computing device is to send the contents of the second contiguous block by performing an RDMA put operation to send the contents of the second serialized object from the first memory to the second memory over the network fabric.

11. The computing system of claim 7 , wherein the first computing device is further to:
generate a second remote promise object, wherein the second remote promise object is an object that uniquely identifies a third contiguous block of a third serialized object stored in the first memory, wherein the second remote promise object is released when a fourth serialized object is provided back to the first computing device;
send the second remote promise object to another computing device in the data center over the network fabric; and
receive a second message from the other computing device to release the second remote promise object responsive to the fourth serialized object being provided back to the first computing device.

12. The computing system of claim 11 , wherein the second remote promise object is an object that uniquely identifies a starting address of the third contiguous block, a size of the third contiguous block, a physical machine corresponding to the first memory, a remote direct memory access (RDMA)

Assignees

• Nvidia Corp

Inventors

• Olson Ryan
• Demoret Michael
• Richardson Bartley

Classifications

• H04L67/025

  for remote control or remote monitoring of applications · CPC title

• G06F9/3004

  to perform operations on memory · CPC title

• H04L67/1097 Primary

  for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS] · CPC title

• G06F15/17331 Primary

  Distributed shared memory [DSM], e.g. remote direct memory access [RDMA] · CPC title