ServerThread.h

Go to the documentation of this file.

//-*- Mode: C++ -*-
//  DDC originally by Alexey Sokirko
//  Changes and modifications 2011-2016 by Bryan Jurish
//
//  This file is part of DDC.
// 
//  DDC is free software: you can redistribute it and/or modify
//  it under the terms of the GNU Lesser General Public License as published by
//  the Free Software Foundation, either version 3 of the License, or
//  (at your option) any later version.
// 
//  DDC 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 Lesser General Public License for more details.
// 
//  You should have received a copy of the GNU Lesser General Public License
//  along with DDC.  If not, see <http://www.gnu.org/licenses/>.
//
#ifndef DDC_SERVER_THREAD_H
#define DDC_SERVER_THREAD_H

#include "Server.h"
#include "../CommonLib/ddcThread.h"
#include "../CommonLib/ddcThreadQueue.h"

//======================================================================
// globals

#define DDC_DEFAULT_THREAD_POOL_SIZE 4

//======================================================================
class CDDCServerThread : public ddcThread
{
public:
    //--------------------------------------------------------------
    // data

    size_t      m_ThreadId;

    string       m_Label;

    CDDCServer  *m_Parent;

    CDDCServer  *m_Server;

    SOCKET       m_Client;

public:
    //--------------------------------------------------------------
    // methods

    CDDCServerThread(CDDCServer* Parent=NULL, size_t ThreadId=1);

    virtual ~CDDCServerThread();

    virtual void* run();
};


//======================================================================
class CDDCServerThreadPool
{
public:
    ddcThreadQueue<SOCKET> m_Queue;

    vector<CDDCServerThread*> m_Workers;

    pthread_mutex_t m_mutex;

public:
    //--------------------------------------------------------------
    // Constructors etc.

    CDDCServerThreadPool(void);

    CDDCServerThreadPool(CDDCServer *Server, size_t nWorkers=DDC_DEFAULT_THREAD_POOL_SIZE, size_t maxQueueSize=DDC_DEFAULT_THREAD_QUEUE_SIZE);

    virtual ~CDDCServerThreadPool();

public:
    //--------------------------------------------------------------
    // API

    virtual void start(CDDCServer *Server, size_t nWorkers=DDC_DEFAULT_THREAD_POOL_SIZE, size_t maxQueueSize=DDC_DEFAULT_THREAD_QUEUE_SIZE);

    virtual void stop(void);

    inline size_t size(void) const
    { return m_Workers.size(); };

    inline bool started(void) const
    { return (size() != 0); };
};



#endif /* DDC_SERVER_THREAD_H */

/*--- emacs style variables ---
 * Local Variables:
 *  mode: C++
 *  c-file-style: "ellemtel"
 *  c-basic-offset: 4
 *  tab-width: 8
 *  indent-tabs-mode: nil
 * End:
 */