struct serialization in C and transfer over MPI

by

Jeremiah is right – MPI_Type_create_struct is the way to go here.

It’s important to remember that MPI is a library, not built into the language; so it can’t “see” what a structure looks like to serialize it by itself. So to send complex data types, you have to explicitly define its layout. In a language that does have native support for serialization, a set of MPI wrappers can concievably make use of that; mpi4py for instance makes use of python’s pickle to transparently send complex data types; but in C, you have to roll up your sleeves and do it yourself.

For your structure, it looks like this:

#include <stdio.h>
#include <stdlib.h>
#include <mpi.h>
#include <stddef.h>

typedef struct car_s {
        int shifts;
        int topSpeed;
} car;

int main(int argc, char **argv) {

    const int tag = 13;
    int size, rank;

    MPI_Init(&argc, &argv);
    MPI_Comm_size(MPI_COMM_WORLD, &size);

    if (size < 2) {
        fprintf(stderr,"Requires at least two processes.\n");
        exit(-1);
    }

    /* create a type for struct car */
    const int nitems=2;
    int          blocklengths[2] = {1,1};
    MPI_Datatype types[2] = {MPI_INT, MPI_INT};
    MPI_Datatype mpi_car_type;
    MPI_Aint     offsets[2];

    offsets[0] = offsetof(car, shifts);
    offsets[1] = offsetof(car, topSpeed);

    MPI_Type_create_struct(nitems, blocklengths, offsets, types, &mpi_car_type);
    MPI_Type_commit(&mpi_car_type);

    MPI_Comm_rank(MPI_COMM_WORLD, &rank);
    if (rank == 0) {
        car send;
        send.shifts = 4;
        send.topSpeed = 100;

        const int dest = 1;
        MPI_Send(&send,   1, mpi_car_type, dest, tag, MPI_COMM_WORLD);

        printf("Rank %d: sent structure car\n", rank);
    }
    if (rank == 1) {
        MPI_Status status;
        const int src=0;

        car recv;

        MPI_Recv(&recv,   1, mpi_car_type, src, tag, MPI_COMM_WORLD, &status);
        printf("Rank %d: Received: shifts = %d topSpeed = %d\n", rank,
                 recv.shifts, recv.topSpeed);
    }

    MPI_Type_free(&mpi_car_type);
    MPI_Finalize();

    return 0;
}

More Related Contents:

  1. Trouble Understanding MPI_Type_create_struct
  2. Access violation reading data from binary file into struct in C
  3. typedef struct vs struct definitions [duplicate]
  4. How to initialize a struct in accordance with C programming language standards
  5. sending blocks of 2D array in C using MPI
  6. Difference between a Structure and a Union
  7. Pointer to pointer of structs indexing out of bounds(?) when I try to index anything other than zero
  8. C – function inside struct
  9. Passing struct to function
  10. C typedef of pointer to structure
  11. Are C-structs with the same members types guaranteed to have the same layout in memory?
  12. Why does “typdef struct { struct S *s; } S;” containing a pointer to same type compile?
  13. Are “malloc(sizeof(struct a *))” and “malloc(sizeof(struct a))” the same?
  14. What does “request for member ‘*******’ in something not a structure or union” mean?
  15. How is the result struct of localtime allocated in C?
  16. How to initialize a structure with flexible array member
  17. memcpy vs assignment in C
  18. How to compile an MPI included c program using cmake
  19. what is the difference between struct {0} and memset 0 [duplicate]
  20. Why declare a struct that only contains an array in C?
  21. How to include a dynamic array INSIDE a struct in C?
  22. Initializing a struct to 0
  23. Anonymous union within struct not in c99?
  24. C Typedef – Incomplete Type
  25. How do you use offsetof() on a struct?
  26. How does C return a structure? [duplicate]
  27. C initialize array within structure
  28. offsetof at compile time
  29. Iterating over same type struct members in C
  30. How can I malloc a struct array inside a function? Code works otherwise

Leave a Comment