00001 /* -*- C++ -*- */ 00002 00003 /* 00004 * The Apache Software License, Version 1.1 00005 * 00006 * 00007 * Copyright (c) 2002 The Apache Software Foundation. All rights 00008 * reserved. 00009 * 00010 * Redistribution and use in source and binary forms, with or without 00011 * modification, are permitted provided that the following conditions 00012 * are met: 00013 * 00014 * 1. Redistributions of source code must retain the above copyright 00015 * notice, this list of conditions and the following disclaimer. 00016 * 00017 * 2. Redistributions in binary form must reproduce the above copyright 00018 * notice, this list of conditions and the following disclaimer in 00019 * the documentation and/or other materials provided with the 00020 * distribution. 00021 * 00022 * 3. The end-user documentation included with the redistribution, 00023 * if any, must include the following acknowledgment: 00024 * "This product includes software developed by the 00025 * Apache Software Foundation (http://www.apache.org/)." 00026 * Alternately, this acknowledgment may appear in the software itself, 00027 * if and wherever such third-party acknowledgments normally appear. 00028 * 00029 * 4. The names "SOAP" and "Apache Software Foundation" must 00030 * not be used to endorse or promote products derived from this 00031 * software without prior written permission. For written 00032 * permission, please contact apache@apache.org. 00033 * 00034 * 5. Products derived from this software may not be called "Apache", 00035 * nor may "Apache" appear in their name, without prior written 00036 * permission of the Apache Software Foundation. 00037 * 00038 * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED 00039 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES 00040 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 00041 * DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR 00042 * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 00043 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT 00044 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF 00045 * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND 00046 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, 00047 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT 00048 * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 00049 * SUCH DAMAGE. 00050 * ==================================================================== 00051 * 00052 * This software consists of voluntary contributions made by many 00053 * individuals on behalf of the Apache Software Foundation. For more 00054 * information on the Apache Software Foundation, please see 00055 * <http://www.apache.org/>. 00056 */ 00057 00058 /* 00059 * 00060 * 00061 * @author Lilantha Darshana (lilantha@virtusa.com) 00062 * @author Damitha Kumarage (damitha@jkcsworld.com, damitha@opensource.lk) 00063 * 00064 */ 00065 00066 #if !defined(_AXIS_CHANNEL_HPP) 00067 #define _AXIS_CHANNEL_HPP 00068 00069 #include <string> 00070 #include "Transport.hpp" 00071 00072 // platform specific stuff 00073 00074 #ifdef WIN32 00075 00076 #include <winsock2.h> 00077 00078 // what version of WinSock is required 00079 const int WS_VERSION_REQD = 0x0101; 00080 00081 // macros to get version major & minor 00082 inline WS_VERSION_MAJOR() {return HIBYTE(WS_VERSION_REQD);} 00083 inline WS_VERSION_MINOR() {return LOBYTE(WS_VERSION_REQD);} 00084 00085 00086 #else 00087 00088 #include <unistd.h> 00089 #include <sys/types.h> // basic system data types 00090 #include <sys/socket.h> // basic socket definitions 00091 #include <fcntl.h> // for nonblocking if need 00092 #include <netdb.h> 00093 #include <netinet/in.h> 00094 #include <arpa/inet.h> // inet(3) functions 00095 00096 const unsigned int INVALID_SOCKET = 0; 00097 const int SOCKET_ERROR = -1; 00098 00099 // Other OS specific stuff goes here 00100 00101 00102 00103 #endif 00104 00105 00115 class ChannelException 00116 { 00117 public: 00119 ChannelException(std::string p_Err){m_Error = p_Err;} 00120 ~ChannelException(){} 00121 00123 const std::string& GetErr(){return m_Error;} 00124 00125 private: 00126 00127 std::string m_Error; 00128 }; 00129 00140 class Channel 00141 { 00142 public: 00143 Channel(); 00144 virtual ~Channel(); 00145 00147 virtual bool Open(std::string& p_RemoteNode, unsigned short p_RemoteEnd) throw (ChannelException); 00148 00150 virtual void Close(){CloseChannel();} 00151 00153 virtual const Channel& operator >> (std::string& msg); 00154 00156 virtual const Channel& operator << (const char* msg); 00157 00159 virtual const std::string& GetLastError(){return m_LastErr;} 00160 00162 virtual void SetTransportHandler(Transport* transport){m_pTransportHandler = transport;} 00163 00164 protected: 00166 virtual bool Init(); 00167 00169 virtual void Error(const char * err); 00170 00172 virtual void CloseChannel(); 00173 00174 unsigned int m_Sock; 00175 std::string m_RemoteNode; 00176 unsigned short m_RemoteEnd; 00177 std::string m_LastErr; 00178 00179 Transport * m_pTransportHandler; 00180 }; 00181 00182 00183 00184 00185 #endif // _AXIS_CHANNEL_HPP 00186 00187