---

PipeServer.h

/*****************************************************************************
 * Author:   Valient Gough <vgough@pobox.com>
 *
 *****************************************************************************
 * Copyright (c) 2001, Valient Gough
 *
 * This library is free software; you can distribute it and/or modify it under
 * the terms of the GNU Lesser General Public License (LGPL), as published by
 * the Free Software Foundation; either version 2.1 of the License, or (at your
 * option) any later version.
 *
 * This library 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 LGPL in the file COPYING for more
 * details.
 *
 */

#ifndef _PipeServer_incl_
#define _PipeServer_incl_

#include <rel-server/ServerConnector.h>

#include <list>
#include <string>

namespace rel
{

    class BinaryCoding;

    struct PipeServerData
    {
        int readChan;
        int writeChan;
        Pointer<Coding> coding;

        PipeServerData() {}
        PipeServerData(const PipeServerData &src)
            : readChan(src.readChan)
            , writeChan(src.writeChan)
            , coding(src.coding)
            { }
    };

    class PipeServer : public ServerConnector
    {
    public:

        /* The incoming pipe is the primary connect point.  When a client
         * connects, it must provide it's own connection point, where data is
         * actually communicated between client <-> server.  The incoming pipe
         * is only for clients to request a new connection to the server.
         */
        PipeServer(const char *incomingPipe);
        ~PipeServer();

        Pointer<Coding> accept();

    private:
        bool acceptConnection();
        int openWriteChannel(const char *fileName);
        int createReadChannel(const char *fileName);

        std::string newPipeName();

        // the connectionFD and connectionStream are read-only 
        int connectionFD;
        BinaryCoding *connectionStream;

        // list of read/write channels for connected clients
        std::list< PipeServerData > connections;
    };


} // namespace rel

#endif

---