XRootD
XrdScheduler.hh
Go to the documentation of this file.
1 #ifndef ___XRD_SCHED_H___
2 #define ___XRD_SCHED_H___
3 /******************************************************************************/
4 /* */
5 /* X r d S c h e d u l e r . h h */
6 /* */
7 /* (c) 2004 by the Board of Trustees of the Leland Stanford, Jr., University */
8 /* Produced by Andrew Hanushevsky for Stanford University under contract */
9 /* DE-AC02-76-SFO0515 with the Department of Energy */
10 /* */
11 /* This file is part of the XRootD software suite. */
12 /* */
13 /* XRootD is free software: you can redistribute it and/or modify it under */
14 /* the terms of the GNU Lesser General Public License as published by the */
15 /* Free Software Foundation, either version 3 of the License, or (at your */
16 /* option) any later version. */
17 /* */
18 /* XRootD is distributed in the hope that it will be useful, but WITHOUT */
19 /* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or */
20 /* FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public */
21 /* License for more details. */
22 /* */
23 /* You should have received a copy of the GNU Lesser General Public License */
24 /* along with XRootD in a file called COPYING.LESSER (LGPL license) and file */
25 /* COPYING (GPL license). If not, see <http://www.gnu.org/licenses/>. */
26 /* */
27 /* The copyright holder's institutional names and contributor's names may not */
28 /* be used to endorse or promote products derived from this software without */
29 /* specific prior written permission of the institution or contributor. */
30 /******************************************************************************/
31 
32 #include <unistd.h>
33 #include <sys/types.h>
34 
35 #include "XrdSys/XrdSysPthread.hh"
36 #include "Xrd/XrdJob.hh"
37 
38 class XrdOucTrace;
39 class XrdSchedulerPID;
40 class XrdSysError;
41 class XrdSysTrace;
42 
43 #define MAX_SCHED_PROCS 30000
44 
45 class XrdScheduler : public XrdJob
46 {
47 public:
48 
49 int Active() {return num_Workers - idl_Workers + num_JobsinQ;}
50 
51 void Cancel(XrdJob *jp);
52 
53 inline int canStick() {return num_Workers < stk_Workers
54  || (num_Workers-idl_Workers) < stk_Workers;}
55 
56 void DoIt();
57 
58 pid_t Fork(const char *id);
59 
60 void *Reaper();
61 
62 void Run();
63 
64 void Schedule(XrdJob *jp);
65 void Schedule(int num, XrdJob *jfirst, XrdJob *jlast);
66 void Schedule(XrdJob *jp, time_t atime);
67 
68 void setParms(int minw, int maxw, int avlt, int maxi, int once=0);
69 
70 void Start();
71 
72 int Stats(char *buff, int blen, int do_sync=0);
73 
74 void TimeSched();
75 
76 // Statistical information
77 //
78 int num_TCreate; // Number of threads created
79 int num_TDestroy;// Number of threads destroyed
80 int num_Jobs; // Number of jobs scheduled
81 int max_QLength; // Longest queue length we had
82 int num_Limited; // Number of times max was reached
83 
84 // This is the preferred constructor
85 //
87  int minw=8, int maxw=8192, int maxi=780);
88 
89 // This constructor is only maintained for ABI compatibility and will be
90 // removed in a future major release. While syntactically compatible the
91 // sematics now are slightly different and tracing might not occur.
92 //
94  int minw=8, int maxw=8192, int maxi=780);
95 
96 // This constructor is used for a stand-alone scheduler.
97 //
98  XrdScheduler(int minw=3, int maxw=128, int maxi=12);
99 
100  ~XrdScheduler();
101 
102 private:
103 XrdSysError *XrdLog;
104 XrdSysTrace *XrdTrace;
105 XrdOucTrace *XrdTraceOld; // This is only used for ABI compatibility
106 
107 XrdSysMutex DispatchMutex; // Disp: Protects above area
108 int idl_Workers; // Disp: Number of idle workers
109 
110 int min_Workers; // Sched: Min threads we need to have
111 int max_Workers; // Sched: Max threads we can start
112 int max_Workidl; // Sched: Max idle time for threads above min_Workers
113 int num_Workers; // Sched: Number of threads we have
114 int stk_Workers; // Sched: Number of sticky workers we can have
115 int num_JobsinQ; // Sched: Number of outstanding jobs in the queue
116 int num_Layoffs; // Sched: Number of threads to terminate
117 
118 XrdJob *WorkFirst; // Pending work
119 XrdJob *WorkLast;
120 XrdSysSemaphore WorkAvail;
121 XrdSysMutex SchedMutex; // Protects private area
122 
123 XrdJob *TimerQueue; // Pending work
124 XrdSysCondVar TimerRings;
125 XrdSysMutex TimerMutex; // Protects scheduler area
126 
127 XrdSchedulerPID *firstPID;
128 XrdSysMutex ReaperMutex;
129 
130 void Boot(XrdSysError *eP, XrdSysTrace *tP, int minw, int maxw, int maxi);
131 void hireWorker(int dotrace=1);
132 void Init(int minw, int maxw, int maxi);
133 void Monitor();
134 void traceExit(pid_t pid, int status);
135 static const char *TraceID;
136 };
137 #endif
Definition: XrdJob.hh:43
friend class XrdScheduler
Definition: XrdJob.hh:44
int Stats(char *buff, int blen, int do_sync=0)
void Schedule(XrdJob *jp)
void TimeSched()
void setParms(int minw, int maxw, int avlt, int maxi, int once=0)
void Cancel(XrdJob *jp)
void * Reaper()
pid_t Fork(const char *id)