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