003 File Manager
Current Path:
/usr/src/contrib/kyua/utils
usr
/
src
/
contrib
/
kyua
/
utils
/
📁
..
📄
.gitignore
(27 B)
📄
Kyuafile
(651 B)
📄
Makefile.am.inc
(5.42 KB)
📄
auto_array.hpp
(3.32 KB)
📄
auto_array.ipp
(6 KB)
📄
auto_array_fwd.hpp
(1.8 KB)
📄
auto_array_test.cpp
(8.27 KB)
📁
cmdline
📁
config
📄
datetime.cpp
(16.78 KB)
📄
datetime.hpp
(4.57 KB)
📄
datetime_fwd.hpp
(1.83 KB)
📄
datetime_test.cpp
(19.52 KB)
📄
defs.hpp.in
(2.18 KB)
📄
env.cpp
(6.62 KB)
📄
env.hpp
(2.31 KB)
📄
env_test.cpp
(4.97 KB)
📁
format
📁
fs
📁
logging
📄
memory.cpp
(5.29 KB)
📄
memory.hpp
(1.8 KB)
📄
memory_test.cpp
(2.25 KB)
📄
noncopyable.hpp
(2.78 KB)
📄
optional.hpp
(2.97 KB)
📄
optional.ipp
(6.3 KB)
📄
optional_fwd.hpp
(2.14 KB)
📄
optional_test.cpp
(7.83 KB)
📄
passwd.cpp
(5.68 KB)
📄
passwd.hpp
(2.4 KB)
📄
passwd_fwd.hpp
(1.8 KB)
📄
passwd_test.cpp
(5.75 KB)
📁
process
📄
sanity.cpp
(6.48 KB)
📄
sanity.hpp
(6.93 KB)
📄
sanity_fwd.hpp
(1.98 KB)
📄
sanity_test.cpp
(9.36 KB)
📁
signals
📁
sqlite
📄
stacktrace.cpp
(12.56 KB)
📄
stacktrace.hpp
(2.71 KB)
📄
stacktrace_helper.cpp
(1.58 KB)
📄
stacktrace_test.cpp
(21.15 KB)
📄
stream.cpp
(4.59 KB)
📄
stream.hpp
(2.16 KB)
📄
stream_test.cpp
(4.92 KB)
📄
test_utils.ipp
(3.53 KB)
📁
text
📄
units.cpp
(5.25 KB)
📄
units.hpp
(2.99 KB)
📄
units_fwd.hpp
(1.79 KB)
📄
units_test.cpp
(7.79 KB)
Editing: stream.cpp
// Copyright 2011 The Kyua Authors. // All rights reserved. // // Redistribution and use in source and binary forms, with or without // modification, are permitted provided that the following conditions are // met: // // * Redistributions of source code must retain the above copyright // notice, this list of conditions and the following disclaimer. // * Redistributions in binary form must reproduce the above copyright // notice, this list of conditions and the following disclaimer in the // documentation and/or other materials provided with the distribution. // * Neither the name of Google Inc. nor the names of its contributors // may be used to endorse or promote products derived from this software // without specific prior written permission. // // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT // OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. #include "utils/stream.hpp" #include <fstream> #include <iostream> #include <sstream> #include <stdexcept> #include "utils/format/macros.hpp" #include "utils/fs/path.hpp" #include "utils/sanity.hpp" namespace fs = utils::fs; namespace { /// Constant that represents the path to stdout. static const fs::path stdout_path("/dev/stdout"); /// Constant that represents the path to stderr. static const fs::path stderr_path("/dev/stderr"); } // anonymous namespace /// Opens a new file for output, respecting the stdout and stderr streams. /// /// \param path The path to the output file to be created. /// /// \return A pointer to a new output stream. std::auto_ptr< std::ostream > utils::open_ostream(const fs::path& path) { std::auto_ptr< std::ostream > out; if (path == stdout_path) { out.reset(new std::ofstream()); out->copyfmt(std::cout); out->clear(std::cout.rdstate()); out->rdbuf(std::cout.rdbuf()); } else if (path == stderr_path) { out.reset(new std::ofstream()); out->copyfmt(std::cerr); out->clear(std::cerr.rdstate()); out->rdbuf(std::cerr.rdbuf()); } else { out.reset(new std::ofstream(path.c_str())); if (!(*out)) { throw std::runtime_error(F("Cannot open output file %s") % path); } } INV(out.get() != NULL); return out; } /// Gets the length of a stream. /// /// \param is The input stream for which to calculate its length. /// /// \return The length of the stream. This is of size_t type instead of /// directly std::streampos to simplify the caller. Some systems do not /// support comparing a std::streampos directly to an integer (see /// NetBSD 1.5.x), which is what we often want to do. /// /// \throw std::exception If calculating the length fails due to a stream error. std::size_t utils::stream_length(std::istream& is) { const std::streampos current_pos = is.tellg(); try { is.seekg(0, std::ios::end); const std::streampos length = is.tellg(); is.seekg(current_pos, std::ios::beg); return static_cast< std::size_t >(length); } catch (...) { is.seekg(current_pos, std::ios::beg); throw; } } /// Reads a whole file into memory. /// /// \param path The file to read. /// /// \return A plain string containing the raw contents of the file. /// /// \throw std::runtime_error If the file cannot be opened. std::string utils::read_file(const fs::path& path) { std::ifstream input(path.c_str()); if (!input) throw std::runtime_error(F("Failed to open '%s' for read") % path); return read_stream(input); } /// Reads the whole contents of a stream into memory. /// /// \param input The input stream from which to read. /// /// \return A plain string containing the raw contents of the file. std::string utils::read_stream(std::istream& input) { std::ostringstream buffer; char tmp[1024]; while (input.good()) { input.read(tmp, sizeof(tmp)); if (input.good() || input.eof()) { buffer.write(tmp, input.gcount()); } } return buffer.str(); }
Upload File
Create Folder