Subject: [Boost-commit] svn:boost r64533 - in sandbox/SOC/2010/process/libs/process/test: . util
From: fotanus_at_[hidden]
Date: 2010-08-02 01:53:49
Author: fotanus
Date: 2010-08-02 01:53:47 EDT (Mon, 02 Aug 2010)
New Revision: 64533
URL: http://svn.boost.org/trac/boost/changeset/64533
Log:
addded async tests, but it don't works yet
Added:
sandbox/SOC/2010/process/libs/process/test/helpers.cpp (contents, props changed)
Text files modified:
sandbox/SOC/2010/process/libs/process/test/child.cpp | 49 ++++++++++++++++++++++++++++++++++++++++
sandbox/SOC/2010/process/libs/process/test/util/boost.hpp | 1
sandbox/SOC/2010/process/libs/process/test/util/helpers.cpp | 11 ++++++++
3 files changed, 61 insertions(+), 0 deletions(-)
Modified: sandbox/SOC/2010/process/libs/process/test/child.cpp
==============================================================================
--- sandbox/SOC/2010/process/libs/process/test/child.cpp (original)
+++ sandbox/SOC/2010/process/libs/process/test/child.cpp 2010-08-02 01:53:47 EDT (Mon, 02 Aug 2010)
@@ -436,3 +436,52 @@
BOOST_CHECK_EQUAL(p2.second, "''");
#endif
}
+
+void handler(const boost::system::error_code &ec, std::size_t bytes_transferred)
+{
+}
+
+ba::io_service ioservice;
+BOOST_AUTO_TEST_CASE(should_write_async)
+{
+
+ std::vector<std::string> args;
+ args.push_back("read-message");
+ args.push_back("my_message");
+
+ bp::context ctx;
+ ctx.stdin_behavior = bp::behavior::named_pipe::create(bp::behavior::named_pipe::input_stream);
+
+ bp::child c = bp::create_child(get_helpers_path(), args, ctx);
+ bp::postream &os = c.get_stdin();
+
+ bp::pipe write_end(ioservice, os.handle().release());
+
+ write_end.async_write_some(ba::buffer("my_message\n"), handler);
+ ioservice.run();
+
+ //need to wait for value
+}
+
+BOOST_AUTO_TEST_CASE(should_write_async)
+{
+ std::vector<std::string> args;
+ args.push_back("echo-stdout");
+ args.push_back("my_message");
+
+ bp::context ctx;
+ ctx.stdout_behavior = bp::behavior::named_pipe::create(bp::behavior::named_pipe::output_stream);
+
+ bp::child c = bp::create_child(get_helpers_path(), args, ctx);
+ bp::pistream &is = c.get_stdout();
+
+ bp::pipe read_end(ioservice, is.handle().release());
+
+ ba::buffer buff;
+ read_end.async_read_some(buff, handler);
+ ioservice.run();
+
+ //need to wait for value
+ BOOST_CHECK_EQUAL(buff, "my_message");
+
+}
Added: sandbox/SOC/2010/process/libs/process/test/helpers.cpp
==============================================================================
--- (empty file)
+++ sandbox/SOC/2010/process/libs/process/test/helpers.cpp 2010-08-02 01:53:47 EDT (Mon, 02 Aug 2010)
@@ -0,0 +1,270 @@
+//
+// Boost.Process
+// ~~~~~~~~~~~~~
+//
+// Copyright (c) 2006, 2007 Julio M. Merino Vidal
+// Copyright (c) 2008 Ilya Sokolov, Boris Schaeling
+// Copyright (c) 2009 Boris Schaeling
+// Copyright (c) 2010 Felipe Tanus, Boris Schaeling
+//
+// Distributed under the Boost Software License, Version 1.0. (See accompanying
+// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
+//
+
+#include <boost/process/config.hpp>
+
+#if defined(BOOST_POSIX_API)
+# include <stdlib.h>
+#elif defined(BOOST_WINDOWS_API)
+# include <windows.h>
+#else
+# error "Unsupported platform."
+#endif
+
+#include <boost/process/detail/systembuf.hpp>
+#include <boost/filesystem.hpp>
+#include <iostream>
+#include <string>
+#include <cstdlib>
+
+namespace bpd = boost::process::detail;
+namespace bfs = boost::filesystem;
+
+namespace {
+
+int h_echo_quoted(int argc, char *argv[])
+{
+ std::cout << ">>>" << argv[1] << "<<<" << std::endl;
+ return EXIT_SUCCESS;
+}
+
+int h_echo_stdout(int argc, char *argv[])
+{
+ std::cout << argv[1] << std::endl;
+ return EXIT_SUCCESS;
+}
+
+int h_echo_stderr(int argc, char *argv[])
+{
+ std::cerr << argv[1] << std::endl;
+ return EXIT_SUCCESS;
+}
+
+int h_echo_stdout_stderr(int argc, char *argv[])
+{
+ std::cout << "stdout " << argv[1] << std::endl;
+ std::cout.flush();
+ std::cerr << "stderr " << argv[1] << std::endl;
+ std::cerr.flush();
+ return EXIT_SUCCESS;
+}
+
+int h_exit_failure(int argc, char *argv[])
+{
+ return EXIT_FAILURE;
+}
+
+int h_exit_success(int argc, char *argv[])
+{
+ return EXIT_SUCCESS;
+}
+
+int h_is_closed_stdin(int argc, char *argv[])
+{
+ std::string word;
+ std::cin >> word;
+ return std::cin.eof() ? EXIT_SUCCESS : EXIT_FAILURE;
+}
+
+int h_is_closed_stdout(int argc, char *argv[])
+{
+ std::cout << "foo" << std::endl;
+ return std::cout.bad() ? EXIT_SUCCESS : EXIT_FAILURE;
+}
+
+int h_is_closed_stderr(int argc, char *argv[])
+{
+ std::cerr << "foo" << std::endl;
+ return std::cerr.bad() ? EXIT_SUCCESS : EXIT_FAILURE;
+}
+
+int h_loop(int argc, char *argv[])
+{
+ for (;;)
+ ;
+
+ return EXIT_SUCCESS;
+}
+
+int h_prefix(int argc, char *argv[])
+{
+ std::string line;
+ while (std::getline(std::cin, line))
+ std::cout << argv[1] << line << std::endl;
+
+ return EXIT_SUCCESS;
+}
+
+int h_pwd(int argc, char *argv[])
+{
+ std::cout << bfs::current_path().string() << std::endl;
+ return EXIT_SUCCESS;
+}
+
+int h_query_env(int argc, char *argv[])
+{
+#if defined(BOOST_WINDOWS_API)
+ char buf[1024];
+ DWORD res = GetEnvironmentVariableA(argv[1], buf, sizeof(buf));
+ if (res == 0)
+ std::cout << "undefined" << std::endl;
+ else
+ {
+ std::cout << "defined" << std::endl;
+ std::cout << "'" << buf << "'" << std::endl;
+ }
+#else
+ const char *value = getenv(argv[1]);
+ if (value == NULL)
+ std::cout << "undefined" << std::endl;
+ else
+ {
+ std::cout << "defined" << std::endl;
+ std::cout << "'" << value << "'" << std::endl;
+ }
+#endif
+
+ return EXIT_SUCCESS;
+}
+
+int h_stdin_to_stdout(int argc, char *argv[])
+{
+ char ch;
+ while (std::cin >> ch)
+ std::cout << ch;
+
+ return EXIT_SUCCESS;
+}
+
+#if defined(BOOST_POSIX_API)
+int h_posix_echo_one(int argc, char *argv[])
+{
+ int desc = std::atoi(argv[1]);
+
+ bpd::systembuf buf(desc);
+ std::ostream os(&buf);
+ os << argv[2] << std::endl;
+
+ return EXIT_SUCCESS;
+}
+
+int h_posix_echo_two(int argc, char *argv[])
+{
+ int desc1 = std::atoi(argv[1]);
+ int desc2 = std::atoi(argv[2]);
+
+ bpd::systembuf buf1(desc1);
+ std::ostream os1(&buf1);
+ os1 << argv[1] << " " << argv[3] << std::endl;
+
+ bpd::systembuf buf2(desc2);
+ std::ostream os2(&buf2);
+ os2 << argv[2] << " " << argv[3] << std::endl;
+
+ return EXIT_SUCCESS;
+}
+#endif
+
+#if defined(BOOST_WINDOWS_API)
+int h_win32_print_startupinfo(int argc, char *argv[])
+{
+ STARTUPINFO si;
+ GetStartupInfo(&si);
+ std::cout << "dwFlags = " << si.dwFlags << std::endl;
+ std::cout << "dwX = " << si.dwX << std::endl;
+ std::cout << "dwY = " << si.dwY << std::endl;
+ std::cout << "dwXSize = " << si.dwXSize << std::endl;
+ std::cout << "dwYSize = " << si.dwYSize << std::endl;
+
+ return EXIT_SUCCESS;
+}
+#endif
+
+int h_read_message(int argc, char *argv[]){
+ std::string buff;
+ std::cin >> buff;
+ if(buff == argv[1])
+ return EXIT_SUCCESS;
+ else
+ return -1;
+}
+
+
+}
+
+struct helper
+{
+ const char *name;
+ int (*entry)(int, char*[]);
+ int min_argc;
+ const char *syntax;
+} helpers[] = {
+ { "read-message", h_read_message, 1, "message" },
+ { "echo-quoted", h_echo_quoted, 2, "word" },
+ { "echo-stdout", h_echo_stdout, 2, "message" },
+ { "echo-stderr", h_echo_stderr, 2, "message" },
+ { "echo-stdout-stderr", h_echo_stdout_stderr, 2, "message" },
+ { "exit-failure", h_exit_failure, 1, "" },
+ { "exit-success", h_exit_success, 1, "" },
+ { "is-closed-stdin", h_is_closed_stdin, 1, "" },
+ { "is-closed-stdout", h_is_closed_stdout, 1, "" },
+ { "is-closed-stderr", h_is_closed_stderr, 1, "" },
+ { "loop", h_loop, 1, "" },
+ { "prefix", h_prefix, 2, "string" },
+ { "pwd", h_pwd, 1, "" },
+ { "query-env", h_query_env, 2, "variable" },
+ { "stdin-to-stdout", h_stdin_to_stdout, 1, "" },
+#if defined(BOOST_POSIX_API)
+ { "posix-echo-one", h_posix_echo_one, 3, "desc message" },
+ { "posix-echo-two", h_posix_echo_two, 4, "desc1 desc2 message" },
+#elif defined(BOOST_WINDOWS_API)
+ { "win32-print-startupinfo", h_win32_print_startupinfo, 1, "" },
+#endif
+ { 0 }
+};
+
+int main(int argc, char *argv[])
+{
+ if (argc < 2)
+ {
+ std::cerr << "helpers: Missing command" << std::endl;
+ return 128;
+ }
+
+ std::string command(argv[1]);
+ --argc;
+ ++argv;
+
+ struct helper *h = helpers;
+ while (h->name != 0)
+ {
+ if (command == h->name)
+ {
+ int res;
+ if (argc < h->min_argc)
+ {
+ std::cerr << "helpers: Command syntax: `" << command << " "
+ << h->syntax << "'" << std::endl;
+ res = 128;
+ }
+ else
+ res = (*h->entry)(argc, argv);
+ return res;
+ }
+ ++h;
+ }
+
+ std::cerr << "helpers: Invalid command `" << command << "'"
+ << std::endl;
+ return 128;
+}
Modified: sandbox/SOC/2010/process/libs/process/test/util/boost.hpp
==============================================================================
--- sandbox/SOC/2010/process/libs/process/test/util/boost.hpp (original)
+++ sandbox/SOC/2010/process/libs/process/test/util/boost.hpp 2010-08-02 01:53:47 EDT (Mon, 02 Aug 2010)
@@ -25,5 +25,6 @@
namespace but = boost::unit_test;
namespace butf = boost::unit_test::framework;
namespace bfs = boost::filesystem;
+namespace ba = boost::asio;
#endif
Modified: sandbox/SOC/2010/process/libs/process/test/util/helpers.cpp
==============================================================================
--- sandbox/SOC/2010/process/libs/process/test/util/helpers.cpp (original)
+++ sandbox/SOC/2010/process/libs/process/test/util/helpers.cpp 2010-08-02 01:53:47 EDT (Mon, 02 Aug 2010)
@@ -190,6 +190,16 @@
}
#endif
+int h_read_message(int argc, char *argv[]){
+ std::string buff;
+ std::cin >> buff;
+ if(buff == argv[1])
+ return EXIT_SUCCESS;
+ else
+ return -1;
+}
+
+
}
struct helper
@@ -199,6 +209,7 @@
int min_argc;
const char *syntax;
} helpers[] = {
+ { "read-message", h_read_message, 1, "message" },
{ "echo-quoted", h_echo_quoted, 2, "word" },
{ "echo-stdout", h_echo_stdout, 2, "message" },
{ "echo-stderr", h_echo_stderr, 2, "message" },