aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/io.h
diff options
context:
space:
mode:
authorGravatar Kurtis Rader <krader@skepticism.us>2016-05-01 20:32:40 -0700
committerGravatar Kurtis Rader <krader@skepticism.us>2016-05-01 20:38:19 -0700
commitb19bfc0dd3e9f5a0f8530ebccf207cef0824de7e (patch)
treef12a6ba87d9da1959540bf15ca26f7448ce49ebe /src/io.h
parent8b2cf81f17f1da78c2fdc2940dd489a2321c247a (diff)
restyle io module to match project style
Reduces lint errors from 15 to 10 (-33%). Line count from 637 to 489 (-23%). Another step in resolving issue #2902.
Diffstat (limited to 'src/io.h')
-rw-r--r--src/io.h295
1 files changed, 108 insertions, 187 deletions
diff --git a/src/io.h b/src/io.h
index ed634f19..a105e67f 100644
--- a/src/io.h
+++ b/src/io.h
@@ -1,10 +1,10 @@
#ifndef FISH_IO_H
#define FISH_IO_H
-#include <vector>
+#include <stdarg.h>
#include <stddef.h>
#include <stdlib.h>
-#include <stdarg.h>
+#include <vector>
// Note that we have to include something to get any _LIBCPP_VERSION defined so we can detect libc++
// So it's key that vector go above. If we didn't need vector for other reasons, we might include
// ciso646, which does nothing
@@ -21,180 +21,124 @@ using std::tr1::shared_ptr;
#include "common.h"
-/**
- Describes what type of IO operation an io_data_t represents
-*/
-enum io_mode_t
-{
- IO_FILE, IO_PIPE, IO_FD, IO_BUFFER, IO_CLOSE
-};
+/// Describes what type of IO operation an io_data_t represents.
+enum io_mode_t { IO_FILE, IO_PIPE, IO_FD, IO_BUFFER, IO_CLOSE };
-/** Represents an FD redirection */
-class io_data_t
-{
-private:
- /* No assignment or copying allowed */
+/// Represents an FD redirection.
+class io_data_t {
+ private:
+ // No assignment or copying allowed.
io_data_t(const io_data_t &rhs);
void operator=(const io_data_t &rhs);
-protected:
- io_data_t(io_mode_t m, int f) :
- io_mode(m),
- fd(f)
- {
- }
+ protected:
+ io_data_t(io_mode_t m, int f) : io_mode(m), fd(f) {}
-public:
- /** Type of redirect */
+ public:
+ /// Type of redirect.
const io_mode_t io_mode;
- /** FD to redirect */
+ /// FD to redirect.
const int fd;
virtual void print() const = 0;
virtual ~io_data_t() = 0;
};
-class io_close_t : public io_data_t
-{
-public:
- explicit io_close_t(int f) :
- io_data_t(IO_CLOSE, f)
- {
- }
+class io_close_t : public io_data_t {
+ public:
+ explicit io_close_t(int f) : io_data_t(IO_CLOSE, f) {}
virtual void print() const;
};
-class io_fd_t : public io_data_t
-{
-public:
- /** fd to redirect specified fd to. For example, in 2>&1, old_fd is 1, and io_data_t::fd is 2 */
+class io_fd_t : public io_data_t {
+ public:
+ /// fd to redirect specified fd to. For example, in 2>&1, old_fd is 1, and io_data_t::fd is 2.
const int old_fd;
-
- /** Whether this redirection was supplied by a script. For example, 'cmd <&3' would have user_supplied set to true. But a redirection that comes about through transmogrification would not. */
+
+ /// Whether this redirection was supplied by a script. For example, 'cmd <&3' would have
+ /// user_supplied set to true. But a redirection that comes about through transmogrification
+ /// would not.
const bool user_supplied;
-
+
virtual void print() const;
- io_fd_t(int f, int old, bool us) :
- io_data_t(IO_FD, f),
- old_fd(old),
- user_supplied(us)
- {
- }
+ io_fd_t(int f, int old, bool us) : io_data_t(IO_FD, f), old_fd(old), user_supplied(us) {}
};
-class io_file_t : public io_data_t
-{
-public:
- /** Filename, malloc'd. This needs to be used after fork, so don't use wcstring here. */
- const char * const filename_cstr;
- /** file creation flags to send to open */
+class io_file_t : public io_data_t {
+ public:
+ /// Filename, malloc'd. This needs to be used after fork, so don't use wcstring here.
+ const char *const filename_cstr;
+ /// file creation flags to send to open.
const int flags;
virtual void print() const;
- io_file_t(int f, const wcstring &fname, int fl = 0) :
- io_data_t(IO_FILE, f),
- filename_cstr(wcs2str(fname)),
- flags(fl)
- {
- }
+ io_file_t(int f, const wcstring &fname, int fl = 0)
+ : io_data_t(IO_FILE, f), filename_cstr(wcs2str(fname)), flags(fl) {}
- virtual ~io_file_t()
- {
- free((void *)filename_cstr);
- }
+ virtual ~io_file_t() { free((void *)filename_cstr); }
};
-class io_pipe_t : public io_data_t
-{
-protected:
- io_pipe_t(io_mode_t m, int f, bool i):
- io_data_t(m, f),
- is_input(i)
- {
+class io_pipe_t : public io_data_t {
+ protected:
+ io_pipe_t(io_mode_t m, int f, bool i) : io_data_t(m, f), is_input(i) {
pipe_fd[0] = pipe_fd[1] = -1;
}
-public:
+ public:
int pipe_fd[2];
const bool is_input;
virtual void print() const;
- io_pipe_t(int f, bool i):
- io_data_t(IO_PIPE, f),
- is_input(i)
- {
- pipe_fd[0] = pipe_fd[1] = -1;
- }
+ io_pipe_t(int f, bool i) : io_data_t(IO_PIPE, f), is_input(i) { pipe_fd[0] = pipe_fd[1] = -1; }
};
class io_chain_t;
-class io_buffer_t : public io_pipe_t
-{
-private:
- /** buffer to save output in */
+class io_buffer_t : public io_pipe_t {
+ private:
+ /// Buffer to save output in.
std::vector<char> out_buffer;
- explicit io_buffer_t(int f):
- io_pipe_t(IO_BUFFER, f, false /* not input */),
- out_buffer()
- {
- }
+ explicit io_buffer_t(int f) : io_pipe_t(IO_BUFFER, f, false /* not input */), out_buffer() {}
-public:
+ public:
virtual void print() const;
virtual ~io_buffer_t();
- /** Function to append to the buffer */
- void out_buffer_append(const char *ptr, size_t count)
- {
+ /// Function to append to the buffer.
+ void out_buffer_append(const char *ptr, size_t count) {
out_buffer.insert(out_buffer.end(), ptr, ptr + count);
}
- /** Function to get a pointer to the buffer */
- char *out_buffer_ptr(void)
- {
- return out_buffer.empty() ? NULL : &out_buffer.at(0);
- }
+ /// Function to get a pointer to the buffer.
+ char *out_buffer_ptr(void) { return out_buffer.empty() ? NULL : &out_buffer.at(0); }
- const char *out_buffer_ptr(void) const
- {
- return out_buffer.empty() ? NULL : &out_buffer.at(0);
- }
+ const char *out_buffer_ptr(void) const { return out_buffer.empty() ? NULL : &out_buffer.at(0); }
- /** Function to get the size of the buffer */
- size_t out_buffer_size(void) const
- {
- return out_buffer.size();
- }
-
- /* Ensures that the pipes do not conflict with any fd redirections in the chain */
+ /// Function to get the size of the buffer.
+ size_t out_buffer_size(void) const { return out_buffer.size(); }
+
+ /// Ensures that the pipes do not conflict with any fd redirections in the chain.
bool avoid_conflicts_with_io_chain(const io_chain_t &ios);
- /**
- Close output pipe, and read from input pipe until eof.
- */
+ /// Close output pipe, and read from input pipe until eof.
void read();
- /**
- Create a IO_BUFFER type io redirection, complete with a pipe and a
- vector<char> for output. The default file descriptor used is STDOUT_FILENO
- for buffering.
-
- \param fd the fd that will be mapped in the child process, typically STDOUT_FILENO
- \param conflicts A set of IO redirections. The function ensures that any pipe it makes
- does not conflict with an fd redirection in this list.
- */
+ /// Create a IO_BUFFER type io redirection, complete with a pipe and a vector<char> for output.
+ /// The default file descriptor used is STDOUT_FILENO for buffering.
+ ///
+ /// \param fd the fd that will be mapped in the child process, typically STDOUT_FILENO
+ /// \param conflicts A set of IO redirections. The function ensures that any pipe it makes does
+ /// not conflict with an fd redirection in this list.
static io_buffer_t *create(int fd, const io_chain_t &conflicts);
};
-class io_chain_t : public std::vector<shared_ptr<io_data_t> >
-{
-public:
+class io_chain_t : public std::vector<shared_ptr<io_data_t> > {
+ public:
io_chain_t();
explicit io_chain_t(const shared_ptr<io_data_t> &);
@@ -207,102 +151,79 @@ public:
shared_ptr<io_data_t> get_io_for_fd(int fd);
};
-
-/**
- Return the last io redirection in the chain for the specified file descriptor.
-*/
+/// Return the last io redirection in the chain for the specified file descriptor.
shared_ptr<const io_data_t> io_chain_get(const io_chain_t &src, int fd);
shared_ptr<io_data_t> io_chain_get(io_chain_t &src, int fd);
-/* Given a pair of fds, if an fd is used by the given io chain, duplicate that fd repeatedly until we find one that does not conflict, or we run out of fds. Returns the new fds by reference, closing the old ones. If we get an error, returns false (in which case both fds are closed and set to -1). */
+/// Given a pair of fds, if an fd is used by the given io chain, duplicate that fd repeatedly until
+/// we find one that does not conflict, or we run out of fds. Returns the new fds by reference,
+/// closing the old ones. If we get an error, returns false (in which case both fds are closed and
+/// set to -1).
bool pipe_avoid_conflicts_with_io_chain(int fds[2], const io_chain_t &ios);
-/** Class representing the output that a builtin can generate */
-class output_stream_t
-{
-private:
- // no copying
+/// Class representing the output that a builtin can generate.
+class output_stream_t {
+ private:
+ // No copying.
output_stream_t(const output_stream_t &s);
void operator=(const output_stream_t &s);
-
+
wcstring buffer_;
-
-public:
- output_stream_t()
- {
- }
-
- void append(const wcstring &s)
- {
- this->buffer_.append(s);
- }
-
- void append(const wchar_t *s)
- {
- this->buffer_.append(s);
- }
-
- void append(wchar_t s)
- {
- this->buffer_.push_back(s);
- }
-
- void append(const wchar_t *s, size_t amt)
- {
- this->buffer_.append(s, amt);
- }
-
- void push_back(wchar_t c)
- {
- this->buffer_.push_back(c);
- }
-
- void append_format(const wchar_t *format, ...)
- {
+
+ public:
+ output_stream_t() {}
+
+ void append(const wcstring &s) { this->buffer_.append(s); }
+
+ void append(const wchar_t *s) { this->buffer_.append(s); }
+
+ void append(wchar_t s) { this->buffer_.push_back(s); }
+
+ void append(const wchar_t *s, size_t amt) { this->buffer_.append(s, amt); }
+
+ void push_back(wchar_t c) { this->buffer_.push_back(c); }
+
+ void append_format(const wchar_t *format, ...) {
va_list va;
va_start(va, format);
::append_formatv(this->buffer_, format, va);
va_end(va);
}
-
- void append_formatv(const wchar_t *format, va_list va_orig)
- {
+
+ void append_formatv(const wchar_t *format, va_list va_orig) {
::append_formatv(this->buffer_, format, va_orig);
}
-
- const wcstring &buffer() const
- {
- return this->buffer_;
- }
-
- bool empty() const
- {
- return buffer_.empty();
- }
+
+ const wcstring &buffer() const { return this->buffer_; }
+
+ bool empty() const { return buffer_.empty(); }
};
-struct io_streams_t
-{
+struct io_streams_t {
output_stream_t out;
output_stream_t err;
-
+
// fd representing stdin. This is not closed by the destructor.
int stdin_fd;
-
- // Whether stdin is "directly redirected," meaning it is the recipient of a pipe (foo | cmd) or direct redirection (cmd < foo.txt)
- // An "indirect redirection" would be e.g. begin ; cmd ; end < foo.txt
+
+ // Whether stdin is "directly redirected," meaning it is the recipient of a pipe (foo | cmd) or
+ // direct redirection (cmd < foo.txt). An "indirect redirection" would be e.g. begin ; cmd ; end
+ // < foo.txt
bool stdin_is_directly_redirected;
-
- // Indicates whether stdout and stderr are redirected (e.g. to a file or piped)
+
+ // Indicates whether stdout and stderr are redirected (e.g. to a file or piped).
bool out_is_redirected;
bool err_is_redirected;
-
+
// Actual IO redirections. This is only used by the source builtin. Unowned.
const io_chain_t *io_chain;
-
- io_streams_t() : stdin_fd(-1), stdin_is_directly_redirected(false), out_is_redirected(false), err_is_redirected(false), io_chain(NULL)
- {
- }
+
+ io_streams_t()
+ : stdin_fd(-1),
+ stdin_is_directly_redirected(false),
+ out_is_redirected(false),
+ err_is_redirected(false),
+ io_chain(NULL) {}
};
#if 0