nm_onesided_private.h

Go to the documentation of this file.

/*
 * NewMadeleine
 * Copyright (C) 2006-2022 (see AUTHORS file)
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or (at
 * your option) any later version.
 *
 * This program is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * General Public License for more details.
 */
 
#ifndef NM_ONESIDED_PRIVATE_H
#define NM_ONESIDED_PRIVATE_H
 
#include <nm_sendrecv_interface.h>
 
#include <stdint.h>
 
typedef uint32_t nm_onesided_flag_t;
 
#define NM_ONESIDED_OP_PUT                 ((nm_onesided_flag_t)0x01)
#define NM_ONESIDED_OP_GET                 ((nm_onesided_flag_t)0x02)
#define NM_ONESIDED_OP_FENCE               ((nm_onesided_flag_t)0x03)
#define NM_ONESIDED_OP_QUEUE               ((nm_onesided_flag_t)0x04)
#define NM_ONESIDED_OP_MASK                ((nm_onesided_flag_t)0x0F)
#define NM_ONESIDED_FLAG_TARGET_COMPLETION ((nm_onesided_flag_t)0x10)
 
 
struct nm_onesided_header_s
{
  uintptr_t addr;            
  nm_len_t size;             
  nm_onesided_flag_t flags;
  nm_seq_t seq;              
  uint8_t target_size;       
} __attribute__((packed));
 
struct nm_onesided_request_s
{
  nm_sr_request_t sr_req;
  struct nm_onesided_header_s header;
  struct nm_data_s user_data;
  struct nm_data_s target_data;
};
 
PUK_ALLOCATOR_TYPE(nm_sr_req, nm_sr_request_t);
 
struct nm_onesided_target_request_s
{
  nm_sr_request_t local_req;  
  nm_len_t size;              
  nm_onesided_flag_t op;      
  uintptr_t addr;             
};
 
#define NM_ONESIDED_TARGET_COMPLETION_MAX 64
 
struct nm_onesided_target_completion_s
{
  struct nm_onesided_s*p_onesided;
  nm_len_t op_size;           
  nm_onesided_flag_t op;      
  uintptr_t addr;             
  nm_len_t target_size;       
  char target_buf[NM_ONESIDED_TARGET_COMPLETION_MAX]; 
};
 
PUK_ALLOCATOR_TYPE(nm_onesided_target_completion, struct nm_onesided_target_completion_s);
 
PUK_DLFQ_TYPE(nm_onesided_queue_entry, void*, NULL);
PUK_VECT_TYPE(nm_onesided_queue, struct nm_onesided_queue_entry_dlfq_s*);
 
struct nm_onesided_s
{
  nm_session_t p_session;
  struct nm_onesided_request_s request; 
  struct nm_onesided_target_completion_s*p_target; 
  struct nm_data_s data; 
  nm_sr_req_allocator_t req_allocator;
  nm_onesided_target_completion_allocator_t completion_allocator;
  struct nm_onesided_queue_vect_s queues;
  int running;
  nm_cond_status_t done;
};
 
#endif /* NM_ONESIDED_PRIVATE_H */