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