Source/Packages

Runtime.NativeDataParallel

packages/execution/src/Runtime/NativeDataParallel.alpha

1,529 lines92 declarations70.3 KiBSHA-256 a009e951c1b2

def · lines 608–690

dpWithStarLayout

Full file
The star: capture and release frames and the region checkpoint after the combine storage, then the owner state.
608def dpWithStarLayout =
609  (lambda unrestricted c : Nat .
610    (lambda unrestricted u : Nat .
611      (lambda unrestricted system : (family DataParallelSystem c u) .
612        (lambda unrestricted role : Nat .
613          (lambda unrestricted epoch : Nat .
614            (lambda unrestricted available : Nat .
615              (lambda unrestricted emit : (pi unrestricted layout : (family NativeDataParallelLayout) . (pi unrestricted star : (family NativeDataParallelStarLayout) . Bytes)) .
616                (let unrestricted digest =
617                  (dpIdentityDigest c u system)
618                  in
619                  (let unrestricted placement =
620                    (dpPlacementFor
621                      c
622                      u
623                      system
624                      digest
625                      (constructor DataParallelTopology DataParallelStar)
626                      role)
627                    in
628                    (let unrestricted frames =
629                      (dpPublicationBase c u system placement)
630                      in
631                      (eliminate
632                        StdResult
633                        (lambda unrestricted result : (family StdResult (family RegionFrameLayoutFailure) (family RegionFrameLayout)) .
634                          Bytes)
635                        (planRegionFrameLayout
636                          (dpPublicationIdentity c u system digest 0 1 0)
637                          (dpStateBytes c u system)
638                          512
639                          frames
640                          available)
641                        (branch StdFailure error . b"")
642                        (branch
643                          StdSuccess
644                          capture
645                          .
646                          (eliminate
647                            StdResult
648                            (lambda unrestricted result : (family StdResult (family RegionFrameLayoutFailure) (family RegionFrameLayout)) .
649                              Bytes)
650                            (planRegionFrameLayout
651                              (dpPublicationIdentity c u system digest 1 0 1)
652                              dpWord
653                              512
654                              (frameAlign (frameEnd capture))
655                              available)
656                            (branch StdFailure error . b"")
657                            (branch
658                              StdSuccess
659                              committed
660                              .
661                              (eliminate
662                                StdResult
663                                (lambda unrestricted result : (family StdResult (family NativeCheckpointFailure) (family NativeRegionCheckpoint)) .
664                                  Bytes)
665                                (planNativeRegionCheckpoint
666                                  (dpContext c u system digest)
667                                  (dpRegions c u system)
668                                  (dpPartitions c u system)
669                                  epoch
670                                  (frameAlign (frameEnd committed))
671                                  available
672                                  (dpShardCount c u system))
673                                (branch StdFailure error . b"")
674                                (branch
675                                  StdSuccess
676                                  checkpoint
677                                  .
678                                  (emit
679                                    (constructor
680                                      NativeDataParallelLayout
681                                      NativeDataParallelLayoutOf
682                                      placement
683                                      (nativeRegionEnd checkpoint)
684                                      digest)
685                                    (constructor
686                                      NativeDataParallelStarLayout
687                                      NativeDataParallelStarLayoutOf
688                                      capture
689                                      committed
690                                      checkpoint))))))))))))))))))

The compiler supplied declaration spans and resolved links from this source snapshot. This page does not assert that this file belongs to a checked closure.