1 kumpf 1.11 //%/////////////////////////////////////////////////////////////////////////////

  2 mike  1.2  //

  3 kumpf 1.11 // Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Company, IBM,

  4 mike  1.2  // The Open Group, Tivoli Systems
  5            //
  6            // Permission is hereby granted, free of charge, to any person obtaining a copy

  7 kumpf 1.11 // of this software and associated documentation files (the "Software"), to
  8            // deal in the Software without restriction, including without limitation the
  9            // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or

 10 mike  1.2  // sell copies of the Software, and to permit persons to whom the Software is
 11            // furnished to do so, subject to the following conditions:
 12            // 

 13 kumpf 1.11 // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN

 14 mike  1.2  // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED
 15            // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT

 16 kumpf 1.11 // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
 17            // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
 18            // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN

 19 mike  1.2  // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
 20            // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 21            //
 22            //==============================================================================
 23            //
 24            // Author: Mike Brasher (mbrasher@bmc.com)
 25            //
 26            // Modified By:
 27            //
 28            //%/////////////////////////////////////////////////////////////////////////////
 29            
 30            #ifndef Pegasus_HTTPConnector_h
 31            #define Pegasus_HTTPConnector_h
 32            
 33            #include <Pegasus/Common/Config.h>

 34 mday  1.3  #include <Pegasus/Common/MessageQueueService.h>

 35 mike  1.2  #include <Pegasus/Common/Monitor.h>
 36            #include <Pegasus/Common/String.h>
 37            #include <Pegasus/Common/TLS.h>
 38            
 39            PEGASUS_NAMESPACE_BEGIN
 40            
 41            struct HTTPConnectorRep;
 42            class HTTPConnection;
 43            
 44            /** This class is used by clients to establish a connection with a
 45                server. For each established connection, a HTTPConnection object
 46                is created.
 47            */

 48 mday  1.10 class PEGASUS_COMMON_LINKAGE HTTPConnector : public MessageQueueService

 49 mike  1.2  {

 50 mday  1.4     public:

 51 mday  1.3     

 52 mday  1.10       typedef MessageQueueService Base;

 53 mday  1.3    

 54 mday  1.4        /** Constructor.
 55            	  @param monitor pointer to monitor object which this class uses to
 56            	  solicit SocketMessages on the server port (socket).
 57            	  @param outputMessageQueue ouptut message queue for connections
 58            	  created by this connector.
 59                  */
 60                  HTTPConnector(Monitor* monitor);
 61            
 62                  HTTPConnector(Monitor* monitor, SSLContext * sslcontext);
 63            
 64                  /** Destructor. */
 65                  ~HTTPConnector();
 66            
 67                  /** This method is called whenever a SocketMessage is enqueued
 68            	  on the input queue of the HTTPConnector object.
 69                  */ 
 70            
 71                  virtual void handleEnqueue(Message *);
 72                  virtual void handleEnqueue();
 73            
 74                  /** Establishes a new connection and creates an HTTPConnection object
 75 mday  1.4  	  to represent it.
 76            
 77            	  @param locator indicates which server to connect to (of the form
 78            	  host:port).
 79            	  @param outputMessageQueue output message queue for the HTTPConnection
 80            	  that will be created.
 81            	  @exception InvalidLocator
 82            	  @exception CannotCreateSocket
 83            	  @exception CannotConnect
 84            	  @exception UnexpectedFailure
 85                  */

 86 kumpf 1.7        inline HTTPConnection* connect(
 87            	 const String& locator, 
 88            	 MessageQueue* outputMessageQueue)
 89                  {
 90                      return connect(locator, NULL, outputMessageQueue);
 91                  }
 92            
 93                  /** Establishes a new connection and creates an HTTPConnection object
 94            	  to represent it.
 95            
 96            	  @param locator indicates which server to connect to (of the form
 97            	  host:port).
 98            	  @param sslContext Specifies the SSL context to use for this connection
 99            	  @param outputMessageQueue output message queue for the HTTPConnection
100            	  that will be created.
101            	  @exception InvalidLocator
102            	  @exception CannotCreateSocket
103            	  @exception CannotConnect
104            	  @exception UnexpectedFailure
105                  */

106 mday  1.4        HTTPConnection* connect(
107            	 const String& locator, 

108 kumpf 1.7  	 SSLContext * sslContext,

109 mday  1.4  	 MessageQueue* outputMessageQueue);

110 mike  1.2  

111 mday  1.4        /** Destroys all the connections created by this connector. */
112                  void destroyConnections();

113 mike  1.2  

114 kumpf 1.5        /** Close the specified connection. */
115                  void disconnect(HTTPConnection* connection);
116            

117 mday  1.4     private:

118 mike  1.2  

119 kumpf 1.6        /** Delete the specified connection. */
120                  void _deleteConnection(HTTPConnection* httpConnection);
121            

122 mday  1.4        Monitor* _monitor;
123                  HTTPConnectorRep* _rep;

124 mike  1.2      

125 mday  1.4        SSLContext * _sslcontext;

126 mday  1.12       int _entry_index;
127                  

128 mike  1.2  };
129            
130            PEGASUS_NAMESPACE_END
131            
132            #endif /* Pegasus_HTTPConnector_h */