Go2Py/deploy/dds_bridge/thirdparty/include/dds/ddsi/q_thread.h

/*
 * Copyright(c) 2006 to 2021 ZettaScale Technology and others
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Public License v. 2.0 which is available at
 * http://www.eclipse.org/legal/epl-2.0, or the Eclipse Distribution License
 * v. 1.0 which is available at
 * http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * SPDX-License-Identifier: EPL-2.0 OR BSD-3-Clause
 */
#ifndef Q_THREAD_H
#define Q_THREAD_H

#include <assert.h>
#include "dds/export.h"
#include "dds/ddsrt/atomics.h"
#include "dds/ddsrt/sync.h"
#include "dds/ddsrt/threads.h"
#include "dds/ddsrt/static_assert.h"

#if defined (__cplusplus)
extern "C" {
#endif

/* Things don't go wrong if CACHE_LINE_SIZE is defined incorrectly,
   they just run slower because of false cache-line sharing. It can be
   discovered at run-time, but in practice it's 64 for most CPUs and
   128 for some. */
#define CACHE_LINE_SIZE 64

typedef uint32_t vtime_t;
typedef int32_t svtime_t; /* signed version */
#define VTIME_NEST_MASK 0xfu
#define VTIME_TIME_MASK 0xfffffff0u
#define VTIME_TIME_SHIFT 4

/* GCC has a nifty feature allowing the specification of the required
   alignment: __attribute__ ((aligned (CACHE_LINE_SIZE))) in this
   case. Many other compilers implement it as well, but it is by no
   means a standard feature.  So we do it the old-fashioned way. */


/* These strings are used to indicate the required scheduling class to the "create_thread()" */
#define Q_THREAD_SCHEDCLASS_REALTIME  "Realtime"
#define Q_THREAD_SCHEDCLASS_TIMESHARE "Timeshare"

/* When this value is used, the platform default for scheduling priority will be used */
#define Q_THREAD_SCHEDPRIO_DEFAULT 0

enum thread_state_kind {
  THREAD_STATE_ZERO, /* known to be dead */
  THREAD_STATE_STOPPED, /* internal thread, stopped-but-not-reaped */
  THREAD_STATE_INIT, /* internal thread, initializing */
  THREAD_STATE_LAZILY_CREATED, /* lazily created in response because an application used it. Reclaimed if the thread terminates, but not considered an error if all of Cyclone is shutdown while this thread hasn't terminated yet */
  THREAD_STATE_ALIVE /* known to be alive - for Cyclone internal threads */
};

struct ddsi_domaingv;
struct ddsi_config;
struct ddsrt_log_cfg;

/*
 * vtime indicates progress for the garbage collector and the liveliness monitoring.
 *
 * vtime is updated without using atomic operations: only the owning thread updates
 * them, and the garbage collection mechanism and the liveliness monitoring only
 * observe the value
 *
 * gv is constant for internal threads, i.e., for threads with state = ALIVE
 * gv is non-NULL for internal threads except thread liveliness monitoring
 *
 * Q_THREAD_DEBUG enables some really costly debugging stuff that may not be fully
 * portable (I used it once, might as well keep it)
 */
#define Q_THREAD_DEBUG 0
#if Q_THREAD_DEBUG
#define Q_THREAD_NSTACKS 20
#define Q_THREAD_STACKDEPTH 10
#define Q_THREAD_BASE_DEBUG \
  void *stks[Q_THREAD_NSTACKS][Q_THREAD_STACKDEPTH]; \
  int stks_depth[Q_THREAD_NSTACKS]; \
  int stks_idx;

struct thread_state;
void thread_vtime_trace (struct thread_state *thrst);
#else /* Q_THREAD_DEBUG */
#define Q_THREAD_BASE_DEBUG
#define thread_vtime_trace(thrst) do { } while (0)
#endif /* Q_THREAD_DEBUG */

#define THREAD_BASE                             \
  ddsrt_atomic_uint32_t vtime;                  \
  enum thread_state_kind state;                 \
  ddsrt_atomic_voidp_t gv;                      \
  ddsrt_thread_t tid;                           \
  uint32_t (*f) (void *arg);                    \
  void *f_arg;                                  \
  Q_THREAD_BASE_DEBUG /* note: no semicolon! */ \
  char name[24] /* note: no semicolon! */

struct thread_state_base {
  THREAD_BASE;
};

struct thread_state {
  THREAD_BASE;
  char pad[CACHE_LINE_SIZE
           * ((sizeof (struct thread_state_base) + CACHE_LINE_SIZE - 1)
              / CACHE_LINE_SIZE)
           - sizeof (struct thread_state_base)];
};
#undef THREAD_BASE

#define THREAD_STATE_BATCH 32

struct thread_states_list {
  struct thread_state thrst[THREAD_STATE_BATCH];
  struct thread_states_list *next;
  uint32_t nthreads; // = THREAD_STATE_BATCH + (next ? next->nthreads : 0)
};

struct thread_states {
  ddsrt_mutex_t lock;
  ddsrt_atomic_voidp_t thread_states_head;
};

extern DDS_EXPORT struct thread_states thread_states;

// thread_local cannot (and doesn't need to?) be exported on Windows
#ifdef _WIN32
extern ddsrt_thread_local struct thread_state *tsd_thread_state;
#else
extern DDS_EXPORT ddsrt_thread_local struct thread_state *tsd_thread_state;
#endif


DDS_EXPORT void thread_states_init (void);
DDS_EXPORT bool thread_states_fini (void);

DDS_EXPORT const struct ddsi_config_thread_properties_listelem *lookup_thread_properties (const struct ddsi_config *config, const char *name);
DDS_EXPORT dds_return_t create_thread_with_properties (struct thread_state **thrst, struct ddsi_config_thread_properties_listelem const * const tprops, const char *name, uint32_t (*f) (void *arg), void *arg);
DDS_EXPORT dds_return_t create_thread (struct thread_state **thrst, const struct ddsi_domaingv *gv, const char *name, uint32_t (*f) (void *arg), void *arg);
DDS_EXPORT struct thread_state *lookup_thread_state_real (void);
DDS_EXPORT dds_return_t join_thread (struct thread_state *thrst);
DDS_EXPORT void log_stack_traces (const struct ddsrt_log_cfg *logcfg, const struct ddsi_domaingv *gv);

DDS_INLINE_EXPORT inline struct thread_state *lookup_thread_state (void) {
  struct thread_state *thrst = tsd_thread_state;
  if (thrst)
    return thrst;
  else
    return lookup_thread_state_real ();
}

DDS_INLINE_EXPORT inline bool vtime_awake_p (vtime_t vtime)
{
  return (vtime & VTIME_NEST_MASK) != 0;
}

DDS_INLINE_EXPORT inline bool vtime_asleep_p (vtime_t vtime)
{
  return (vtime & VTIME_NEST_MASK) == 0;
}

DDS_INLINE_EXPORT inline bool vtime_gt (vtime_t vtime1, vtime_t vtime0)
{
  DDSRT_STATIC_ASSERT_CODE (sizeof (vtime_t) == sizeof (svtime_t));
  return (svtime_t) ((vtime1 & VTIME_TIME_MASK) - (vtime0 & VTIME_TIME_MASK)) > 0;
}

DDS_INLINE_EXPORT inline bool thread_is_awake (void)
{
  struct thread_state *thrst = lookup_thread_state ();
  vtime_t vt = ddsrt_atomic_ld32 (&thrst->vtime);
  return vtime_awake_p (vt);
}

DDS_INLINE_EXPORT inline bool thread_is_asleep (void)
{
  struct thread_state *thrst = lookup_thread_state ();
  vtime_t vt = ddsrt_atomic_ld32 (&thrst->vtime);
  return vtime_asleep_p (vt);
}

DDS_INLINE_EXPORT inline void thread_state_asleep (struct thread_state *thrst)
{
  vtime_t vt = ddsrt_atomic_ld32 (&thrst->vtime);
  assert (vtime_awake_p (vt));
  /* nested calls a rare and an extra fence doesn't break things */
  ddsrt_atomic_fence_rel ();
  thread_vtime_trace (thrst);
  if ((vt & VTIME_NEST_MASK) == 1)
    vt += (1u << VTIME_TIME_SHIFT) - 1u;
  else
    vt -= 1u;
  ddsrt_atomic_st32 (&thrst->vtime, vt);
}

DDS_INLINE_EXPORT inline void thread_state_awake (struct thread_state *thrst, const struct ddsi_domaingv *gv)
{
  vtime_t vt = ddsrt_atomic_ld32 (&thrst->vtime);
  assert ((vt & VTIME_NEST_MASK) < VTIME_NEST_MASK);
  assert (gv != NULL);
  assert (thrst->state != THREAD_STATE_ALIVE || gv == ddsrt_atomic_ldvoidp (&thrst->gv));
  thread_vtime_trace (thrst);
  ddsrt_atomic_stvoidp (&thrst->gv, (struct ddsi_domaingv *) gv);
  ddsrt_atomic_fence_stst ();
  ddsrt_atomic_st32 (&thrst->vtime, vt + 1u);
  /* nested calls a rare and an extra fence doesn't break things */
  ddsrt_atomic_fence_acq ();
}

DDS_INLINE_EXPORT inline void thread_state_awake_domain_ok (struct thread_state *thrst)
{
  vtime_t vt = ddsrt_atomic_ld32 (&thrst->vtime);
  assert ((vt & VTIME_NEST_MASK) < VTIME_NEST_MASK);
  assert (ddsrt_atomic_ldvoidp (&thrst->gv) != NULL);
  thread_vtime_trace (thrst);
  ddsrt_atomic_st32 (&thrst->vtime, vt + 1u);
  /* nested calls a rare and an extra fence doesn't break things */
  ddsrt_atomic_fence_acq ();
}

DDS_INLINE_EXPORT inline void thread_state_awake_fixed_domain (struct thread_state *thrst)
{
  /* fixed domain -> must be an internal thread */
  assert (thrst->state == THREAD_STATE_ALIVE);
  thread_state_awake_domain_ok (thrst);
}

DDS_INLINE_EXPORT inline void thread_state_awake_to_awake_no_nest (struct thread_state *thrst)
{
  vtime_t vt = ddsrt_atomic_ld32 (&thrst->vtime);
  assert ((vt & VTIME_NEST_MASK) == 1);
  ddsrt_atomic_fence_rel ();
  thread_vtime_trace (thrst);
  ddsrt_atomic_st32 (&thrst->vtime, vt + (1u << VTIME_TIME_SHIFT));
  ddsrt_atomic_fence_acq ();
}

#if defined (__cplusplus)
}
#endif

#endif /* Q_THREAD_H */