15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 2 -*- */ 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * The contents of this file are subject to the Mozilla Public 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * License Version 1.1 (the "License"); you may not use this file 55821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * except in compliance with the License. You may obtain a copy of 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * the License at http://www.mozilla.org/MPL/ 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * 85821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * Software distributed under the License is distributed on an "AS 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * implied. See the License for the specific language governing 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * rights and limitations under the License. 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * The Original Code is the Netscape Portable Runtime (NSPR). 145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * 155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * The Initial Developer of the Original Code is Netscape 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * Communications Corporation. Portions created by Netscape are 175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * Copyright (C) 1999-2000 Netscape Communications Corporation. All 185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * Rights Reserved. 195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * Contributor(s): 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * 225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * Alternatively, the contents of this file may be used under the 235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * terms of the GNU General Public License Version 2 or later (the 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * "GPL"), in which case the provisions of the GPL are applicable 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * instead of those above. If you wish to allow use of your 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * version of this file only under the terms of the GPL and not to 275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * allow others to use your version of this file under the MPL, 285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * indicate your decision by deleting the provisions above and 295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * replace them with the notice and other provisions required by 305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * the GPL. If you do not delete the provisions above, a recipient 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * may use your version of this file under either the MPL or the 325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * GPL. 335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) */ 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#ifndef prtpool_h___ 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#define prtpool_h___ 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "prtypes.h" 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "prthread.h" 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "prio.h" 415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "prerror.h" 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * NOTE: 455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * THIS API IS A PRELIMINARY VERSION IN NSPR 4.0 AND IS SUBJECT TO 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * CHANGE 475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) */ 485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)PR_BEGIN_EXTERN_C 505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)typedef struct PRJobIoDesc { 525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) PRFileDesc *socket; 535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) PRErrorCode error; 545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) PRIntervalTime timeout; 555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} PRJobIoDesc; 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)typedef struct PRThreadPool PRThreadPool; 585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)typedef struct PRJob PRJob; 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)typedef void (PR_CALLBACK *PRJobFn) (void *arg); 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* Create thread pool */ 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)NSPR_API(PRThreadPool *) 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)PR_CreateThreadPool(PRInt32 initial_threads, PRInt32 max_threads, 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) PRUint32 stacksize); 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* queue a job */ 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)NSPR_API(PRJob *) 685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)PR_QueueJob(PRThreadPool *tpool, PRJobFn fn, void *arg, PRBool joinable); 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* queue a job, when a socket is readable */ 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)NSPR_API(PRJob *) 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)PR_QueueJob_Read(PRThreadPool *tpool, PRJobIoDesc *iod, 735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) PRJobFn fn, void * arg, PRBool joinable); 745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* queue a job, when a socket is writeable */ 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)NSPR_API(PRJob *) 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)PR_QueueJob_Write(PRThreadPool *tpool, PRJobIoDesc *iod, 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) PRJobFn fn, void * arg, PRBool joinable); 795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* queue a job, when a socket has a pending connection */ 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)NSPR_API(PRJob *) 825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)PR_QueueJob_Accept(PRThreadPool *tpool, PRJobIoDesc *iod, 835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) PRJobFn fn, void * arg, PRBool joinable); 845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* queue a job, when the socket connection to addr succeeds or fails */ 865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)NSPR_API(PRJob *) 875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)PR_QueueJob_Connect(PRThreadPool *tpool, PRJobIoDesc *iod, 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const PRNetAddr *addr, PRJobFn fn, void * arg, PRBool joinable); 895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* queue a job, when a timer exipres */ 915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)NSPR_API(PRJob *) 925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)PR_QueueJob_Timer(PRThreadPool *tpool, PRIntervalTime timeout, 935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) PRJobFn fn, void * arg, PRBool joinable); 945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* cancel a job */ 955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)NSPR_API(PRStatus) 965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)PR_CancelJob(PRJob *job); 975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* join a job */ 995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)NSPR_API(PRStatus) 1005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)PR_JoinJob(PRJob *job); 1015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* shutdown pool */ 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)NSPR_API(PRStatus) 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)PR_ShutdownThreadPool(PRThreadPool *tpool); 1055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* join pool, wait for exit of all threads */ 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)NSPR_API(PRStatus) 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)PR_JoinThreadPool(PRThreadPool *tpool); 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)PR_END_EXTERN_C 1115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#endif /* prtpool_h___ */ 113