CodeQL / Analyze (actions) (push) Canceled after 0s
CodeQL / Analyze (python) (push) Canceled after 0s
pre-commit / pre-commit (push) Canceled after 0s
Multi-Arch CI / setup (push) Canceled after 0s
Publish build_manylinux_x86_64 images / publish_build_manylinux_x86_64 (push) Canceled after 0s
Setup (Multi-Arch) / setup (push) Canceled after 0s
Multi-Arch CI / Linux::${{ fromJSON(needs.setup.outputs.linux_build_config || '{}').build_variant_label || 'skip' }} (push) Canceled after 0s
Publish TheRock Docker image / build-and-push-image (push) Canceled after 0s
Publish no_rocm_image_ubi10 image / publish_no_rocm_image_ubi10 (push) Canceled after 0s
Multi-Arch CI / Windows::${{ fromJSON(needs.setup.outputs.windows_build_config || '{}').build_variant_label || 'skip' }} (push) Canceled after 0s
Publish TheRock Docker image / build-and-push-image (push) Canceled after 0s
Multi-Arch CI / Manifest Diff (push) Canceled after 0s
TheRock Manifest Diff Report / Generate Manifest Diff Report (push) Canceled after 0s
Multi-Arch CI / CI Summary (push) Canceled after 0s
Publish no_rocm_image_ubuntu24_04 images / publish_no_rocm_image_ubuntu24_04 (push) Canceled after 0s
Publish no_rocm_image_ubuntu24_04_ocl_rt images / publish_no_rocm_image_ubuntu24_04_ocl_rt (push) Canceled after 0s
Publish TheRock Docker image / build-and-push-image (push) Canceled after 0s
Publish TheRock Docker image / build-and-push-image (push) Canceled after 0s
Publish no_rocm_image_ubuntu24_04 images / publish_no_rocm_image_ubuntu24_04_rocgdb (push) Canceled after 0s
Publish no_rocm_image_ubuntu24_04_rocgdb images / publish_no_rocm_image_ubuntu24_04_rocgdb (push) Canceled after 0s
Publish no_rocm_image_ubuntu24_04 images / publish_no_rocm_image_ubuntu24_04_ocl_rt (push) Canceled after 0s
Publish TheRock Docker image / build-and-push-image (push) Canceled after 0s
Unit Tests / Unit Tests :: ubuntu-24.04 (push) Canceled after 0s
Unit Tests / Unit Tests :: windows-2022 (push) Canceled after 0s
Publish no_rocm_image_ubuntu24_04 images / publish_no_rocm_image_ubuntu24_04_media (push) Canceled after 0s
Unit Tests / Unit Tests Summary (push) Canceled after 0s
Publish no_rocm_image_ubuntu24_04 images / publish_no_rocm_image_ubuntu24_04_openmpi (push) Canceled after 0s
55 lines
1.6 KiB
C
55 lines
1.6 KiB
C
// Copyright (c) Advanced Micro Devices, Inc.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
#include <shmem.h>
|
|
#include <stdio.h>
|
|
|
|
int
|
|
main(void)
|
|
{
|
|
// 1. Initialize the SHMEM environment
|
|
shmem_init();
|
|
|
|
// 2. Get basic information about my place in the world
|
|
int me = shmem_my_pe(); // my Processing Element (like rank)
|
|
int npes = shmem_n_pes(); // total number of PEs (like size)
|
|
|
|
// Simple output from every process
|
|
printf("Hello from PE %d of %d\n", me, npes);
|
|
|
|
// -------------------------------------------------------------------------
|
|
// A bit more interesting: simple point-to-point communication
|
|
// -------------------------------------------------------------------------
|
|
|
|
// Allocate one integer in the symmetric heap (visible to all PEs)
|
|
int* value = (int*) shmem_malloc(sizeof(int));
|
|
|
|
// Everyone initializes their own slot to their PE number
|
|
*value = me;
|
|
|
|
// Barrier so everyone has written their value
|
|
shmem_barrier_all();
|
|
|
|
// Each PE reads the value from the next PE (with wrap-around)
|
|
int next_pe = (me + 1) % npes;
|
|
int received;
|
|
|
|
// Blocking get from next PE
|
|
shmem_int_get(&received, value, 1, next_pe);
|
|
|
|
printf("PE %d received value %d from PE %d\n", me, received, next_pe);
|
|
|
|
// Optional: make sure remote memory operations are completed
|
|
shmem_quiet();
|
|
|
|
// -------------------------------------------------------------------------
|
|
// Cleanup
|
|
// -------------------------------------------------------------------------
|
|
shmem_free(value);
|
|
|
|
// Finalize SHMEM (required in modern versions)
|
|
shmem_finalize();
|
|
|
|
return 0;
|
|
}
|