Function frontend_eof_writer

tests/test_daemon_frontend.c:248–277

}

static void *frontend_eof_writer(void *opaque) {
    frontend_eof_writer_t *writer = opaque;
    static const char first[] =
        "{\"jsonrpc\":\"2.0\",\"id\":1,\"method\":\"test/block\",\"params\":{}}\n";
    bool ok = frontend_eof_write_all(writer->fd, first, sizeof(first) - 1);
    uint64_t deadline = cbm_now_ms() + FRONTEND_EOF_TEST_REQUEST_TIMEOUT_MS;
    while (
        ok &&
        !atomic_load_explicit(&writer->application->first_request_started, memory_order_acquire) &&
        cbm_now_ms() < deadline) {
        cbm_usleep(1000);
    }
    ok = ok &&
         atomic_load_explicit(&writer->application->first_request_started, memory_order_acquire);
    for (int index = 0; ok && writer->overflow && index < FRONTEND_EOF_TEST_OVERFLOW_MESSAGES;
         index++) {
        char message[160];
        int written =
            snprintf(message, sizeof(message),
                     "{\"jsonrpc\":\"2.0\",\"id\":%d,\"method\":\"test/queued\",\"params\":{}}\n",
                     index + 2);
        ok = written > 0 && written < (int)sizeof(message) &&
             frontend_eof_write_all(writer->fd, message, (size_t)written);
    }
    ok = close(writer->fd) == 0 && ok;
    writer->fd = -1;
    atomic_store_explicit(&writer->succeeded, ok, memory_order_release);
    atomic_store_explicit(&writer->finished, true, memory_order_release);
    return NULL;
}

static bool frontend_eof_fixture_start(frontend_eof_fixture_t *fixture, const char *parent) {
    memset(fixture, 0, sizeof(*fixture));