photon_rndv.h

Go to the documentation of this file.

// =============================================================================
//  Photon RDMA Library (libphoton)
//
//  Copyright (c) 2017, Trustees of Indiana University,
//  All rights reserved.
//
//  This software may be modified and distributed under the terms of the BSD
//  license.  See the COPYING file for details.
//
//  This software was created at the Indiana University Center for Research in
//  Extreme Scale Technologies (CREST).
// =============================================================================

#ifndef PHOTON_RNDV_H
#define PHOTON_RNDV_H

#ifdef __cplusplus
extern "C" {
#endif


  
int photon_post_recv_buffer_rdma(int proc, void *ptr, uint64_t size, int tag, photon_rid *request);

int photon_post_send_buffer_rdma(int proc, void *ptr, uint64_t size, int tag, photon_rid *request);

int photon_post_send_request_rdma(int proc, uint64_t size, int tag, photon_rid *request);

int photon_wait_recv_buffer_rdma(int proc, uint64_t size, int tag, photon_rid *request);

int photon_wait_send_buffer_rdma(int proc, uint64_t size, int tag, photon_rid *request);

int photon_wait_send_request_rdma(int tag);

int photon_post_os_put(photon_rid request, int proc, void *ptr, uint64_t size, int tag, uint64_t r_offset);

int photon_post_os_get(photon_rid request, int proc, void *ptr, uint64_t size, int tag, uint64_t r_offset);

int photon_send_FIN(photon_rid request, int proc, int flags);

int photon_post_os_put_direct(int proc, void *ptr, uint64_t size, photonBuffer rbuf, int flags, photon_rid *request);

int photon_post_os_get_direct(int proc, void *ptr, uint64_t size, photonBuffer rbuf, int flags, photon_rid *request);

//
int photon_test(photon_rid request, int *flag, int *type, photonStatus status);

int photon_probe_ledger(int proc, int *flag, int type, photonStatus status);
  
int photon_wait(photon_rid request);

int photon_wait_any(int *ret_proc, photon_rid *ret_req);

int photon_wait_any_ledger(int *ret_proc, photon_rid *ret_req);

// Vectored one-sided put/get (TBD)
//int photon_post_os_putv_direct(int proc, void *ptr[], uint64_t size[], photonBuffer rbuf[], int nbuf,
//                               int flags, photon_rid *request);
//int photon_post_os_getv_direct(int proc, void *ptr[], uint64_t size[], photonBuffer rbuf[], int nbuf,
//                               int flags, photon_rid *request);

#ifdef __cplusplus
}
#endif

#endif