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_disconnected_server,
  64     ps_wait_connect
  65 };
  66
  67 struct named_pipe;
  68
  69 struct pipe_server
  70 {
  71     struct object        obj;        /* object header */
  72     struct fd           *fd;         /* pipe file descriptor */
  73     struct fd           *ioctl_fd;   /* file descriptor for ioctls when not connected */
  74     struct list          entry;      /* entry in named pipe servers list */
  75     enum pipe_state      state;      /* server state */
  76     struct pipe_client  *client;     /* client that this server is connected to */
  77     struct named_pipe   *pipe;
  78     struct timeout_user *flush_poll;
  79     struct event        *event;
  80     unsigned int         options;    /* pipe options */
  81     unsigned int         pipe_flags;
  82 };
  83
  84 struct pipe_client
  85 {
  86     struct object        obj;        /* object header */
  87     struct fd           *fd;         /* pipe file descriptor */
  88     struct pipe_server  *server;     /* server that this client is connected to */
  89     unsigned int         flags;      /* file flags */
  90     unsigned int         pipe_flags;
  91 };
  92
  93 struct named_pipe
  94 {
  95     struct object       obj;         /* object header */
  96     unsigned int        flags;
  97     unsigned int        sharing;
  98     unsigned int        maxinstances;
  99     unsigned int        outsize;
 100     unsigned int        insize;
 101     unsigned int        instances;
 102     timeout_t           timeout;
 103     struct list         servers;     /* list of servers using this pipe */
 104     struct async_queue *waiters;     /* list of clients waiting to connect */
 105 };
 106
 107 struct named_pipe_device
 108 {
 109     struct object       obj;         /* object header */
 110     struct fd          *fd;          /* pseudo-fd for ioctls */
 111     struct namespace   *pipes;       /* named pipe namespace */
 112 };
 113
 114 static void named_pipe_dump( struct object *obj, int verbose );
 115 static unsigned int named_pipe_map_access( struct object *obj, unsigned int access );
 116 static struct object *named_pipe_open_file( struct object *obj, unsigned int access,
 117                                             unsigned int sharing, unsigned int options );
 118 static void named_pipe_destroy( struct object *obj );
 119
 120 static const struct object_ops named_pipe_ops =
 121 {
 122     sizeof(struct named_pipe),    /* size */
 123     named_pipe_dump,              /* dump */
 124     no_get_type,                  /* get_type */
 125     no_add_queue,                 /* add_queue */
 126     NULL,                         /* remove_queue */
 127     NULL,                         /* signaled */
 128     NULL,                         /* satisfied */
 129     no_signal,                    /* signal */
 130     no_get_fd,                    /* get_fd */
 131     named_pipe_map_access,        /* map_access */
 132     default_get_sd,               /* get_sd */
 133     default_set_sd,               /* set_sd */
 134     no_lookup_name,               /* lookup_name */
 135     named_pipe_open_file,         /* open_file */
 136     no_close_handle,              /* close_handle */
 137     named_pipe_destroy            /* destroy */
 138 };
 139
 140 /* server end functions */
 141 static void pipe_server_dump( struct object *obj, int verbose );
 142 static struct fd *pipe_server_get_fd( struct object *obj );
 143 static void pipe_server_destroy( struct object *obj);
 144 static void pipe_server_flush( struct fd *fd, struct event **event );
 145 static enum server_fd_type pipe_server_get_fd_type( struct fd *fd );
 146 static obj_handle_t pipe_server_ioctl( struct fd *fd, ioctl_code_t code, const async_data_t *async,
 147                                        int blocking, const void *data, data_size_t size );
 148
 149 static const struct object_ops pipe_server_ops =
 150 {
 151     sizeof(struct pipe_server),   /* size */
 152     pipe_server_dump,             /* dump */
 153     no_get_type,                  /* get_type */
 154     add_queue,                    /* add_queue */
 155     remove_queue,                 /* remove_queue */
 156     default_fd_signaled,          /* signaled */
 157     no_satisfied,                 /* satisfied */
 158     no_signal,                    /* signal */
 159     pipe_server_get_fd,           /* get_fd */
 160     default_fd_map_access,        /* map_access */
 161     default_get_sd,               /* get_sd */
 162     default_set_sd,               /* set_sd */
 163     no_lookup_name,               /* lookup_name */
 164     no_open_file,                 /* open_file */
 165     fd_close_handle,              /* close_handle */
 166     pipe_server_destroy           /* destroy */
 167 };
 168
 169 static const struct fd_ops pipe_server_fd_ops =
 170 {
 171     default_fd_get_poll_events,   /* get_poll_events */
 172     default_poll_event,           /* poll_event */
 173     pipe_server_flush,            /* flush */
 174     pipe_server_get_fd_type,      /* get_fd_type */
 175     pipe_server_ioctl,            /* ioctl */
 176     default_fd_queue_async,       /* queue_async */
 177     default_fd_reselect_async,    /* reselect_async */
 178     default_fd_cancel_async,      /* cancel_async */
 179 };
 180
 181 /* client end functions */
 182 static void pipe_client_dump( struct object *obj, int verbose );
 183 static int pipe_client_signaled( struct object *obj, struct wait_queue_entry *entry );
 184 static struct fd *pipe_client_get_fd( struct object *obj );
 185 static void pipe_client_destroy( struct object *obj );
 186 static void pipe_client_flush( struct fd *fd, struct event **event );
 187 static enum server_fd_type pipe_client_get_fd_type( struct fd *fd );
 188
 189 static const struct object_ops pipe_client_ops =
 190 {
 191     sizeof(struct pipe_client),   /* size */
 192     pipe_client_dump,             /* dump */
 193     no_get_type,                  /* get_type */
 194     add_queue,                    /* add_queue */
 195     remove_queue,                 /* remove_queue */
 196     pipe_client_signaled,         /* signaled */
 197     no_satisfied,                 /* satisfied */
 198     no_signal,                    /* signal */
 199     pipe_client_get_fd,           /* get_fd */
 200     default_fd_map_access,        /* map_access */
 201     default_get_sd,               /* get_sd */
 202     default_set_sd,               /* set_sd */
 203     no_lookup_name,               /* lookup_name */
 204     no_open_file,                 /* open_file */
 205     fd_close_handle,              /* close_handle */
 206     pipe_client_destroy           /* destroy */
 207 };
 208
 209 static const struct fd_ops pipe_client_fd_ops =
 210 {
 211     default_fd_get_poll_events,   /* get_poll_events */
 212     default_poll_event,           /* poll_event */
 213     pipe_client_flush,            /* flush */
 214     pipe_client_get_fd_type,      /* get_fd_type */
 215     default_fd_ioctl,             /* ioctl */
 216     default_fd_queue_async,       /* queue_async */
 217     default_fd_reselect_async,    /* reselect_async */
 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     named_pipe_device_ioctl,          /* ioctl */
 260     default_fd_queue_async,           /* queue_async */
 261     default_fd_reselect_async,        /* reselect_async */
 262     default_fd_cancel_async           /* cancel_async */
 263 };
 264
 265 static void named_pipe_dump( struct object *obj, int verbose )
 266 {
 267     struct named_pipe *pipe = (struct named_pipe *) obj;
 268     assert( obj->ops == &named_pipe_ops );
 269     fprintf( stderr, "Named pipe " );
 270     dump_object_name( &pipe->obj );
 271     fprintf( stderr, "\n" );
 272 }
 273
 274 static unsigned int named_pipe_map_access( struct object *obj, unsigned int access )
 275 {
 276     if (access & GENERIC_READ)    access |= STANDARD_RIGHTS_READ;
 277     if (access & GENERIC_WRITE)   access |= STANDARD_RIGHTS_WRITE | FILE_CREATE_PIPE_INSTANCE;
 278     if (access & GENERIC_EXECUTE) access |= STANDARD_RIGHTS_EXECUTE;
 279     if (access & GENERIC_ALL)     access |= STANDARD_RIGHTS_ALL;
 280     return access & ~(GENERIC_READ | GENERIC_WRITE | GENERIC_EXECUTE | GENERIC_ALL);
 281 }
 282
 283 static void pipe_server_dump( struct object *obj, int verbose )
 284 {
 285     struct pipe_server *server = (struct pipe_server *) obj;
 286     assert( obj->ops == &pipe_server_ops );
 287     fprintf( stderr, "Named pipe server pipe=%p state=%d\n", server->pipe, server->state );
 288 }
 289
 290 static void pipe_client_dump( struct object *obj, int verbose )
 291 {
 292     struct pipe_client *client = (struct pipe_client *) obj;
 293     assert( obj->ops == &pipe_client_ops );
 294     fprintf( stderr, "Named pipe client server=%p\n", client->server );
 295 }
 296
 297 static int pipe_client_signaled( struct object *obj, struct wait_queue_entry *entry )
 298 {
 299     struct pipe_client *client = (struct pipe_client *) obj;
 300
 301     return client->fd && is_fd_signaled(client->fd);
 302 }
 303
 304 static void named_pipe_destroy( struct object *obj)
 305 {
 306     struct named_pipe *pipe = (struct named_pipe *) obj;
 307
 308     assert( list_empty( &pipe->servers ) );
 309     assert( !pipe->instances );
 310     free_async_queue( pipe->waiters );
 311 }
 312
 313 static struct fd *pipe_client_get_fd( struct object *obj )
 314 {
 315     struct pipe_client *client = (struct pipe_client *) obj;
 316     if (client->fd)
 317         return (struct fd *) grab_object( client->fd );
 318     set_error( STATUS_PIPE_DISCONNECTED );
 319     return NULL;
 320 }
 321
 322 static void set_server_state( struct pipe_server *server, enum pipe_state state )
 323 {
 324     server->state = state;
 325
 326     switch(state)
 327     {
 328     case ps_connected_server:
 329     case ps_wait_disconnect:
 330         assert( server->fd );
 331         break;
 332     case ps_wait_open:
 333     case ps_idle_server:
 334         assert( !server->fd );
 335         set_no_fd_status( server->ioctl_fd, STATUS_PIPE_LISTENING );
 336         break;
 337     case ps_disconnected_server:
 338     case ps_wait_connect:
 339         assert( !server->fd );
 340         set_no_fd_status( server->ioctl_fd, STATUS_PIPE_DISCONNECTED );
 341         break;
 342     }
 343 }
 344
 345 static struct fd *pipe_server_get_fd( struct object *obj )
 346 {
 347     struct pipe_server *server = (struct pipe_server *) obj;
 348
 349     return (struct fd *)grab_object( server->fd ? server->fd : server->ioctl_fd );
 350 }
 351
 352
 353 static void notify_empty( struct pipe_server *server )
 354 {
 355     if (!server->flush_poll)
 356         return;
 357     assert( server->state == ps_connected_server );
 358     assert( server->event );
 359     remove_timeout_user( server->flush_poll );
 360     server->flush_poll = NULL;
 361     set_event( server->event );
 362     release_object( server->event );
 363     server->event = NULL;
 364 }
 365
 366 static void do_disconnect( struct pipe_server *server )
 367 {
 368     /* we may only have a server fd, if the client disconnected */
 369     if (server->client)
 370     {
 371         assert( server->client->server == server );
 372         assert( server->client->fd );
 373         release_object( server->client->fd );
 374         server->client->fd = NULL;
 375     }
 376     assert( server->fd );
 377     shutdown( get_unix_fd( server->fd ), SHUT_RDWR );
 378     release_object( server->fd );
 379     server->fd = NULL;
 380 }
 381
 382 static void pipe_server_destroy( struct object *obj)
 383 {
 384     struct pipe_server *server = (struct pipe_server *)obj;
 385
 386     assert( obj->ops == &pipe_server_ops );
 387
 388     if (server->fd)
 389     {
 390         notify_empty( server );
 391         do_disconnect( server );
 392     }
 393
 394     if (server->client)
 395     {
 396         server->client->server = NULL;
 397         server->client = NULL;
 398     }
 399
 400     assert( server->pipe->instances );
 401     server->pipe->instances--;
 402
 403     if (server->ioctl_fd) release_object( server->ioctl_fd );
 404     list_remove( &server->entry );
 405     release_object( server->pipe );
 406 }
 407
 408 static void pipe_client_destroy( struct object *obj)
 409 {
 410     struct pipe_client *client = (struct pipe_client *)obj;
 411     struct pipe_server *server = client->server;
 412
 413     assert( obj->ops == &pipe_client_ops );
 414
 415     if (server)
 416     {
 417         notify_empty( server );
 418
 419         switch(server->state)
 420         {
 421         case ps_connected_server:
 422             /* Don't destroy the server's fd here as we can't
 423                do a successful flush without it. */
 424             set_server_state( server, ps_wait_disconnect );
 425             break;
 426         case ps_disconnected_server:
 427             set_server_state( server, ps_wait_connect );
 428             break;
 429         case ps_idle_server:
 430         case ps_wait_open:
 431         case ps_wait_disconnect:
 432         case ps_wait_connect:
 433             assert( 0 );
 434         }
 435         assert( server->client );
 436         server->client = NULL;
 437         client->server = NULL;
 438     }
 439     if (client->fd) release_object( client->fd );
 440 }
 441
 442 static void named_pipe_device_dump( struct object *obj, int verbose )
 443 {
 444     assert( obj->ops == &named_pipe_device_ops );
 445     fprintf( stderr, "Named pipe device\n" );
 446 }
 447
 448 static struct object_type *named_pipe_device_get_type( struct object *obj )
 449 {
 450     static const WCHAR name[] = {'D','e','v','i','c','e'};
 451     static const struct unicode_str str = { name, sizeof(name) };
 452     return get_object_type( &str );
 453 }
 454
 455 static struct fd *named_pipe_device_get_fd( struct object *obj )
 456 {
 457     struct named_pipe_device *device = (struct named_pipe_device *)obj;
 458     return (struct fd *)grab_object( device->fd );
 459 }
 460
 461 static struct object *named_pipe_device_lookup_name( struct object *obj, struct unicode_str *name,
 462                                                      unsigned int attr )
 463 {
 464     struct named_pipe_device *device = (struct named_pipe_device*)obj;
 465     struct object *found;
 466
 467     assert( obj->ops == &named_pipe_device_ops );
 468     assert( device->pipes );
 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 void create_named_pipe_device( struct directory *root, const struct unicode_str *name )
 496 {
 497     struct named_pipe_device *dev;
 498
 499     if ((dev = create_named_object_dir( root, name, 0, &named_pipe_device_ops )) &&
 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     if (dev) make_object_static( &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     assert( server->event );
 538     if (pipe_data_remaining( server ))
 539     {
 540         server->flush_poll = add_timeout_user( -TICKS_PER_SEC / 10, check_flushed, server );
 541     }
 542     else
 543     {
 544         /* notify_empty( server ); */
 545         server->flush_poll = NULL;
 546         set_event( server->event );
 547         release_object( server->event );
 548         server->event = NULL;
 549     }
 550 }
 551
 552 static void pipe_server_flush( struct fd *fd, struct event **event )
 553 {
 554     struct pipe_server *server = get_fd_user( fd );
 555
 556     if (!server || server->state != ps_connected_server) return;
 557
 558     /* FIXME: if multiple threads flush the same pipe,
 559               maybe should create a list of processes to notify */
 560     if (server->flush_poll) return;
 561
 562     if (pipe_data_remaining( server ))
 563     {
 564         /* this kind of sux -
 565            there's no unix way to be alerted when a pipe becomes empty */
 566         server->event = create_event( NULL, NULL, 0, 0, 0, NULL );
 567         if (!server->event) return;
 568         server->flush_poll = add_timeout_user( -TICKS_PER_SEC / 10, check_flushed, server );
 569         *event = server->event;
 570     }
 571 }
 572
 573 static void pipe_client_flush( struct fd *fd, struct event **event )
 574 {
 575     /* FIXME: what do we have to do for this? */
 576 }
 577
 578 static inline int is_overlapped( unsigned int options )
 579 {
 580     return !(options & (FILE_SYNCHRONOUS_IO_ALERT | FILE_SYNCHRONOUS_IO_NONALERT));
 581 }
 582
 583 static enum server_fd_type pipe_server_get_fd_type( struct fd *fd )
 584 {
 585     return FD_TYPE_PIPE;
 586 }
 587
 588 static enum server_fd_type pipe_client_get_fd_type( struct fd *fd )
 589 {
 590     return FD_TYPE_PIPE;
 591 }
 592
 593 static obj_handle_t alloc_wait_event( struct process *process )
 594 {
 595     obj_handle_t handle = 0;
 596     struct event *event = create_event( NULL, NULL, 0, 1, 0, NULL );
 597
 598     if (event)
 599     {
 600         handle = alloc_handle( process, event, EVENT_ALL_ACCESS, 0 );
 601         release_object( event );
 602     }
 603     return handle;
 604 }
 605
 606 static obj_handle_t pipe_server_ioctl( struct fd *fd, ioctl_code_t code, const async_data_t *async_data,
 607                                        int blocking, const void *data, data_size_t size )
 608 {
 609     struct pipe_server *server = get_fd_user( fd );
 610     struct async *async;
 611     obj_handle_t wait_handle = 0;
 612
 613     switch(code)
 614     {
 615     case FSCTL_PIPE_LISTEN:
 616         switch(server->state)
 617         {
 618         case ps_idle_server:
 619         case ps_wait_connect:
 620             if (blocking)
 621             {
 622                 async_data_t new_data = *async_data;
 623                 if (!(wait_handle = alloc_wait_event( current->process ))) break;
 624                 new_data.event = wait_handle;
 625                 if (!(async = fd_queue_async( server->ioctl_fd, &new_data, ASYNC_TYPE_WAIT )))
 626                 {
 627                     close_handle( current->process, wait_handle );
 628                     break;
 629                 }
 630             }
 631             else async = fd_queue_async( server->ioctl_fd, async_data, ASYNC_TYPE_WAIT );
 632
 633             if (async)
 634             {
 635                 set_server_state( server, ps_wait_open );
 636                 if (server->pipe->waiters) async_wake_up( server->pipe->waiters, STATUS_SUCCESS );
 637                 release_object( async );
 638                 set_error( STATUS_PENDING );
 639                 return wait_handle;
 640             }
 641             break;
 642         case ps_connected_server:
 643             set_error( STATUS_PIPE_CONNECTED );
 644             break;
 645         case ps_disconnected_server:
 646             set_error( STATUS_PIPE_BUSY );
 647             break;
 648         case ps_wait_disconnect:
 649             set_error( STATUS_NO_DATA_DETECTED );
 650             break;
 651         case ps_wait_open:
 652             set_error( STATUS_INVALID_HANDLE );
 653             break;
 654         }
 655         return 0;
 656
 657     case FSCTL_PIPE_DISCONNECT:
 658         switch(server->state)
 659         {
 660         case ps_connected_server:
 661             assert( server->client );
 662             assert( server->client->fd );
 663
 664             notify_empty( server );
 665
 666             /* dump the client and server fds, but keep the pointers
 667                around - client loses all waiting data */
 668             do_disconnect( server );
 669             set_server_state( server, ps_disconnected_server );
 670             break;
 671         case ps_wait_disconnect:
 672             assert( !server->client );
 673             do_disconnect( server );
 674             set_server_state( server, ps_wait_connect );
 675             break;
 676         case ps_idle_server:
 677         case ps_wait_open:
 678             set_error( STATUS_PIPE_LISTENING );
 679             break;
 680         case ps_disconnected_server:
 681         case ps_wait_connect:
 682             set_error( STATUS_PIPE_DISCONNECTED );
 683             break;
 684         }
 685         return 0;
 686
 687     default:
 688         return default_fd_ioctl( fd, code, async_data, blocking, data, size );
 689     }
 690 }
 691
 692 static struct named_pipe *create_named_pipe( struct directory *root, const struct unicode_str *name,
 693                                              unsigned int attr, const struct security_descriptor *sd )
 694 {
 695     struct object *obj;
 696     struct named_pipe *pipe = NULL;
 697     struct unicode_str new_name;
 698
 699     if (!name || !name->len) return alloc_object( &named_pipe_ops );
 700
 701     if (!(obj = find_object_dir( root, name, attr, &new_name )))
 702     {
 703         set_error( STATUS_OBJECT_NAME_INVALID );
 704         return NULL;
 705     }
 706     if (!new_name.len)
 707     {
 708         if (attr & OBJ_OPENIF && obj->ops == &named_pipe_ops)
 709             set_error( STATUS_OBJECT_NAME_EXISTS );
 710         else
 711         {
 712             release_object( obj );
 713             obj = NULL;
 714             if (attr & OBJ_OPENIF)
 715                 set_error( STATUS_OBJECT_TYPE_MISMATCH );
 716             else
 717                 set_error( STATUS_OBJECT_NAME_COLLISION );
 718         }
 719         return (struct named_pipe *)obj;
 720     }
 721
 722     if (obj->ops != &named_pipe_device_ops)
 723         set_error( STATUS_OBJECT_NAME_INVALID );
 724     else
 725     {
 726         struct named_pipe_device *dev = (struct named_pipe_device *)obj;
 727         if ((pipe = create_object( dev->pipes, &named_pipe_ops, &new_name, NULL )))
 728             clear_error();
 729     }
 730
 731     release_object( obj );
 732     return pipe;
 733 }
 734
 735 static struct pipe_server *get_pipe_server_obj( struct process *process,
 736                                 obj_handle_t handle, unsigned int access )
 737 {
 738     struct object *obj;
 739     obj = get_handle_obj( process, handle, access, &pipe_server_ops );
 740     return (struct pipe_server *) obj;
 741 }
 742
 743 static struct pipe_server *create_pipe_server( struct named_pipe *pipe, unsigned int options,
 744                                                unsigned int pipe_flags )
 745 {
 746     struct pipe_server *server;
 747
 748     server = alloc_object( &pipe_server_ops );
 749     if (!server)
 750         return NULL;
 751
 752     server->fd = NULL;
 753     server->pipe = pipe;
 754     server->client = NULL;
 755     server->flush_poll = NULL;
 756     server->options = options;
 757     server->pipe_flags = pipe_flags;
 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, unsigned int pipe_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     client->pipe_flags = pipe_flags;
 782
 783     return client;
 784 }
 785
 786 static struct pipe_server *find_available_server( struct named_pipe *pipe )
 787 {
 788     struct pipe_server *server;
 789
 790     /* look for pipe servers that are listening */
 791     LIST_FOR_EACH_ENTRY( server, &pipe->servers, struct pipe_server, entry )
 792     {
 793         if (server->state == ps_wait_open)
 794             return (struct pipe_server *)grab_object( server );
 795     }
 796
 797     /* fall back to pipe servers that are idle */
 798     LIST_FOR_EACH_ENTRY( server, &pipe->servers, struct pipe_server, entry )
 799     {
 800         if (server->state == ps_idle_server)
 801             return (struct pipe_server *)grab_object( server );
 802     }
 803
 804     return NULL;
 805 }
 806
 807 static struct object *named_pipe_open_file( struct object *obj, unsigned int access,
 808                                             unsigned int sharing, unsigned int options )
 809 {
 810     struct named_pipe *pipe = (struct named_pipe *)obj;
 811     struct pipe_server *server;
 812     struct pipe_client *client;
 813     unsigned int pipe_sharing;
 814     int fds[2];
 815
 816     if (!(server = find_available_server( pipe )))
 817     {
 818         set_error( STATUS_PIPE_NOT_AVAILABLE );
 819         return NULL;
 820     }
 821
 822     pipe_sharing = server->pipe->sharing;
 823     if (((access & GENERIC_READ) && !(pipe_sharing & FILE_SHARE_READ)) ||
 824         ((access & GENERIC_WRITE) && !(pipe_sharing & FILE_SHARE_WRITE)))
 825     {
 826         set_error( STATUS_ACCESS_DENIED );
 827         release_object( server );
 828         return NULL;
 829     }
 830
 831     if ((client = create_pipe_client( options, pipe->flags )))
 832     {
 833         if (!socketpair( PF_UNIX, SOCK_STREAM, 0, fds ))
 834         {
 835             assert( !server->fd );
 836
 837             /* for performance reasons, only set nonblocking mode when using
 838              * overlapped I/O. Otherwise, we will be doing too much busy
 839              * looping */
 840             if (is_overlapped( options )) fcntl( fds[1], F_SETFL, O_NONBLOCK );
 841             if (is_overlapped( server->options )) fcntl( fds[0], F_SETFL, O_NONBLOCK );
 842
 843             if (pipe->insize)
 844             {
 845                 setsockopt( fds[0], SOL_SOCKET, SO_RCVBUF, &pipe->insize, sizeof(pipe->insize) );
 846                 setsockopt( fds[1], SOL_SOCKET, SO_RCVBUF, &pipe->insize, sizeof(pipe->insize) );
 847             }
 848             if (pipe->outsize)
 849             {
 850                 setsockopt( fds[0], SOL_SOCKET, SO_SNDBUF, &pipe->outsize, sizeof(pipe->outsize) );
 851                 setsockopt( fds[1], SOL_SOCKET, SO_SNDBUF, &pipe->outsize, sizeof(pipe->outsize) );
 852             }
 853
 854             client->fd = create_anonymous_fd( &pipe_client_fd_ops, fds[1], &client->obj, options );
 855             server->fd = create_anonymous_fd( &pipe_server_fd_ops, fds[0], &server->obj, server->options );
 856             if (client->fd && server->fd)
 857             {
 858                 allow_fd_caching( client->fd );
 859                 allow_fd_caching( server->fd );
 860                 fd_copy_completion( server->ioctl_fd, server->fd );
 861                 if (server->state == ps_wait_open)
 862                     fd_async_wake_up( server->ioctl_fd, ASYNC_TYPE_WAIT, STATUS_SUCCESS );
 863                 set_server_state( server, ps_connected_server );
 864                 server->client = client;
 865                 client->server = server;
 866             }
 867             else
 868             {
 869                 release_object( client );
 870                 client = NULL;
 871             }
 872         }
 873         else
 874         {
 875             file_set_error();
 876             release_object( client );
 877             client = NULL;
 878         }
 879     }
 880     release_object( server );
 881     return &client->obj;
 882 }
 883
 884 static obj_handle_t named_pipe_device_ioctl( struct fd *fd, ioctl_code_t code, const async_data_t *async_data,
 885                                              int blocking, const void *data, data_size_t size )
 886 {
 887     struct named_pipe_device *device = get_fd_user( fd );
 888
 889     switch(code)
 890     {
 891     case FSCTL_PIPE_WAIT:
 892         {
 893             const FILE_PIPE_WAIT_FOR_BUFFER *buffer = data;
 894             obj_handle_t wait_handle = 0;
 895             struct named_pipe *pipe;
 896             struct pipe_server *server;
 897             struct unicode_str name;
 898
 899             if (size < sizeof(*buffer) ||
 900                 size < FIELD_OFFSET(FILE_PIPE_WAIT_FOR_BUFFER, Name[buffer->NameLength/sizeof(WCHAR)]))
 901             {
 902                 set_error( STATUS_INVALID_PARAMETER );
 903                 return 0;
 904             }
 905             name.str = buffer->Name;
 906             name.len = (buffer->NameLength / sizeof(WCHAR)) * sizeof(WCHAR);
 907             if (!(pipe = (struct named_pipe *)find_object( device->pipes, &name, OBJ_CASE_INSENSITIVE )))
 908             {
 909                 set_error( STATUS_OBJECT_NAME_NOT_FOUND );
 910                 return 0;
 911             }
 912             if (!(server = find_available_server( pipe )))
 913             {
 914                 struct async *async;
 915
 916                 if (!pipe->waiters && !(pipe->waiters = create_async_queue( NULL ))) goto done;
 917
 918                 if (blocking)
 919                 {
 920                     async_data_t new_data = *async_data;
 921                     if (!(wait_handle = alloc_wait_event( current->process ))) goto done;
 922                     new_data.event = wait_handle;
 923                     if (!(async = create_async( current, pipe->waiters, &new_data )))
 924                     {
 925                         close_handle( current->process, wait_handle );
 926                         wait_handle = 0;
 927                     }
 928                 }
 929                 else async = create_async( current, pipe->waiters, async_data );
 930
 931                 if (async)
 932                 {
 933                     timeout_t when = buffer->TimeoutSpecified ? buffer->Timeout.QuadPart : pipe->timeout;
 934                     async_set_timeout( async, when, STATUS_IO_TIMEOUT );
 935                     release_object( async );
 936                     set_error( STATUS_PENDING );
 937                 }
 938             }
 939             else release_object( server );
 940
 941         done:
 942             release_object( pipe );
 943             return wait_handle;
 944         }
 945
 946     default:
 947         return default_fd_ioctl( fd, code, async_data, blocking, data, size );
 948     }
 949 }
 950
 951
 952 DECL_HANDLER(create_named_pipe)
 953 {
 954     struct named_pipe *pipe;
 955     struct pipe_server *server;
 956     struct unicode_str name;
 957     struct directory *root = NULL;
 958     const struct object_attributes *objattr = get_req_data();
 959     const struct security_descriptor *sd;
 960
 961     if (!req->sharing || (req->sharing & ~(FILE_SHARE_READ | FILE_SHARE_WRITE)) ||
 962         (!(req->flags & NAMED_PIPE_MESSAGE_STREAM_WRITE) && (req->flags & NAMED_PIPE_MESSAGE_STREAM_READ)))
 963     {
 964         set_error( STATUS_INVALID_PARAMETER );
 965         return;
 966     }
 967
 968     reply->handle = 0;
 969
 970     if (!objattr_is_valid( objattr, get_req_data_size() ))
 971         return;
 972
 973     sd = objattr->sd_len ? (const struct security_descriptor *)(objattr + 1) : NULL;
 974     objattr_get_name( objattr, &name );
 975
 976     if (objattr->rootdir && !(root = get_directory_obj( current->process, objattr->rootdir, 0 )))
 977         return;
 978
 979     pipe = create_named_pipe( root, &name, req->attributes | OBJ_OPENIF, sd );
 980
 981     if (root) release_object( root );
 982     if (!pipe) return;
 983
 984     if (get_error() != STATUS_OBJECT_NAME_EXISTS)
 985     {
 986         /* initialize it if it didn't already exist */
 987         pipe->instances = 0;
 988         pipe->waiters = NULL;
 989         list_init( &pipe->servers );
 990         pipe->insize = req->insize;
 991         pipe->outsize = req->outsize;
 992         pipe->maxinstances = req->maxinstances;
 993         pipe->timeout = req->timeout;
 994         pipe->flags = req->flags & NAMED_PIPE_MESSAGE_STREAM_WRITE;
 995         pipe->sharing = req->sharing;
 996     }
 997     else
 998     {
 999         if (pipe->maxinstances <= pipe->instances)
1000         {
1001             set_error( STATUS_INSTANCE_NOT_AVAILABLE );
1002             release_object( pipe );
1003             return;
1004         }
1005         if (pipe->sharing != req->sharing)
1006         {
1007             set_error( STATUS_ACCESS_DENIED );
1008             release_object( pipe );
1009             return;
1010         }
1011         clear_error(); /* clear the name collision */
1012     }
1013
1014     server = create_pipe_server( pipe, req->options, req->flags );
1015     if (server)
1016     {
1017         reply->handle = alloc_handle( current->process, server, req->access, req->attributes );
1018         server->pipe->instances++;
1019         if (sd) default_set_sd( &server->obj, sd, OWNER_SECURITY_INFORMATION |
1020                                                   GROUP_SECURITY_INFORMATION |
1021                                                   DACL_SECURITY_INFORMATION |
1022                                                   SACL_SECURITY_INFORMATION );
1023         release_object( server );
1024     }
1025
1026     release_object( pipe );
1027 }
1028
1029 DECL_HANDLER(get_named_pipe_info)
1030 {
1031     struct pipe_server *server;
1032     struct pipe_client *client = NULL;
1033
1034     server = get_pipe_server_obj( current->process, req->handle, FILE_READ_ATTRIBUTES );
1035     if (!server)
1036     {
1037         if (get_error() != STATUS_OBJECT_TYPE_MISMATCH)
1038             return;
1039
1040         clear_error();
1041         client = (struct pipe_client *)get_handle_obj( current->process, req->handle,
1042                                                        0, &pipe_client_ops );
1043         if (!client) return;
1044         server = client->server;
1045     }
1046
1047     reply->flags        = client ? client->pipe_flags : server->pipe_flags;
1048     reply->sharing      = server->pipe->sharing;
1049     reply->maxinstances = server->pipe->maxinstances;
1050     reply->instances    = server->pipe->instances;
1051     reply->insize       = server->pipe->insize;
1052     reply->outsize      = server->pipe->outsize;
1053
1054     if (client)
1055         release_object(client);
1056     else
1057     {
1058         reply->flags |= NAMED_PIPE_SERVER_END;
1059         release_object(server);
1060     }
1061 }
1062
1063 DECL_HANDLER(set_named_pipe_info)
1064 {
1065     struct pipe_server *server;
1066     struct pipe_client *client = NULL;
1067
1068     server = get_pipe_server_obj( current->process, req->handle, FILE_WRITE_ATTRIBUTES );
1069     if (!server)
1070     {
1071         if (get_error() != STATUS_OBJECT_TYPE_MISMATCH)
1072             return;
1073
1074         clear_error();
1075         client = (struct pipe_client *)get_handle_obj( current->process, req->handle,
1076                                                        0, &pipe_client_ops );
1077         if (!client) return;
1078         server = client->server;
1079     }
1080
1081     if ((req->flags & ~(NAMED_PIPE_MESSAGE_STREAM_READ | NAMED_PIPE_NONBLOCKING_MODE)) ||
1082             ((req->flags & NAMED_PIPE_MESSAGE_STREAM_READ) && !(server->pipe->flags & NAMED_PIPE_MESSAGE_STREAM_WRITE)))
1083     {
1084         set_error( STATUS_INVALID_PARAMETER );
1085     }
1086     else if (client)
1087     {
1088         client->pipe_flags = server->pipe->flags | req->flags;
1089     }
1090     else
1091     {
1092         server->pipe_flags = server->pipe->flags | req->flags;
1093     }
1094
1095     if (client)
1096         release_object(client);
1097     else
1098         release_object(server);
1099 }