server/named_pipe.c

   1 /*
   2  * Server-side pipe management
   3  *
   4  * Copyright (C) 1998 Alexandre Julliard
   5  * Copyright (C) 2001 Mike McCormack
   6  *
   7  * This library is free software; you can redistribute it and/or
   8  * modify it under the terms of the GNU Lesser General Public
   9  * License as published by the Free Software Foundation; either
  10  * version 2.1 of the License, or (at your option) any later version.
  11  *
  12  * This library is distributed in the hope that it will be useful,
  13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  15  * Lesser General Public License for more details.
  16  *
  17  * You should have received a copy of the GNU Lesser General Public
  18  * License along with this library; if not, write to the Free Software
  19  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
  20  *
  21  * TODO:
  22  *   message mode
  23  */
  24
  25 #include "config.h"
  26 #include "wine/port.h"
  27
  28 #include <assert.h>
  29 #include <fcntl.h>
  30 #include <string.h>
  31 #include <stdarg.h>
  32 #include <stdio.h>
  33 #include <stdlib.h>
  34 #include <sys/time.h>
  35 #include <sys/types.h>
  36 #ifdef HAVE_SYS_SOCKET_H
  37 #include <sys/socket.h>
  38 #endif
  39 #include <time.h>
  40 #include <unistd.h>
  41 #ifdef HAVE_POLL_H
  42 #include <poll.h>
  43 #endif
  44
  45 #include "ntstatus.h"
  46 #define WIN32_NO_STATUS
  47 #include "windef.h"
  48 #include "winternl.h"
  49 #include "winioctl.h"
  50
  51 #include "file.h"
  52 #include "handle.h"
  53 #include "thread.h"
  54 #include "request.h"
  55
  56 enum pipe_state
  57 {
  58     ps_idle_server,
  59     ps_wait_open,
  60     ps_connected_server,
  61     ps_wait_disconnect,
  62     ps_disconnected_server,
  63     ps_wait_connect
  64 };
  65
  66 struct named_pipe;
  67
  68 struct pipe_server
  69 {
  70     struct object        obj;        /* object header */
  71     struct fd           *fd;         /* pipe file descriptor */
  72     struct fd           *ioctl_fd;   /* file descriptor for ioctls when not connected */
  73     struct list          entry;      /* entry in named pipe servers list */
  74     enum pipe_state      state;      /* server state */
  75     struct pipe_client  *client;     /* client that this server is connected to */
  76     struct named_pipe   *pipe;
  77     struct timeout_user *flush_poll;
  78     struct event        *event;
  79     unsigned int         options;    /* pipe options */
  80 };
  81
  82 struct pipe_client
  83 {
  84     struct object        obj;        /* object header */
  85     struct fd           *fd;         /* pipe file descriptor */
  86     struct pipe_server  *server;     /* server that this client is connected to */
  87     unsigned int         flags;      /* file flags */
  88 };
  89
  90 struct named_pipe
  91 {
  92     struct object       obj;         /* object header */
  93     unsigned int        flags;
  94     unsigned int        maxinstances;
  95     unsigned int        outsize;
  96     unsigned int        insize;
  97     unsigned int        instances;
  98     timeout_t           timeout;
  99     struct list         servers;     /* list of servers using this pipe */
 100     struct async_queue *waiters;     /* list of clients waiting to connect */
 101 };
 102
 103 struct named_pipe_device
 104 {
 105     struct object       obj;         /* object header */
 106     struct fd          *fd;          /* pseudo-fd for ioctls */
 107     struct namespace   *pipes;       /* named pipe namespace */
 108 };
 109
 110 static void named_pipe_dump( struct object *obj, int verbose );
 111 static unsigned int named_pipe_map_access( struct object *obj, unsigned int access );
 112 static struct object *named_pipe_open_file( struct object *obj, unsigned int access,
 113                                             unsigned int sharing, unsigned int options );
 114 static void named_pipe_destroy( struct object *obj );
 115
 116 static const struct object_ops named_pipe_ops =
 117 {
 118     sizeof(struct named_pipe),    /* size */
 119     named_pipe_dump,              /* dump */
 120     no_get_type,                  /* get_type */
 121     no_add_queue,                 /* add_queue */
 122     NULL,                         /* remove_queue */
 123     NULL,                         /* signaled */
 124     NULL,                         /* satisfied */
 125     no_signal,                    /* signal */
 126     no_get_fd,                    /* get_fd */
 127     named_pipe_map_access,        /* map_access */
 128     default_get_sd,               /* get_sd */
 129     default_set_sd,               /* set_sd */
 130     no_lookup_name,               /* lookup_name */
 131     named_pipe_open_file,         /* open_file */
 132     no_close_handle,              /* close_handle */
 133     named_pipe_destroy            /* destroy */
 134 };
 135
 136 /* server end functions */
 137 static void pipe_server_dump( struct object *obj, int verbose );
 138 static struct fd *pipe_server_get_fd( struct object *obj );
 139 static void pipe_server_destroy( struct object *obj);
 140 static void pipe_server_flush( struct fd *fd, struct event **event );
 141 static enum server_fd_type pipe_server_get_fd_type( struct fd *fd );
 142 static obj_handle_t pipe_server_ioctl( struct fd *fd, ioctl_code_t code, const async_data_t *async,
 143                                        int blocking, const void *data, data_size_t size );
 144
 145 static const struct object_ops pipe_server_ops =
 146 {
 147     sizeof(struct pipe_server),   /* size */
 148     pipe_server_dump,             /* dump */
 149     no_get_type,                  /* get_type */
 150     add_queue,                    /* add_queue */
 151     remove_queue,                 /* remove_queue */
 152     default_fd_signaled,          /* signaled */
 153     no_satisfied,                 /* satisfied */
 154     no_signal,                    /* signal */
 155     pipe_server_get_fd,           /* get_fd */
 156     default_fd_map_access,        /* map_access */
 157     default_get_sd,               /* get_sd */
 158     default_set_sd,               /* set_sd */
 159     no_lookup_name,               /* lookup_name */
 160     no_open_file,                 /* open_file */
 161     fd_close_handle,              /* close_handle */
 162     pipe_server_destroy           /* destroy */
 163 };
 164
 165 static const struct fd_ops pipe_server_fd_ops =
 166 {
 167     default_fd_get_poll_events,   /* get_poll_events */
 168     default_poll_event,           /* poll_event */
 169     pipe_server_flush,            /* flush */
 170     pipe_server_get_fd_type,      /* get_fd_type */
 171     pipe_server_ioctl,            /* ioctl */
 172     default_fd_queue_async,       /* queue_async */
 173     default_fd_reselect_async,    /* reselect_async */
 174     default_fd_cancel_async,      /* cancel_async */
 175 };
 176
 177 /* client end functions */
 178 static void pipe_client_dump( struct object *obj, int verbose );
 179 static int pipe_client_signaled( struct object *obj, struct thread *thread );
 180 static struct fd *pipe_client_get_fd( struct object *obj );
 181 static void pipe_client_destroy( struct object *obj );
 182 static void pipe_client_flush( struct fd *fd, struct event **event );
 183 static enum server_fd_type pipe_client_get_fd_type( struct fd *fd );
 184
 185 static const struct object_ops pipe_client_ops =
 186 {
 187     sizeof(struct pipe_client),   /* size */
 188     pipe_client_dump,             /* dump */
 189     no_get_type,                  /* get_type */
 190     add_queue,                    /* add_queue */
 191     remove_queue,                 /* remove_queue */
 192     pipe_client_signaled,         /* signaled */
 193     no_satisfied,                 /* satisfied */
 194     no_signal,                    /* signal */
 195     pipe_client_get_fd,           /* get_fd */
 196     default_fd_map_access,        /* map_access */
 197     default_get_sd,               /* get_sd */
 198     default_set_sd,               /* set_sd */
 199     no_lookup_name,               /* lookup_name */
 200     no_open_file,                 /* open_file */
 201     fd_close_handle,              /* close_handle */
 202     pipe_client_destroy           /* destroy */
 203 };
 204
 205 static const struct fd_ops pipe_client_fd_ops =
 206 {
 207     default_fd_get_poll_events,   /* get_poll_events */
 208     default_poll_event,           /* poll_event */
 209     pipe_client_flush,            /* flush */
 210     pipe_client_get_fd_type,      /* get_fd_type */
 211     default_fd_ioctl,             /* ioctl */
 212     default_fd_queue_async,       /* queue_async */
 213     default_fd_reselect_async,    /* reselect_async */
 214     default_fd_cancel_async       /* cancel_async */
 215 };
 216
 217 static void named_pipe_device_dump( struct object *obj, int verbose );
 218 static struct object_type *named_pipe_device_get_type( struct object *obj );
 219 static struct fd *named_pipe_device_get_fd( struct object *obj );
 220 static struct object *named_pipe_device_lookup_name( struct object *obj,
 221     struct unicode_str *name, unsigned int attr );
 222 static struct object *named_pipe_device_open_file( struct object *obj, unsigned int access,
 223                                                    unsigned int sharing, unsigned int options );
 224 static void named_pipe_device_destroy( struct object *obj );
 225 static enum server_fd_type named_pipe_device_get_fd_type( struct fd *fd );
 226 static obj_handle_t named_pipe_device_ioctl( struct fd *fd, ioctl_code_t code, const async_data_t *async_data,
 227                                              int blocking, const void *data, data_size_t size );
 228
 229 static const struct object_ops named_pipe_device_ops =
 230 {
 231     sizeof(struct named_pipe_device), /* size */
 232     named_pipe_device_dump,           /* dump */
 233     named_pipe_device_get_type,       /* get_type */
 234     no_add_queue,                     /* add_queue */
 235     NULL,                             /* remove_queue */
 236     NULL,                             /* signaled */
 237     no_satisfied,                     /* satisfied */
 238     no_signal,                        /* signal */
 239     named_pipe_device_get_fd,         /* get_fd */
 240     no_map_access,                    /* map_access */
 241     default_get_sd,                   /* get_sd */
 242     default_set_sd,                   /* set_sd */
 243     named_pipe_device_lookup_name,    /* lookup_name */
 244     named_pipe_device_open_file,      /* open_file */
 245     fd_close_handle,                  /* close_handle */
 246     named_pipe_device_destroy         /* destroy */
 247 };
 248
 249 static const struct fd_ops named_pipe_device_fd_ops =
 250 {
 251     default_fd_get_poll_events,       /* get_poll_events */
 252     default_poll_event,               /* poll_event */
 253     no_flush,                         /* flush */
 254     named_pipe_device_get_fd_type,    /* get_fd_type */
 255     named_pipe_device_ioctl,          /* ioctl */
 256     default_fd_queue_async,           /* queue_async */
 257     default_fd_reselect_async,        /* reselect_async */
 258     default_fd_cancel_async           /* cancel_async */
 259 };
 260
 261 static void named_pipe_dump( struct object *obj, int verbose )
 262 {
 263     struct named_pipe *pipe = (struct named_pipe *) obj;
 264     assert( obj->ops == &named_pipe_ops );
 265     fprintf( stderr, "Named pipe " );
 266     dump_object_name( &pipe->obj );
 267     fprintf( stderr, "\n" );
 268 }
 269
 270 static unsigned int named_pipe_map_access( struct object *obj, unsigned int access )
 271 {
 272     if (access & GENERIC_READ)    access |= STANDARD_RIGHTS_READ;
 273     if (access & GENERIC_WRITE)   access |= STANDARD_RIGHTS_WRITE | FILE_CREATE_PIPE_INSTANCE;
 274     if (access & GENERIC_EXECUTE) access |= STANDARD_RIGHTS_EXECUTE;
 275     if (access & GENERIC_ALL)     access |= STANDARD_RIGHTS_ALL;
 276     return access & ~(GENERIC_READ | GENERIC_WRITE | GENERIC_EXECUTE | GENERIC_ALL);
 277 }
 278
 279 static void pipe_server_dump( struct object *obj, int verbose )
 280 {
 281     struct pipe_server *server = (struct pipe_server *) obj;
 282     assert( obj->ops == &pipe_server_ops );
 283     fprintf( stderr, "Named pipe server pipe=%p state=%d\n", server->pipe, server->state );
 284 }
 285
 286 static void pipe_client_dump( struct object *obj, int verbose )
 287 {
 288     struct pipe_client *client = (struct pipe_client *) obj;
 289     assert( obj->ops == &pipe_client_ops );
 290     fprintf( stderr, "Named pipe client server=%p\n", client->server );
 291 }
 292
 293 static int pipe_client_signaled( struct object *obj, struct thread *thread )
 294 {
 295     struct pipe_client *client = (struct pipe_client *) obj;
 296
 297     return client->fd && is_fd_signaled(client->fd);
 298 }
 299
 300 static void named_pipe_destroy( struct object *obj)
 301 {
 302     struct named_pipe *pipe = (struct named_pipe *) obj;
 303
 304     assert( list_empty( &pipe->servers ) );
 305     assert( !pipe->instances );
 306     free_async_queue( pipe->waiters );
 307 }
 308
 309 static struct fd *pipe_client_get_fd( struct object *obj )
 310 {
 311     struct pipe_client *client = (struct pipe_client *) obj;
 312     if (client->fd)
 313         return (struct fd *) grab_object( client->fd );
 314     set_error( STATUS_PIPE_DISCONNECTED );
 315     return NULL;
 316 }
 317
 318 static void set_server_state( struct pipe_server *server, enum pipe_state state )
 319 {
 320     server->state = state;
 321
 322     switch(state)
 323     {
 324     case ps_connected_server:
 325     case ps_wait_disconnect:
 326         assert( server->fd );
 327         break;
 328     case ps_wait_open:
 329     case ps_idle_server:
 330         assert( !server->fd );
 331         set_no_fd_status( server->ioctl_fd, STATUS_PIPE_LISTENING );
 332         break;
 333     case ps_disconnected_server:
 334     case ps_wait_connect:
 335         assert( !server->fd );
 336         set_no_fd_status( server->ioctl_fd, STATUS_PIPE_DISCONNECTED );
 337         break;
 338     }
 339 }
 340
 341 static struct fd *pipe_server_get_fd( struct object *obj )
 342 {
 343     struct pipe_server *server = (struct pipe_server *) obj;
 344
 345     return (struct fd *)grab_object( server->fd ? server->fd : server->ioctl_fd );
 346 }
 347
 348
 349 static void notify_empty( struct pipe_server *server )
 350 {
 351     if (!server->flush_poll)
 352         return;
 353     assert( server->state == ps_connected_server );
 354     assert( server->event );
 355     remove_timeout_user( server->flush_poll );
 356     server->flush_poll = NULL;
 357     set_event( server->event );
 358     release_object( server->event );
 359     server->event = NULL;
 360 }
 361
 362 static void do_disconnect( struct pipe_server *server )
 363 {
 364     /* we may only have a server fd, if the client disconnected */
 365     if (server->client)
 366     {
 367         assert( server->client->server == server );
 368         assert( server->client->fd );
 369         release_object( server->client->fd );
 370         server->client->fd = NULL;
 371     }
 372     assert( server->fd );
 373     shutdown( get_unix_fd( server->fd ), SHUT_RDWR );
 374     release_object( server->fd );
 375     server->fd = NULL;
 376 }
 377
 378 static void pipe_server_destroy( struct object *obj)
 379 {
 380     struct pipe_server *server = (struct pipe_server *)obj;
 381
 382     assert( obj->ops == &pipe_server_ops );
 383
 384     if (server->fd)
 385     {
 386         notify_empty( server );
 387         do_disconnect( server );
 388     }
 389
 390     if (server->client)
 391     {
 392         server->client->server = NULL;
 393         server->client = NULL;
 394     }
 395
 396     assert( server->pipe->instances );
 397     server->pipe->instances--;
 398
 399     if (server->ioctl_fd) release_object( server->ioctl_fd );
 400     list_remove( &server->entry );
 401     release_object( server->pipe );
 402 }
 403
 404 static void pipe_client_destroy( struct object *obj)
 405 {
 406     struct pipe_client *client = (struct pipe_client *)obj;
 407     struct pipe_server *server = client->server;
 408
 409     assert( obj->ops == &pipe_client_ops );
 410
 411     if (server)
 412     {
 413         notify_empty( server );
 414
 415         switch(server->state)
 416         {
 417         case ps_connected_server:
 418             /* Don't destroy the server's fd here as we can't
 419                do a successful flush without it. */
 420             set_server_state( server, ps_wait_disconnect );
 421             break;
 422         case ps_disconnected_server:
 423             set_server_state( server, ps_wait_connect );
 424             break;
 425         case ps_idle_server:
 426         case ps_wait_open:
 427         case ps_wait_disconnect:
 428         case ps_wait_connect:
 429             assert( 0 );
 430         }
 431         assert( server->client );
 432         server->client = NULL;
 433         client->server = NULL;
 434     }
 435     if (client->fd) release_object( client->fd );
 436 }
 437
 438 static void named_pipe_device_dump( struct object *obj, int verbose )
 439 {
 440     assert( obj->ops == &named_pipe_device_ops );
 441     fprintf( stderr, "Named pipe device\n" );
 442 }
 443
 444 static struct object_type *named_pipe_device_get_type( struct object *obj )
 445 {
 446     static const WCHAR name[] = {'D','e','v','i','c','e'};
 447     static const struct unicode_str str = { name, sizeof(name) };
 448     return get_object_type( &str );
 449 }
 450
 451 static struct fd *named_pipe_device_get_fd( struct object *obj )
 452 {
 453     struct named_pipe_device *device = (struct named_pipe_device *)obj;
 454     return (struct fd *)grab_object( device->fd );
 455 }
 456
 457 static struct object *named_pipe_device_lookup_name( struct object *obj, struct unicode_str *name,
 458                                                      unsigned int attr )
 459 {
 460     struct named_pipe_device *device = (struct named_pipe_device*)obj;
 461     struct object *found;
 462
 463     assert( obj->ops == &named_pipe_device_ops );
 464     assert( device->pipes );
 465
 466     if ((found = find_object( device->pipes, name, attr | OBJ_CASE_INSENSITIVE )))
 467         name->len = 0;
 468
 469     return found;
 470 }
 471
 472 static struct object *named_pipe_device_open_file( struct object *obj, unsigned int access,
 473                                                    unsigned int sharing, unsigned int options )
 474 {
 475     return grab_object( obj );
 476 }
 477
 478 static void named_pipe_device_destroy( struct object *obj )
 479 {
 480     struct named_pipe_device *device = (struct named_pipe_device*)obj;
 481     assert( obj->ops == &named_pipe_device_ops );
 482     if (device->fd) release_object( device->fd );
 483     free( device->pipes );
 484 }
 485
 486 static enum server_fd_type named_pipe_device_get_fd_type( struct fd *fd )
 487 {
 488     return FD_TYPE_DEVICE;
 489 }
 490
 491 void create_named_pipe_device( struct directory *root, const struct unicode_str *name )
 492 {
 493     struct named_pipe_device *dev;
 494
 495     if ((dev = create_named_object_dir( root, name, 0, &named_pipe_device_ops )) &&
 496         get_error() != STATUS_OBJECT_NAME_EXISTS)
 497     {
 498         dev->pipes = NULL;
 499         if (!(dev->fd = alloc_pseudo_fd( &named_pipe_device_fd_ops, &dev->obj, 0 )) ||
 500             !(dev->pipes = create_namespace( 7 )))
 501         {
 502             release_object( dev );
 503             dev = NULL;
 504         }
 505     }
 506     if (dev) make_object_static( &dev->obj );
 507 }
 508
 509 static int pipe_data_remaining( struct pipe_server *server )
 510 {
 511     struct pollfd pfd;
 512     int fd;
 513
 514     assert( server->client );
 515
 516     fd = get_unix_fd( server->client->fd );
 517     if (fd < 0)
 518         return 0;
 519     pfd.fd = fd;
 520     pfd.events = POLLIN;
 521     pfd.revents = 0;
 522
 523     if (0 > poll( &pfd, 1, 0 ))
 524         return 0;
 525
 526     return pfd.revents&POLLIN;
 527 }
 528
 529 static void check_flushed( void *arg )
 530 {
 531     struct pipe_server *server = (struct pipe_server*) arg;
 532
 533     assert( server->event );
 534     if (pipe_data_remaining( server ))
 535     {
 536         server->flush_poll = add_timeout_user( -TICKS_PER_SEC / 10, check_flushed, server );
 537     }
 538     else
 539     {
 540         /* notify_empty( server ); */
 541         server->flush_poll = NULL;
 542         set_event( server->event );
 543         release_object( server->event );
 544         server->event = NULL;
 545     }
 546 }
 547
 548 static void pipe_server_flush( struct fd *fd, struct event **event )
 549 {
 550     struct pipe_server *server = get_fd_user( fd );
 551
 552     if (!server || server->state != ps_connected_server) return;
 553
 554     /* FIXME: if multiple threads flush the same pipe,
 555               maybe should create a list of processes to notify */
 556     if (server->flush_poll) return;
 557
 558     if (pipe_data_remaining( server ))
 559     {
 560         /* this kind of sux -
 561            there's no unix way to be alerted when a pipe becomes empty */
 562         server->event = create_event( NULL, NULL, 0, 0, 0, NULL );
 563         if (!server->event) return;
 564         server->flush_poll = add_timeout_user( -TICKS_PER_SEC / 10, check_flushed, server );
 565         *event = server->event;
 566     }
 567 }
 568
 569 static void pipe_client_flush( struct fd *fd, struct event **event )
 570 {
 571     /* FIXME: what do we have to do for this? */
 572 }
 573
 574 static inline int is_overlapped( unsigned int options )
 575 {
 576     return !(options & (FILE_SYNCHRONOUS_IO_ALERT | FILE_SYNCHRONOUS_IO_NONALERT));
 577 }
 578
 579 static enum server_fd_type pipe_server_get_fd_type( struct fd *fd )
 580 {
 581     return FD_TYPE_PIPE;
 582 }
 583
 584 static enum server_fd_type pipe_client_get_fd_type( struct fd *fd )
 585 {
 586     return FD_TYPE_PIPE;
 587 }
 588
 589 static obj_handle_t alloc_wait_event( struct process *process )
 590 {
 591     obj_handle_t handle = 0;
 592     struct event *event = create_event( NULL, NULL, 0, 1, 0, NULL );
 593
 594     if (event)
 595     {
 596         handle = alloc_handle( process, event, EVENT_ALL_ACCESS, 0 );
 597         release_object( event );
 598     }
 599     return handle;
 600 }
 601
 602 static obj_handle_t pipe_server_ioctl( struct fd *fd, ioctl_code_t code, const async_data_t *async_data,
 603                                        int blocking, const void *data, data_size_t size )
 604 {
 605     struct pipe_server *server = get_fd_user( fd );
 606     struct async *async;
 607     obj_handle_t wait_handle = 0;
 608
 609     switch(code)
 610     {
 611     case FSCTL_PIPE_LISTEN:
 612         switch(server->state)
 613         {
 614         case ps_idle_server:
 615         case ps_wait_connect:
 616             if (blocking)
 617             {
 618                 async_data_t new_data = *async_data;
 619                 if (!(wait_handle = alloc_wait_event( current->process ))) break;
 620                 new_data.event = wait_handle;
 621                 if (!(async = fd_queue_async( server->ioctl_fd, &new_data, ASYNC_TYPE_WAIT )))
 622                 {
 623                     close_handle( current->process, wait_handle );
 624                     break;
 625                 }
 626             }
 627             else async = fd_queue_async( server->ioctl_fd, async_data, ASYNC_TYPE_WAIT );
 628
 629             if (async)
 630             {
 631                 set_server_state( server, ps_wait_open );
 632                 if (server->pipe->waiters) async_wake_up( server->pipe->waiters, STATUS_SUCCESS );
 633                 release_object( async );
 634                 set_error( STATUS_PENDING );
 635                 return wait_handle;
 636             }
 637             break;
 638         case ps_connected_server:
 639             set_error( STATUS_PIPE_CONNECTED );
 640             break;
 641         case ps_disconnected_server:
 642             set_error( STATUS_PIPE_BUSY );
 643             break;
 644         case ps_wait_disconnect:
 645             set_error( STATUS_NO_DATA_DETECTED );
 646             break;
 647         case ps_wait_open:
 648             set_error( STATUS_INVALID_HANDLE );
 649             break;
 650         }
 651         return 0;
 652
 653     case FSCTL_PIPE_DISCONNECT:
 654         switch(server->state)
 655         {
 656         case ps_connected_server:
 657             assert( server->client );
 658             assert( server->client->fd );
 659
 660             notify_empty( server );
 661
 662             /* dump the client and server fds, but keep the pointers
 663                around - client loses all waiting data */
 664             do_disconnect( server );
 665             set_server_state( server, ps_disconnected_server );
 666             break;
 667         case ps_wait_disconnect:
 668             assert( !server->client );
 669             do_disconnect( server );
 670             set_server_state( server, ps_wait_connect );
 671             break;
 672         case ps_idle_server:
 673         case ps_wait_open:
 674             set_error( STATUS_PIPE_LISTENING );
 675             break;
 676         case ps_disconnected_server:
 677         case ps_wait_connect:
 678             set_error( STATUS_PIPE_DISCONNECTED );
 679             break;
 680         }
 681         return 0;
 682
 683     default:
 684         return default_fd_ioctl( fd, code, async_data, blocking, data, size );
 685     }
 686 }
 687
 688 static struct named_pipe *create_named_pipe( struct directory *root, const struct unicode_str *name,
 689                                              unsigned int attr )
 690 {
 691     struct object *obj;
 692     struct named_pipe *pipe = NULL;
 693     struct unicode_str new_name;
 694
 695     if (!name || !name->len) return alloc_object( &named_pipe_ops );
 696
 697     if (!(obj = find_object_dir( root, name, attr, &new_name )))
 698     {
 699         set_error( STATUS_OBJECT_NAME_INVALID );
 700         return NULL;
 701     }
 702     if (!new_name.len)
 703     {
 704         if (attr & OBJ_OPENIF && obj->ops == &named_pipe_ops)
 705             set_error( STATUS_OBJECT_NAME_EXISTS );
 706         else
 707         {
 708             release_object( obj );
 709             obj = NULL;
 710             if (attr & OBJ_OPENIF)
 711                 set_error( STATUS_OBJECT_TYPE_MISMATCH );
 712             else
 713                 set_error( STATUS_OBJECT_NAME_COLLISION );
 714         }
 715         return (struct named_pipe *)obj;
 716     }
 717
 718     if (obj->ops != &named_pipe_device_ops)
 719         set_error( STATUS_OBJECT_NAME_INVALID );
 720     else
 721     {
 722         struct named_pipe_device *dev = (struct named_pipe_device *)obj;
 723         if ((pipe = create_object( dev->pipes, &named_pipe_ops, &new_name, NULL )))
 724             clear_error();
 725     }
 726
 727     release_object( obj );
 728     return pipe;
 729 }
 730
 731 static struct pipe_server *get_pipe_server_obj( struct process *process,
 732                                 obj_handle_t handle, unsigned int access )
 733 {
 734     struct object *obj;
 735     obj = get_handle_obj( process, handle, access, &pipe_server_ops );
 736     return (struct pipe_server *) obj;
 737 }
 738
 739 static struct pipe_server *create_pipe_server( struct named_pipe *pipe, unsigned int options )
 740 {
 741     struct pipe_server *server;
 742
 743     server = alloc_object( &pipe_server_ops );
 744     if (!server)
 745         return NULL;
 746
 747     server->fd = NULL;
 748     server->pipe = pipe;
 749     server->client = NULL;
 750     server->flush_poll = NULL;
 751     server->options = options;
 752
 753     list_add_head( &pipe->servers, &server->entry );
 754     grab_object( pipe );
 755     if (!(server->ioctl_fd = alloc_pseudo_fd( &pipe_server_fd_ops, &server->obj, options )))
 756     {
 757         release_object( server );
 758         return NULL;
 759     }
 760     set_server_state( server, ps_idle_server );
 761     return server;
 762 }
 763
 764 static struct pipe_client *create_pipe_client( unsigned int flags )
 765 {
 766     struct pipe_client *client;
 767
 768     client = alloc_object( &pipe_client_ops );
 769     if (!client)
 770         return NULL;
 771
 772     client->fd = NULL;
 773     client->server = NULL;
 774     client->flags = flags;
 775
 776     return client;
 777 }
 778
 779 static struct pipe_server *find_available_server( struct named_pipe *pipe )
 780 {
 781     struct pipe_server *server;
 782
 783     /* look for pipe servers that are listening */
 784     LIST_FOR_EACH_ENTRY( server, &pipe->servers, struct pipe_server, entry )
 785     {
 786         if (server->state == ps_wait_open)
 787             return (struct pipe_server *)grab_object( server );
 788     }
 789
 790     /* fall back to pipe servers that are idle */
 791     LIST_FOR_EACH_ENTRY( server, &pipe->servers, struct pipe_server, entry )
 792     {
 793         if (server->state == ps_idle_server)
 794             return (struct pipe_server *)grab_object( server );
 795     }
 796
 797     return NULL;
 798 }
 799
 800 static struct object *named_pipe_open_file( struct object *obj, unsigned int access,
 801                                             unsigned int sharing, unsigned int options )
 802 {
 803     struct named_pipe *pipe = (struct named_pipe *)obj;
 804     struct pipe_server *server;
 805     struct pipe_client *client;
 806     int fds[2];
 807
 808     if (!(server = find_available_server( pipe )))
 809     {
 810         set_error( STATUS_PIPE_NOT_AVAILABLE );
 811         return NULL;
 812     }
 813
 814     if ((client = create_pipe_client( options )))
 815     {
 816         if (!socketpair( PF_UNIX, SOCK_STREAM, 0, fds ))
 817         {
 818             assert( !server->fd );
 819
 820             /* for performance reasons, only set nonblocking mode when using
 821              * overlapped I/O. Otherwise, we will be doing too much busy
 822              * looping */
 823             if (is_overlapped( options )) fcntl( fds[1], F_SETFL, O_NONBLOCK );
 824             if (is_overlapped( server->options )) fcntl( fds[0], F_SETFL, O_NONBLOCK );
 825
 826             if (pipe->insize)
 827             {
 828                 setsockopt( fds[0], SOL_SOCKET, SO_RCVBUF, &pipe->insize, sizeof(pipe->insize) );
 829                 setsockopt( fds[1], SOL_SOCKET, SO_RCVBUF, &pipe->insize, sizeof(pipe->insize) );
 830             }
 831             if (pipe->outsize)
 832             {
 833                 setsockopt( fds[0], SOL_SOCKET, SO_SNDBUF, &pipe->outsize, sizeof(pipe->outsize) );
 834                 setsockopt( fds[1], SOL_SOCKET, SO_SNDBUF, &pipe->outsize, sizeof(pipe->outsize) );
 835             }
 836
 837             client->fd = create_anonymous_fd( &pipe_client_fd_ops, fds[1], &client->obj, options );
 838             server->fd = create_anonymous_fd( &pipe_server_fd_ops, fds[0], &server->obj, server->options );
 839             if (client->fd && server->fd)
 840             {
 841                 fd_copy_completion( server->ioctl_fd, server->fd );
 842                 if (server->state == ps_wait_open)
 843                     fd_async_wake_up( server->ioctl_fd, ASYNC_TYPE_WAIT, STATUS_SUCCESS );
 844                 set_server_state( server, ps_connected_server );
 845                 server->client = client;
 846                 client->server = server;
 847             }
 848             else
 849             {
 850                 release_object( client );
 851                 client = NULL;
 852             }
 853         }
 854         else
 855         {
 856             file_set_error();
 857             release_object( client );
 858             client = NULL;
 859         }
 860     }
 861     release_object( server );
 862     return &client->obj;
 863 }
 864
 865 static obj_handle_t named_pipe_device_ioctl( struct fd *fd, ioctl_code_t code, const async_data_t *async_data,
 866                                              int blocking, const void *data, data_size_t size )
 867 {
 868     struct named_pipe_device *device = get_fd_user( fd );
 869
 870     switch(code)
 871     {
 872     case FSCTL_PIPE_WAIT:
 873         {
 874             const FILE_PIPE_WAIT_FOR_BUFFER *buffer = data;
 875             obj_handle_t wait_handle = 0;
 876             struct named_pipe *pipe;
 877             struct pipe_server *server;
 878             struct unicode_str name;
 879
 880             if (size < sizeof(*buffer) ||
 881                 size < FIELD_OFFSET(FILE_PIPE_WAIT_FOR_BUFFER, Name[buffer->NameLength/sizeof(WCHAR)]))
 882             {
 883                 set_error( STATUS_INVALID_PARAMETER );
 884                 return 0;
 885             }
 886             name.str = buffer->Name;
 887             name.len = (buffer->NameLength / sizeof(WCHAR)) * sizeof(WCHAR);
 888             if (!(pipe = (struct named_pipe *)find_object( device->pipes, &name, OBJ_CASE_INSENSITIVE )))
 889             {
 890                 set_error( STATUS_PIPE_NOT_AVAILABLE );
 891                 return 0;
 892             }
 893             if (!(server = find_available_server( pipe )))
 894             {
 895                 struct async *async;
 896
 897                 if (!pipe->waiters && !(pipe->waiters = create_async_queue( NULL ))) goto done;
 898
 899                 if (blocking)
 900                 {
 901                     async_data_t new_data = *async_data;
 902                     if (!(wait_handle = alloc_wait_event( current->process ))) goto done;
 903                     new_data.event = wait_handle;
 904                     if (!(async = create_async( current, pipe->waiters, &new_data )))
 905                     {
 906                         close_handle( current->process, wait_handle );
 907                         wait_handle = 0;
 908                     }
 909                 }
 910                 else async = create_async( current, pipe->waiters, async_data );
 911
 912                 if (async)
 913                 {
 914                     timeout_t when = buffer->TimeoutSpecified ? buffer->Timeout.QuadPart : pipe->timeout;
 915                     async_set_timeout( async, when, STATUS_IO_TIMEOUT );
 916                     release_object( async );
 917                     set_error( STATUS_PENDING );
 918                 }
 919             }
 920             else release_object( server );
 921
 922         done:
 923             release_object( pipe );
 924             return wait_handle;
 925         }
 926
 927     default:
 928         return default_fd_ioctl( fd, code, async_data, blocking, data, size );
 929     }
 930 }
 931
 932
 933 DECL_HANDLER(create_named_pipe)
 934 {
 935     struct named_pipe *pipe;
 936     struct pipe_server *server;
 937     struct unicode_str name;
 938     struct directory *root = NULL;
 939
 940     reply->handle = 0;
 941     get_req_unicode_str( &name );
 942     if (req->rootdir && !(root = get_directory_obj( current->process, req->rootdir, 0 )))
 943         return;
 944
 945     pipe = create_named_pipe( root, &name, req->attributes | OBJ_OPENIF );
 946
 947     if (root) release_object( root );
 948     if (!pipe) return;
 949
 950     if (get_error() != STATUS_OBJECT_NAME_EXISTS)
 951     {
 952         /* initialize it if it didn't already exist */
 953         pipe->instances = 0;
 954         pipe->waiters = NULL;
 955         list_init( &pipe->servers );
 956         pipe->insize = req->insize;
 957         pipe->outsize = req->outsize;
 958         pipe->maxinstances = req->maxinstances;
 959         pipe->timeout = req->timeout;
 960         pipe->flags = req->flags;
 961     }
 962     else
 963     {
 964         if (pipe->maxinstances <= pipe->instances)
 965         {
 966             set_error( STATUS_INSTANCE_NOT_AVAILABLE );
 967             release_object( pipe );
 968             return;
 969         }
 970         if ((pipe->maxinstances != req->maxinstances) ||
 971             (pipe->timeout != req->timeout) ||
 972             (pipe->flags != req->flags))
 973         {
 974             set_error( STATUS_ACCESS_DENIED );
 975             release_object( pipe );
 976             return;
 977         }
 978         clear_error(); /* clear the name collision */
 979     }
 980
 981     server = create_pipe_server( pipe, req->options );
 982     if (server)
 983     {
 984         reply->handle = alloc_handle( current->process, server, req->access, req->attributes );
 985         server->pipe->instances++;
 986         release_object( server );
 987     }
 988
 989     release_object( pipe );
 990 }
 991
 992 DECL_HANDLER(get_named_pipe_info)
 993 {
 994     struct pipe_server *server;
 995     struct pipe_client *client = NULL;
 996
 997     server = get_pipe_server_obj( current->process, req->handle, FILE_READ_ATTRIBUTES );
 998     if (!server)
 999     {
1000         clear_error();
1001         client = (struct pipe_client *)get_handle_obj( current->process, req->handle,
1002                                                        FILE_READ_ATTRIBUTES, &pipe_client_ops );
1003         if (!client) return;
1004         server = client->server;
1005     }
1006
1007     reply->flags        = server->pipe->flags;
1008     reply->maxinstances = server->pipe->maxinstances;
1009     reply->instances    = server->pipe->instances;
1010     reply->insize       = server->pipe->insize;
1011     reply->outsize      = server->pipe->outsize;
1012
1013     if (client)
1014         release_object(client);
1015     else
1016     {
1017         reply->flags |= NAMED_PIPE_SERVER_END;
1018         release_object(server);
1019     }
1020 }