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