UnixPipe.cc

Go to the documentation of this file.

/*
 * UnixPipe.cc
 *
 * Smalltalk like class library for C++
 * Accessor to unix pipe.
 *
 * Copyright (c) 2006 Milan Cermak
 */
/*
 * This library 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.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 GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
#include <stlib/os/UnixPipe.h>

#include <stlib/ByteArray.h>
#include <stlib/ExternalReadStream.h>
#include <stlib/ExternalWriteStream.h>
#include <stlib/FileAccessor.h>
#include <stlib/String.h>

#include <stlib/Error.h>

#include <stdio.h>
#include <unistd.h>

namespace OS {

UnixPipe::UnixPipe(Core::FileAccessor *in, Core::FileAccessor *out)
{
    input = in;
    output = out;
}

/* Class-accessing protocol */
String *UnixPipe::className(void) const
{
    return new String("UnixPipe");
}

/* Instance creation protocol */
UnixPipe *UnixPipe::openPair(void)
{
    int fds[2];

    if (pipe(fds) < 0) {
        perror(__PRETTY_FUNCTION__);
        (new Error(new String("Cannot create pipe"),
                   new String(__PRETTY_FUNCTION__)))->raise();
    }
    return new UnixPipe(new FileAccessor(fds[1]), new FileAccessor(fds[0]));
}

/* Initialize-release protocol */
void UnixPipe::close(void)
{
    closeInput();
    closeOutput();
}

void UnixPipe::closeInput(void)
{
    input->close();
}

void UnixPipe::closeOutput(void)
{
    output->close();
}

/* Accessing protocol */
Core::FileAccessor *UnixPipe::inputAccessor(void)
{
    return input;
}

Core::FileAccessor *UnixPipe::outputAccessor(void)
{
    return output;
}

/* Data transfer protocol */
int UnixPipe::readInto(ByteArray *buffer, long startIndex, long count)
{
    output->readInto(buffer, startIndex, count);
}

int UnixPipe::writeFrom(ByteArray *buffer, long startIndex, long count)
{
    input->writeFrom(buffer, startIndex, count);
}

/* Positioning protocol */
void UnixPipe::seekTo(long position)
{
    shouldNotImplement(__PRETTY_FUNCTION__);
}

/* Stream creation protocol */
ExternalReadStream *UnixPipe::readStream(void)
{
    return output->readStream();
}

ExternalWriteStream *UnixPipe::writeStream(void)
{
    return input->writeStream();
}

}; /* namespace OS */

---