linuxdeploy/src/subprocess/pipe_reader.cpp at master · ly-coding/linuxdeploy

32 lines (26 loc) · 859 Bytes

// system headers
#include <algorithm>
#include <fcntl.h>
#include <unistd.h>
#include <functional>
#include <cstring>
#include <stdexcept>

// local headers
#include "linuxdeploy/subprocess/pipe_reader.h"

pipe_reader::pipe_reader(int pipe_fd) : pipe_fd_(pipe_fd) {
    // add O_NONBLOCK TO fd's flags to be able to read
    auto flags = fcntl(pipe_fd_, F_GETFL, 0);
    flags |= O_NONBLOCK;
    fcntl(pipe_fd_, F_SETFL, flags);
}

size_t pipe_reader::read(std::vector<std::string::value_type>& buffer) const {
    ssize_t rv = ::read(pipe_fd_, buffer.data(), buffer.size());

    if (rv == -1) {
        // no data available
        if (errno == EAGAIN)
            return 0;

        // TODO: introduce custom subprocess_error
        throw std::runtime_error{"unexpected error reading from pipe: " + std::string(strerror(errno))};
    }

    return rv;
}

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Expand file tree

Search code, repositories, users, issues, pull requests...

Uh oh!

FilesExpand file tree

pipe_reader.cpp

Latest commit

History

pipe_reader.cpp

File metadata and controls

Expand file tree