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