Home | History | Annotate | Line # | Download | only in test
test-ipc-send-recv.c revision 1.1.1.2.4.2 
      1  1.1.1.2.4.2  martin /* Copyright Joyent, Inc. and other Node contributors. All rights reserved.
      2  1.1.1.2.4.2  martin  *
      3  1.1.1.2.4.2  martin  * Permission is hereby granted, free of charge, to any person obtaining a copy
      4  1.1.1.2.4.2  martin  * of this software and associated documentation files (the "Software"), to
      5  1.1.1.2.4.2  martin  * deal in the Software without restriction, including without limitation the
      6  1.1.1.2.4.2  martin  * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
      7  1.1.1.2.4.2  martin  * sell copies of the Software, and to permit persons to whom the Software is
      8  1.1.1.2.4.2  martin  * furnished to do so, subject to the following conditions:
      9  1.1.1.2.4.2  martin  *
     10  1.1.1.2.4.2  martin  * The above copyright notice and this permission notice shall be included in
     11  1.1.1.2.4.2  martin  * all copies or substantial portions of the Software.
     12  1.1.1.2.4.2  martin  *
     13  1.1.1.2.4.2  martin  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
     14  1.1.1.2.4.2  martin  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
     15  1.1.1.2.4.2  martin  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
     16  1.1.1.2.4.2  martin  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
     17  1.1.1.2.4.2  martin  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
     18  1.1.1.2.4.2  martin  * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
     19  1.1.1.2.4.2  martin  * IN THE SOFTWARE.
     20  1.1.1.2.4.2  martin  */
     21  1.1.1.2.4.2  martin 
     22  1.1.1.2.4.2  martin #include "uv.h"
     23  1.1.1.2.4.2  martin #include "task.h"
     24  1.1.1.2.4.2  martin 
     25  1.1.1.2.4.2  martin #include <stdio.h>
     26  1.1.1.2.4.2  martin #include <string.h>
     27  1.1.1.2.4.2  martin 
     28  1.1.1.2.4.2  martin /* See test-ipc.c */
     29  1.1.1.2.4.2  martin void spawn_helper(uv_pipe_t* channel,
     30  1.1.1.2.4.2  martin                   uv_process_t* process,
     31  1.1.1.2.4.2  martin                   const char* helper);
     32  1.1.1.2.4.2  martin 
     33  1.1.1.2.4.2  martin void ipc_send_recv_helper_threadproc(void* arg);
     34  1.1.1.2.4.2  martin 
     35  1.1.1.2.4.2  martin union handles {
     36  1.1.1.2.4.2  martin   uv_handle_t handle;
     37  1.1.1.2.4.2  martin   uv_stream_t stream;
     38  1.1.1.2.4.2  martin   uv_pipe_t pipe;
     39  1.1.1.2.4.2  martin   uv_tcp_t tcp;
     40  1.1.1.2.4.2  martin   uv_tty_t tty;
     41  1.1.1.2.4.2  martin };
     42  1.1.1.2.4.2  martin 
     43  1.1.1.2.4.2  martin struct test_ctx {
     44  1.1.1.2.4.2  martin   uv_pipe_t channel;
     45  1.1.1.2.4.2  martin   uv_connect_t connect_req;
     46  1.1.1.2.4.2  martin   uv_write_t write_req;
     47  1.1.1.2.4.2  martin   uv_write_t write_req2;
     48  1.1.1.2.4.2  martin   uv_handle_type expected_type;
     49  1.1.1.2.4.2  martin   union handles send;
     50  1.1.1.2.4.2  martin   union handles send2;
     51  1.1.1.2.4.2  martin   union handles recv;
     52  1.1.1.2.4.2  martin   union handles recv2;
     53  1.1.1.2.4.2  martin };
     54  1.1.1.2.4.2  martin 
     55  1.1.1.2.4.2  martin struct echo_ctx {
     56  1.1.1.2.4.2  martin   uv_pipe_t listen;
     57  1.1.1.2.4.2  martin   uv_pipe_t channel;
     58  1.1.1.2.4.2  martin   uv_write_t write_req;
     59  1.1.1.2.4.2  martin   uv_write_t write_req2;
     60  1.1.1.2.4.2  martin   uv_handle_type expected_type;
     61  1.1.1.2.4.2  martin   union handles recv;
     62  1.1.1.2.4.2  martin   union handles recv2;
     63  1.1.1.2.4.2  martin };
     64  1.1.1.2.4.2  martin 
     65  1.1.1.2.4.2  martin static struct test_ctx ctx;
     66  1.1.1.2.4.2  martin static struct echo_ctx ctx2;
     67  1.1.1.2.4.2  martin 
     68  1.1.1.2.4.2  martin /* Used in write2_cb to decide if we need to cleanup or not */
     69  1.1.1.2.4.2  martin static int is_child_process;
     70  1.1.1.2.4.2  martin static int is_in_process;
     71  1.1.1.2.4.2  martin static int read_cb_count;
     72  1.1.1.2.4.2  martin static int recv_cb_count;
     73  1.1.1.2.4.2  martin static int write2_cb_called;
     74  1.1.1.2.4.2  martin 
     75  1.1.1.2.4.2  martin 
     76  1.1.1.2.4.2  martin static void alloc_cb(uv_handle_t* handle,
     77  1.1.1.2.4.2  martin                      size_t suggested_size,
     78  1.1.1.2.4.2  martin                      uv_buf_t* buf) {
     79  1.1.1.2.4.2  martin   /* we're not actually reading anything so a small buffer is okay */
     80  1.1.1.2.4.2  martin   static char slab[8];
     81  1.1.1.2.4.2  martin   buf->base = slab;
     82  1.1.1.2.4.2  martin   buf->len = sizeof(slab);
     83  1.1.1.2.4.2  martin }
     84  1.1.1.2.4.2  martin 
     85  1.1.1.2.4.2  martin 
     86  1.1.1.2.4.2  martin static void recv_cb(uv_stream_t* handle,
     87  1.1.1.2.4.2  martin                     ssize_t nread,
     88  1.1.1.2.4.2  martin                     const uv_buf_t* buf) {
     89  1.1.1.2.4.2  martin   uv_handle_type pending;
     90  1.1.1.2.4.2  martin   uv_pipe_t* pipe;
     91  1.1.1.2.4.2  martin   int r;
     92  1.1.1.2.4.2  martin   union handles* recv;
     93  1.1.1.2.4.2  martin 
     94  1.1.1.2.4.2  martin   pipe = (uv_pipe_t*) handle;
     95  1.1.1.2.4.2  martin   ASSERT(pipe == &ctx.channel);
     96  1.1.1.2.4.2  martin 
     97  1.1.1.2.4.2  martin   do {
     98  1.1.1.2.4.2  martin     if (++recv_cb_count == 1) {
     99  1.1.1.2.4.2  martin       recv = &ctx.recv;
    100  1.1.1.2.4.2  martin     } else {
    101  1.1.1.2.4.2  martin       recv = &ctx.recv2;
    102  1.1.1.2.4.2  martin     }
    103  1.1.1.2.4.2  martin 
    104  1.1.1.2.4.2  martin     /* Depending on the OS, the final recv_cb can be called after
    105  1.1.1.2.4.2  martin      * the child process has terminated which can result in nread
    106  1.1.1.2.4.2  martin      * being UV_EOF instead of the number of bytes read.  Since
    107  1.1.1.2.4.2  martin      * the other end of the pipe has closed this UV_EOF is an
    108  1.1.1.2.4.2  martin      * acceptable value. */
    109  1.1.1.2.4.2  martin     if (nread == UV_EOF) {
    110  1.1.1.2.4.2  martin       /* UV_EOF is only acceptable for the final recv_cb call */
    111  1.1.1.2.4.2  martin       ASSERT(recv_cb_count == 2);
    112  1.1.1.2.4.2  martin     } else {
    113  1.1.1.2.4.2  martin       ASSERT(nread >= 0);
    114  1.1.1.2.4.2  martin       ASSERT(uv_pipe_pending_count(pipe) > 0);
    115  1.1.1.2.4.2  martin 
    116  1.1.1.2.4.2  martin       pending = uv_pipe_pending_type(pipe);
    117  1.1.1.2.4.2  martin       ASSERT(pending == ctx.expected_type);
    118  1.1.1.2.4.2  martin 
    119  1.1.1.2.4.2  martin       if (pending == UV_NAMED_PIPE)
    120  1.1.1.2.4.2  martin         r = uv_pipe_init(ctx.channel.loop, &recv->pipe, 0);
    121  1.1.1.2.4.2  martin       else if (pending == UV_TCP)
    122  1.1.1.2.4.2  martin         r = uv_tcp_init(ctx.channel.loop, &recv->tcp);
    123  1.1.1.2.4.2  martin       else
    124  1.1.1.2.4.2  martin         abort();
    125  1.1.1.2.4.2  martin       ASSERT(r == 0);
    126  1.1.1.2.4.2  martin 
    127  1.1.1.2.4.2  martin       r = uv_accept(handle, &recv->stream);
    128  1.1.1.2.4.2  martin       ASSERT(r == 0);
    129  1.1.1.2.4.2  martin     }
    130  1.1.1.2.4.2  martin   } while (uv_pipe_pending_count(pipe) > 0);
    131  1.1.1.2.4.2  martin 
    132  1.1.1.2.4.2  martin   /* Close after two writes received */
    133  1.1.1.2.4.2  martin   if (recv_cb_count == 2) {
    134  1.1.1.2.4.2  martin     uv_close((uv_handle_t*)&ctx.channel, NULL);
    135  1.1.1.2.4.2  martin   }
    136  1.1.1.2.4.2  martin }
    137  1.1.1.2.4.2  martin 
    138  1.1.1.2.4.2  martin static void connect_cb(uv_connect_t* req, int status) {
    139  1.1.1.2.4.2  martin   int r;
    140  1.1.1.2.4.2  martin   uv_buf_t buf;
    141  1.1.1.2.4.2  martin 
    142  1.1.1.2.4.2  martin   ASSERT(req == &ctx.connect_req);
    143  1.1.1.2.4.2  martin   ASSERT(status == 0);
    144  1.1.1.2.4.2  martin 
    145  1.1.1.2.4.2  martin   buf = uv_buf_init(".", 1);
    146  1.1.1.2.4.2  martin   r = uv_write2(&ctx.write_req,
    147  1.1.1.2.4.2  martin                 (uv_stream_t*)&ctx.channel,
    148  1.1.1.2.4.2  martin                 &buf, 1,
    149  1.1.1.2.4.2  martin                 &ctx.send.stream,
    150  1.1.1.2.4.2  martin                 NULL);
    151  1.1.1.2.4.2  martin   ASSERT(r == 0);
    152  1.1.1.2.4.2  martin 
    153  1.1.1.2.4.2  martin   /* Perform two writes to the same pipe to make sure that on Windows we are
    154  1.1.1.2.4.2  martin    * not running into issue 505:
    155  1.1.1.2.4.2  martin    *   https://github.com/libuv/libuv/issues/505 */
    156  1.1.1.2.4.2  martin   buf = uv_buf_init(".", 1);
    157  1.1.1.2.4.2  martin   r = uv_write2(&ctx.write_req2,
    158  1.1.1.2.4.2  martin                 (uv_stream_t*)&ctx.channel,
    159  1.1.1.2.4.2  martin                 &buf, 1,
    160  1.1.1.2.4.2  martin                 &ctx.send2.stream,
    161  1.1.1.2.4.2  martin                 NULL);
    162  1.1.1.2.4.2  martin   ASSERT(r == 0);
    163  1.1.1.2.4.2  martin 
    164  1.1.1.2.4.2  martin   r = uv_read_start((uv_stream_t*)&ctx.channel, alloc_cb, recv_cb);
    165  1.1.1.2.4.2  martin   ASSERT(r == 0);
    166  1.1.1.2.4.2  martin }
    167  1.1.1.2.4.2  martin 
    168  1.1.1.2.4.2  martin static int run_test(int inprocess) {
    169  1.1.1.2.4.2  martin   uv_process_t process;
    170  1.1.1.2.4.2  martin   uv_thread_t tid;
    171  1.1.1.2.4.2  martin   int r;
    172  1.1.1.2.4.2  martin 
    173  1.1.1.2.4.2  martin   if (inprocess) {
    174  1.1.1.2.4.2  martin     r = uv_thread_create(&tid, ipc_send_recv_helper_threadproc, (void *) 42);
    175  1.1.1.2.4.2  martin     ASSERT(r == 0);
    176  1.1.1.2.4.2  martin 
    177  1.1.1.2.4.2  martin     uv_sleep(1000);
    178  1.1.1.2.4.2  martin 
    179  1.1.1.2.4.2  martin     r = uv_pipe_init(uv_default_loop(), &ctx.channel, 1);
    180  1.1.1.2.4.2  martin     ASSERT(r == 0);
    181  1.1.1.2.4.2  martin 
    182  1.1.1.2.4.2  martin     uv_pipe_connect(&ctx.connect_req, &ctx.channel, TEST_PIPENAME_3, connect_cb);
    183  1.1.1.2.4.2  martin   } else {
    184  1.1.1.2.4.2  martin     spawn_helper(&ctx.channel, &process, "ipc_send_recv_helper");
    185  1.1.1.2.4.2  martin 
    186  1.1.1.2.4.2  martin     connect_cb(&ctx.connect_req, 0);
    187  1.1.1.2.4.2  martin   }
    188  1.1.1.2.4.2  martin 
    189  1.1.1.2.4.2  martin   r = uv_run(uv_default_loop(), UV_RUN_DEFAULT);
    190  1.1.1.2.4.2  martin   ASSERT(r == 0);
    191  1.1.1.2.4.2  martin 
    192  1.1.1.2.4.2  martin   ASSERT(recv_cb_count == 2);
    193  1.1.1.2.4.2  martin 
    194  1.1.1.2.4.2  martin   if (inprocess) {
    195  1.1.1.2.4.2  martin     r = uv_thread_join(&tid);
    196  1.1.1.2.4.2  martin     ASSERT(r == 0);
    197  1.1.1.2.4.2  martin   }
    198  1.1.1.2.4.2  martin 
    199  1.1.1.2.4.2  martin   return 0;
    200  1.1.1.2.4.2  martin }
    201  1.1.1.2.4.2  martin 
    202  1.1.1.2.4.2  martin static int run_ipc_send_recv_pipe(int inprocess) {
    203  1.1.1.2.4.2  martin   int r;
    204  1.1.1.2.4.2  martin 
    205  1.1.1.2.4.2  martin   ctx.expected_type = UV_NAMED_PIPE;
    206  1.1.1.2.4.2  martin 
    207  1.1.1.2.4.2  martin   r = uv_pipe_init(uv_default_loop(), &ctx.send.pipe, 1);
    208  1.1.1.2.4.2  martin   ASSERT(r == 0);
    209  1.1.1.2.4.2  martin 
    210  1.1.1.2.4.2  martin   r = uv_pipe_bind(&ctx.send.pipe, TEST_PIPENAME);
    211  1.1.1.2.4.2  martin   ASSERT(r == 0);
    212  1.1.1.2.4.2  martin 
    213  1.1.1.2.4.2  martin   r = uv_pipe_init(uv_default_loop(), &ctx.send2.pipe, 1);
    214  1.1.1.2.4.2  martin   ASSERT(r == 0);
    215  1.1.1.2.4.2  martin 
    216  1.1.1.2.4.2  martin   r = uv_pipe_bind(&ctx.send2.pipe, TEST_PIPENAME_2);
    217  1.1.1.2.4.2  martin   ASSERT(r == 0);
    218  1.1.1.2.4.2  martin 
    219  1.1.1.2.4.2  martin   r = run_test(inprocess);
    220  1.1.1.2.4.2  martin   ASSERT(r == 0);
    221  1.1.1.2.4.2  martin 
    222  1.1.1.2.4.2  martin   MAKE_VALGRIND_HAPPY();
    223  1.1.1.2.4.2  martin   return 0;
    224  1.1.1.2.4.2  martin }
    225  1.1.1.2.4.2  martin 
    226  1.1.1.2.4.2  martin TEST_IMPL(ipc_send_recv_pipe) {
    227  1.1.1.2.4.2  martin #if defined(NO_SEND_HANDLE_ON_PIPE)
    228  1.1.1.2.4.2  martin   RETURN_SKIP(NO_SEND_HANDLE_ON_PIPE);
    229  1.1.1.2.4.2  martin #endif
    230  1.1.1.2.4.2  martin   return run_ipc_send_recv_pipe(0);
    231  1.1.1.2.4.2  martin }
    232  1.1.1.2.4.2  martin 
    233  1.1.1.2.4.2  martin TEST_IMPL(ipc_send_recv_pipe_inprocess) {
    234  1.1.1.2.4.2  martin #if defined(NO_SEND_HANDLE_ON_PIPE)
    235  1.1.1.2.4.2  martin   RETURN_SKIP(NO_SEND_HANDLE_ON_PIPE);
    236  1.1.1.2.4.2  martin #endif
    237  1.1.1.2.4.2  martin   return run_ipc_send_recv_pipe(1);
    238  1.1.1.2.4.2  martin }
    239  1.1.1.2.4.2  martin 
    240  1.1.1.2.4.2  martin static int run_ipc_send_recv_tcp(int inprocess) {
    241  1.1.1.2.4.2  martin   struct sockaddr_in addr;
    242  1.1.1.2.4.2  martin   int r;
    243  1.1.1.2.4.2  martin 
    244  1.1.1.2.4.2  martin   ASSERT(0 == uv_ip4_addr("127.0.0.1", TEST_PORT, &addr));
    245  1.1.1.2.4.2  martin 
    246  1.1.1.2.4.2  martin   ctx.expected_type = UV_TCP;
    247  1.1.1.2.4.2  martin 
    248  1.1.1.2.4.2  martin   r = uv_tcp_init(uv_default_loop(), &ctx.send.tcp);
    249  1.1.1.2.4.2  martin   ASSERT(r == 0);
    250  1.1.1.2.4.2  martin 
    251  1.1.1.2.4.2  martin   r = uv_tcp_init(uv_default_loop(), &ctx.send2.tcp);
    252  1.1.1.2.4.2  martin   ASSERT(r == 0);
    253  1.1.1.2.4.2  martin 
    254  1.1.1.2.4.2  martin   r = uv_tcp_bind(&ctx.send.tcp, (const struct sockaddr*) &addr, 0);
    255  1.1.1.2.4.2  martin   ASSERT(r == 0);
    256  1.1.1.2.4.2  martin 
    257  1.1.1.2.4.2  martin   r = uv_tcp_bind(&ctx.send2.tcp, (const struct sockaddr*) &addr, 0);
    258  1.1.1.2.4.2  martin   ASSERT(r == 0);
    259  1.1.1.2.4.2  martin 
    260  1.1.1.2.4.2  martin   r = run_test(inprocess);
    261  1.1.1.2.4.2  martin   ASSERT(r == 0);
    262  1.1.1.2.4.2  martin 
    263  1.1.1.2.4.2  martin   MAKE_VALGRIND_HAPPY();
    264  1.1.1.2.4.2  martin   return 0;
    265  1.1.1.2.4.2  martin }
    266  1.1.1.2.4.2  martin 
    267  1.1.1.2.4.2  martin TEST_IMPL(ipc_send_recv_tcp) {
    268  1.1.1.2.4.2  martin #if defined(NO_SEND_HANDLE_ON_PIPE)
    269  1.1.1.2.4.2  martin   RETURN_SKIP(NO_SEND_HANDLE_ON_PIPE);
    270  1.1.1.2.4.2  martin #endif
    271  1.1.1.2.4.2  martin   return run_ipc_send_recv_tcp(0);
    272  1.1.1.2.4.2  martin }
    273  1.1.1.2.4.2  martin 
    274  1.1.1.2.4.2  martin TEST_IMPL(ipc_send_recv_tcp_inprocess) {
    275  1.1.1.2.4.2  martin #if defined(NO_SEND_HANDLE_ON_PIPE)
    276  1.1.1.2.4.2  martin   RETURN_SKIP(NO_SEND_HANDLE_ON_PIPE);
    277  1.1.1.2.4.2  martin #endif
    278  1.1.1.2.4.2  martin   return run_ipc_send_recv_tcp(1);
    279  1.1.1.2.4.2  martin }
    280  1.1.1.2.4.2  martin 
    281  1.1.1.2.4.2  martin 
    282  1.1.1.2.4.2  martin /* Everything here runs in a child process or second thread. */
    283  1.1.1.2.4.2  martin 
    284  1.1.1.2.4.2  martin static void write2_cb(uv_write_t* req, int status) {
    285  1.1.1.2.4.2  martin   ASSERT(status == 0);
    286  1.1.1.2.4.2  martin 
    287  1.1.1.2.4.2  martin   /* After two successful writes in the child process, allow the child
    288  1.1.1.2.4.2  martin    * process to be closed. */
    289  1.1.1.2.4.2  martin   if (++write2_cb_called == 2 && (is_child_process || is_in_process)) {
    290  1.1.1.2.4.2  martin     uv_close(&ctx2.recv.handle, NULL);
    291  1.1.1.2.4.2  martin     uv_close(&ctx2.recv2.handle, NULL);
    292  1.1.1.2.4.2  martin     uv_close((uv_handle_t*)&ctx2.channel, NULL);
    293  1.1.1.2.4.2  martin     uv_close((uv_handle_t*)&ctx2.listen, NULL);
    294  1.1.1.2.4.2  martin   }
    295  1.1.1.2.4.2  martin }
    296  1.1.1.2.4.2  martin 
    297  1.1.1.2.4.2  martin static void read_cb(uv_stream_t* handle,
    298  1.1.1.2.4.2  martin                     ssize_t nread,
    299  1.1.1.2.4.2  martin                     const uv_buf_t* rdbuf) {
    300  1.1.1.2.4.2  martin   uv_buf_t wrbuf;
    301  1.1.1.2.4.2  martin   uv_pipe_t* pipe;
    302  1.1.1.2.4.2  martin   uv_handle_type pending;
    303  1.1.1.2.4.2  martin   int r;
    304  1.1.1.2.4.2  martin   union handles* recv;
    305  1.1.1.2.4.2  martin   uv_write_t* write_req;
    306  1.1.1.2.4.2  martin 
    307  1.1.1.2.4.2  martin   if (nread == UV_EOF || nread == UV_ECONNABORTED) {
    308  1.1.1.2.4.2  martin     return;
    309  1.1.1.2.4.2  martin   }
    310  1.1.1.2.4.2  martin 
    311  1.1.1.2.4.2  martin   ASSERT_GE(nread, 0);
    312  1.1.1.2.4.2  martin 
    313  1.1.1.2.4.2  martin   pipe = (uv_pipe_t*) handle;
    314  1.1.1.2.4.2  martin   ASSERT_EQ(pipe, &ctx2.channel);
    315  1.1.1.2.4.2  martin 
    316  1.1.1.2.4.2  martin   while (uv_pipe_pending_count(pipe) > 0) {
    317  1.1.1.2.4.2  martin     if (++read_cb_count == 2) {
    318  1.1.1.2.4.2  martin       recv = &ctx2.recv;
    319  1.1.1.2.4.2  martin       write_req = &ctx2.write_req;
    320  1.1.1.2.4.2  martin     } else {
    321  1.1.1.2.4.2  martin       recv = &ctx2.recv2;
    322  1.1.1.2.4.2  martin       write_req = &ctx2.write_req2;
    323  1.1.1.2.4.2  martin     }
    324  1.1.1.2.4.2  martin 
    325  1.1.1.2.4.2  martin     pending = uv_pipe_pending_type(pipe);
    326  1.1.1.2.4.2  martin     ASSERT(pending == UV_NAMED_PIPE || pending == UV_TCP);
    327  1.1.1.2.4.2  martin 
    328  1.1.1.2.4.2  martin     if (pending == UV_NAMED_PIPE)
    329  1.1.1.2.4.2  martin       r = uv_pipe_init(ctx2.channel.loop, &recv->pipe, 0);
    330  1.1.1.2.4.2  martin     else if (pending == UV_TCP)
    331  1.1.1.2.4.2  martin       r = uv_tcp_init(ctx2.channel.loop, &recv->tcp);
    332  1.1.1.2.4.2  martin     else
    333  1.1.1.2.4.2  martin       abort();
    334  1.1.1.2.4.2  martin     ASSERT(r == 0);
    335  1.1.1.2.4.2  martin 
    336  1.1.1.2.4.2  martin     r = uv_accept(handle, &recv->stream);
    337  1.1.1.2.4.2  martin     ASSERT(r == 0);
    338  1.1.1.2.4.2  martin 
    339  1.1.1.2.4.2  martin     wrbuf = uv_buf_init(".", 1);
    340  1.1.1.2.4.2  martin     r = uv_write2(write_req,
    341  1.1.1.2.4.2  martin                   (uv_stream_t*)&ctx2.channel,
    342  1.1.1.2.4.2  martin                   &wrbuf,
    343  1.1.1.2.4.2  martin                   1,
    344  1.1.1.2.4.2  martin                   &recv->stream,
    345  1.1.1.2.4.2  martin                   write2_cb);
    346  1.1.1.2.4.2  martin     ASSERT(r == 0);
    347  1.1.1.2.4.2  martin   }
    348  1.1.1.2.4.2  martin }
    349  1.1.1.2.4.2  martin 
    350  1.1.1.2.4.2  martin static void send_recv_start(void) {
    351  1.1.1.2.4.2  martin   int r;
    352  1.1.1.2.4.2  martin   ASSERT(1 == uv_is_readable((uv_stream_t*)&ctx2.channel));
    353  1.1.1.2.4.2  martin   ASSERT(1 == uv_is_writable((uv_stream_t*)&ctx2.channel));
    354  1.1.1.2.4.2  martin   ASSERT(0 == uv_is_closing((uv_handle_t*)&ctx2.channel));
    355  1.1.1.2.4.2  martin 
    356  1.1.1.2.4.2  martin   r = uv_read_start((uv_stream_t*)&ctx2.channel, alloc_cb, read_cb);
    357  1.1.1.2.4.2  martin   ASSERT(r == 0);
    358  1.1.1.2.4.2  martin }
    359  1.1.1.2.4.2  martin 
    360  1.1.1.2.4.2  martin static void listen_cb(uv_stream_t* handle, int status) {
    361  1.1.1.2.4.2  martin   int r;
    362  1.1.1.2.4.2  martin   ASSERT(handle == (uv_stream_t*)&ctx2.listen);
    363  1.1.1.2.4.2  martin   ASSERT(status == 0);
    364  1.1.1.2.4.2  martin 
    365  1.1.1.2.4.2  martin   r = uv_accept((uv_stream_t*)&ctx2.listen, (uv_stream_t*)&ctx2.channel);
    366  1.1.1.2.4.2  martin   ASSERT(r == 0);
    367  1.1.1.2.4.2  martin 
    368  1.1.1.2.4.2  martin   send_recv_start();
    369  1.1.1.2.4.2  martin }
    370  1.1.1.2.4.2  martin 
    371  1.1.1.2.4.2  martin int run_ipc_send_recv_helper(uv_loop_t* loop, int inprocess) {
    372  1.1.1.2.4.2  martin   int r;
    373  1.1.1.2.4.2  martin 
    374  1.1.1.2.4.2  martin   is_in_process = inprocess;
    375  1.1.1.2.4.2  martin 
    376  1.1.1.2.4.2  martin   memset(&ctx2, 0, sizeof(ctx2));
    377  1.1.1.2.4.2  martin 
    378  1.1.1.2.4.2  martin   r = uv_pipe_init(loop, &ctx2.listen, 0);
    379  1.1.1.2.4.2  martin   ASSERT(r == 0);
    380  1.1.1.2.4.2  martin 
    381  1.1.1.2.4.2  martin   r = uv_pipe_init(loop, &ctx2.channel, 1);
    382  1.1.1.2.4.2  martin   ASSERT(r == 0);
    383  1.1.1.2.4.2  martin 
    384  1.1.1.2.4.2  martin   if (inprocess) {
    385  1.1.1.2.4.2  martin     r = uv_pipe_bind(&ctx2.listen, TEST_PIPENAME_3);
    386  1.1.1.2.4.2  martin     ASSERT(r == 0);
    387  1.1.1.2.4.2  martin 
    388  1.1.1.2.4.2  martin     r = uv_listen((uv_stream_t*)&ctx2.listen, SOMAXCONN, listen_cb);
    389  1.1.1.2.4.2  martin     ASSERT(r == 0);
    390  1.1.1.2.4.2  martin   } else {
    391  1.1.1.2.4.2  martin     r = uv_pipe_open(&ctx2.channel, 0);
    392  1.1.1.2.4.2  martin     ASSERT(r == 0);
    393  1.1.1.2.4.2  martin 
    394  1.1.1.2.4.2  martin     send_recv_start();
    395  1.1.1.2.4.2  martin   }
    396  1.1.1.2.4.2  martin 
    397  1.1.1.2.4.2  martin   notify_parent_process();
    398  1.1.1.2.4.2  martin   r = uv_run(loop, UV_RUN_DEFAULT);
    399  1.1.1.2.4.2  martin   ASSERT(r == 0);
    400  1.1.1.2.4.2  martin 
    401  1.1.1.2.4.2  martin   return 0;
    402  1.1.1.2.4.2  martin }
    403  1.1.1.2.4.2  martin 
    404  1.1.1.2.4.2  martin /* stdin is a duplex channel over which a handle is sent.
    405  1.1.1.2.4.2  martin  * We receive it and send it back where it came from.
    406  1.1.1.2.4.2  martin  */
    407  1.1.1.2.4.2  martin int ipc_send_recv_helper(void) {
    408  1.1.1.2.4.2  martin   int r;
    409  1.1.1.2.4.2  martin 
    410  1.1.1.2.4.2  martin   r = run_ipc_send_recv_helper(uv_default_loop(), 0);
    411  1.1.1.2.4.2  martin   ASSERT(r == 0);
    412  1.1.1.2.4.2  martin 
    413  1.1.1.2.4.2  martin   MAKE_VALGRIND_HAPPY();
    414  1.1.1.2.4.2  martin   return 0;
    415  1.1.1.2.4.2  martin }
    416  1.1.1.2.4.2  martin 
    417  1.1.1.2.4.2  martin void ipc_send_recv_helper_threadproc(void* arg) {
    418  1.1.1.2.4.2  martin   int r;
    419  1.1.1.2.4.2  martin   uv_loop_t loop;
    420  1.1.1.2.4.2  martin 
    421  1.1.1.2.4.2  martin   r = uv_loop_init(&loop);
    422  1.1.1.2.4.2  martin   ASSERT(r == 0);
    423  1.1.1.2.4.2  martin 
    424  1.1.1.2.4.2  martin   r = run_ipc_send_recv_helper(&loop, 1);
    425  1.1.1.2.4.2  martin   ASSERT(r == 0);
    426  1.1.1.2.4.2  martin 
    427  1.1.1.2.4.2  martin   r = uv_loop_close(&loop);
    428  1.1.1.2.4.2  martin   ASSERT(r == 0);
    429  1.1.1.2.4.2  martin }
    430