Logo ROOT   6.14/05
Reference Guide
TXSocketHandler.cxx
Go to the documentation of this file.
1 // @(#)root/proofx:$Id$
2 // Author: Gerardo Ganis 12/12/2005
3 
4 /*************************************************************************
5  * Copyright (C) 1995-2005, Rene Brun and Fons Rademakers. *
6  * All rights reserved. *
7  * *
8  * For the licensing terms see $ROOTSYS/LICENSE. *
9  * For the list of contributors see $ROOTSYS/README/CREDITS. *
10  *************************************************************************/
11 
12 /** \class TXSocketHandler
13 \ingroup proofx
14 
15 Input handler for XProofD sockets. These sockets cannot be directly
16 monitored on their descriptor, because the reading activity goes via
17 the internal reader thread. This class allows to handle the related issue.
18 
19 */
20 
21 #include "TMonitor.h"
22 #include "TProof.h"
23 #include "TSlave.h"
24 #include "TXSocketHandler.h"
25 #include "TXHandler.h"
26 #include "TList.h"
27 
28 
30 
31 // Unique instance of the socket input handler
33 
34 ////////////////////////////////////////////////////////////////////////////////
35 /// Set readiness on the monitor
36 
38 {
39  if (gDebug > 2)
41 
42  // Get the socket
44  if (gDebug > 2)
45  Info("Notify", "ready socket %p (%s) (input socket: %p) (fFileNum: %d)",
46  s, (s ? s->GetTitle() : "***undef***"), fInputSock, fFileNum);
47 
48  // If empty, nothing to do
49  if (!s) {
50  Warning("Notify","socket-ready list is empty!");
51  return kTRUE;
52  }
53 
54  // Handle this input
55  s->fHandler->HandleInput();
56 
57  // We are done
58  return kTRUE;
59 }
60 
61 ////////////////////////////////////////////////////////////////////////////////
62 /// Get an instance of the input socket handler with 'h' as handler,
63 /// connected to socket 's'.
64 /// Create the instance, if not already existing
65 
67 {
68  if (!fgSocketHandler)
69  fgSocketHandler = new TXSocketHandler(h, s);
70  else
71  if (h && s)
73 
74  return fgSocketHandler;
75 }
virtual void Info(const char *method, const char *msgfmt,...) const
Issue info message.
Definition: TObject.cxx:854
static TXSocketHandler * GetSocketHandler(TFileHandler *h=0, TSocket *s=0)
Get an instance of the input socket handler with 'h' as handler, connected to socket 's'...
bool Bool_t
Definition: RtypesCore.h:59
TXSocket * GetLastReady()
Return last ready socket.
Definition: TXSocket.cxx:2393
void SetHandler(TFileHandler *h, TSocket *s)
TXHandler * fHandler
Definition: TXSocket.h:80
Bool_t Notify()
Set readiness on the monitor.
virtual Bool_t HandleInput(const void *in=0)
Handler of asynchronous input events.
Definition: TXHandler.cxx:28
static TXSocketHandler * fgSocketHandler
Input handler for XProofD sockets.
High level handler of connections to XProofD.
Definition: TXSocket.h:59
#define h(i)
Definition: RSha256.hxx:106
#define ClassImp(name)
Definition: Rtypes.h:359
static constexpr double s
void DumpReadySock()
Dump content of the ready socket list.
Definition: TXSocket.cxx:2378
TSocket * fInputSock
static TXSockPipe fgPipe
Definition: TXSocket.h:111
R__EXTERN Int_t gDebug
Definition: Rtypes.h:86
const Bool_t kTRUE
Definition: RtypesCore.h:87
TXSocketHandler(TFileHandler *h, TSocket *s)
virtual void Warning(const char *method, const char *msgfmt,...) const
Issue warning message.
Definition: TObject.cxx:866
virtual const char * GetTitle() const
Returns title of object.
Definition: TNamed.h:48