Това е въпрос относно Boost.Process 0.5, не по-късно или по-ранна версия, Boost вече съдържа библиотека Boost.Process с различен синтаксис и функции.
Да предположим, че имам проста програма, която иска номер и връща друг номер, а именно:
// ask.x, simple program with IO
#include<iostream>
int main(){
double n;
std::cout << "number?" << std::endl;
std::cin >> n;
std::cout << n + 1 << std::endl;
}
Сега искам да взаимодействам с тази програма програмно с помощта на Boost.Process 0.5 (http://www.highscore.de/boost/process0.5/boost_process/tutorial.html). Когато се опитам да използвам библиотеката, не получавам очакваното поведение, номерът никога не е изпратен на програмата. (четенето на първия ред е добре). Опитах се да напиша обобщение на примера, описан в http://www.highscore.de/boost/process0.5/boost_process/tutorial.html#boost_process.tutorial.synchronous_i_o, но не успях.
MWE, първата половина е много необходим шаблон, също и там, където мисля, че правя грешката.
#include <boost/process.hpp> // version 0.5
#include <boost/iostreams/device/file_descriptor.hpp>
#include <boost/iostreams/stream.hpp>
#include <string>
#define ALSOSEND // for fully interactive case
using namespace boost;
int main() {
// Boilerplate code, see input only example here https://stackoverflow.com/questions/12329065/how-to-bind-program-termination-with-end-of-stream-in-boost-process-0-5
process::pipe pi = boost::process::create_pipe();
process::pipe po = boost::process::create_pipe();
{
iostreams::file_descriptor_sink sink(
pi.sink,
iostreams::close_handle
);
iostreams::file_descriptor_source source(
po.source,
boost::iostreams::close_handle
);
process::execute(
process::initializers::run_exe("./ask.x"),
process::initializers::bind_stdout(sink)
#ifdef ALSOSEND
, process::initializers::bind_stdin(source)
#endif
);
}
iostreams::file_descriptor_source fdsource(pi.source, iostreams::close_handle);
iostreams::stream<iostreams::file_descriptor_source> is(fdsource);
iostreams::file_descriptor_sink fdsink(po.source, iostreams::close_handle);
iostreams::stream<iostreams::file_descriptor_sink> os(fdsink);
// actual interaction with the process
std::string line;
std::getline(is, line);
assert(line == "number?");
std::cout << "sending: " << "5" << std::endl;
os << "5" << std::endl; // RUN GETS STUCK HERE
std::getline(is, line);
assert(line == "6");
}
Явно не разбирам логиката на поглътителите и източниците. Опитах също да използвам един pipe
за приемник и източник, но не се получи.
Как мога да накарам програмата да чете и записва от и към изпълнения проект?
Не мога да намеря пример, при който и входът, и изходът са подредени.
РЕДАКТИРАЙТЕ, за да покажете работния пример с по-ранна версия на библиотеката
Така се правеше в Boost.Process GSOC2010 (а не 0,5, както във въпроса по-горе), имайте предвид, че действителното взаимодействие с програмата е същото като по-горе.
#include <boost/filesystem.hpp> // quasibug in process GSOC2010 needs to include filesystem BEFORE
#include <boost/process.hpp> // version GSOC2010 (not 0.5)
#include <boost/iostreams/device/file_descriptor.hpp>
#include <boost/iostreams/stream.hpp>
#include <string>
using namespace boost;
int main() {
// boiler plate code
std::vector<std::string> args;
process::context ctx;
ctx.process_name = "askprocess";
ctx.streams[process::stdout_id] = boost::process::behavior::pipe();
ctx.streams[process::stdin_id ] = boost::process::behavior::pipe();
process::child c = create_child("./ask", args, ctx);
process::pistream is(c.get_handle(process::stdout_id));
process::postream os(c.get_handle(process::stdin_id ));
// actual interaction with the process
std::string line;
std::getline(is, line);
assert(line == "number?");
std::cout << "sending: " << "5" << std::endl;
os << "5" << std::endl; // RUN GETS STUCK HERE
std::getline(is, line);
assert(line == "6");
}