Function cbm_daemon_ipc_send_frame

src/daemon/ipc.c:6096–6118

#endif /* _WIN32 */

bool cbm_daemon_ipc_send_frame(cbm_daemon_ipc_connection_t *connection,
                               cbm_daemon_frame_type_t type, uint16_t flags, const void *payload,
                               uint32_t length) {
    if (!connection || atomic_load_explicit(&connection->poisoned, memory_order_acquire) ||
        (length > 0 && !payload)) {
        return false;
    }
    uint8_t header[CBM_DAEMON_FRAME_HEADER_SIZE];
    if (!cbm_daemon_frame_header_encode(header, type, flags, length)) {
        return false;
    }
    uint64_t deadline_ms = ipc_deadline_after(CBM_DAEMON_IPC_SEND_TIMEOUT_MS);
    if (connection_write_full(connection, header, sizeof(header), deadline_ms) != 1) {
        return false;
    }
    if (length > 0 && connection_write_full(connection, payload, length, deadline_ms) != 1) {
        /* The peer has already received a complete header and will interpret
         * subsequent bytes as this payload, so this stream cannot be reused. */
        atomic_store_explicit(&connection->poisoned, true, memory_order_release);
        return false;
    }
    return true;
}

int cbm_daemon_ipc_receive_frame_bounded(cbm_daemon_ipc_connection_t *connection,
                                         uint32_t timeout_ms, uint32_t max_payload_length,