US 2026/0252526 A1 · SYNCHRONIZING DISTRIBUTED DATAFLOW PROGRAMS USING PAIRWISE DATA-DEPENDENCIES

Abstract

Techniques and systems are disclosed for synchronizing distributed dataflow programs using pairwise data-dependencies in a coarse-grained reconfigurable architecture (CGRA). For example, a system may comprise a producer CGR processor (CGRP) of the plurality of CGRPs configured to load producer configuration data for a producer subgraph of a dataflow program, wherein the producer configuration data configures the producer CGRP to execute the producer subgraph. The producer CGRP may be further configured to execute the producer subgraph to determine, during a program state of the dataflow program, whether a stream ready token (SRT) for the program state was received from a consumer CGRP and, in response to receiving the SRT, send first data for the program state to the consumer CGRP.

Claims20

Dependent claims

A system for synchronizing distributed dataflow programs using pairwise data-dependencies in a coarse-grained reconfigurable architecture (CGRA) including a plurality of coarse-grained reconfigurable processors (CGRPs), the system comprising:

a producer CGRP of the plurality of CGRPs configured to:
load producer configuration data for a producer subgraph of a dataflow program, wherein the producer configuration data configures the producer CGRP to execute the producer subgraph;
execute the producer subgraph to:
determine, during a program state of the dataflow program, whether a stream ready token (SRT) for the program state was received from a consumer CGRP;
and
in response to receiving the SRT, send first data for the program state to the consumer CGRP.

3 more elements

A method for synchronizing distributed dataflow programs using pairwise data-dependencies in a coarse-grained reconfigurable architecture (CGRA) comprising a plurality of coarse-grained reconfigurable processors (CGRPs), the method comprising:

loading producer configuration data for a producer subgraph of a dataflow program on a producer CGR processor of the plurality of CGRPs, wherein the producer configuration data configures the producer CGRP to execute the producer subgraph;
executing the producer subgraph to:
determine, during a program state of the dataflow program, by the producer CGRP, whether a stream ready token (SRT) for the program state was received from a consumer CGRP;
and
in response to receiving the SRT, send, by the producer CGRP, first data for the program state to the consumer CGRP.

2 more elements

A non-transitory computer-readable storage medium storing computer program instructions, wherein the computer program instructions, when executed on a processor, implement a method for synchronizing distributed dataflow programs using pairwise data-dependencies in a coarse-grained reconfigurable architecture (CGRA) comprising a plurality of coarse-grained reconfigurable processors (CGRPs), the method comprising:

executing a producer subgraph of a dataflow program on a producer CGRP of the CGRA to:
determine, during a program state of the dataflow program, whether a stream ready token (SRT) for the program state was received by the producer CGRP from a consumer CGRP;
and
in response to receiving the SRT, send first data for the program state to the consumer CGR processor;
executing a consumer subgraph of the dataflow program on the consumer CGRP to:
upon entering the program state, block processing of the consumer subgraph on the consumer CGRP;
send the SRT for the program state to the producer CGRP;
receive the first data from the producer CGRP via the inter-processor stream;
and
in response to receiving the first data, unblock the processing of the consumer subgraph.

7 more elements

Dependencies are inferred from the claim text.

Synchronizing distributed dataflow programs using pairwise data-dependencies

Life of this patent

Synchronizing distributed dataflow programs using pairwise data-dependencies

Life of this patent

Abstract

Claims20