|
|
|
@ -107,10 +107,11 @@ int main(int argc, char **argv) {
|
|
|
|
|
|
|
|
|
|
std::cout << "Result: " << result.out << std::endl;
|
|
|
|
|
|
|
|
|
|
// Send the job id and result.out to sink
|
|
|
|
|
zmq::message_t reply(JOB_ID_LEN + result.out.size());
|
|
|
|
|
// Send the job id, the exit code and result.out to sink
|
|
|
|
|
zmq::message_t reply(JOB_ID_LEN + sizeof(uint32_t) + result.out.size());
|
|
|
|
|
memcpy(reply.data(), jobId.data(), JOB_ID_LEN);
|
|
|
|
|
memcpy(static_cast<char *>(reply.data()) + JOB_ID_LEN, result.out.data(), result.out.size());
|
|
|
|
|
sk::write_uint32(static_cast<char *>(reply.data()) + JOB_ID_LEN, result.exit_code);
|
|
|
|
|
memcpy(static_cast<char *>(reply.data()) + JOB_ID_LEN + sizeof(uint32_t), result.out.data(), result.out.size());
|
|
|
|
|
sender.send(reply, zmq::send_flags::none);
|
|
|
|
|
}
|
|
|
|
|
return 0;
|
|
|
|
|