---

IgServerPool Class Reference

#include <Iguana/WebFramework/interface/IgServerPool.h>

Inheritance diagram for IgServerPool:

List of all members.

Public Member Functions
void	addServer (void)
int	availableServers (void) const
void	childTerminated (int pid)
int	processPoolSize (void) const
std::string	redirect (const std::string &url, std::string &cookie)
Static Public Member Functions
static IgServerPool *	getInstance (IgState *state)
Private Types
typedef std::map< std::string, std::string >	CookieToServerMap
typedef std::map< pid_t, std::string >	PIDToServerMap
typedef std::set< std::string >	ServerSet
Private Member Functions
std::string	createProcess (void)
	IG_DECLARE_STATE_ELEMENT (IgServerPool)
	IgServerPool (IgState *state)
	~IgServerPool (void)
Private Attributes
lat::Argz *	m_argz
ServerSet	m_availableServers
CookieToServerMap	m_cookieServerMap
std::string	m_hostname
int	m_maxProcesses
PIDToServerMap	m_pidServerMap
int	m_processPoolSize
IgState *	m_state
Static Private Attributes
static IgServerPool *	m_instance = 0

---

Detailed Description

Definition at line 24 of file IgServerPool.h.

---

Member Typedef Documentation

typedef std::map<std::string, std::string> IgServerPool::CookieToServerMap [private]

Definition at line 45 of file IgServerPool.h.

typedef std::map<pid_t, std::string> IgServerPool::PIDToServerMap [private]

Definition at line 46 of file IgServerPool.h.

typedef std::set<std::string> IgServerPool::ServerSet [private]

Definition at line 44 of file IgServerPool.h.

---

Constructor & Destructor Documentation

IgServerPool::IgServerPool

(

IgState *

state

)

[private]

Definition at line 48 of file IgServerPool.cc.

References lat::Argz::add(), addServer(), arg, IgArgsElement::arg(), IgArgsElement::args(), ASSERT, childServerFinished(), IgServerSocket::cmdLineHostname(), IgServerSocket::cmdLinePort(), IgServerSocket::cmdLineProxy(), empty, IgArgsElement::find(), DBSPlugin::get(), i, m_argz, m_hostname, m_maxProcesses, m_processPoolSize, m_state, processPoolSize(), IgState::put(), and signal.

Referenced by getInstance().

    : m_state (state), 
      m_argz (new lat::Argz ("iguana")),
      m_maxProcesses (65000),
      m_processPoolSize(2),
      m_hostname ("")
{
    m_state->put (s_key, this);
    signal (SIGCHLD, childServerFinished);
    
    IgArgsElement *args = IgArgsElement::get (state);
    std::string processPoolSize = QString::number(m_processPoolSize);
    if (args->find ("--ig-process-pool-size", processPoolSize))
        m_processPoolSize = atoi (processPoolSize.c_str ());

    std::string maxProcesses = QString::number(m_maxProcesses);
    if (args->find ("--ig-max-processes", maxProcesses))
        m_maxProcesses = atoi (maxProcesses.c_str ());
        
    ASSERT (m_processPoolSize <= m_maxProcesses);

    m_hostname = IgServerSocket::cmdLineHostname(m_state);
    ASSERT (!m_hostname.empty());

    m_argz->add ("-D");
    m_argz->add ("SOCKET");
    
    if (IgServerSocket::cmdLineProxy(state).empty())
    {
        m_argz->add ("--ig-main-hosturl");
        m_argz->add (m_hostname + ":" +
                     QString::number(IgServerSocket::cmdLinePort(state)));
    }
    // copy the arguments from command-line
    // map of "<command-line arg>=<has value?>" which should not be passed to
    // child server.
    std::map <std::string, bool> ignoreArgs;
    ignoreArgs ["--ig-port"]=true;
    ignoreArgs ["--ig-server"]=false;
    ignoreArgs ["--ig-main-hosturl"]=true;
    ignoreArgs ["--ig-process-pool-size"]=true;
    ignoreArgs ["--ig-max-processes"]=true;
    ignoreArgs ["-D"]=true;
    ignoreArgs ["--driver"]=true;
        
    for (int i = 1 ; i < args->args (); i++)
    {
        std::string arg (args->arg (i));
        if (arg.empty ()) continue;
        if (ignoreArgs.find (arg) != ignoreArgs.end())
        {
            if (ignoreArgs[arg])
                i++;
        }
        else
            m_argz->add (args->arg (i));
    }

    for (int i = 0; i < m_processPoolSize; i++)
        addServer ();
}

IgServerPool::~IgServerPool

(

void

)

[private]

Definition at line 110 of file IgServerPool.cc.

References IgState::detach(), and m_state.

{
    m_state->detach (s_key);    
}

---

Member Function Documentation

void IgServerPool::addServer

(

void

)

Definition at line 194 of file IgServerPool.cc.

References createProcess(), m_availableServers, m_maxProcesses, m_pidServerMap, and m_processPoolSize.

Referenced by childTerminated(), IgSocket::dump(), and IgServerPool().

{
    if (((int)m_pidServerMap.size() < m_maxProcesses) &&
        ((int)m_availableServers.size () < m_processPoolSize))
    {
        m_availableServers.insert (createProcess ());
    }
}

int IgServerPool::availableServers

(

void

)

const

Definition at line 228 of file IgServerPool.cc.

References m_availableServers.

{
    return m_availableServers.size ();    
}

void IgServerPool::childTerminated

(

int

pid

)

Definition at line 205 of file IgServerPool.cc.

References addServer(), TestMuL1L2Filter_cff::cerr, lat::endl(), m_availableServers, m_cookieServerMap, m_pidServerMap, and filesave_online::server.

Referenced by childServerFinished().

{
    PIDToServerMap::iterator pidItr = m_pidServerMap.find(pid);
    if (pidItr != m_pidServerMap.end())
    {
        std::string server = m_pidServerMap[pid];
        std::cerr <<"Server terminated:"<<server<<std::endl;
        m_pidServerMap.erase(pidItr);
        if (m_availableServers.find(server)!=m_availableServers.end())
            m_availableServers.erase (server);
        CookieToServerMap::iterator itr = m_cookieServerMap.begin();
        for(itr = m_cookieServerMap.begin();
            itr != m_cookieServerMap.end();
            itr++)
        {
            if (itr->second == server)
                m_cookieServerMap.erase (itr);
        }
        addServer ();
    }
}

std::string IgServerPool::createProcess

(

void

)

[private]

Definition at line 117 of file IgServerPool.cc.

References lat::Argz::add(), lat::Filename::append(), lat::Argz::argz(), TestMuL1L2Filter_cff::cerr, lat::TempFile::dir(), lat::endl(), IgServerSocket::getFreePort(), m_argz, m_hostname, m_pidServerMap, lat::Filename::makedir(), lat::Filename::name(), process, lat::Argz::quote(), HLT_VtxMuL3::result, lat::SubProcess::run(), and lat::TempFile::tempdir().

Referenced by addServer().

{
    lat::Argz argz (*m_argz);
    int childPort = IgServerSocket::getFreePort ();
    std::string portValue = QString::number (childPort).latin1 ();    
    argz.add ("--ig-port");
    argz.add (portValue);
    lat::SubProcess *process = new lat::SubProcess ();
    
    std::cerr << argz.quote () << std::endl;
    
    lat::Argz shellCommand ("/bin/sh");
    shellCommand.add ("-c");
    lat::Filename directoryName (lat::TempFile::tempdir().asDirectory());
    directoryName.append ("IGUANAWEB/");
    directoryName.makedir(directoryName, 0700, true, true);
    lat::TempFile::dir (directoryName);
    
    shellCommand.add (std::string ("\"cd ") + directoryName.name () + "; "+
                      argz.quote () + "\"");
    std::cerr << shellCommand.quote () << std::endl;
    
    pid_t pid = process->run (shellCommand.argz ());
    
    std::string result = m_hostname + ":" + portValue;    
    m_pidServerMap.insert (std::pair<pid_t, std::string>(pid,result));
    
    return result;
}

IgServerPool * IgServerPool::getInstance

(

IgState *

state

)

[static]

Definition at line 41 of file IgServerPool.cc.

References IgServerPool(), and m_instance.

Referenced by childServerFinished(), and IgSocketDriver::run().

{
    if (!m_instance)
        m_instance = new IgServerPool(state);
    return m_instance;
}

IgServerPool::IG_DECLARE_STATE_ELEMENT

(

IgServerPool

)

[private]

int IgServerPool::processPoolSize

(

void

)

const

Definition at line 234 of file IgServerPool.cc.

References m_processPoolSize.

Referenced by IgServerPool().

{ return m_processPoolSize; }

std::string IgServerPool::redirect	(	const std::string &	url,
		std::string &	cookie
	)

Definition at line 148 of file IgServerPool.cc.

References TestMuL1L2Filter_cff::cerr, lat::endl(), IgServerSocket::generateCookie(), m_availableServers, m_cookieServerMap, IgServerSocket::redirect(), and HLT_VtxMuL3::result.

Referenced by IgSocket::dump().

{
    std::string result;
    std::string redir;

    if (cookie.empty())
      IgServerSocket::generateCookie (cookie);
      
    if (m_cookieServerMap.find (cookie) != m_cookieServerMap.end ())
    {
        redir = m_cookieServerMap[cookie];
    }
    else 
    {
        if (m_availableServers.size ())
        {
            // We have atleast one child server available
            redir = *(m_availableServers.begin ());
            m_availableServers.erase (m_availableServers.begin ());
            m_cookieServerMap.insert (std::pair<std::string, std::string>
                                      (cookie,redir));
        }
        else
        {
            // Already serving max number of clients.
            result = "HTTP/1.1 200 Ok\r\n"
                     "Content-Type: text/html; charset=\"utf-8\"\r\n\r\n"
                     "<html><body>"          
                     "<style  type=\"text/css\">"
                     "a {color:#FFFFFF}"
                     "</style>"
                     "<h3>Server is busy.</h3>"
                     "Max number of clients are already connected. Please try again later."
                     "</body>"
                     "</html>\r\n\r\n";
    
            std::cerr << result << std::endl;
    
            return result;    
        }
    }  
    
    return IgServerSocket::redirect (url, redir, cookie);
}

---

Member Data Documentation

lat::Argz* IgServerPool::m_argz [private]

Definition at line 52 of file IgServerPool.h.

Referenced by createProcess(), and IgServerPool().

ServerSet IgServerPool::m_availableServers [private]

Definition at line 53 of file IgServerPool.h.

Referenced by addServer(), availableServers(), childTerminated(), and redirect().

CookieToServerMap IgServerPool::m_cookieServerMap [private]

Definition at line 50 of file IgServerPool.h.

Referenced by childTerminated(), and redirect().

std::string IgServerPool::m_hostname [private]

Definition at line 56 of file IgServerPool.h.

Referenced by createProcess(), and IgServerPool().

IgServerPool * IgServerPool::m_instance = 0 [static, private]

Definition at line 48 of file IgServerPool.h.

Referenced by getInstance().

int IgServerPool::m_maxProcesses [private]

Definition at line 54 of file IgServerPool.h.

Referenced by addServer(), and IgServerPool().

PIDToServerMap IgServerPool::m_pidServerMap [private]

Definition at line 51 of file IgServerPool.h.

Referenced by addServer(), childTerminated(), and createProcess().

int IgServerPool::m_processPoolSize [private]

Definition at line 55 of file IgServerPool.h.

Referenced by addServer(), IgServerPool(), and processPoolSize().

IgState* IgServerPool::m_state [private]

Definition at line 49 of file IgServerPool.h.

Referenced by IgServerPool(), and ~IgServerPool().

---

The documentation for this class was generated from the following files:

• Iguana/WebFramework/interface/IgServerPool.h
• Iguana/WebFramework/src/IgServerPool.cc

---