deps/uv/test/test-tcp-try-write.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 <stdio.h>
  26 #include <stdlib.h>
  27 #include <string.h>
  28
  29 #define MAX_BYTES 1024 * 1024
  30
  31 #ifdef _WIN32
  32
  33 TEST_IMPL(tcp_try_write) {
  34
  35   MAKE_VALGRIND_HAPPY();
  36   return 0;
  37 }
  38
  39 #else  /* !_WIN32 */
  40
  41 static uv_tcp_t server;
  42 static uv_tcp_t client;
  43 static uv_tcp_t incoming;
  44 static int connect_cb_called;
  45 static int close_cb_called;
  46 static int connection_cb_called;
  47 static int bytes_read;
  48 static int bytes_written;
  49
  50
  51 static void close_cb(uv_handle_t* handle) {
  52   close_cb_called++;
  53 }
  54
  55
  56 static void connect_cb(uv_connect_t* req, int status) {
  57   static char zeroes[1024];
  58   int r;
  59   uv_buf_t buf;
  60   ASSERT(status == 0);
  61   connect_cb_called++;
  62
  63   do {
  64     r = uv_try_write((uv_stream_t*) &client, zeroes, sizeof(zeroes));
  65     ASSERT(r >= 0);
  66     bytes_written += r;
  67
  68     /* Partial write */
  69     if (r != (int) sizeof(zeroes))
  70       break;
  71   } while (1);
  72   uv_close((uv_handle_t*) &client, close_cb);
  73 }
  74
  75
  76 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) {
  77   static char base[1024];
  78
  79   buf->base = base;
  80   buf->len = sizeof(base);
  81 }
  82
  83
  84 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) {
  85   if (nread < 0) {
  86     uv_close((uv_handle_t*) tcp, close_cb);
  87     uv_close((uv_handle_t*) &server, close_cb);
  88     return;
  89   }
  90
  91   bytes_read += nread;
  92 }
  93
  94
  95 static void connection_cb(uv_stream_t* tcp, int status) {
  96   ASSERT(status == 0);
  97
  98   ASSERT(0 == uv_tcp_init(tcp->loop, &incoming));
  99   ASSERT(0 == uv_accept(tcp, (uv_stream_t*) &incoming));
 100
 101   connection_cb_called++;
 102   ASSERT(0 == uv_read_start((uv_stream_t*) &incoming, alloc_cb, read_cb));
 103 }
 104
 105
 106 static void start_server(void) {
 107   struct sockaddr_in addr;
 108
 109   ASSERT(0 == uv_ip4_addr("0.0.0.0", TEST_PORT, &addr));
 110
 111   ASSERT(0 == uv_tcp_init(uv_default_loop(), &server));
 112   ASSERT(0 == uv_tcp_bind(&server, (struct sockaddr*) &addr));
 113   ASSERT(0 == uv_listen((uv_stream_t*) &server, 128, connection_cb));
 114 }
 115
 116
 117 TEST_IMPL(tcp_try_write) {
 118   uv_connect_t connect_req;
 119   struct sockaddr_in addr;
 120
 121   start_server();
 122
 123   ASSERT(0 == uv_ip4_addr("127.0.0.1", TEST_PORT, &addr));
 124
 125   ASSERT(0 == uv_tcp_init(uv_default_loop(), &client));
 126   ASSERT(0 == uv_tcp_connect(&connect_req,
 127                              &client,
 128                              (struct sockaddr*) &addr,
 129                              connect_cb));
 130
 131   ASSERT(0 == uv_run(uv_default_loop(), UV_RUN_DEFAULT));
 132
 133   ASSERT(connect_cb_called == 1);
 134   ASSERT(close_cb_called == 3);
 135   ASSERT(connection_cb_called == 1);
 136   ASSERT(bytes_read == bytes_written);
 137   ASSERT(bytes_written > 0);
 138
 139   MAKE_VALGRIND_HAPPY();
 140   return 0;
 141 }
 142
 143 #endif  /* !_WIN32 */