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 kumpf 1.13 #include <Pegasus/Common/Linkage.h>

 39 mike  1.2  
 40            PEGASUS_NAMESPACE_BEGIN
 41            
 42            struct HTTPConnectorRep;
 43            class HTTPConnection;
 44            
 45            /** This class is used by clients to establish a connection with a
 46                server. For each established connection, a HTTPConnection object
 47                is created.
 48            */

 49 mday  1.10 class PEGASUS_COMMON_LINKAGE HTTPConnector : public MessageQueueService

 50 mike  1.2  {

 51 mday  1.4     public:

 52 mday  1.3     

 53 mday  1.10       typedef MessageQueueService Base;

 54 mday  1.3    

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

 82 kumpf 1.14 	  @exception InvalidLocatorException
 83            	  @exception CannotCreateSocketException
 84            	  @exception CannotConnectException

 85 mday  1.4        */

 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 kumpf 1.14 	  @exception InvalidLocatorException
102            	  @exception CannotCreateSocketException
103            	  @exception CannotConnectException

104 kumpf 1.7        */

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

107 kumpf 1.7  	 SSLContext * sslContext,

108 mday  1.4  	 MessageQueue* outputMessageQueue);

109 mike  1.2  

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

112 mike  1.2  

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

116 mday  1.4     private:

117 mike  1.2  

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

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

123 mike  1.2      

124 mday  1.4        SSLContext * _sslcontext;

125 mday  1.12       int _entry_index;
126                  

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