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