mprocess_rpc_server.h

Go to the documentation of this file.

/***************************************************************************
             mprocess_rpc_server.h  -  multi process rpc server
                             -------------------
    begin                : Sun May 29 2005
    copyright            : (C) 2005 Dmitry Nizovtsev <funt@alarit.com>
                                    Olexander Shtepa <isk@alarit.com>

    $Id: mprocess_rpc_server.h 945 2007-01-03 13:05:48Z ewald-arnold $

 ***************************************************************************/

/**************************************************************************
 *
 * This program 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 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 Lesser General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 *
 ***************************************************************************/


#ifndef FUNTIK_MPROCESS_RPC_SERVER_H
#define FUNTIK_MPROCESS_RPC_SERVER_H

#include <ulxmlrpcpp/ulxmlrpcpp.h>  // always first header

//STL
#include <vector>
#include <map>
#include <memory>

#include <ulxmlrpcpp/ulxr_dispatcher.h>
#include <ulxmlrpcpp/ulxr_tcpip_connection.h>

#include <sys/types.h>
#include <unistd.h>
#include <time.h>

#include <signal.h>


namespace funtik {


class ULXR_API_DECL0 MultiProcessRpcServerError : public std::exception
{
    std::string _what;
public:
    MultiProcessRpcServerError(const std::string& what_arg);
    ~MultiProcessRpcServerError() throw();
    const char* what () const throw();
};

class ULXR_API_DECL0 MultiProcessRpcServer
{
public:
    struct ProcessContext
    {
//      pid_t   pidProcess;
        time_t  timeStart;
        int     iState;
    };

   MultiProcessRpcServer(unsigned uNumProcess=0,bool bHandleSigchld=true, bool wbxml_mode = false);

    MultiProcessRpcServer(ulxr::Protocol* poProtocol, unsigned uNumProcess,bool bHandleSigchld=true, bool wbxml_mode = false);


    virtual ~MultiProcessRpcServer();

    virtual unsigned getNumProcesses() const;

    virtual bool terminateAllProcess(bool bForce,long lTimeout = 3000);

    void setMaxNumProcesses(unsigned uNumProcesses);

    unsigned getMaxNumProcesses() const;


    ulxr::Dispatcher* getDispatcher() const;


    void resetDispatcher(ulxr::Protocol* poProtocol=0);


    virtual void serverLoop();


    static void sigchild_handler(int signal);

    virtual void handleRequest();

    virtual bool waitConnection(bool bInterruptBySig=true);

    void setState(int iState);


    void printProcess() const;

    int getState() const;


    virtual std::map<pid_t,ProcessContext> getProcInfo() const;

    virtual bool waitChildren(long lTimeout=-1) const;

    enum ProcessState
    {
        RUN = 1,
        FINISH = 2
    };

protected:

    virtual void doChild();

    virtual void acceptConnection();

    virtual void storeFuncResult(const ulxr::MethodCall& callMethod,const ulxr::MethodResponse& respMethod) const;

    virtual ulxr::MethodCall handleXmlRequest();

    virtual void blockSigchld();

    virtual void unblockSigchld();

    virtual void storeProcessData(pid_t pid);

    virtual void sweepProcessData();

    virtual void sigchild_register();

    virtual void sigchild_unregister();

    struct sigaction old_sigchld;


    unsigned                        m_maxProcesses;
    static std::map<pid_t,ProcessContext>   m_mapProcesses;
    std::auto_ptr<ulxr::Dispatcher> m_poDispatcher;
    int                             m_iState;
    bool                            m_wbxml_mode;
private:
    bool                            m_bHandleSigchld;
};


} // namespace funtik


#endif // FUNTIK_MPROCESS_RPC_SERVER_H

---