\section{tcp.cpp} \footnotesize\begin{verbatim}1 // Copyright (C) 1999-2001 Open Source Telecom Corporation. 2 // 3 // This program is free software; you can redistribute it and/or modify 4 // it under the terms of the GNU General Public License as published by 5 // the Free Software Foundation; either version 2 of the License, or 6 // (at your option) any later version. 7 // 8 // This program is distributed in the hope that it will be useful, 9 // but WITHOUT ANY WARRANTY; without even the implied warranty of 10 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 11 // GNU General Public License for more details. 12 // 13 // You should have received a copy of the GNU General Public License 14 // along with this program; if not, write to the Free Software 15 // Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. 16 // 17 // As a special exception to the GNU General Public License, permission is 18 // granted for additional uses of the text contained in its release 19 // of Common C++. 20 // 21 // The exception is that, if you link the Common C++ library with other 22 // files to produce an executable, this does not by itself cause the 23 // resulting executable to be covered by the GNU General Public License. 24 // Your use of that executable is in no way restricted on account of 25 // linking the Common C++ library code into it. 26 // 27 // This exception does not however invalidate any other reasons why 28 // the executable file might be covered by the GNU General Public License. 29 // 30 // This exception applies only to the code released under the 31 // name Common C++. If you copy code from other releases into a copy of 32 // Common C++, as the General Public License permits, the exception does 33 // not apply to the code that you add in this way. To avoid misleading 34 // anyone as to the status of such modified files, you must delete 35 // this exception notice from them. 36 // 37 // If you write modifications of your own for Common C++, it is your choice 38 // whether to permit this exception to apply to your modifications. 39 // If you do not wish that, delete this exception notice. 40 41 #include <cc++/socket.h> 42 #include <iostream> 43 #include <cstdlib> 44 45 #ifdef CCXX_NAMESPACES 46 using namespace std; 47 using namespace ost; 48 #endif 49 50 class myTCPSocket : public TCPSocket 51 { 52 protected: 53 bool onAccept(const InetHostAddress &ia, tpport_t port); 54 55 public: 56 myTCPSocket(InetAddress &ia); 57 }; 58 59 myTCPSocket::myTCPSocket(InetAddress &ia) : TCPSocket(ia, 4096) 60 { 61 cout << "binding segsize: " << getSegmentSize() << endl; 62 } 63 64 bool myTCPSocket::onAccept(const InetHostAddress &ia, tpport_t port) 65 { 66 cout << "accepting from: " << ia << ":" << port << endl;; 67 return true; 68 } 69 70 int main(int argc, char *argv[]) 71 { 72 tpport_t port; 73 int i; 74 TCPStream tcp; 75 InetAddress addr; 76 addr = "255.255.255.255"; 77 cout << "testing addr: " << addr << ":" << 4096 << endl; 78 79 addr = "127.0.0.1"; 80 cout << "binding for: " << addr << ":" << 4096 << endl; 81 82 Thread::setException(Thread::throwException); 83 84 try 85 { 86 myTCPSocket server(addr); 87 while(server.isPendingConnection(30000)) 88 { 89 tcp.connect(server); 90 91 // tcp.unsetf(ios::binary); 92 tcp << "welcome to " << addr << "; segment size=" << tcp.getSegmentSize() << endl; 93 tcp << "connected from " << tcp.getPeer(&port) << endl; 94 95 if(tcp.isPending(Socket::pendingInput, 2000)) 96 { 97 tcp >> i; 98 tcp << "user entered " << i << endl; 99 } 100 tcp << "exiting now" << endl; 101 tcp.disconnect(); 102 } 103 } 104 catch(SockException& e) 105 { 106 cout << e.getString() << ": " << e.getSystemErrorString() << endl; 107 exit(-1); 108 } 109 cout << "timeout after 30 seconds inactivity, exiting" << endl; 110 return 0; 111 } 112 \end{verbatim} \normalsize