Method write

cpp/core/XmonAgent.cpp:20–41

};

void XmonRequest::write(int fd) const {
    ALWAYS_ASSERT(message.size() < 1<<16);
    XmonRequestHeader header = {
        .alertId = alertId,
        .quietPeriod = quietPeriod,
        .msgType = msgType,
        .appType = appType,
        .binnable = binnable,
        .messageLen = (uint16_t)message.size(),
    };
    static thread_local char buf[PIPE_BUF];
    ALWAYS_ASSERT(sizeof(header) + header.messageLen < PIPE_BUF);
    memcpy(buf, &header, sizeof(header));
    memcpy(buf+sizeof(header), message.data(), header.messageLen);
    {
        // pipe writes of < PIPE_BUF are guaranteed to be atomic, see pipe(7)
        int written = ::write(fd, buf, sizeof(header)+header.messageLen);
        if (written != sizeof(header)+header.messageLen) {
            throw SYSCALL_EXCEPTION("write");
        }
    }
}

bool XmonRequest::read(int fd) {
    static thread_local char buf[PIPE_BUF];