|
Packit |
b5b901 |
/* Copyright Joyent, Inc. and other Node contributors. All rights reserved.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
Packit |
b5b901 |
* of this software and associated documentation files (the "Software"), to
|
|
Packit |
b5b901 |
* deal in the Software without restriction, including without limitation the
|
|
Packit |
b5b901 |
* rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
|
|
Packit |
b5b901 |
* sell copies of the Software, and to permit persons to whom the Software is
|
|
Packit |
b5b901 |
* furnished to do so, subject to the following conditions:
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* The above copyright notice and this permission notice shall be included in
|
|
Packit |
b5b901 |
* all copies or substantial portions of the Software.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
Packit |
b5b901 |
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
Packit |
b5b901 |
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
Packit |
b5b901 |
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
Packit |
b5b901 |
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
|
|
Packit |
b5b901 |
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
|
|
Packit |
b5b901 |
* IN THE SOFTWARE.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/*
|
|
Packit |
b5b901 |
* TODO: Add explanation of why we want on_close to be called from fresh
|
|
Packit |
b5b901 |
* stack.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#include "uv.h"
|
|
Packit |
b5b901 |
#include "task.h"
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static const char MESSAGE[] = "Failure is for the weak. Everyone dies alone.";
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static uv_tcp_t client;
|
|
Packit |
b5b901 |
static uv_timer_t timer;
|
|
Packit |
b5b901 |
static uv_connect_t connect_req;
|
|
Packit |
b5b901 |
static uv_write_t write_req;
|
|
Packit |
b5b901 |
static uv_shutdown_t shutdown_req;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static int nested = 0;
|
|
Packit |
b5b901 |
static int close_cb_called = 0;
|
|
Packit |
b5b901 |
static int connect_cb_called = 0;
|
|
Packit |
b5b901 |
static int write_cb_called = 0;
|
|
Packit |
b5b901 |
static int timer_cb_called = 0;
|
|
Packit |
b5b901 |
static int bytes_received = 0;
|
|
Packit |
b5b901 |
static int shutdown_cb_called = 0;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) {
|
|
Packit |
b5b901 |
buf->len = size;
|
|
Packit |
b5b901 |
buf->base = malloc(size);
|
|
Packit |
b5b901 |
ASSERT(buf->base != NULL);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void close_cb(uv_handle_t* handle) {
|
|
Packit |
b5b901 |
ASSERT(nested == 0 && "close_cb must be called from a fresh stack");
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
close_cb_called++;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void shutdown_cb(uv_shutdown_t* req, int status) {
|
|
Packit |
b5b901 |
ASSERT(status == 0);
|
|
Packit |
b5b901 |
ASSERT(nested == 0 && "shutdown_cb must be called from a fresh stack");
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
shutdown_cb_called++;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) {
|
|
Packit |
b5b901 |
ASSERT(nested == 0 && "read_cb must be called from a fresh stack");
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
printf("Read. nread == %d\n", (int)nread);
|
|
Packit |
b5b901 |
free(buf->base);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (nread == 0) {
|
|
Packit |
b5b901 |
return;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
} else if (nread < 0) {
|
|
Packit |
b5b901 |
ASSERT(nread == UV_EOF);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
nested++;
|
|
Packit |
b5b901 |
uv_close((uv_handle_t*)tcp, close_cb);
|
|
Packit |
b5b901 |
nested--;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
bytes_received += nread;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* We call shutdown here because when bytes_received == sizeof MESSAGE there
|
|
Packit |
b5b901 |
* will be no more data sent nor received, so here it would be possible for a
|
|
Packit |
b5b901 |
* backend to call shutdown_cb immediately and *not* from a fresh stack. */
|
|
Packit |
b5b901 |
if (bytes_received == sizeof MESSAGE) {
|
|
Packit |
b5b901 |
nested++;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
puts("Shutdown");
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (uv_shutdown(&shutdown_req, (uv_stream_t*)tcp, shutdown_cb)) {
|
|
Packit |
b5b901 |
FATAL("uv_shutdown failed");
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
nested--;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void timer_cb(uv_timer_t* handle) {
|
|
Packit |
b5b901 |
ASSERT(handle == &timer;;
|
|
Packit |
b5b901 |
ASSERT(nested == 0 && "timer_cb must be called from a fresh stack");
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
puts("Timeout complete. Now read data...");
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
nested++;
|
|
Packit |
b5b901 |
if (uv_read_start((uv_stream_t*)&client, alloc_cb, read_cb)) {
|
|
Packit |
b5b901 |
FATAL("uv_read_start failed");
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
nested--;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
timer_cb_called++;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uv_close((uv_handle_t*)handle, close_cb);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void write_cb(uv_write_t* req, int status) {
|
|
Packit |
b5b901 |
int r;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
ASSERT(status == 0);
|
|
Packit |
b5b901 |
ASSERT(nested == 0 && "write_cb must be called from a fresh stack");
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
puts("Data written. 500ms timeout...");
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* After the data has been sent, we're going to wait for a while, then start
|
|
Packit |
b5b901 |
* reading. This makes us certain that the message has been echoed back to
|
|
Packit |
b5b901 |
* our receive buffer when we start reading. This maximizes the temptation
|
|
Packit |
b5b901 |
* for the backend to use dirty stack for calling read_cb. */
|
|
Packit |
b5b901 |
nested++;
|
|
Packit |
b5b901 |
r = uv_timer_init(uv_default_loop(), &timer;;
|
|
Packit |
b5b901 |
ASSERT(r == 0);
|
|
Packit |
b5b901 |
r = uv_timer_start(&timer, timer_cb, 500, 0);
|
|
Packit |
b5b901 |
ASSERT(r == 0);
|
|
Packit |
b5b901 |
nested--;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
write_cb_called++;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void connect_cb(uv_connect_t* req, int status) {
|
|
Packit |
b5b901 |
uv_buf_t buf;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
puts("Connected. Write some data to echo server...");
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
ASSERT(status == 0);
|
|
Packit |
b5b901 |
ASSERT(nested == 0 && "connect_cb must be called from a fresh stack");
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
nested++;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
buf.base = (char*) &MESSAGE;
|
|
Packit |
b5b901 |
buf.len = sizeof MESSAGE;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (uv_write(&write_req, (uv_stream_t*)req->handle, &buf, 1, write_cb)) {
|
|
Packit |
b5b901 |
FATAL("uv_write failed");
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
nested--;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
connect_cb_called++;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
TEST_IMPL(callback_stack) {
|
|
Packit |
b5b901 |
struct sockaddr_in addr;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
ASSERT(0 == uv_ip4_addr("127.0.0.1", TEST_PORT, &addr));
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (uv_tcp_init(uv_default_loop(), &client)) {
|
|
Packit |
b5b901 |
FATAL("uv_tcp_init failed");
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
puts("Connecting...");
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
nested++;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (uv_tcp_connect(&connect_req,
|
|
Packit |
b5b901 |
&client,
|
|
Packit |
b5b901 |
(const struct sockaddr*) &addr,
|
|
Packit |
b5b901 |
connect_cb)) {
|
|
Packit |
b5b901 |
FATAL("uv_tcp_connect failed");
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
nested--;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uv_run(uv_default_loop(), UV_RUN_DEFAULT);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
ASSERT(nested == 0);
|
|
Packit |
b5b901 |
ASSERT(connect_cb_called == 1 && "connect_cb must be called exactly once");
|
|
Packit |
b5b901 |
ASSERT(write_cb_called == 1 && "write_cb must be called exactly once");
|
|
Packit |
b5b901 |
ASSERT(timer_cb_called == 1 && "timer_cb must be called exactly once");
|
|
Packit |
b5b901 |
ASSERT(bytes_received == sizeof MESSAGE);
|
|
Packit |
b5b901 |
ASSERT(shutdown_cb_called == 1 && "shutdown_cb must be called exactly once");
|
|
Packit |
b5b901 |
ASSERT(close_cb_called == 2 && "close_cb must be called exactly twice");
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
MAKE_VALGRIND_HAPPY();
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|