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