Home | History | Annotate | Download | only in private
      1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
      2 /*
      3  * The contents of this file are subject to the Mozilla Public
      4  * License Version 1.1 (the "License"); you may not use this file
      5  * except in compliance with the License. You may obtain a copy of
      6  * the License at http://www.mozilla.org/MPL/
      7  *
      8  * Software distributed under the License is distributed on an "AS
      9  * IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
     10  * implied. See the License for the specific language governing
     11  * rights and limitations under the License.
     12  *
     13  * The Original Code is the Netscape Portable Runtime (NSPR).
     14  *
     15  * The Initial Developer of the Original Code is Netscape
     16  * Communications Corporation.  Portions created by Netscape are
     17  * Copyright (C) 1998-2000 Netscape Communications Corporation.  All
     18  * Rights Reserved.
     19  *
     20  * Contributor(s):
     21  *
     22  * Alternatively, the contents of this file may be used under the
     23  * terms of the GNU General Public License Version 2 or later (the
     24  * "GPL"), in which case the provisions of the GPL are applicable
     25  * instead of those above.  If you wish to allow use of your
     26  * version of this file only under the terms of the GPL and not to
     27  * allow others to use your version of this file under the MPL,
     28  * indicate your decision by deleting the provisions above and
     29  * replace them with the notice and other provisions required by
     30  * the GPL.  If you do not delete the provisions above, a recipient
     31  * may use your version of this file under either the MPL or the
     32  * GPL.
     33  */
     34 
     35 #ifndef pprthred_h___
     36 #define pprthred_h___
     37 
     38 /*
     39 ** API for PR private functions.  These calls are to be used by internal
     40 ** developers only.
     41 */
     42 #include "nspr.h"
     43 
     44 #if defined(XP_OS2)
     45 #define INCL_DOS
     46 #define INCL_DOSERRORS
     47 #define INCL_WIN
     48 #include <os2.h>
     49 #endif
     50 
     51 PR_BEGIN_EXTERN_C
     52 
     53 /*---------------------------------------------------------------------------
     54 ** THREAD PRIVATE FUNCTIONS
     55 ---------------------------------------------------------------------------*/
     56 
     57 /*
     58 ** Associate a thread object with an existing native thread.
     59 ** 	"type" is the type of thread object to attach
     60 ** 	"priority" is the priority to assign to the thread
     61 ** 	"stack" defines the shape of the threads stack
     62 **
     63 ** This can return NULL if some kind of error occurs, or if memory is
     64 ** tight. This call invokes "start(obj,arg)" and returns when the
     65 ** function returns. The thread object is automatically destroyed.
     66 **
     67 ** This call is not normally needed unless you create your own native
     68 ** thread. PR_Init does this automatically for the primordial thread.
     69 */
     70 NSPR_API(PRThread*) PR_AttachThread(PRThreadType type,
     71                                      PRThreadPriority priority,
     72 				     PRThreadStack *stack);
     73 
     74 /*
     75 ** Detach the nspr thread from the currently executing native thread.
     76 ** The thread object will be destroyed and all related data attached
     77 ** to it. The exit procs will be invoked.
     78 **
     79 ** This call is not normally needed unless you create your own native
     80 ** thread. PR_Exit will automatially detach the nspr thread object
     81 ** created by PR_Init for the primordial thread.
     82 **
     83 ** This call returns after the nspr thread object is destroyed.
     84 */
     85 NSPR_API(void) PR_DetachThread(void);
     86 
     87 /*
     88 ** Get the id of the named thread. Each thread is assigned a unique id
     89 ** when it is created or attached.
     90 */
     91 NSPR_API(PRUint32) PR_GetThreadID(PRThread *thread);
     92 
     93 /*
     94 ** Set the procedure that is called when a thread is dumped. The procedure
     95 ** will be applied to the argument, arg, when called. Setting the procedure
     96 ** to NULL effectively removes it.
     97 */
     98 typedef void (*PRThreadDumpProc)(PRFileDesc *fd, PRThread *t, void *arg);
     99 NSPR_API(void) PR_SetThreadDumpProc(
    100     PRThread* thread, PRThreadDumpProc dump, void *arg);
    101 
    102 /*
    103 ** Get this thread's affinity mask.  The affinity mask is a 32 bit quantity
    104 ** marking a bit for each processor this process is allowed to run on.
    105 ** The processor mask is returned in the mask argument.
    106 ** The least-significant-bit represents processor 0.
    107 **
    108 ** Returns 0 on success, -1 on failure.
    109 */
    110 NSPR_API(PRInt32) PR_GetThreadAffinityMask(PRThread *thread, PRUint32 *mask);
    111 
    112 /*
    113 ** Set this thread's affinity mask.
    114 **
    115 ** Returns 0 on success, -1 on failure.
    116 */
    117 NSPR_API(PRInt32) PR_SetThreadAffinityMask(PRThread *thread, PRUint32 mask );
    118 
    119 /*
    120 ** Set the default CPU Affinity mask.
    121 **
    122 */
    123 NSPR_API(PRInt32) PR_SetCPUAffinityMask(PRUint32 mask);
    124 
    125 /*
    126 ** Show status of all threads to standard error output.
    127 */
    128 NSPR_API(void) PR_ShowStatus(void);
    129 
    130 /*
    131 ** Set thread recycle mode to on (1) or off (0)
    132 */
    133 NSPR_API(void) PR_SetThreadRecycleMode(PRUint32 flag);
    134 
    135 
    136 /*---------------------------------------------------------------------------
    137 ** THREAD PRIVATE FUNCTIONS FOR GARBAGE COLLECTIBLE THREADS
    138 ---------------------------------------------------------------------------*/
    139 
    140 /*
    141 ** Only Garbage collectible threads participate in resume all, suspend all and
    142 ** enumeration operations.  They are also different during creation when
    143 ** platform specific action may be needed (For example, all Solaris GC able
    144 ** threads are bound threads).
    145 */
    146 
    147 /*
    148 ** Same as PR_CreateThread except that the thread is marked as garbage
    149 ** collectible.
    150 */
    151 NSPR_API(PRThread*) PR_CreateThreadGCAble(PRThreadType type,
    152 				     void (*start)(void *arg),
    153 				     void *arg,
    154 				     PRThreadPriority priority,
    155 				     PRThreadScope scope,
    156 				     PRThreadState state,
    157 				     PRUint32 stackSize);
    158 
    159 /*
    160 ** Same as PR_AttachThread except that the thread being attached is marked as
    161 ** garbage collectible.
    162 */
    163 NSPR_API(PRThread*) PR_AttachThreadGCAble(PRThreadType type,
    164 					PRThreadPriority priority,
    165 					PRThreadStack *stack);
    166 
    167 /*
    168 ** Mark the thread as garbage collectible.
    169 */
    170 NSPR_API(void) PR_SetThreadGCAble(void);
    171 
    172 /*
    173 ** Unmark the thread as garbage collectible.
    174 */
    175 NSPR_API(void) PR_ClearThreadGCAble(void);
    176 
    177 /*
    178 ** This routine prevents all other GC able threads from running. This call is needed by
    179 ** the garbage collector.
    180 */
    181 NSPR_API(void) PR_SuspendAll(void);
    182 
    183 /*
    184 ** This routine unblocks all other GC able threads that were suspended from running by
    185 ** PR_SuspendAll(). This call is needed by the garbage collector.
    186 */
    187 NSPR_API(void) PR_ResumeAll(void);
    188 
    189 /*
    190 ** Return the thread stack pointer of the given thread.
    191 ** Needed by the garbage collector.
    192 */
    193 NSPR_API(void *) PR_GetSP(PRThread *thread);
    194 
    195 /*
    196 ** Save the registers that the GC would find interesting into the thread
    197 ** "t". isCurrent will be non-zero if the thread state that is being
    198 ** saved is the currently executing thread. Return the address of the
    199 ** first register to be scanned as well as the number of registers to
    200 ** scan in "np".
    201 **
    202 ** If "isCurrent" is non-zero then it is allowed for the thread context
    203 ** area to be used as scratch storage to hold just the registers
    204 ** necessary for scanning.
    205 **
    206 ** This function simply calls the internal function _MD_HomeGCRegisters().
    207 */
    208 NSPR_API(PRWord *) PR_GetGCRegisters(PRThread *t, int isCurrent, int *np);
    209 
    210 /*
    211 ** (Get|Set)ExecutionEnvironent
    212 **
    213 ** Used by Java to associate it's execution environment so garbage collector
    214 ** can find it. If return is NULL, then it's probably not a collectable thread.
    215 **
    216 ** There's no locking required around these calls.
    217 */
    218 NSPR_API(void*) GetExecutionEnvironment(PRThread *thread);
    219 NSPR_API(void) SetExecutionEnvironment(PRThread* thread, void *environment);
    220 
    221 /*
    222 ** Enumeration function that applies "func(thread,i,arg)" to each active
    223 ** thread in the process. The enumerator returns PR_SUCCESS if the enumeration
    224 ** should continue, any other value is considered failure, and enumeration
    225 ** stops, returning the failure value from PR_EnumerateThreads.
    226 ** Needed by the garbage collector.
    227 */
    228 typedef PRStatus (PR_CALLBACK *PREnumerator)(PRThread *t, int i, void *arg);
    229 NSPR_API(PRStatus) PR_EnumerateThreads(PREnumerator func, void *arg);
    230 
    231 /*
    232 ** Signature of a thread stack scanning function. It is applied to every
    233 ** contiguous group of potential pointers within a thread. Count denotes the
    234 ** number of pointers.
    235 */
    236 typedef PRStatus
    237 (PR_CALLBACK *PRScanStackFun)(PRThread* t,
    238 			      void** baseAddr, PRUword count, void* closure);
    239 
    240 /*
    241 ** Applies scanFun to all contiguous groups of potential pointers
    242 ** within a thread. This includes the stack, registers, and thread-local
    243 ** data. If scanFun returns a status value other than PR_SUCCESS the scan
    244 ** is aborted, and the status value is returned.
    245 */
    246 NSPR_API(PRStatus)
    247 PR_ThreadScanStackPointers(PRThread* t,
    248                            PRScanStackFun scanFun, void* scanClosure);
    249 
    250 /*
    251 ** Calls PR_ThreadScanStackPointers for every thread.
    252 */
    253 NSPR_API(PRStatus)
    254 PR_ScanStackPointers(PRScanStackFun scanFun, void* scanClosure);
    255 
    256 /*
    257 ** Returns a conservative estimate on the amount of stack space left
    258 ** on a thread in bytes, sufficient for making decisions about whether
    259 ** to continue recursing or not.
    260 */
    261 NSPR_API(PRUword)
    262 PR_GetStackSpaceLeft(PRThread* t);
    263 
    264 /*---------------------------------------------------------------------------
    265 ** THREAD CPU PRIVATE FUNCTIONS
    266 ---------------------------------------------------------------------------*/
    267 
    268 /*
    269 ** Get a pointer to the primordial CPU.
    270 */
    271 NSPR_API(struct _PRCPU *) _PR_GetPrimordialCPU(void);
    272 
    273 /*---------------------------------------------------------------------------
    274 ** THREAD SYNCHRONIZATION PRIVATE FUNCTIONS
    275 ---------------------------------------------------------------------------*/
    276 
    277 /*
    278 ** Create a new named monitor (named for debugging purposes).
    279 **  Monitors are re-entrant locks with a built-in condition variable.
    280 **
    281 ** This may fail if memory is tight or if some operating system resource
    282 ** is low.
    283 */
    284 NSPR_API(PRMonitor*) PR_NewNamedMonitor(const char* name);
    285 
    286 /*
    287 ** Test and then lock the lock if it's not already locked by some other
    288 ** thread. Return PR_FALSE if some other thread owned the lock at the
    289 ** time of the call.
    290 */
    291 NSPR_API(PRBool) PR_TestAndLock(PRLock *lock);
    292 
    293 /*
    294 ** Test and then enter the mutex associated with the monitor if it's not
    295 ** already entered by some other thread. Return PR_FALSE if some other
    296 ** thread owned the mutex at the time of the call.
    297 */
    298 NSPR_API(PRBool) PR_TestAndEnterMonitor(PRMonitor *mon);
    299 
    300 /*
    301 ** Return the number of times that the current thread has entered the
    302 ** mutex. Returns zero if the current thread has not entered the mutex.
    303 */
    304 NSPR_API(PRIntn) PR_GetMonitorEntryCount(PRMonitor *mon);
    305 
    306 /*
    307 ** Just like PR_CEnterMonitor except that if the monitor is owned by
    308 ** another thread NULL is returned.
    309 */
    310 NSPR_API(PRMonitor*) PR_CTestAndEnterMonitor(void *address);
    311 
    312 /*---------------------------------------------------------------------------
    313 ** PLATFORM-SPECIFIC THREAD SYNCHRONIZATION FUNCTIONS
    314 ---------------------------------------------------------------------------*/
    315 #if defined(XP_MAC)
    316 
    317 NSPR_API(void) PR_Mac_WaitForAsyncNotify(PRIntervalTime timeout);
    318 NSPR_API(void) PR_Mac_PostAsyncNotify(PRThread *thread);
    319 
    320 #endif /* XP_MAC */
    321 
    322 /*---------------------------------------------------------------------------
    323 ** PLATFORM-SPECIFIC INITIALIZATION FUNCTIONS
    324 ---------------------------------------------------------------------------*/
    325 #if defined(IRIX)
    326 /*
    327 ** Irix specific initialization funtion to be called before PR_Init
    328 ** is called by the application. Sets the CONF_INITUSERS and CONF_INITSIZE
    329 ** attributes of the shared arena set up by nspr.
    330 **
    331 ** The environment variables _NSPR_IRIX_INITUSERS and _NSPR_IRIX_INITSIZE
    332 ** can also be used to set these arena attributes. If _NSPR_IRIX_INITUSERS
    333 ** is set, but not _NSPR_IRIX_INITSIZE, the value of the CONF_INITSIZE
    334 ** attribute of the nspr arena is scaled as a function of the
    335 ** _NSPR_IRIX_INITUSERS value.
    336 **
    337 ** If the _PR_Irix_Set_Arena_Params() is called in addition to setting the
    338 ** environment variables, the values of the environment variables are used.
    339 **
    340 */
    341 NSPR_API(void) _PR_Irix_Set_Arena_Params(PRInt32 initusers, PRInt32 initsize);
    342 
    343 #endif /* IRIX */
    344 
    345 #if defined(XP_OS2)
    346 /*
    347 ** These functions need to be called at the start and end of a thread.
    348 ** An EXCEPTIONREGISTRATIONRECORD must be declared on the stack and its
    349 ** address passed to the two functions.
    350 */
    351 NSPR_API(void) PR_OS2_SetFloatExcpHandler(EXCEPTIONREGISTRATIONRECORD* e);
    352 NSPR_API(void) PR_OS2_UnsetFloatExcpHandler(EXCEPTIONREGISTRATIONRECORD* e);
    353 #endif /* XP_OS2 */
    354 
    355 /* I think PR_GetMonitorEntryCount is useless. All you really want is this... */
    356 #define PR_InMonitor(m)		(PR_GetMonitorEntryCount(m) > 0)
    357 
    358 /*---------------------------------------------------------------------------
    359 ** Special X-Lock hack for client
    360 ---------------------------------------------------------------------------*/
    361 
    362 #ifdef XP_UNIX
    363 extern void PR_XLock(void);
    364 extern void PR_XUnlock(void);
    365 extern PRBool PR_XIsLocked(void);
    366 #endif /* XP_UNIX */
    367 
    368 PR_END_EXTERN_C
    369 
    370 #endif /* pprthred_h___ */
    371