Search:

SENF Extensible Network Framework

• Home
• Download
• Wiki
• BerliOS
• ChangeLog
• Browse SVN
• Bug Tracker

Server.hh

Go to the documentation of this file.

// $Id: Server.hh 1781 2011-04-11 12:10:19Z tho $
//
// Copyright (C) 2008
// Fraunhofer (FOKUS)
// Competence Center NETwork research (NET), St. Augustin, GERMANY
//     Stefan Bund <g0dil@berlios.de>
//
// 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 HH_SENF_Scheduler_Console_Server_
#define HH_SENF_Scheduler_Console_Server_ 1

// Custom includes
#include <set>
#include <boost/utility.hpp>
#include <boost/scoped_ptr.hpp>
#include <senf/Scheduler/FdEvent.hh>
#include <senf/Scheduler/TimerEvent.hh>
#include <senf/Socket/Protocols/INet/INetAddressing.hh>
#include <senf/Utils/Logger.hh>
#include <senf/Utils/intrusive_refcount.hh>
#include "Executor.hh"

//#include "Server.mpp"
#include "Server.ih"
//-/////////////////////////////////////////////////////////////////////////////////////////////////

namespace senf {
namespace console {

    class Client;

    class Server
        : public senf::intrusive_refcount
    {
        SENF_LOG_CLASS_AREA();
        SENF_LOG_DEFAULT_LEVEL( senf::log::NOTICE );
    public:
        //-////////////////////////////////////////////////////////////////////////
        // Types

        typedef detail::ServerHandle ServerHandle;

        enum Mode { Automatic, Interactive, Noninteractive };

        //-////////////////////////////////////////////////////////////////////////

        static Server & start(senf::INet4SocketAddress const & address);
        static Server & start(senf::INet6SocketAddress const & address);

        std::string const & name() const; 

        Server & name(std::string const & name); 

        DirectoryNode & root() const;   

        Server & root(DirectoryNode & root); 

        Mode mode() const;              

        Server & mode(Mode mode);       

        void stop();                    

    protected:

    private:
        Server(ServerHandle handle);

        static Server & start(ServerHandle handle);

        void newClient(int event);
        void removeClient(Client & client);

        ServerHandle handle_;
        scheduler::FdEvent event_;
        DirectoryNode::ptr root_;
        Mode mode_;

        typedef std::set< boost::intrusive_ptr<Client> > Clients;
        Clients clients_;
        std::string name_;

        friend class Client;
    };

    class Client
        : public senf::intrusive_refcount,
          private boost::base_from_member< detail::NonblockingSocketOStream >,
          public senf::log::IOStreamTarget
    {
        typedef boost::base_from_member< detail::NonblockingSocketOStream > out_t;

        SENF_LOG_CLASS_AREA();
        SENF_LOG_DEFAULT_LEVEL( senf::log::NOTICE );

        static const unsigned INTERACTIVE_TIMEOUT = 500; // milliseconds;

    public:
        typedef Server::ServerHandle::ClientHandle ClientHandle;

        ~Client();

        void stop();                    

        std::string const & name() const; 

        ClientHandle handle() const;    
        std::ostream & stream();        

        std::string promptString() const; 
        DirectoryNode & root() const;   
        DirectoryNode & cwd() const;    

        Server::Mode mode() const;      

        void write(std::string const & data) const;

        std::string const & backtrace() const; 
        unsigned width() const;         

        static Client & get(std::ostream & os);

        static unsigned getWidth(std::ostream & os, unsigned defaultWidth = 0,
                                 unsigned minWidth = 0);

    protected:

    private:
        Client(Server & server, ClientHandle handle);

        void setInteractive();
        void setNoninteractive();

        size_t handleInput(std::string input, bool incremental = false);
        virtual void v_write(senf::log::time_type timestamp, std::string const & stream,
                             std::string const & area, unsigned level,
                             std::string const & message);

        Server & server_;
        ClientHandle handle_;
        scheduler::FdEvent readevent_;
        scheduler::TimerEvent timer_;
        CommandParser parser_;
        Executor executor_;
        std::string name_;
        boost::scoped_ptr<detail::ClientReader> reader_;
        Server::Mode mode_;
        std::string backtrace_;

        friend class Server;
        friend class detail::ClientReader;
        friend class detail::NonblockingSocketSink;

        class SysBacktrace
        {
            SysBacktrace();
            static void  backtrace(std::ostream & os);
            static SysBacktrace instance_;
        };

    };

    std::ostream & operator<<(std::ostream & os, Client const & client);

    std::ostream & operator<<(std::ostream & os, Client * client);

}}

//-/////////////////////////////////////////////////////////////////////////////////////////////////
#include "Server.cci"
//#include "Server.ct"
//#include "Server.cti"
#endif


// Local Variables:
// mode: c++
// fill-column: 100
// comment-column: 40
// c-file-style: "senf"
// indent-tabs-mode: nil
// ispell-local-dictionary: "american"
// compile-command: "scons -u test"
// End:

---

Contact: senf-dev@lists.berlios.de | © 2006-2010 Fraunhofer Institute for Open Communication Systems, Network Research