C++ Sockets Library

00001 //InSocket.cpp
00002 /*
00003 Copyright (C) 2004  Anders Hedstrom
00004 
00005 This program is free software; you can redistribute it and/or
00006 modify it under the terms of the GNU General Public License
00007 as published by the Free Software Foundation; either version 2
00008 of the License, or (at your option) any later version.
00009 
00010 This program is distributed in the hope that it will be useful,
00011 but WITHOUT ANY WARRANTY; without even the implied warranty of
00012 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
00013 GNU General Public License for more details.
00014 
00015 You should have received a copy of the GNU General Public License
00016 along with this program; if not, write to the Free Software
00017 Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
00018 */
00019 
00020 //#include <stdio.h>
00021 
00022 #include <ISocketHandler.h>
00023 #include "OutSocket.h"
00024 #include "InSocket.h"
00025 
00026 
00027 
00028 
00029 InSocket::InSocket(ISocketHandler& h)
00030 :TcpSocket(h, 32000, 32000)
00031 ,tmpl(0)
00032 {
00033 }
00034 
00035 
00036 InSocket::~InSocket()
00037 {
00038 }
00039 
00040 
00041 void InSocket::OnAccept()
00042 {
00043         printf(" *** Remote Address: '%s'\n",GetRemoteHostname().c_str());
00044         m_remote = new OutSocket(Handler());
00045 //      m_remote -> Open("159.153.197.91",8888);
00046         m_remote -> Open("127.0.0.1",80);
00047         m_remote -> SetDeleteByHandler();
00048         m_remote -> SetRemote(this);
00049 //      sleep(1);
00050         Handler().Add(m_remote);
00051 }
00052 
00053 
00054 void InSocket::OnDelete()
00055 {
00056         if (Handler().Valid(m_remote))
00057         {
00058                 m_remote -> SetCloseAndDelete();
00059         }
00060 }
00061 
00062 
00063 void InSocket::OnRawData(const char *p,size_t l)
00064 {
00065         if (Handler().Valid(m_remote) && m_remote -> Ready())
00066         {
00067                 if (tmpl)
00068                 {
00069                         m_remote -> SendBuf(tmps, tmpl);
00070                         tmpl = 0;
00071                 }
00072                 m_remote -> SendBuf(p, l);
00073         }
00074         else
00075         {
00076                 Handler().LogError(this, "OnRawData", 0, "m_remote not ready");
00077                 memcpy(tmps + tmpl, p, l);
00078                 tmpl += l;
00079         }
00080 }
00081 
00082