Generated/html/netserver_8h_source.html

#pragma once


/*+

________________________________________________________________________


 (C) dGB Beheer B.V.; (LICENSE) http://opendtect.org/OpendTect_license.txt

 Author:        Nanne Hemstra

 Date:          March 2009

 RCS:           $Id$

________________________________________________________________________


-*/


#include "networkcommon.h"


mFDQtclass(QTcpSocket)

mFDQtclass(QTcpServer)

mFDQtclass(QLocalSocket)

mFDQtclass(QLocalServer)

mFDQtclass(QTcpServerComm)


namespace Network

{


class Socket;


mExpClass(Network) Server : public CallBacker

{ mODTextTranslationClass(Server)

public:

                        Server(bool islocal);

                        ~Server();


    bool                listen(SpecAddr=Any,PortNr_Type port=0);

    bool                listen(const char* servernm,uiRetVal&);

    bool                isListening() const;

    PortNr_Type         port() const;

    Authority           authority() const;

    bool                isLocal() const { return qlocalserver_; }


    void                close();

    bool                hasPendingConnections() const;

    int                 write(int id,const char*);

    int                 write(int id,const IOPar&);

    void                read(int id,BufferString&) const;

    void                read(int id,IOPar&) const;

    const char*         errorMsg() const;


    Socket*             getSocket(int id);

    const Socket*       getSocket(int id) const;


    CNotifier<Server,int> newConnection;

    CNotifier<Server,int> readyRead;


    mQtclass(QTcpSocket)* nextPendingConnection();

    mQtclass(QLocalSocket)* nextPendingLocalConnection();


    bool                waitForNewConnection(int msec);


    static const char*  sKeyHostName()          { return "hostname"; }

    static const char*  sKeyNoListen()          { return "no-listen"; }

    static const char*  sKeyPort()              { return "port"; }

    static const char*  sKeyTimeout()           { return "timeout"; }

    static const char*  sKeyKillword()          { return "kill"; }

    static const char*  sKeyLocal()             { return "local"; }


protected:


    void                notifyNewConnection();

    void                readyReadCB(CallBacker*);

    void                disconnectCB(CallBacker*);


    mQtclass(QTcpServer)* qtcpserver_       = nullptr;

    mQtclass(QLocalServer)* qlocalserver_   = nullptr;

    mQtclass(QTcpServerComm)* comm_;

    mutable BufferString errmsg_;

    ObjectSet<Socket>   sockets_;

    TypeSet<int>        ids_;

    ObjectSet<Socket>   sockets2bdeleted_;


    friend class        mQtclass(QTcpServerComm);


};


} // namespace Network