Прежде всего: если вы хотите, чтобы "1" означало, что mpstat запускается многократно с интервалом в 1 секунду, вы должны сделать это первым аргументом, а не именем процесса:
if (execlp("mpstat", "mpstat", "1", "-P", "ALL", 0) == -1) {
См. документацию :
Первый аргумент, по соглашению, должен указывать на имя файла, связанное с исполняемым файлом.
async_read_until считывает, пока входной буфер не менее содержит разделитель. Поэтому, когда вы читаете буфер, вы должны учитывать bytes_tranferred, который будет исключать разделитель.
Не забудьте также использовать разделитель, чтобы избежать зацикливания в бесконечном цикле (поскольку условие остановки уже выполнено):
void handle_read(const boost::system::error_code &error, std::size_t bytes_transferred) {
std::cout << "Enter handle_read (" << error.message() << ")\n";
if (!error) {
if (bytes_transferred > 0) {
std::copy_n(std::istreambuf_iterator<char>(&data), bytes_transferred, std::ostreambuf_iterator<char>(std::cout << "handle_read got data: '"));
std::cout << "' --\n";
data.consume(delimiter.size());
}
do_read_loop();
}
}
Или проще:
void handle_read(const boost::system::error_code &error, std::size_t bytes_transferred) {
std::cout << "Enter handle_read (" << error.message() << ")\n";
if (!error) {
std::string line;
if (getline(std::istream(&data), line))
std::cout << "handle_read got data: '" << line << "'\n";
do_read_loop();
}
}
Я бы предпочел первый, потому что он более явный и в целом применим.
Примечания стороны:
Фиксированный / упрощенный Asio
Вот некоторые упрощения и сокращения глобалов:
Live On Coliru
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <iostream>
#include <unistd.h>
namespace ba = boost::asio;
struct Reader : std::enable_shared_from_this<Reader> {
ba::streambuf data;
ba::posix::stream_descriptor cpuLoadDataStream;
std::string const delimiter = "\n";
Reader(ba::io_service& svc, int fd)
: cpuLoadDataStream(svc, fd) {}
void do_read_loop() {
async_read_until(cpuLoadDataStream, data, delimiter, boost::bind(&Reader::handle_read, shared_from_this(), _1, _2));
}
void handle_read(const boost::system::error_code &error, std::size_t bytes_transferred) {
std::cout << "Enter handle_read (" << error.message() << ")\n";
if (!error) {
if (bytes_transferred > 0) {
std::copy_n(std::istreambuf_iterator<char>(&data), bytes_transferred, std::ostreambuf_iterator<char>(std::cout << "handle_read got data: '"));
std::cout << "' --\n";
data.consume(delimiter.size());
}
do_read_loop();
}
}
};
int main() {
int fds[2];
int& readFd = fds[0];
int& writeFd = fds[1];
if (pipe(fds) == -1) {
std::cout << "pipe error" << std::endl;
return 1;
}
if (int pid = fork()) {
ba::io_service ioService;
// parent
if (pid == -1) {
std::cerr << "fork error" << std::endl;
return 2;
} else {
close(writeFd);
std::make_shared<Reader>(ioService, ::dup(readFd))->do_read_loop();
}
ioService.run();
} else {
ba::io_service ioService;
// child
if (dup2(writeFd, STDOUT_FILENO) == -1) {
std::cerr << "dup2 error" << std::endl;
return 3;
}
close(readFd);
close(writeFd);
if (execlp("mpstat", "mpstat", "-P", "ALL", 0) == -1) {
std::cerr << "execlp error" << std::endl;
return 4;
}
ioService.run();
}
}
Обратите внимание, что в Coliru он не является непрерывным по очевидным причинам
Намного проще: ускорить процесс
Почему бы вместо этого не использовать Boost Process?
#include <boost/process.hpp>
#include <iostream>
#include <iomanip>
namespace bp = boost::process;
int main() {
bp::pstream output;
bp::system("mpstat -P ALL", bp::std_out > output);
for (std::string line; std::getline(output, line);) {
std::cout << "Got: " << std::quoted(line) << "\n";
}
}
Или снова сделать его асинхронным:
Live On Coliru
#include <boost/asio.hpp>
#include <boost/process.hpp>
#include <iostream>
#include <iomanip>
namespace bp = boost::process;
using Args = std::vector<std::string>;
int main() {
boost::asio::io_service io;
bp::async_pipe output(io);
bp::child mpstat(bp::search_path("mpstat"),
//Args { "1", "-P", "ALL" },
Args { "1", "3" }, // limited to 3 iterations on Coliru
bp::std_out > output, io);
boost::asio::streambuf data;
std::function<void(boost::system::error_code, size_t)> handle = [&](boost::system::error_code ec, size_t /*bytes_transferred*/) {
if (ec) {
std::cout << "Good bye (" << ec.message() << ")\n";
} else {
std::string line;
std::getline(std::istream(&data), line);
std::cout << "Got: " << std::quoted(line) << "\n";
async_read_until(output, data, "\n", handle);
}
};
async_read_until(output, data, "\n", handle);
io.run();
}
Печать
Got: "Linux 4.4.0-57-generic (stacked-crooked) 08/26/18 _x86_64_ (4 CPU)"
Got: ""
Got: "13:23:20 CPU %usr %nice %sys %iowait %irq %soft %steal %guest %gnice %idle"
Got: "13:23:21 all 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 100.00"
Got: "13:23:22 all 0.00 0.00 0.00 0.25 0.00 0.00 0.00 0.00 0.00 99.75"
Got: "13:23:23 all 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 100.00"
Got: "Average: all 0.00 0.00 0.00 0.08 0.00 0.00 0.00 0.00 0.00 99.92"
Good bye (End of file)