src/third_party/npapi/npspy/extern/nspr/prtpool.h

   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) 1999-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 prtpool_h___
  36 #define prtpool_h___
  37
  38 #include "prtypes.h"
  39 #include "prthread.h"
  40 #include "prio.h"
  41 #include "prerror.h"
  42
  43 /*
  44  * NOTE:
  45  *              THIS API IS A PRELIMINARY VERSION IN NSPR 4.0 AND IS SUBJECT TO
  46  *              CHANGE
  47  */
  48
  49 PR_BEGIN_EXTERN_C
  50
  51 typedef struct PRJobIoDesc {
  52     PRFileDesc *socket;
  53     PRErrorCode error;
  54     PRIntervalTime timeout;
  55 } PRJobIoDesc;
  56
  57 typedef struct PRThreadPool PRThreadPool;
  58 typedef struct PRJob PRJob;
  59 typedef void (PR_CALLBACK *PRJobFn) (void *arg);
  60
  61 /* Create thread pool */
  62 NSPR_API(PRThreadPool *)
  63 PR_CreateThreadPool(PRInt32 initial_threads, PRInt32 max_threads,
  64                           PRUint32 stacksize);
  65
  66 /* queue a job */
  67 NSPR_API(PRJob *)
  68 PR_QueueJob(PRThreadPool *tpool, PRJobFn fn, void *arg, PRBool joinable);
  69
  70 /* queue a job, when a socket is readable */
  71 NSPR_API(PRJob *)
  72 PR_QueueJob_Read(PRThreadPool *tpool, PRJobIoDesc *iod,
  73                                                         PRJobFn fn, void * arg, PRBool joinable);
  74
  75 /* queue a job, when a socket is writeable */
  76 NSPR_API(PRJob *)
  77 PR_QueueJob_Write(PRThreadPool *tpool, PRJobIoDesc *iod,
  78                                                                 PRJobFn fn, void * arg, PRBool joinable);
  79
  80 /* queue a job, when a socket has a pending connection */
  81 NSPR_API(PRJob *)
  82 PR_QueueJob_Accept(PRThreadPool *tpool, PRJobIoDesc *iod,
  83                                                                         PRJobFn fn, void * arg, PRBool joinable);
  84
  85 /* queue a job, when the socket connection to addr succeeds or fails */
  86 NSPR_API(PRJob *)
  87 PR_QueueJob_Connect(PRThreadPool *tpool, PRJobIoDesc *iod,
  88                         const PRNetAddr *addr, PRJobFn fn, void * arg, PRBool joinable);
  89
  90 /* queue a job, when a timer exipres */
  91 NSPR_API(PRJob *)
  92 PR_QueueJob_Timer(PRThreadPool *tpool, PRIntervalTime timeout,
  93                                                                 PRJobFn fn, void * arg, PRBool joinable);
  94 /* cancel a job */
  95 NSPR_API(PRStatus)
  96 PR_CancelJob(PRJob *job);
  97
  98 /* join a job */
  99 NSPR_API(PRStatus)
 100 PR_JoinJob(PRJob *job);
 101
 102 /* shutdown pool */
 103 NSPR_API(PRStatus)
 104 PR_ShutdownThreadPool(PRThreadPool *tpool);
 105
 106 /* join pool, wait for exit of all threads */
 107 NSPR_API(PRStatus)
 108 PR_JoinThreadPool(PRThreadPool *tpool);
 109
 110 PR_END_EXTERN_C
 111
 112 #endif /* prtpool_h___ */