aboutsummaryrefslogtreecommitdiff
path: root/0.4.0/paludis/util/pstream.cc
diff options
context:
space:
mode:
Diffstat (limited to '0.4.0/paludis/util/pstream.cc')
-rw-r--r--0.4.0/paludis/util/pstream.cc99
1 files changed, 99 insertions, 0 deletions
diff --git a/0.4.0/paludis/util/pstream.cc b/0.4.0/paludis/util/pstream.cc
new file mode 100644
index 000000000..940b4d200
--- /dev/null
+++ b/0.4.0/paludis/util/pstream.cc
@@ -0,0 +1,99 @@
+/* vim: set sw=4 sts=4 et foldmethod=syntax : */
+
+/*
+ * Copyright (c) 2006 Ciaran McCreesh <ciaran.mccreesh@blueyonder.co.uk>
+ *
+ * This file is part of the Paludis package manager. Paludis is free software;
+ * you can redistribute it and/or modify it under the terms of the GNU General
+ * Public License version 2, as published by the Free Software Foundation.
+ *
+ * Paludis 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
+ */
+
+#include <cstring>
+#include <errno.h>
+#include <paludis/util/log.hh>
+#include <paludis/util/pstream.hh>
+
+/** \file
+ * Implementation for PStream.
+ *
+ * \ingroup grpsystem
+ */
+
+using namespace paludis;
+
+PStreamError::PStreamError(const std::string & message) throw () :
+ Exception(message)
+{
+}
+
+PStreamInBuf::int_type
+PStreamInBuf::underflow()
+{
+ if (0 == fd)
+ return EOF;
+
+ if (gptr() < egptr())
+ return *gptr();
+
+ int num_putback = gptr() - eback();
+ if (num_putback > putback_size)
+ num_putback = putback_size;
+ std::memmove(buffer + putback_size - num_putback,
+ gptr() - num_putback, num_putback);
+
+ size_t n = fread(buffer + putback_size, 1, buffer_size - putback_size, fd);
+ if (n <= 0)
+ return EOF;
+
+ setg(buffer + putback_size - num_putback, buffer + putback_size,
+ buffer + putback_size + n);
+
+ return *gptr();
+}
+
+PStreamInBuf::PStreamInBuf(const std::string & command) :
+ _command(command),
+ fd(popen(command.c_str(), "r"))
+{
+ Log::get_instance()->message(ll_debug, lc_no_context,
+ "popen " + command + " -> " + stringify(fileno(fd)));
+
+ if (0 == fd)
+ throw PStreamError("popen('" + _command + "', 'r') failed: " +
+ std::strerror(errno));
+
+ setg(buffer + putback_size, buffer + putback_size, buffer + putback_size);
+}
+
+PStreamInBuf::~PStreamInBuf()
+{
+ if (0 != fd)
+ {
+ int fdn = fileno(fd), x = pclose(fd);
+ Log::get_instance()->message(ll_debug, lc_no_context,
+ "pclose " + stringify(fdn) + " -> " + stringify(x));
+ }
+}
+
+int
+PStreamInBuf::exit_status()
+{
+ if (0 != fd)
+ {
+ int fdn = fileno(fd);
+ _exit_status = pclose(fd);
+ fd = 0;
+ Log::get_instance()->message(ll_debug, lc_no_context,
+ "manual pclose " + stringify(fdn) + " -> " + stringify(_exit_status));
+ }
+ return _exit_status;
+}