(file) Return to Monitor.cpp CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / Common

Diff for /pegasus/src/Pegasus/Common/Monitor.cpp between version 1.6 and 1.7

version 1.6, 2002/05/08 20:28:44 version 1.7, 2002/05/15 17:15:34
Line 32 
Line 32 
 #include "MessageQueue.h" #include "MessageQueue.h"
 #include "Socket.h" #include "Socket.h"
 #include <Pegasus/Common/Tracer.h> #include <Pegasus/Common/Tracer.h>
   #include <Pegasus/Common/HTTPConnection.h>
  
 #ifdef PEGASUS_OS_TYPE_WINDOWS #ifdef PEGASUS_OS_TYPE_WINDOWS
 # if defined(FD_SETSIZE) && FD_SETSIZE != 1024 # if defined(FD_SETSIZE) && FD_SETSIZE != 1024
Line 82 
Line 83 
 //////////////////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////////////////////
  
 Monitor::Monitor() Monitor::Monitor()
      : _module_handle(0), _controller(0), _async(false)
 { {
     Socket::initializeInterface();     Socket::initializeInterface();
   
     _rep = new MonitorRep;     _rep = new MonitorRep;
     FD_ZERO(&_rep->rd_fd_set);     FD_ZERO(&_rep->rd_fd_set);
     FD_ZERO(&_rep->wr_fd_set);     FD_ZERO(&_rep->wr_fd_set);
Line 100 
Line 101 
     Socket::uninitializeInterface();     Socket::uninitializeInterface();
 } }
  
   
   
   //<<< Tue May 14 20:38:26 2002 mdd >>>
   //  register with module controller
   //  when it is time to enqueue the message,
   // use an async_thread_exec call to
   // isolate the entire if(events) { enqueue -> fd_clear } block
   //  let the thread pool grow and shrink according to load.
   
 Boolean Monitor::run(Uint32 milliseconds) Boolean Monitor::run(Uint32 milliseconds)
 { {
   
   
      // register the monitor as a module to gain access to the cimserver's thread pool
      // <<< Wed May 15 09:52:16 2002 mdd >>>
      while(_module_handle == NULL)
      {
         try
         {
   
            _controller = &(ModuleController::register_module(PEGASUS_QUEUENAME_CONTROLSERVICE,
                                                              PEGASUS_MODULENAME_MONITOR,
                                                              (void *)this,
                                                              0,
                                                              0,
                                                              0,
                                                              &_module_handle));
         }
         catch(AlreadyExists & )
         {
            break;
         }
      }
   
   
 #ifdef PEGASUS_OS_TYPE_WINDOWS #ifdef PEGASUS_OS_TYPE_WINDOWS
  
     // Windows select() has a strange little bug. It returns immediately if     // Windows select() has a strange little bug. It returns immediately if
Line 167 
Line 201 
             Tracer::trace(TRC_HTTP, Tracer::LEVEL4,             Tracer::trace(TRC_HTTP, Tracer::LEVEL4,
                "Monitor::run - Socket Event Detected events = %d", events);                "Monitor::run - Socket Event Detected events = %d", events);
  
   
             MessageQueue* queue = MessageQueue::lookup(_entries[i].queueId);             MessageQueue* queue = MessageQueue::lookup(_entries[i].queueId);
  
               if (!_async)
               {
             if (!queue)             if (!queue)
                 unsolicitSocketMessages(_entries[i].queueId);                 unsolicitSocketMessages(_entries[i].queueId);
   
   
             Message* message = new SocketMessage(socket, events);             Message* message = new SocketMessage(socket, events);
             queue->enqueue(message);             queue->enqueue(message);
  
Line 197 
Line 232 
                    "Monitor::run FD_CLR READ");                    "Monitor::run FD_CLR READ");
             }             }
  
               }
               else
               {
   
                  monitor_dispatch *parms =
                     new monitor_dispatch(this, queue, i, socket, events);
                  _controller->async_thread_exec(*_module_handle, _dispatch, (void *)parms);
               }
             count--;             count--;
             return true;             return true;
         }         }
Line 235 
Line 278 
  
     // Add the entry to the list:     // Add the entry to the list:
  
     _MonitorEntry entry = { socket, queueId };  //    _MonitorEntry entry = { socket, queueId };
       _MonitorEntry entry(socket, queueId);
   
     _entries.append(entry);     _entries.append(entry);
  
     // Success!     // Success!
       ModuleController* controlService =
           new ModuleController(PEGASUS_QUEUENAME_CONTROLSERVICE);
     PEG_METHOD_EXIT();     PEG_METHOD_EXIT();
     return true;     return true;
 } }
Line 279 
Line 325 
     return PEG_NOT_FOUND;     return PEG_NOT_FOUND;
 } }
  
   
   PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL Monitor::_dispatch(void *parm)
   {
   
      Monitor::monitor_dispatch *parms = reinterpret_cast<Monitor::monitor_dispatch *>(parm);
   
      if (! parms->_decoder)
      {
   
         parms->_myself->unsolicitSocketMessages(parms->_myself->_entries[parms->_entry].queueId);
         return(0);
      }
   
      Message* message = new SocketMessage(parms->_socket, parms->_events);
      parms->_decoder->enqueue(message);
   
      if (parms->_events & SocketMessage::WRITE)
      {
         FD_CLR(parms->_socket, &(parms->_myself->_rep->active_wr_fd_set));
         Tracer::trace(TRC_HTTP, Tracer::LEVEL4,
                       "Monitor::run FD_CLR WRITE");
      }
   
      if (parms->_events & SocketMessage::EXCEPTION)
      {
         FD_CLR(parms->_socket, &(parms->_myself->_rep->active_ex_fd_set));
         Tracer::trace(TRC_HTTP, Tracer::LEVEL4,
                       "Monitor::run FD_CLR EXECEPTION");
      }
   
      if (parms->_events & SocketMessage::READ)
      {
         FD_CLR(parms->_socket, &(parms->_myself->_rep->active_rd_fd_set));
         Tracer::trace(TRC_HTTP, Tracer::LEVEL4,
                       "Monitor::run FD_CLR READ");
      }
   
      delete parms;
      return(0);
   }
   
   
   void Monitor::set_async(Boolean async)
   {
      _async = async;
   }
   
 PEGASUS_NAMESPACE_END PEGASUS_NAMESPACE_END

Legend:
Removed from v.1.6  
changed lines
  Added in v.1.7
No CVS admin address has been configured
 Powered by
ViewCVS 0.9.2