nm_core.h

Go to the documentation of this file.

/*
 * NewMadeleine
 * Copyright (C) 2006-2026 (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_CORE_H
#define NM_CORE_H
 
#ifndef NM_PRIVATE_H
#  error "Cannot include this file directly. Please include <nm_private.h>"
#endif
 
#ifndef PIOMAN
#include <pthread.h>
#endif
 
#ifdef PIOMAN_MULTITHREAD
PUK_LFQUEUE_TYPE(nm_core_task, struct nm_core_task_s*, NULL, NM_CORE_TASK_QUEUE_SIZE);
#else /* PIOMAN_MULTITHREAD */
PUK_LFQUEUE_NOTHREAD_TYPE(nm_core_task, struct nm_core_task_s*, NULL, NM_CORE_TASK_QUEUE_SIZE);
#endif /* PIOMAN_MULTITHREAD */
 
struct nm_core
{
  nm_spinlock_t lock;                            
  nm_thread_level_t thread_level;
 
#ifdef PIOMAN
  piom_ltask_t ltask;                            
#else /* PIOMAN */
  /* if PIOMan is enabled, it already manages a list of pw to poll */
  struct nm_pw_poll_list_s pw_poll_list;         
  struct nm_core_pollable_list_s poll_list;      
#endif /* PIOMAN */
  struct nm_pkt_wrap_list_s prefetch_large_send; 
#ifdef NMAD_HWLOC
  hwloc_topology_t topology;
#endif /* NMAD_HWLOC */
 
  puk_component_t strategy_component;              
  puk_context_t strategy_context;                  
  const struct nm_strategy_iface_s*strategy_iface; 
  struct nm_gate_list_s gate_list;              
  struct nm_drv_list_s driver_list;             
  int nb_drivers;                               
  struct nm_core_task_lfqueue_s pending_tasks;     
  struct nm_req_chunk_allocator_s req_chunk_allocator;   
  struct nm_ctrl_chunk_allocator_s ctrl_chunk_allocator; 
  uint64_t unpack_seq;                             
  int n_packs, n_unpacks;                          
  struct nm_matching_tag_table_s tag_table;        
  struct nm_matching_wildcard_table_s wildcard_table; 
  struct nm_core_monitor_vect_s monitors;          
  struct nm_active_gate_list_s active_gates;       
  struct nm_trk_hashtable_s trk_table;             
  struct nm_core_dispatching_event_lfqueue_s dispatching_events; 
  struct nm_core_dispatching_event_allocator_s dispatching_event_allocator; 
  nm_spinlock_t dispatching_lock;                  
  bool running;                                 
  int enable_schedopt;                          
  int enable_auto_flush;                        
  int enable_isend_csum;                        
  int enable_pwsend_timeout;
  int enable_send_prefetch;                     
  int enable_recv_prefetch;                     
  int enable_gpu_support;                       
#ifdef NMAD_PROFILE
  puk_tick_t time_orig;
  struct
  {
    unsigned long long n_locks;
    unsigned long long n_schedule;
    unsigned long long n_packs;
    unsigned long long n_unpacks;
    unsigned long long n_core_tasks;
    unsigned long long n_unexpected;
    unsigned long long n_rdvs;
    unsigned long long n_rdvs_accept_small;
    unsigned long long n_rdvs_accept_single;
    unsigned long long n_rdvs_accept_split;
    unsigned long long n_pw_split;
    unsigned long long n_pw_out;
    unsigned long long n_pw_in;
    unsigned long long n_strat_schedule;
    unsigned long long n_outoforder_event;
    unsigned long long n_event_queue_full;
    unsigned long long n_packs_partitioned;
    unsigned long long n_send_data_copy;
    unsigned long long n_recv_data_copy;
    unsigned long max_unpacks;
    unsigned long max_packs;
    unsigned long long n_memory_host;
    unsigned long long n_memory_managed;
    unsigned long long n_memory_unregistered;
    unsigned long long n_memory_device;
  } profiling;
#endif /* NMAD_PROFILE */
};
 
#endif /* NM_CORE_H */