libags-dev 1.4.24-1ubuntu2 / usr / include / ags / thread / ags_thread-posix.h

/* GSequencer - Advanced GTK Sequencer
 * Copyright (C) 2005-2015 Joël Krähemann
 *
 * This file is part of GSequencer.
 *
 * GSequencer 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 3 of the License, or
 * (at your option) any later version.
 *
 * GSequencer 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.
 *
 * You should have received a copy of the GNU General Public License
 * along with GSequencer.  If not, see <http://www.gnu.org/licenses/>.
 */

#ifndef __AGS_THREAD_H__
#define __AGS_THREAD_H__

#include <glib.h>
#include <glib-object.h>

#include <ags/lib/ags_time.h>

#define _GNU_SOURCE
#include <signal.h>

#define _GNU_SOURCE
#include <pthread.h>

#include <time.h>

#define AGS_TYPE_THREAD                (ags_thread_get_type())
#define AGS_THREAD(obj)                (G_TYPE_CHECK_INSTANCE_CAST((obj), AGS_TYPE_THREAD, AgsThread))
#define AGS_THREAD_CLASS(class)        (G_TYPE_CHECK_CLASS_CAST(class, AGS_TYPE_THREAD, AgsThreadClass))
#define AGS_IS_THREAD(obj)             (G_TYPE_CHECK_INSTANCE_TYPE ((obj), AGS_TYPE_THREAD))
#define AGS_IS_THREAD_CLASS(class)     (G_TYPE_CHECK_CLASS_TYPE ((class), AGS_TYPE_THREAD))
#define AGS_THREAD_GET_CLASS(obj)      (G_TYPE_INSTANCE_GET_CLASS(obj, AGS_TYPE_THREAD, AgsThreadClass))

#define AGS_THREAD_RESUME_SIG SIGUSR2
#define AGS_THREAD_SUSPEND_SIG SIGUSR1

#ifndef AGS_RT_PRIORITY
#define AGS_RT_PRIORITY (45)
#endif

#define AGS_THREAD_HERTZ_JIFFIE (1000.0)
#define AGS_THREAD_YIELD_JIFFIE (2.0)

#define AGS_THREAD_DEFAULT_JIFFIE (250.0)
#define AGS_THREAD_DEFAULT_MAX_PRECISION (1000.0)

#define AGS_THREAD_MAX_PRECISION (1000.0)

#define AGS_THREAD_DEFAULT_ATTACK (1.0)

#define AGS_THREAD_TOLERANCE (0.0)

typedef struct _AgsThread AgsThread;
typedef struct _AgsThreadClass AgsThreadClass;

/**
 * AgsThreadFlags:
 * @AGS_THREAD_CONNECTED: the thread was connected by #AgsConnectable::connect()
 * @AGS_THREAD_SINGLE_LOOP: the thread doesn't actually run in its owns thread
 * @AGS_THREAD_INITIAL_SYNC: initial sync indicates the thread wasn't synced before
 * @AGS_THREAD_INITIAL_RUN: the first call to #AgsThread:run()
 * @AGS_THREAD_RT_SETUP: realtime setup was performed
 * @AGS_THREAD_WAITING: the thread is waiting
 * @AGS_THREAD_RUNNING: the thread is running
 * @AGS_THREAD_IDLE: the thread is in idle mode
 * @AGS_THREAD_LOCKED: the thread is locked
 * @AGS_THREAD_SUSPENDED: the thread is suspended
 * @AGS_THREAD_READY: the thread is ready
 * @AGS_THREAD_UNREF_ON_EXIT: call g_object_unref() before pthread_exit()
 * @AGS_THREAD_IS_CHAOS_TREE: the thread is not synced
 * @AGS_THREAD_IMMEDIATE_SYNC: do sync immediately
 * @AGS_THREAD_RECOVER_INTERRUPTED: check if thread was interrupted
 * @AGS_THREAD_RESUME_INTERRUPTED: call ags_thread_resume() if @AGS_THREAD_SUSPENDED is set
 * @AGS_THREAD_TIMING: do timing
 * @AGS_THREAD_INTERMEDIATE_PRE_SYNC: intermediate pre sync to parent thread
 * @AGS_THREAD_INTERMEDIATE_POST_SYNC: intermediate post sync to parent thread
 *
 * Enum values to control the behavior or indicate internal state of #AgsThread by
 * enable/disable as flags.
 */
typedef enum{
  AGS_THREAD_CONNECTED               = 1,
  AGS_THREAD_SINGLE_LOOP             = 1 <<  1,
  AGS_THREAD_INITIAL_SYNC            = 1 <<  2,
  AGS_THREAD_INITIAL_RUN             = 1 <<  3,
  AGS_THREAD_RT_SETUP                = 1 <<  4,
  AGS_THREAD_WAITING                 = 1 <<  5,
  AGS_THREAD_RUNNING                 = 1 <<  6,
  AGS_THREAD_IDLE                    = 1 <<  7,
  AGS_THREAD_LOCKED                  = 1 <<  8,
  AGS_THREAD_SUSPENDED               = 1 <<  9,
  AGS_THREAD_READY                   = 1 << 10,
  AGS_THREAD_UNREF_ON_EXIT           = 1 << 11,
  AGS_THREAD_IS_CHAOS_TREE           = 1 << 12,
  AGS_THREAD_IMMEDIATE_SYNC          = 1 << 13,
  AGS_THREAD_RECOVER_INTERRUPTED     = 1 << 14,
  AGS_THREAD_RESUME_INTERRUPTED      = 1 << 15,
  AGS_THREAD_TIMING                  = 1 << 16,
  AGS_THREAD_INTERMEDIATE_PRE_SYNC   = 1 << 17,
  AGS_THREAD_INTERMEDIATE_POST_SYNC  = 1 << 18,
}AgsThreadFlags;

/**
 * AgsThreadSyncFlags:
 * @AGS_THREAD_WAIT_FOR_PARENT: wait for parent
 * @AGS_THREAD_WAIT_FOR_SIBLING: wait for sibling
 * @AGS_THREAD_WAIT_FOR_CHILDREN: wait for children
 * @AGS_THREAD_WAIT_FOR_BARRIER: wait for barrier
 * @AGS_THREAD_WAITING_FOR_PARENT: the thread is waiting for parent
 * @AGS_THREAD_WAITING_FOR_SIBLING: the thread is waiting for sibling
 * @AGS_THREAD_WAITING_FOR_CHILDREN: the thread is waiting for children
 * @AGS_THREAD_WAITING_FOR_BARRIER: the thread is waiting for barrier
 * @AGS_THREAD_BROADCAST_PARENT: broadcast parent
 * @AGS_THREAD_BROADCAST_SIBLING: broadcast sibling
 * @AGS_THREAD_BROADCAST_CHILDREN: broadcast children
 * @AGS_THREAD_TREE_SYNC_0: exclusively synced tic group
 * @AGS_THREAD_WAIT_0: wait tree to be synced
 * @AGS_THREAD_TREE_SYNC_1: exclusively synced tic group
 * @AGS_THREAD_WAIT_1: wait tree to be synced
 * @AGS_THREAD_TREE_SYNC_2: exclusively synced tic group
 * @AGS_THREAD_WAIT_2: wait tree to be synced
 * @AGS_THREAD_TIMELOCK_RUN: run timelock
 * @AGS_THREAD_TIMELOCK_WAIT: timelock wait
 * @AGS_THREAD_TIMELOCK_RESUME: timelock resume
 * @AGS_THREAD_SKIP_NON_GREEDY: skip non greedy
 * @AGS_THREAD_SKIPPED_BY_TIMELOCK: thread was skipped by timelock
 * @AGS_THREAD_LOCK_GREEDY_RUN_MUTEX: you shall lock run mutex of greedy locks
 * @AGS_THREAD_START_SYNCED_FREQ: sync frequency as starting thread
 * @AGS_THREAD_SYNCED_FREQ: the frequency was synced
 * @AGS_THREAD_INTERRUPTED: the thread is interrupted
 * @AGS_THREAD_MONITORING: the thread is monitoring interrupts
 * @AGS_THREAD_WAIT_ASYNC_QUEUE: wait exclusive async running queue
 * @AGS_THREAD_DONE_ASYNC_QUEUE: done exclusive async running queue
 *
 * Enum values to control the behavior or indicate internal state of #AgsThread by
 * enable/disable as sync_flags.
 */
typedef enum{
  AGS_THREAD_WAIT_FOR_PARENT         = 1,
  AGS_THREAD_WAIT_FOR_SIBLING        = 1 <<  1,
  AGS_THREAD_WAIT_FOR_CHILDREN       = 1 <<  2,
  AGS_THREAD_WAIT_FOR_BARRIER        = 1 <<  3,
  AGS_THREAD_WAITING_FOR_PARENT      = 1 <<  4,
  AGS_THREAD_WAITING_FOR_SIBLING     = 1 <<  5,
  AGS_THREAD_WAITING_FOR_CHILDREN    = 1 <<  6,
  AGS_THREAD_WAITING_FOR_BARRIER     = 1 <<  7,
  AGS_THREAD_BROADCAST_PARENT        = 1 <<  8,
  AGS_THREAD_BROADCAST_SIBLING       = 1 <<  9,
  AGS_THREAD_BROADCAST_CHILDREN      = 1 << 10,
  AGS_THREAD_TREE_SYNC_0             = 1 << 11,
  AGS_THREAD_WAIT_0                  = 1 << 12,
  AGS_THREAD_TREE_SYNC_1             = 1 << 13,
  AGS_THREAD_WAIT_1                  = 1 << 14,
  AGS_THREAD_TREE_SYNC_2             = 1 << 15,
  AGS_THREAD_WAIT_2                  = 1 << 16,
  AGS_THREAD_TIMELOCK_RUN            = 1 << 17,
  AGS_THREAD_TIMELOCK_WAIT           = 1 << 18,
  AGS_THREAD_TIMELOCK_RESUME         = 1 << 19,
  /*
   * prefered way would be unlocking greedy_locks
   * and the suspend to not become greedy
   * but while pthread_suspend and pthread_resume
   * are missing you need this as work-around
   */
  AGS_THREAD_SKIP_NON_GREEDY         = 1 << 20,
  AGS_THREAD_SKIPPED_BY_TIMELOCK     = 1 << 21,
  AGS_THREAD_LOCK_GREEDY_RUN_MUTEX   = 1 << 22,
  AGS_THREAD_START_SYNCED_FREQ       = 1 << 23,
  AGS_THREAD_SYNCED_FREQ             = 1 << 24,
  AGS_THREAD_INTERRUPTED             = 1 << 25,
  AGS_THREAD_MONITORING              = 1 << 26,
  AGS_THREAD_WAIT_ASYNC_QUEUE        = 1 << 27,
  AGS_THREAD_DONE_ASYNC_QUEUE        = 1 << 28,
}AgsThreadSyncFlags;

struct _AgsThread
{
  GObject object;

  volatile guint flags;
  volatile guint sync_flags;
  
  sigset_t wait_mask;

  pthread_mutex_t *obj_mutex;
  pthread_mutexattr_t *obj_mutexattr;

  pthread_mutex_t *obj_cond;
  pthread_mutexattr_t *obj_condattr;

  guint delay;
  guint tic_delay;
  guint current_tic;

  guint cycle_iteration;
  volatile guint time_late;
  struct timespec *computing_time;
  
  pthread_t *thread;
  pthread_attr_t *thread_attr;

  gdouble freq;
  gdouble max_precision;
  
  pthread_mutex_t *mutex;
  pthread_mutexattr_t *mutexattr;
  pthread_cond_t *cond;

  volatile GList *start_queue;
  
  pthread_mutex_t *start_mutex;
  pthread_cond_t *start_cond;
  volatile gboolean start_wait;
  volatile gboolean start_done;

#ifndef __APPLE__
  pthread_barrier_t **barrier;
#else
  gpointer barrier;
#endif  
  gboolean first_barrier;
  int wait_count[2];

  pthread_t *timelock_thread;
  pthread_mutex_t *timelock_mutex;
  pthread_cond_t *timelock_cond;

  pthread_mutex_t *greedy_mutex;
  pthread_cond_t *greedy_cond;
  pthread_mutex_t *greedy_run_mutex;
  volatile guint locked_greedy;

  struct timespec timelock;
  GList *greedy_locks;

  pthread_mutex_t *suspend_mutex;
  volatile gboolean critical_region;

  volatile gboolean timer_wait;
  volatile gboolean timer_expired;
  pthread_mutex_t *timer_mutex;
  pthread_cond_t *timer_cond;
  
  volatile AgsThread *parent;

  volatile AgsThread *next;
  volatile AgsThread *prev;

  volatile AgsThread *children;

  gpointer data;
};

struct _AgsThreadClass
{
  GObjectClass object;

  guint (*clock)(AgsThread *thread);
  
  void (*start)(AgsThread *thread);
  void (*run)(AgsThread *thread);
  void (*suspend)(AgsThread *thread);
  void (*resume)(AgsThread *thread);
  void (*timelock)(AgsThread *thread);
  void (*stop)(AgsThread *thread);

  guint (*interrupted)(AgsThread *thread,
		       int sig,
		       guint time_cycle, guint *time_spent);
};

GType ags_thread_get_type();

void ags_thread_resume_handler(int sig);
void ags_thread_suspend_handler(int sig);

void ags_thread_set_sync(AgsThread *thread, guint tic);
void ags_thread_set_sync_all(AgsThread *thread, guint tic);

void ags_thread_reset_all(AgsThread *thread);

void ags_thread_lock(AgsThread *thread);
gboolean ags_thread_trylock(AgsThread *thread);
void ags_thread_unlock(AgsThread *thread);

AgsThread* ags_thread_get_toplevel(AgsThread *thread);
AgsThread* ags_thread_first(AgsThread *thread);
AgsThread* ags_thread_last(AgsThread *thread);

void ags_thread_remove_child(AgsThread *thread, AgsThread *child);
void ags_thread_add_child(AgsThread *thread, AgsThread *child);
void ags_thread_add_child_extended(AgsThread *thread, AgsThread *child,
				   gboolean no_start, gboolean no_wait);

gboolean ags_thread_parental_is_locked(AgsThread *thread, AgsThread *parent);
gboolean ags_thread_sibling_is_locked(AgsThread *thread);
gboolean ags_thread_children_is_locked(AgsThread *thread);

gboolean ags_thread_is_current_ready(AgsThread *current,
				     guint tic);
gboolean ags_thread_is_tree_ready(AgsThread *thread,
				  guint tic);

AgsThread* ags_thread_next_parent_locked(AgsThread *thread, AgsThread *parent);
AgsThread* ags_thread_next_sibling_locked(AgsThread *thread);
AgsThread* ags_thread_next_children_locked(AgsThread *thread);

void ags_thread_lock_parent(AgsThread *thread, AgsThread *parent);
void ags_thread_lock_sibling(AgsThread *thread);
void ags_thread_lock_children(AgsThread *thread);
void ags_thread_lock_all(AgsThread *thread);

void ags_thread_unlock_parent(AgsThread *thread, AgsThread *parent);
void ags_thread_unlock_sibling(AgsThread *thread);
void ags_thread_unlock_children(AgsThread *thread);
void ags_thread_unlock_all(AgsThread *thread);

void ags_thread_wait_parent(AgsThread *thread, AgsThread *parent);
void ags_thread_wait_sibling(AgsThread *thread);
void ags_thread_wait_children(AgsThread *thread);

void ags_thread_signal_parent(AgsThread *thread, AgsThread *parent, gboolean broadcast);
void ags_thread_signal_sibling(AgsThread *thread, gboolean broadcast);
void ags_thread_signal_children(AgsThread *thread, gboolean broadcast);

guint ags_thread_clock(AgsThread *thread);

void ags_thread_add_start_queue(AgsThread *thread,
				AgsThread *child);
void ags_thread_add_start_queue_all(AgsThread *thread,
				    GList *child);

void ags_thread_start(AgsThread *thread);
void ags_thread_run(AgsThread *thread);
void ags_thread_suspend(AgsThread *thread);
void ags_thread_resume(AgsThread *thread);
void ags_thread_timelock(AgsThread *thread);
void ags_thread_stop(AgsThread *thread);

guint ags_thread_interrupted(AgsThread *thread,
			     int sig,
			     guint time_cycle, guint *time_spent);

void ags_thread_hangcheck(AgsThread *thread);

AgsThread* ags_thread_find_type(AgsThread *thread, GType type);
AgsThread* ags_thread_self(void);
AgsThread* ags_thread_chaos_tree(AgsThread *thread);

gboolean ags_thread_is_chaos_tree(AgsThread *thread,
				  guint tic_delay,
				  gboolean is_chaos_tree);

AgsThread* ags_thread_new(gpointer data);

#endif /*__AGS_THREAD_H__*/