communication.h

Go to the documentation of this file.

/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
 * Distributed under BSD 3-Clause license.                                   *
 * Copyright by The HDF Group.                                               *
 * Copyright by the Illinois Institute of Technology.                        *
 * All rights reserved.                                                      *
 *                                                                           *
 * This file is part of Hermes. The full Hermes copyright notice, including  *
 * terms governing use, modification, and redistribution, is contained in    *
 * the COPYING file, which can be found at the top directory. If you do not  *
 * have access to the file, you may request a copy from help@hdfgroup.org.   *
 * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
 
#ifndef HERMES_COMMUNICATION_H_
#define HERMES_COMMUNICATION_H_
 
#include "hermes_types.h"
#include "memory_management.h"
 
namespace hermes {
 
typedef void (*BarrierFunc)(void *);  
typedef void (*FinalizeFunc)(void *); 
struct CommunicationContext {
  BarrierFunc world_barrier; 
  BarrierFunc sub_barrier;   
  FinalizeFunc finalize;     
  void *state;
  i32 world_proc_id;
  i32 sub_proc_id;
  i32 world_size;
  i32 hermes_size;
  i32 app_size;
  i32 num_nodes;
  i32 node_id;
  ProcessKind proc_kind;
  bool first_on_node;
};
 
size_t InitCommunication(CommunicationContext *comm, Arena *arena,
                         size_t trans_arena_size_per_node,
                         bool is_daemon = false, bool is_adapter = false);
inline void WorldBarrier(CommunicationContext *comm) {
  comm->world_barrier(comm->state);
}
 
inline void SubBarrier(CommunicationContext *comm) {
  comm->sub_barrier(comm->state);
}
 
void *GetAppCommunicator(CommunicationContext *comm);
 
}  // namespace hermes
 
#endif  // HERMES_COMMUNICATION_H_