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

Diff for /pegasus/src/Pegasus/DynListener/DynamicListener.cpp between version 1.6 and 1.7

version 1.6, 2006/04/18 19:08:43 version 1.7, 2008/01/15 18:19:34
Line 27 
Line 27 
 // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 // //
 //==============================================================================  //=============================================================================
 // //
 // Author: Heather Sterling (hsterl@us.ibm.com) // Author: Heather Sterling (hsterl@us.ibm.com)
 // //
 // Modified By: // Modified By:
 // //
 //%/////////////////////////////////////////////////////////////////////////////  //%////////////////////////////////////////////////////////////////////////////
  
 #include "DynamicListener.h" #include "DynamicListener.h"
 #include "ListenerService.h" #include "ListenerService.h"
Line 89 
Line 89 
  
     Boolean isAlive();     Boolean isAlive();
  
     Boolean addConsumer(const String& consumerName, const String& location = String::EMPTY);      Boolean addConsumer(
                   const String& consumerName,
                   const String& location = String::EMPTY);
  
     Boolean removeConsumer(const String& consumerName);     Boolean removeConsumer(const String& consumerName);
  
Line 118 
Line 120 
     SSLContext* _sslContext;     SSLContext* _sslContext;
 }; };
  
 DynamicListenerRep::DynamicListenerRep(Uint32 portNumber,  DynamicListenerRep::DynamicListenerRep(
       Uint32 portNumber,
                                        const String& consumerDir,           //consumer mgr                                        const String& consumerDir,           //consumer mgr
                                        const String& consumerConfigDir,     //consumer mgr                                        const String& consumerConfigDir,     //consumer mgr
                                        SSLContext* sslContext,              //listener svc                                        SSLContext* sslContext,              //listener svc
                                        Boolean enableConsumerUnload,        //consumer mgr                                        Boolean enableConsumerUnload,        //consumer mgr
                                        Uint32 consumerIdleTimeout,          //consumer mgr                                        Uint32 consumerIdleTimeout,          //consumer mgr
                                        Uint32 shutdownTimeout) :            //???      Uint32 shutdownTimeout) : _port(portNumber), _sslContext(sslContext)
 _port(portNumber),  
 _sslContext(sslContext)  
 { {
     PEG_METHOD_ENTER(TRC_LISTENER, "DynamicListenerRep::DynamicListenerRep");     PEG_METHOD_ENTER(TRC_LISTENER, "DynamicListenerRep::DynamicListenerRep");
  
     _consumerManager = new ConsumerManager(consumerDir, consumerConfigDir, enableConsumerUnload, consumerIdleTimeout);      _consumerManager = new ConsumerManager(
                                  consumerDir,
                                  consumerConfigDir,
                                  enableConsumerUnload,
                                  consumerIdleTimeout);
  
     _listenerService = new ListenerService(_consumerManager);     _listenerService = new ListenerService(_consumerManager);
  
Line 181 
Line 186 
 } }
  
 //TODO: //TODO:
 Boolean DynamicListenerRep::addConsumer(const String& consumerName, const String& location)  Boolean DynamicListenerRep::addConsumer(
               const String& consumerName,
               const String& location)
 { {
     return true;     return true;
     //return _consumerManager->addConsumer(consumerName, location);     //return _consumerManager->addConsumer(consumerName, location);
Line 251 
Line 258 
 } }
  
 #ifdef PEGASUS_HAS_SSL #ifdef PEGASUS_HAS_SSL
 DynamicListener::DynamicListener(Uint32 portNumber,  DynamicListener::DynamicListener(
       Uint32 portNumber,
                                  const String& consumerDir,                                  const String& consumerDir,
                                  const String& consumerConfigDir,                                  const String& consumerConfigDir,
                                  Boolean useSSL,                                  Boolean useSSL,
Line 264 
Line 272 
     SSLContext* sslContext = 0;     SSLContext* sslContext = 0;
     if (useSSL)     if (useSSL)
     {     {
         sslContext = new SSLContext(String::EMPTY, certPath, keyPath, 0, String::EMPTY);//randFile);          sslContext = new SSLContext(
                                String::EMPTY,
                                certPath,
                                keyPath,
                                0,
                                String::EMPTY); //randFile);
     }     }
  
     _rep = new DynamicListenerRep(portNumber,     _rep = new DynamicListenerRep(portNumber,
Line 276 
Line 289 
                                   shutdownTimeout);                                   shutdownTimeout);
 } }
  
 DynamicListener::DynamicListener(Uint32 portNumber,  DynamicListener::DynamicListener(
       Uint32 portNumber,
                                  const String& consumerDir,                                  const String& consumerDir,
                                  const String& consumerConfigDir,                                  const String& consumerConfigDir,
                                  Boolean useSSL,                                  Boolean useSSL,
Line 315 
Line 329 
     return static_cast<DynamicListenerRep*>(_rep)->isAlive();     return static_cast<DynamicListenerRep*>(_rep)->isAlive();
 } }
  
 Boolean DynamicListener::addConsumer(const String& consumerName, const String& location)  Boolean DynamicListener::addConsumer(
 {      const String& consumerName,
     return static_cast<DynamicListenerRep*>(_rep)->addConsumer(consumerName, location);      const String& location)
   {
       return static_cast<DynamicListenerRep*>(_rep)->addConsumer(
                                                          consumerName,
                                                          location);
 } }
  
 Boolean DynamicListener::removeConsumer(const String& consumerName) Boolean DynamicListener::removeConsumer(const String& consumerName)
 { {
     return static_cast<DynamicListenerRep*>(_rep)->removeConsumer(consumerName);      return static_cast<DynamicListenerRep*>(_rep)->removeConsumer(
                                                          consumerName);
 } }
  
 Uint32 DynamicListener::getPortNumber() Uint32 DynamicListener::getPortNumber()
Line 342 
Line 361 
  
 void DynamicListener::setEnableConsumerUnload(const Boolean consumerUnload) void DynamicListener::setEnableConsumerUnload(const Boolean consumerUnload)
 { {
     static_cast<DynamicListenerRep*>(_rep)->setEnableConsumerUnload(consumerUnload);      static_cast<DynamicListenerRep*>(_rep)->setEnableConsumerUnload(
                                                   consumerUnload);
 } }
  
 Boolean DynamicListener::getEnableConsumerUnload() Boolean DynamicListener::getEnableConsumerUnload()

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