tcpthread.cpp
#include <cc++/socket.h>
#include <cstdlib>
#ifdef CCXX_NAMESPACES
using namespace std;
using namespace ost;
#endif
class myTCPSocket : public TCPSocket
{
protected:
bool onAccept(const InetHostAddress &ia, tpport_t port);
public:
myTCPSocket(InetAddress &ia);
};
class myTCPSession : public TCPSession
{
private:
static Mutex mutex;
void run(void);
void final(void);
public:
myTCPSession(TCPSocket &server);
static volatile int count;
};
myTCPSocket::myTCPSocket(InetAddress &ia) : TCPSocket(ia, 4096) {}
bool myTCPSocket::onAccept(const InetHostAddress &ia, tpport_t port)
{
cout << "accepting from: " << ia.getHostname() << ":" << port << endl;;
return true;
}
volatile int myTCPSession::count = 0;
Mutex myTCPSession::mutex;
myTCPSession::myTCPSession(TCPSocket &server) :
TCPSession(server)
{
cout << "creating session client object" << endl;
mutex.enterMutex();
++count;
mutex.leaveMutex();
}
void myTCPSession::run(void)
{
tpport_t port;
IPV4Address addr = getLocal(&port);
*tcp() << "welcome to " << addr.getHostname() << " from socket " << (int)so << endl;
mutex.enterMutex();
*tcp() << "called from thread " << count << endl;
mutex.leaveMutex();
sleep(5000);
*tcp() << "ending session" << endl;
}
void myTCPSession::final(void)
{
}
int main()
{
myTCPSession *tcp;
BroadcastAddress addr;
addr = "255.255.255.255";
cout << "testing addr: " << addr.getHostname() << ":" << 4096 << endl;
addr = "127.0.0.1";
cout << "binding for: " << addr.getHostname() << ":" << 4096 << endl;
try {
myTCPSocket server(addr);
while(server.isPendingConnection(30000)) {
cout << "before create" << endl;
tcp = new myTCPSession(server);
cout << "after create" << endl;
tcp->detach();
}
}
catch(Socket *socket) {
tpport_t port;
int err = socket->getErrorNumber();
InetAddress saddr = (InetAddress)socket->getPeer(&port);
cerr << "socket error " << saddr.getHostname() << ":" << port << " = " << err << endl;
if(err == Socket::errBindingFailed) {
cerr << "bind failed; port busy" << endl;
::exit(-1);
}
else
cerr << "client socket failed" << endl;
}
cout << "timeout after 30 seconds inactivity, exiting" << endl;
return 0;
}