tcpserver.h

Go to the documentation of this file.

// -*- mode: c++; indent-tabs-mode: nil; c-basic-offset: 4; coding: iso-8859-1; -*-

/*
ACT-CV - Machine Vision for Cognitive Modeling
Copyright (c) 2008 Marc Halbruegge

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., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
*/


#ifndef __TCPSERVER_H
#define __TCPSERVER_H

#ifdef _WINDOWS
#include <winsock.h>
#else
#define SOCKET int
#endif

#include <stdexcept>

#include <garbagecoll.h>
#include <GCString.h>
#include <Threads/Mutex.h>
#include <Threads/ThreadSafeQueue.h>

#include <config.h>

#ifndef _WINDOWS
# define HANDLE int
#endif

class ServerError : public std::runtime_error {
public:
    ServerError(const char *s) : std::runtime_error(s) {
    }
};

class ActCvServer {
    friend struct ActCvServerAutoStop;

    static ActCvServer *singleInstance;
    ActCvServer();
    ~ActCvServer();

    SOCKET fd;
    bool running;
    
    static void ThreadFun(void*p);
    HANDLE threadId;

    mhthreads::Mutex mutex;
    GCPointer<GCString> data;

protected:
    void SetupServerSocket(int portNum);
    SOCKET WaitForIncoming();
    void WriteData(SOCKET s);

public:
    
    static ActCvServer* GetInstance() {
        if (singleInstance==nullptr) {
            singleInstance=new ActCvServer();
        }
        return singleInstance;
    }

    void SetData(const char *s);

    ThreadSafeQueue<int> keyCodeQueue;
};


#endif