/home/toby/moos-ivp/MOOS-2375-Oct0611/Core/MOOSLIB/MOOSCommServer.h

Go to the documentation of this file.

//
//   MOOS - Mission Oriented Operating Suite
//
//   A suit of Applications and Libraries for Mobile Robotics Research
//   Copyright (C) 2001-2005 Massachusetts Institute of Technology and
//   Oxford University.
//
//   This software was written by Paul Newman at MIT 2001-2002 and Oxford
//   University 2003-2005. email: pnewman@robots.ox.ac.uk.
//
//   This file is part of a  MOOS Core Component.
//
//   This program is free software; you can redistribute it and/or
//   modify it under the terms of the GNU General Public License as
//   published by the Free Software Foundation; either version 2 of the
//   License, or (at your option) any later version.
//
//   This program is distributed in the hope that it will be useful,
//   but WITHOUT ANY WARRANTY; without even the implied warranty of
//   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
//   General Public License for more details.
//
//   You should have received a copy of the GNU General Public License
//   along with this program; if not, write to the Free Software
//   Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
//   02111-1307, USA.
//
// MOOSCommServer.h: interface for the CMOOSCommServer class.
//

#if !defined(AFX_MOOSCOMMSERVER_H__2FDF870F_F998_4D3C_AD18_FCC2C5C12DDA__INCLUDED_)
#define AFX_MOOSCOMMSERVER_H__2FDF870F_F998_4D3C_AD18_FCC2C5C12DDA__INCLUDED_

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000


#ifdef _WIN32
    #include <winsock2.h>
    #include "windows.h"
    #include "winbase.h"
    #include "winnt.h"
#else
    #include <sys/time.h>
    #include <pthread.h>
#endif

#include "MOOSCommObject.h"
#include "MOOSCommPkt.h"
#include <MOOSGenLib/MOOSLock.h>

#include <MOOSGenLib/MOOSThread.h>

class XPCTcpSocket;
#include <list>
#include <map>
//using namespace std;

class CMOOSCommServer  : public CMOOSCommObject
{
public:
    typedef std::list<XPCTcpSocket*> SOCKETLIST;
    typedef std::map<int,std::string > SOCKETFD_2_CLIENT_NAME_MAP;
    typedef std::list<std::string > STRING_LIST;

    bool GetClientNames(STRING_LIST & sList);

    void SetOnRxCallBack(bool (*pfn)(const std::string  & sClient,MOOSMSG_LIST & MsgListRx,MOOSMSG_LIST & MsgListTx,void * pParam),void * pParam);

    void SetOnDisconnectCallBack(bool (*pfn)(std::string  & sClient,void * pParam),void * pParam);

    bool ListenLoop();

    bool ServerLoop();

    bool TimerLoop();


    bool Run(long lPort,const std::string  & sCommunityName, bool bDisableNameLookUp = false);
    
    
    void SetQuiet(bool bQ){m_bQuiet = bQ;};


    CMOOSCommServer();

    virtual ~CMOOSCommServer();

protected:
    CMOOSLock m_SocketListLock;

    int GetMaxSocketFD();

    virtual void DoBanner();

    std::string  GetClientName(XPCTcpSocket* pSocket);

    void PoisonClient(XPCTcpSocket* pSocket,const std::string & sReason);

    bool HandShake(XPCTcpSocket* pNewSocket);

    bool IsUniqueName(std::string  & sClientName);

    int m_nTotalActions;

    virtual bool OnClientDisconnect();

    virtual bool OnAbsentClient(XPCTcpSocket* pClient);

    CMOOSThread m_ListenThread;

    CMOOSThread m_ServerThread;

    CMOOSThread m_TimerThread;

    bool (*m_pfnRxCallBack)(const std::string  & sClient,MOOSMSG_LIST & MsgListRx,MOOSMSG_LIST & MsgListTx,void * pCaller);

    void * m_pRxCallBackParam;


    bool (*m_pfnDisconnectCallBack)(std::string  & sClient,void * pParam);

    void * m_pDisconnectCallBackParam;

    XPCTcpSocket * m_pListenSocket;

    XPCTcpSocket * m_pFocusSocket;

    SOCKETLIST    m_ClientSocketList;


    SOCKETFD_2_CLIENT_NAME_MAP m_Socket2ClientMap;

    virtual bool    OnNewClient(XPCTcpSocket * pNewClient,char * sName);

    virtual bool    ProcessClient();

    long    m_lListenPort;

    bool    m_bQuit;

    int        m_nMaxSocketFD;

    bool    StartThreads();

        bool m_bDisableNameLookUp;

    std::string  m_sCommunityName;
    
    
    
    bool m_bQuiet;
};

#endif // !defined(AFX_MOOSCOMMSERVER_H__2FDF870F_F998_4D3C_AD18_FCC2C5C12DDA__INCLUDED_)