requestlistener.h

Go to the documentation of this file.

/***************************************************************************
 *   Copyright (C) 2004 by Ilya A. Volynets-Evenbakh                       *
 *   ilya@total-knowledge.com                                              *
 *                                                                         *
 *   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.             *
 ***************************************************************************/
#ifndef CSERVIMPLREQUESTLISTENER_H
#define CSERVIMPLREQUESTLISTENER_H

#include <map>
#include <unistd.h>

#include <connection.h>
#include <servlet/IOError.h>
#include <ResolverError.h>
#include <sptk4/CThreadPool.h>

namespace container {
class RequestHandler;
class AcceptConnection;

class RequestListener{
public:
    class Acceptor
    {
    protected:
        class FileDesc
        {
            int m_fd;
        public:
            FileDesc(int fd):m_fd(fd){}
            ~FileDesc();
            operator int(){return m_fd;}
            int operator=(int i){m_fd=i; return m_fd;}
        };
    protected:
        FileDesc m_sock;
        Acceptor(): m_sock(-1){}
    public:
        virtual ~Acceptor();
        void init(FileDesc& sock) throw(servlet::IOError);
        virtual Connection* accept();
        friend class RequestListener;
    };
    class TCPAcceptor:
        public Acceptor
    {
    public:
        TCPAcceptor(std::string host, unsigned short port)
            throw(servlet::IOError, container::ResolverError);
    };
    class UnixAcceptor:
        public Acceptor
    {
        // Need to save it, in order to remove the socket on shutdown
        std::string m_path;
        FileDesc m_socklock;
    public:
        UnixAcceptor(const std::string& path) throw(servlet::IOError);
        virtual ~UnixAcceptor();
    };
    friend class container::AcceptConnection;
private:
    //int sock;
    //unsigned short port;
    //std::string listenOn;
    typedef std::map<int, Acceptor*> acceptormap_t;
    acceptormap_t m_listeners;
    sptk::CWaiter m_listenerLock;
    fd_set m_accept_fds;
    int m_maxfd;
    sptk::CThreadPool& m_pool;
public:
    class UnknownProtocolError: public servlet::ServletException
    {
    };
    enum {
        MAX_BACKLOG=512,
        PORT=9004
    };
    RequestListener(sptk::CThreadPool&);
    ~RequestListener();
    void acceptRequests();
    void addAcceptor(container::RequestListener::Acceptor*);
private:
    friend class Connection;
};

}

#endif