deps/uv/test/test-pipe-server-close.c

   1 /* Copyright Joyent, Inc. and other Node contributors. All rights reserved.
   2  *
   3  * Permission is hereby granted, free of charge, to any person obtaining a copy
   4  * of this software and associated documentation files (the "Software"), to
   5  * deal in the Software without restriction, including without limitation the
   6  * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
   7  * sell copies of the Software, and to permit persons to whom the Software is
   8  * furnished to do so, subject to the following conditions:
   9  *
  10  * The above copyright notice and this permission notice shall be included in
  11  * all copies or substantial portions of the Software.
  12  *
  13  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  14  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  15  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  16  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  17  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
  18  * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
  19  * IN THE SOFTWARE.
  20  */
  21
  22 #include "uv.h"
  23 #include "task.h"
  24
  25 #include <string.h>
  26 #include <errno.h>
  27
  28
  29 static uv_pipe_t pipe_client;
  30 static uv_pipe_t pipe_server;
  31 static uv_connect_t connect_req;
  32
  33 static int pipe_close_cb_called = 0;
  34 static int pipe_client_connect_cb_called = 0;
  35
  36
  37 static void pipe_close_cb(uv_handle_t* handle) {
  38   ASSERT(handle == (uv_handle_t*) &pipe_client ||
  39          handle == (uv_handle_t*) &pipe_server);
  40   pipe_close_cb_called++;
  41 }
  42
  43
  44 static void pipe_client_connect_cb(uv_connect_t* req, int status) {
  45   ASSERT(req == &connect_req);
  46   ASSERT(status == 0);
  47
  48   pipe_client_connect_cb_called++;
  49
  50   uv_close((uv_handle_t*) &pipe_client, pipe_close_cb);
  51   uv_close((uv_handle_t*) &pipe_server, pipe_close_cb);
  52 }
  53
  54
  55 static void pipe_server_connection_cb(uv_stream_t* handle, int status) {
  56   /* This function *may* be called, depending on whether accept or the
  57    * connection callback is called first.
  58    */
  59   ASSERT(status == 0);
  60 }
  61
  62
  63 TEST_IMPL(pipe_server_close) {
  64   uv_loop_t* loop;
  65   int r;
  66
  67   loop = uv_default_loop();
  68   ASSERT(loop != NULL);
  69
  70   r = uv_pipe_init(loop, &pipe_server, 0);
  71   ASSERT(r == 0);
  72
  73   r = uv_pipe_bind(&pipe_server, TEST_PIPENAME);
  74   ASSERT(r == 0);
  75
  76   r = uv_listen((uv_stream_t*) &pipe_server, 0, pipe_server_connection_cb);
  77   ASSERT(r == 0);
  78
  79   r = uv_pipe_init(loop, &pipe_client, 0);
  80   ASSERT(r == 0);
  81
  82   uv_pipe_connect(&connect_req, &pipe_client, TEST_PIPENAME, pipe_client_connect_cb);
  83
  84   r = uv_run(loop, UV_RUN_DEFAULT);
  85   ASSERT(r == 0);
  86   ASSERT(pipe_client_connect_cb_called == 1);
  87   ASSERT(pipe_close_cb_called == 2);
  88
  89   MAKE_VALGRIND_HAPPY();
  90   return 0;
  91 }