00001 // Copyright (C) 1999-2005 Open Source Telecom Corporation. 00002 // Copyright (C) 2006-2008 David Sugar, Tycho Softworks. 00003 // 00004 // This program is free software; you can redistribute it and/or modify 00005 // it under the terms of the GNU General Public License as published by 00006 // the Free Software Foundation; either version 2 of the License, or 00007 // (at your option) any later version. 00008 // 00009 // This program is distributed in the hope that it will be useful, 00010 // but WITHOUT ANY WARRANTY; without even the implied warranty of 00011 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 00012 // GNU General Public License for more details. 00013 // 00014 // You should have received a copy of the GNU General Public License 00015 // along with this program; if not, write to the Free Software 00016 // Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. 00017 // 00018 // As a special exception to the GNU General Public License, permission is 00019 // granted for additional uses of the text contained in its release 00020 // of Common C++. 00021 // 00022 // The exception is that, if you link the Common C++ library with other 00023 // files to produce an executable, this does not by itself cause the 00024 // resulting executable to be covered by the GNU General Public License. 00025 // Your use of that executable is in no way restricted on account of 00026 // linking the Common C++ library code into it. 00027 // 00028 // This exception does not however invalidate any other reasons why 00029 // the executable file might be covered by the GNU General Public License. 00030 // 00031 // This exception applies only to the code released under the 00032 // name Common C++. If you copy code from other releases into a copy of 00033 // Common C++, as the General Public License permits, the exception does 00034 // not apply to the code that you add in this way. To avoid misleading 00035 // anyone as to the status of such modified files, you must delete 00036 // this exception notice from them. 00037 // 00038 // If you write modifications of your own for Common C++, it is your choice 00039 // whether to permit this exception to apply to your modifications. 00040 // If you do not wish that, delete this exception notice. 00041 00042 #include <cc++/socket.h> 00043 #include <iostream> 00044 #include <cstdlib> 00045 00046 #ifdef CCXX_NAMESPACES 00047 using namespace std; 00048 using namespace ost; 00049 #endif 00050 00051 class myTCPSocket : public TCPSocket 00052 { 00053 protected: 00054 bool onAccept(const InetHostAddress &ia, tpport_t port); 00055 00056 public: 00057 myTCPSocket(InetAddress &ia); 00058 }; 00059 00060 myTCPSocket::myTCPSocket(InetAddress &ia) : TCPSocket(ia, 4096) 00061 { 00062 cout << "binding segsize: " << getSegmentSize() << endl; 00063 } 00064 00065 bool myTCPSocket::onAccept(const InetHostAddress &ia, tpport_t port) 00066 { 00067 cout << "accepting from: " << ia << ":" << port << endl;; 00068 return true; 00069 } 00070 00071 int main(int argc, char *argv[]) 00072 { 00073 tpport_t port; 00074 int i; 00075 TCPStream tcp; 00076 InetAddress addr; 00077 addr = "255.255.255.255"; 00078 cout << "testing addr: " << addr << ":" << 4096 << endl; 00079 00080 addr = "127.0.0.1"; 00081 cout << "binding for: " << addr << ":" << 4096 << endl; 00082 00083 Thread::setException(Thread::throwException); 00084 00085 try { 00086 myTCPSocket server(addr); 00087 while(server.isPendingConnection(30000)) { 00088 tcp.connect(server); 00089 00090 // tcp.unsetf(ios::binary); 00091 tcp << "welcome to " << addr << "; segment size=" << tcp.getSegmentSize() << endl; 00092 tcp << "connected from " << tcp.getPeer(&port) << endl; 00093 00094 if(tcp.isPending(Socket::pendingInput, 2000)) { 00095 tcp >> i; 00096 tcp << "user entered " << i << endl; 00097 } 00098 tcp << "exiting now" << endl; 00099 tcp.disconnect(); 00100 } 00101 } 00102 catch(SockException& e) { 00103 cout << e.getString() << ": " << e.getSystemErrorString() << endl; 00104 exit(-1); 00105 } 00106 cout << "timeout after 30 seconds inactivity, exiting" << endl; 00107 return 0; 00108 } 00109