lib/frr_pthread.h

   1 /*
   2  * Utilities and interfaces for managing POSIX threads
   3  * Copyright (C) 2017  Cumulus Networks
   4  *
   5  * This program is free software; you can redistribute it and/or modify
   6  * it under the terms of the GNU General Public License as published by
   7  * the Free Software Foundation; either version 2 of the License, or
   8  * (at your option) any later version.
   9  *
  10  * This program is distributed in the hope that it will be useful, but
  11  * WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * General Public License for more details.
  14  *
  15  * You should have received a copy of the GNU General Public License along
  16  * with this program; see the file COPYING; if not, write to the Free Software
  17  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  18  */
  19
  20 #ifndef _FRR_PTHREAD_H
  21 #define _FRR_PTHREAD_H
  22
  23 #include <pthread.h>
  24 #include "thread.h"
  25
  26 struct frr_pthread {
  27
  28         /* pthread id */
  29         pthread_t thread;
  30
  31         /* frr thread identifier */
  32         unsigned int id;
  33
  34         /* thread master for this pthread's thread.c event loop */
  35         struct thread_master *master;
  36
  37         /* start routine */
  38         void *(*start_routine) (void *);
  39
  40         /* stop routine */
  41         int (*stop_routine) (void **, struct frr_pthread *);
  42
  43         /* the (hopefully descriptive) name of this thread */
  44         char *name;
  45 };
  46
  47 /* Initializes this module.
  48  *
  49  * Must be called before using any of the other functions.
  50  */
  51 void frr_pthread_init(void);
  52
  53 /* Uninitializes this module.
  54  *
  55  * Destroys all registered frr_pthread's and internal data structures.
  56  *
  57  * It is safe to call frr_pthread_init() after this function to reinitialize
  58  * the module.
  59  */
  60 void frr_pthread_finish(void);
  61
  62 /* Creates a new frr_pthread.
  63  *
  64  * If the provided ID is already assigned to an existing frr_pthread, the
  65  * return value will be NULL.
  66  *
  67  * @param name - the name of the thread. Doesn't have to be unique, but it
  68  * probably should be. This value is copied and may be safely free'd upon
  69  * return.
  70  *
  71  * @param id - the integral ID of the thread. MUST be unique. The caller may
  72  * use this id to retrieve the thread.
  73  *
  74  * @param start_routine - start routine for the pthread, will be passed to
  75  * pthread_create (see those docs for details)
  76  *
  77  * @param stop_routine - stop routine for the pthread, called to terminate the
  78  * thread. This function should gracefully stop the pthread and clean up any
  79  * thread-specific resources. The passed pointer is used to return a data
  80  * result.
  81  *
  82  * @return the created frr_pthread upon success, or NULL upon failure
  83  */
  84 struct frr_pthread *frr_pthread_new(const char *name, unsigned int id,
  85                                     void *(*start_routine) (void *),
  86                                     int (*stop_routine) (void **, struct frr_pthread *));
  87
  88 /* Destroys an frr_pthread.
  89  *
  90  * Assumes that the associated pthread, if any, has already terminated.
  91  *
  92  * @param fpt - the frr_pthread to destroy
  93  */
  94 void frr_pthread_destroy(struct frr_pthread *fpt);
  95
  96 /* Gets an existing frr_pthread by its id.
  97  *
  98  * @return frr_thread associated with the provided id, or NULL on error
  99  */
 100 struct frr_pthread *frr_pthread_get(unsigned int id);
 101
 102 /* Creates a new pthread and binds it to a frr_pthread.
 103  *
 104  * This function is a wrapper for pthread_create. The first parameter is the
 105  * frr_pthread to bind the created pthread to. All subsequent arguments are
 106  * passed unmodified to pthread_create().
 107  *
 108  * This function returns the same code as pthread_create(). If the value is
 109  * zero, the provided frr_pthread is bound to a running POSIX thread. If the
 110  * value is less than zero, the provided frr_pthread is guaranteed to be a
 111  * clean instance that may be susbsequently passed to frr_pthread_run().
 112  *
 113  * @param id - frr_pthread to bind the created pthread to
 114  * @param attr - see pthread_create(3)
 115  * @param arg - see pthread_create(3)
 116  *
 117  * @return see pthread_create(3)
 118  */
 119 int frr_pthread_run(unsigned int id, const pthread_attr_t * attr, void *arg);
 120
 121 /* Stops an frr_pthread with a result.
 122  *
 123  * @param id - frr_pthread to stop
 124  * @param result - where to store the thread's result, if any. May be NULL if a
 125  * result is not needed.
 126  */
 127 int frr_pthread_stop(unsigned int id, void **result);
 128
 129 /* Stops all frr_pthread's. */
 130 void frr_pthread_stop_all(void);
 131
 132 /* Returns a unique identifier for use with frr_pthread_new().
 133  *
 134  * Internally, this is an integer that increments after each call to this
 135  * function. Because the number of pthreads created should never exceed INT_MAX
 136  * during the life of the program, there is no overflow protection. If by
 137  * chance this function returns an ID which is already in use,
 138  * frr_pthread_new() will fail when it is provided.
 139  *
 140  * @return unique identifier
 141  */
 142 unsigned int frr_pthread_get_id(void);
 143
 144 #endif /* _FRR_PTHREAD_H */