*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
- * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+ * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
*
* TODO:
* message mode
#include <poll.h>
#endif
+#include "ntstatus.h"
+#define WIN32_NO_STATUS
#include "windef.h"
#include "winternl.h"
+#include "winioctl.h"
#include "file.h"
#include "handle.h"
{
struct object obj; /* object header */
struct fd *fd; /* pipe file descriptor */
+ struct fd *ioctl_fd; /* file descriptor for ioctls when not connected */
struct list entry; /* entry in named pipe servers list */
enum pipe_state state; /* server state */
struct pipe_client *client; /* client that this server is connected to */
struct named_pipe *pipe;
struct timeout_user *flush_poll;
struct event *event;
- struct list wait_q; /* only a single one can be queued */
unsigned int options; /* pipe options */
};
{
struct object obj; /* object header */
unsigned int flags;
+ unsigned int sharing;
unsigned int maxinstances;
unsigned int outsize;
unsigned int insize;
- unsigned int timeout;
unsigned int instances;
+ timeout_t timeout;
struct list servers; /* list of servers using this pipe */
- struct list waiters; /* list of clients waiting to connect */
+ struct async_queue *waiters; /* list of clients waiting to connect */
+};
+
+struct named_pipe_device
+{
+ struct object obj; /* object header */
+ struct fd *fd; /* pseudo-fd for ioctls */
+ struct namespace *pipes; /* named pipe namespace */
};
static void named_pipe_dump( struct object *obj, int verbose );
+static unsigned int named_pipe_map_access( struct object *obj, unsigned int access );
+static struct object *named_pipe_open_file( struct object *obj, unsigned int access,
+ unsigned int sharing, unsigned int options );
static void named_pipe_destroy( struct object *obj );
static const struct object_ops named_pipe_ops =
{
sizeof(struct named_pipe), /* size */
named_pipe_dump, /* dump */
+ no_get_type, /* get_type */
no_add_queue, /* add_queue */
NULL, /* remove_queue */
NULL, /* signaled */
NULL, /* satisfied */
no_signal, /* signal */
no_get_fd, /* get_fd */
+ named_pipe_map_access, /* map_access */
+ default_get_sd, /* get_sd */
+ default_set_sd, /* set_sd */
+ no_lookup_name, /* lookup_name */
+ named_pipe_open_file, /* open_file */
no_close_handle, /* close_handle */
named_pipe_destroy /* destroy */
};
static void pipe_server_dump( struct object *obj, int verbose );
static struct fd *pipe_server_get_fd( struct object *obj );
static void pipe_server_destroy( struct object *obj);
-static int pipe_server_flush( struct fd *fd, struct event **event );
-static int pipe_server_get_info( struct fd *fd );
+static void pipe_server_flush( struct fd *fd, struct event **event );
+static enum server_fd_type pipe_server_get_fd_type( struct fd *fd );
+static obj_handle_t pipe_server_ioctl( struct fd *fd, ioctl_code_t code, const async_data_t *async,
+ int blocking, const void *data, data_size_t size );
static const struct object_ops pipe_server_ops =
{
sizeof(struct pipe_server), /* size */
pipe_server_dump, /* dump */
- default_fd_add_queue, /* add_queue */
- default_fd_remove_queue, /* remove_queue */
+ no_get_type, /* get_type */
+ add_queue, /* add_queue */
+ remove_queue, /* remove_queue */
default_fd_signaled, /* signaled */
no_satisfied, /* satisfied */
no_signal, /* signal */
pipe_server_get_fd, /* get_fd */
- no_close_handle, /* close_handle */
+ default_fd_map_access, /* map_access */
+ default_get_sd, /* get_sd */
+ default_set_sd, /* set_sd */
+ no_lookup_name, /* lookup_name */
+ no_open_file, /* open_file */
+ fd_close_handle, /* close_handle */
pipe_server_destroy /* destroy */
};
static const struct fd_ops pipe_server_fd_ops =
{
- default_fd_get_poll_events, /* get_poll_events */
+ default_fd_get_poll_events, /* get_poll_events */
default_poll_event, /* poll_event */
pipe_server_flush, /* flush */
- pipe_server_get_info, /* get_file_info */
+ pipe_server_get_fd_type, /* get_fd_type */
+ pipe_server_ioctl, /* ioctl */
default_fd_queue_async, /* queue_async */
+ default_fd_reselect_async, /* reselect_async */
default_fd_cancel_async, /* cancel_async */
};
/* client end functions */
static void pipe_client_dump( struct object *obj, int verbose );
+static int pipe_client_signaled( struct object *obj, struct thread *thread );
static struct fd *pipe_client_get_fd( struct object *obj );
static void pipe_client_destroy( struct object *obj );
-static int pipe_client_flush( struct fd *fd, struct event **event );
-static int pipe_client_get_info( struct fd *fd );
+static void pipe_client_flush( struct fd *fd, struct event **event );
+static enum server_fd_type pipe_client_get_fd_type( struct fd *fd );
static const struct object_ops pipe_client_ops =
{
sizeof(struct pipe_client), /* size */
pipe_client_dump, /* dump */
- default_fd_add_queue, /* add_queue */
- default_fd_remove_queue, /* remove_queue */
- default_fd_signaled, /* signaled */
+ no_get_type, /* get_type */
+ add_queue, /* add_queue */
+ remove_queue, /* remove_queue */
+ pipe_client_signaled, /* signaled */
no_satisfied, /* satisfied */
no_signal, /* signal */
pipe_client_get_fd, /* get_fd */
- no_close_handle, /* close_handle */
+ default_fd_map_access, /* map_access */
+ default_get_sd, /* get_sd */
+ default_set_sd, /* set_sd */
+ no_lookup_name, /* lookup_name */
+ no_open_file, /* open_file */
+ fd_close_handle, /* close_handle */
pipe_client_destroy /* destroy */
};
default_fd_get_poll_events, /* get_poll_events */
default_poll_event, /* poll_event */
pipe_client_flush, /* flush */
- pipe_client_get_info, /* get_file_info */
+ pipe_client_get_fd_type, /* get_fd_type */
+ default_fd_ioctl, /* ioctl */
default_fd_queue_async, /* queue_async */
+ default_fd_reselect_async, /* reselect_async */
default_fd_cancel_async /* cancel_async */
};
+static void named_pipe_device_dump( struct object *obj, int verbose );
+static struct object_type *named_pipe_device_get_type( struct object *obj );
+static struct fd *named_pipe_device_get_fd( struct object *obj );
+static struct object *named_pipe_device_lookup_name( struct object *obj,
+ struct unicode_str *name, unsigned int attr );
+static struct object *named_pipe_device_open_file( struct object *obj, unsigned int access,
+ unsigned int sharing, unsigned int options );
+static void named_pipe_device_destroy( struct object *obj );
+static enum server_fd_type named_pipe_device_get_fd_type( struct fd *fd );
+static obj_handle_t named_pipe_device_ioctl( struct fd *fd, ioctl_code_t code, const async_data_t *async_data,
+ int blocking, const void *data, data_size_t size );
+
+static const struct object_ops named_pipe_device_ops =
+{
+ sizeof(struct named_pipe_device), /* size */
+ named_pipe_device_dump, /* dump */
+ named_pipe_device_get_type, /* get_type */
+ no_add_queue, /* add_queue */
+ NULL, /* remove_queue */
+ NULL, /* signaled */
+ no_satisfied, /* satisfied */
+ no_signal, /* signal */
+ named_pipe_device_get_fd, /* get_fd */
+ no_map_access, /* map_access */
+ default_get_sd, /* get_sd */
+ default_set_sd, /* set_sd */
+ named_pipe_device_lookup_name, /* lookup_name */
+ named_pipe_device_open_file, /* open_file */
+ fd_close_handle, /* close_handle */
+ named_pipe_device_destroy /* destroy */
+};
+
+static const struct fd_ops named_pipe_device_fd_ops =
+{
+ default_fd_get_poll_events, /* get_poll_events */
+ default_poll_event, /* poll_event */
+ no_flush, /* flush */
+ named_pipe_device_get_fd_type, /* get_fd_type */
+ named_pipe_device_ioctl, /* ioctl */
+ default_fd_queue_async, /* queue_async */
+ default_fd_reselect_async, /* reselect_async */
+ default_fd_cancel_async /* cancel_async */
+};
+
static void named_pipe_dump( struct object *obj, int verbose )
{
struct named_pipe *pipe = (struct named_pipe *) obj;
fprintf( stderr, "\n" );
}
+static unsigned int named_pipe_map_access( struct object *obj, unsigned int access )
+{
+ if (access & GENERIC_READ) access |= STANDARD_RIGHTS_READ;
+ if (access & GENERIC_WRITE) access |= STANDARD_RIGHTS_WRITE | FILE_CREATE_PIPE_INSTANCE;
+ if (access & GENERIC_EXECUTE) access |= STANDARD_RIGHTS_EXECUTE;
+ if (access & GENERIC_ALL) access |= STANDARD_RIGHTS_ALL;
+ return access & ~(GENERIC_READ | GENERIC_WRITE | GENERIC_EXECUTE | GENERIC_ALL);
+}
+
static void pipe_server_dump( struct object *obj, int verbose )
{
struct pipe_server *server = (struct pipe_server *) obj;
fprintf( stderr, "Named pipe client server=%p\n", client->server );
}
+static int pipe_client_signaled( struct object *obj, struct thread *thread )
+{
+ struct pipe_client *client = (struct pipe_client *) obj;
+
+ return client->fd && is_fd_signaled(client->fd);
+}
+
static void named_pipe_destroy( struct object *obj)
{
struct named_pipe *pipe = (struct named_pipe *) obj;
assert( list_empty( &pipe->servers ) );
assert( !pipe->instances );
- async_terminate_queue( &pipe->waiters, STATUS_HANDLES_CLOSED );
+ free_async_queue( pipe->waiters );
}
static struct fd *pipe_client_get_fd( struct object *obj )
return NULL;
}
-static struct fd *pipe_server_get_fd( struct object *obj )
+static void set_server_state( struct pipe_server *server, enum pipe_state state )
{
- struct pipe_server *server = (struct pipe_server *) obj;
+ server->state = state;
- switch(server->state)
+ switch(state)
{
case ps_connected_server:
case ps_wait_disconnect:
assert( server->fd );
- return (struct fd *) grab_object( server->fd );
-
+ break;
case ps_wait_open:
case ps_idle_server:
- set_error( STATUS_PIPE_LISTENING );
+ assert( !server->fd );
+ set_no_fd_status( server->ioctl_fd, STATUS_PIPE_LISTENING );
break;
-
case ps_disconnected_server:
case ps_wait_connect:
- set_error( STATUS_PIPE_DISCONNECTED );
+ assert( !server->fd );
+ set_no_fd_status( server->ioctl_fd, STATUS_PIPE_DISCONNECTED );
break;
}
- return NULL;
+}
+
+static struct fd *pipe_server_get_fd( struct object *obj )
+{
+ struct pipe_server *server = (struct pipe_server *) obj;
+
+ return (struct fd *)grab_object( server->fd ? server->fd : server->ioctl_fd );
}
server->client->fd = NULL;
}
assert( server->fd );
+ shutdown( get_unix_fd( server->fd ), SHUT_RDWR );
release_object( server->fd );
server->fd = NULL;
}
server->client = NULL;
}
- async_terminate_head( &server->wait_q, STATUS_HANDLES_CLOSED );
-
assert( server->pipe->instances );
server->pipe->instances--;
+ if (server->ioctl_fd) release_object( server->ioctl_fd );
list_remove( &server->entry );
release_object( server->pipe );
}
case ps_connected_server:
/* Don't destroy the server's fd here as we can't
do a successful flush without it. */
- server->state = ps_wait_disconnect;
- release_object( client->fd );
- client->fd = NULL;
+ set_server_state( server, ps_wait_disconnect );
break;
case ps_disconnected_server:
- server->state = ps_wait_connect;
+ set_server_state( server, ps_wait_connect );
break;
case ps_idle_server:
case ps_wait_open:
server->client = NULL;
client->server = NULL;
}
- assert( !client->fd );
+ if (client->fd) release_object( client->fd );
+}
+
+static void named_pipe_device_dump( struct object *obj, int verbose )
+{
+ assert( obj->ops == &named_pipe_device_ops );
+ fprintf( stderr, "Named pipe device\n" );
+}
+
+static struct object_type *named_pipe_device_get_type( struct object *obj )
+{
+ static const WCHAR name[] = {'D','e','v','i','c','e'};
+ static const struct unicode_str str = { name, sizeof(name) };
+ return get_object_type( &str );
+}
+
+static struct fd *named_pipe_device_get_fd( struct object *obj )
+{
+ struct named_pipe_device *device = (struct named_pipe_device *)obj;
+ return (struct fd *)grab_object( device->fd );
+}
+
+static struct object *named_pipe_device_lookup_name( struct object *obj, struct unicode_str *name,
+ unsigned int attr )
+{
+ struct named_pipe_device *device = (struct named_pipe_device*)obj;
+ struct object *found;
+
+ assert( obj->ops == &named_pipe_device_ops );
+ assert( device->pipes );
+
+ if ((found = find_object( device->pipes, name, attr | OBJ_CASE_INSENSITIVE )))
+ name->len = 0;
+
+ return found;
+}
+
+static struct object *named_pipe_device_open_file( struct object *obj, unsigned int access,
+ unsigned int sharing, unsigned int options )
+{
+ return grab_object( obj );
+}
+
+static void named_pipe_device_destroy( struct object *obj )
+{
+ struct named_pipe_device *device = (struct named_pipe_device*)obj;
+ assert( obj->ops == &named_pipe_device_ops );
+ if (device->fd) release_object( device->fd );
+ free( device->pipes );
+}
+
+static enum server_fd_type named_pipe_device_get_fd_type( struct fd *fd )
+{
+ return FD_TYPE_DEVICE;
+}
+
+void create_named_pipe_device( struct directory *root, const struct unicode_str *name )
+{
+ struct named_pipe_device *dev;
+
+ if ((dev = create_named_object_dir( root, name, 0, &named_pipe_device_ops )) &&
+ get_error() != STATUS_OBJECT_NAME_EXISTS)
+ {
+ dev->pipes = NULL;
+ if (!(dev->fd = alloc_pseudo_fd( &named_pipe_device_fd_ops, &dev->obj, 0 )) ||
+ !(dev->pipes = create_namespace( 7 )))
+ {
+ release_object( dev );
+ dev = NULL;
+ }
+ }
+ if (dev) make_object_static( &dev->obj );
}
static int pipe_data_remaining( struct pipe_server *server )
assert( server->event );
if (pipe_data_remaining( server ))
{
- struct timeval tv;
-
- gettimeofday( &tv, NULL );
- add_timeout( &tv, 100 );
- server->flush_poll = add_timeout_user( &tv, check_flushed, server );
+ server->flush_poll = add_timeout_user( -TICKS_PER_SEC / 10, check_flushed, server );
}
else
{
}
}
-static int pipe_server_flush( struct fd *fd, struct event **event )
+static void pipe_server_flush( struct fd *fd, struct event **event )
{
struct pipe_server *server = get_fd_user( fd );
- if (!server)
- return 0;
-
- if (server->state != ps_connected_server)
- return 0;
+ if (!server || server->state != ps_connected_server) return;
/* FIXME: if multiple threads flush the same pipe,
maybe should create a list of processes to notify */
- if (server->flush_poll)
- return 0;
+ if (server->flush_poll) return;
if (pipe_data_remaining( server ))
{
- struct timeval tv;
-
- /* this kind of sux -
+ /* this kind of sux -
there's no unix way to be alerted when a pipe becomes empty */
- server->event = create_event( NULL, 0, 0, 0 );
- if (!server->event)
- return 0;
- gettimeofday( &tv, NULL );
- add_timeout( &tv, 100 );
- server->flush_poll = add_timeout_user( &tv, check_flushed, server );
+ server->event = create_event( NULL, NULL, 0, 0, 0, NULL );
+ if (!server->event) return;
+ server->flush_poll = add_timeout_user( -TICKS_PER_SEC / 10, check_flushed, server );
*event = server->event;
}
-
- return 0;
}
-static int pipe_client_flush( struct fd *fd, struct event **event )
+static void pipe_client_flush( struct fd *fd, struct event **event )
{
/* FIXME: what do we have to do for this? */
- return 0;
}
static inline int is_overlapped( unsigned int options )
return !(options & (FILE_SYNCHRONOUS_IO_ALERT | FILE_SYNCHRONOUS_IO_NONALERT));
}
-static int pipe_server_get_info( struct fd *fd )
+static enum server_fd_type pipe_server_get_fd_type( struct fd *fd )
{
- struct pipe_server *server = get_fd_user( fd );
- int flags = FD_FLAG_AVAILABLE;
-
- if (is_overlapped( server->options )) flags |= FD_FLAG_OVERLAPPED;
-
- return flags;
+ return FD_TYPE_PIPE;
}
-static int pipe_client_get_info( struct fd *fd )
+static enum server_fd_type pipe_client_get_fd_type( struct fd *fd )
{
- struct pipe_client *client = get_fd_user( fd );
- int flags = FD_FLAG_AVAILABLE;
+ return FD_TYPE_PIPE;
+}
- if (is_overlapped( client->flags )) flags |= FD_FLAG_OVERLAPPED;
+static obj_handle_t alloc_wait_event( struct process *process )
+{
+ obj_handle_t handle = 0;
+ struct event *event = create_event( NULL, NULL, 0, 1, 0, NULL );
- return flags;
+ if (event)
+ {
+ handle = alloc_handle( process, event, EVENT_ALL_ACCESS, 0 );
+ release_object( event );
+ }
+ return handle;
}
-static struct named_pipe *create_named_pipe( const WCHAR *name, size_t len )
+static obj_handle_t pipe_server_ioctl( struct fd *fd, ioctl_code_t code, const async_data_t *async_data,
+ int blocking, const void *data, data_size_t size )
{
- struct named_pipe *pipe;
+ struct pipe_server *server = get_fd_user( fd );
+ struct async *async;
+ obj_handle_t wait_handle = 0;
- pipe = create_named_object( sync_namespace, &named_pipe_ops, name, len );
- if (pipe)
+ switch(code)
{
- if (get_error() != STATUS_OBJECT_NAME_COLLISION)
+ case FSCTL_PIPE_LISTEN:
+ switch(server->state)
{
- /* initialize it if it didn't already exist */
- pipe->instances = 0;
- list_init( &pipe->servers );
- list_init( &pipe->waiters );
+ case ps_idle_server:
+ case ps_wait_connect:
+ if (blocking)
+ {
+ async_data_t new_data = *async_data;
+ if (!(wait_handle = alloc_wait_event( current->process ))) break;
+ new_data.event = wait_handle;
+ if (!(async = fd_queue_async( server->ioctl_fd, &new_data, ASYNC_TYPE_WAIT )))
+ {
+ close_handle( current->process, wait_handle );
+ break;
+ }
+ }
+ else async = fd_queue_async( server->ioctl_fd, async_data, ASYNC_TYPE_WAIT );
+
+ if (async)
+ {
+ set_server_state( server, ps_wait_open );
+ if (server->pipe->waiters) async_wake_up( server->pipe->waiters, STATUS_SUCCESS );
+ release_object( async );
+ set_error( STATUS_PENDING );
+ return wait_handle;
+ }
+ break;
+ case ps_connected_server:
+ set_error( STATUS_PIPE_CONNECTED );
+ break;
+ case ps_disconnected_server:
+ set_error( STATUS_PIPE_BUSY );
+ break;
+ case ps_wait_disconnect:
+ set_error( STATUS_NO_DATA_DETECTED );
+ break;
+ case ps_wait_open:
+ set_error( STATUS_INVALID_HANDLE );
+ break;
+ }
+ return 0;
+
+ case FSCTL_PIPE_DISCONNECT:
+ switch(server->state)
+ {
+ case ps_connected_server:
+ assert( server->client );
+ assert( server->client->fd );
+
+ notify_empty( server );
+
+ /* dump the client and server fds, but keep the pointers
+ around - client loses all waiting data */
+ do_disconnect( server );
+ set_server_state( server, ps_disconnected_server );
+ break;
+ case ps_wait_disconnect:
+ assert( !server->client );
+ do_disconnect( server );
+ set_server_state( server, ps_wait_connect );
+ break;
+ case ps_idle_server:
+ case ps_wait_open:
+ set_error( STATUS_PIPE_LISTENING );
+ break;
+ case ps_disconnected_server:
+ case ps_wait_connect:
+ set_error( STATUS_PIPE_DISCONNECTED );
+ break;
}
+ return 0;
+
+ default:
+ return default_fd_ioctl( fd, code, async_data, blocking, data, size );
}
- return pipe;
}
-static struct named_pipe *open_named_pipe( const WCHAR *name, size_t len )
+static struct named_pipe *create_named_pipe( struct directory *root, const struct unicode_str *name,
+ unsigned int attr )
{
struct object *obj;
+ struct named_pipe *pipe = NULL;
+ struct unicode_str new_name;
+
+ if (!name || !name->len) return alloc_object( &named_pipe_ops );
+
+ if (!(obj = find_object_dir( root, name, attr, &new_name )))
+ {
+ set_error( STATUS_OBJECT_NAME_INVALID );
+ return NULL;
+ }
+ if (!new_name.len)
+ {
+ if (attr & OBJ_OPENIF && obj->ops == &named_pipe_ops)
+ set_error( STATUS_OBJECT_NAME_EXISTS );
+ else
+ {
+ release_object( obj );
+ obj = NULL;
+ if (attr & OBJ_OPENIF)
+ set_error( STATUS_OBJECT_TYPE_MISMATCH );
+ else
+ set_error( STATUS_OBJECT_NAME_COLLISION );
+ }
+ return (struct named_pipe *)obj;
+ }
- if ((obj = find_object( sync_namespace, name, len )))
+ if (obj->ops != &named_pipe_device_ops)
+ set_error( STATUS_OBJECT_NAME_INVALID );
+ else
{
- if (obj->ops == &named_pipe_ops) return (struct named_pipe *)obj;
- release_object( obj );
- set_error( STATUS_OBJECT_TYPE_MISMATCH );
+ struct named_pipe_device *dev = (struct named_pipe_device *)obj;
+ if ((pipe = create_object( dev->pipes, &named_pipe_ops, &new_name, NULL )))
+ clear_error();
}
- else set_error( STATUS_OBJECT_NAME_NOT_FOUND );
- return NULL;
+ release_object( obj );
+ return pipe;
}
static struct pipe_server *get_pipe_server_obj( struct process *process,
server->fd = NULL;
server->pipe = pipe;
- server->state = ps_idle_server;
server->client = NULL;
server->flush_poll = NULL;
server->options = options;
- list_init( &server->wait_q );
list_add_head( &pipe->servers, &server->entry );
grab_object( pipe );
-
+ if (!(server->ioctl_fd = alloc_pseudo_fd( &pipe_server_fd_ops, &server->obj, options )))
+ {
+ release_object( server );
+ return NULL;
+ }
+ set_server_state( server, ps_idle_server );
return server;
}
-static struct pipe_client *create_pipe_client( struct pipe_server *server, unsigned int flags )
+static struct pipe_client *create_pipe_client( unsigned int flags )
{
struct pipe_client *client;
return NULL;
client->fd = NULL;
- client->server = server;
+ client->server = NULL;
client->flags = flags;
return client;
}
-static inline struct pipe_server *find_server( struct named_pipe *pipe, enum pipe_state state )
+static struct pipe_server *find_available_server( struct named_pipe *pipe )
{
struct pipe_server *server;
+ /* look for pipe servers that are listening */
LIST_FOR_EACH_ENTRY( server, &pipe->servers, struct pipe_server, entry )
{
- if (server->state == state) return (struct pipe_server *)grab_object( server );
+ if (server->state == ps_wait_open)
+ return (struct pipe_server *)grab_object( server );
}
- return NULL;
-}
-
-static inline struct pipe_server *find_server2( struct named_pipe *pipe,
- enum pipe_state state1, enum pipe_state state2 )
-{
- struct pipe_server *server;
+ /* fall back to pipe servers that are idle */
LIST_FOR_EACH_ENTRY( server, &pipe->servers, struct pipe_server, entry )
{
- if (server->state == state1 || server->state == state2)
+ if (server->state == ps_idle_server)
return (struct pipe_server *)grab_object( server );
}
- return NULL;
-}
-DECL_HANDLER(create_named_pipe)
-{
- struct named_pipe *pipe;
- struct pipe_server *server;
-
- reply->handle = 0;
- pipe = create_named_pipe( get_req_data(), get_req_data_size() );
- if (!pipe)
- return;
-
- if (get_error() != STATUS_OBJECT_NAME_COLLISION)
- {
- pipe->insize = req->insize;
- pipe->outsize = req->outsize;
- pipe->maxinstances = req->maxinstances;
- pipe->timeout = req->timeout;
- pipe->flags = req->flags;
- }
- else
- {
- set_error( 0 ); /* clear the name collision */
- if (pipe->maxinstances <= pipe->instances)
- {
- set_error( STATUS_PIPE_BUSY );
- release_object( pipe );
- return;
- }
- if ((pipe->maxinstances != req->maxinstances) ||
- (pipe->timeout != req->timeout) ||
- (pipe->flags != req->flags))
- {
- set_error( STATUS_ACCESS_DENIED );
- release_object( pipe );
- return;
- }
- }
-
- server = create_pipe_server( pipe, req->options );
- if (server)
- {
- reply->handle = alloc_handle( current->process, server,
- req->access, req->inherit );
- server->pipe->instances++;
- release_object( server );
- }
-
- release_object( pipe );
+ return NULL;
}
-DECL_HANDLER(open_named_pipe)
+static struct object *named_pipe_open_file( struct object *obj, unsigned int access,
+ unsigned int sharing, unsigned int options )
{
+ struct named_pipe *pipe = (struct named_pipe *)obj;
struct pipe_server *server;
struct pipe_client *client;
- struct named_pipe *pipe;
+ unsigned int pipe_sharing;
int fds[2];
- pipe = open_named_pipe( get_req_data(), get_req_data_size() );
- if (!pipe)
+ if (!(server = find_available_server( pipe )))
{
- set_error( STATUS_NO_SUCH_FILE );
- return;
+ set_error( STATUS_PIPE_NOT_AVAILABLE );
+ return NULL;
}
- server = find_server2( pipe, ps_idle_server, ps_wait_open );
- release_object( pipe );
-
- if (!server)
+ pipe_sharing = server->pipe->sharing;
+ if (((access & GENERIC_READ) && !(pipe_sharing & FILE_SHARE_READ)) ||
+ ((access & GENERIC_WRITE) && !(pipe_sharing & FILE_SHARE_WRITE)))
{
- set_error( STATUS_PIPE_NOT_AVAILABLE );
- return;
+ set_error( STATUS_ACCESS_DENIED );
+ release_object( server );
+ return NULL;
}
- client = create_pipe_client( server, req->flags );
- if (client)
+ if ((client = create_pipe_client( options )))
{
if (!socketpair( PF_UNIX, SOCK_STREAM, 0, fds ))
{
- int res = 0;
-
- assert( !client->fd );
assert( !server->fd );
/* for performance reasons, only set nonblocking mode when using
* overlapped I/O. Otherwise, we will be doing too much busy
* looping */
- if (is_overlapped( req->flags ))
- res = fcntl( fds[1], F_SETFL, O_NONBLOCK );
- if ((res != -1) && is_overlapped( server->options ))
- res = fcntl( fds[0], F_SETFL, O_NONBLOCK );
-
- client->fd = create_anonymous_fd( &pipe_client_fd_ops,
- fds[1], &client->obj );
- server->fd = create_anonymous_fd( &pipe_server_fd_ops,
- fds[0], &server->obj );
- if (client->fd && server->fd && res != 1)
+ if (is_overlapped( options )) fcntl( fds[1], F_SETFL, O_NONBLOCK );
+ if (is_overlapped( server->options )) fcntl( fds[0], F_SETFL, O_NONBLOCK );
+
+ if (pipe->insize)
+ {
+ setsockopt( fds[0], SOL_SOCKET, SO_RCVBUF, &pipe->insize, sizeof(pipe->insize) );
+ setsockopt( fds[1], SOL_SOCKET, SO_RCVBUF, &pipe->insize, sizeof(pipe->insize) );
+ }
+ if (pipe->outsize)
{
+ setsockopt( fds[0], SOL_SOCKET, SO_SNDBUF, &pipe->outsize, sizeof(pipe->outsize) );
+ setsockopt( fds[1], SOL_SOCKET, SO_SNDBUF, &pipe->outsize, sizeof(pipe->outsize) );
+ }
+
+ client->fd = create_anonymous_fd( &pipe_client_fd_ops, fds[1], &client->obj, options );
+ server->fd = create_anonymous_fd( &pipe_server_fd_ops, fds[0], &server->obj, server->options );
+ if (client->fd && server->fd)
+ {
+ allow_fd_caching( client->fd );
+ allow_fd_caching( server->fd );
+ fd_copy_completion( server->ioctl_fd, server->fd );
if (server->state == ps_wait_open)
- async_terminate_head( &server->wait_q, STATUS_SUCCESS );
- assert( list_empty( &server->wait_q ) );
- server->state = ps_connected_server;
+ fd_async_wake_up( server->ioctl_fd, ASYNC_TYPE_WAIT, STATUS_SUCCESS );
+ set_server_state( server, ps_connected_server );
server->client = client;
client->server = server;
- reply->handle = alloc_handle( current->process, client,
- req->access, req->inherit );
+ }
+ else
+ {
+ release_object( client );
+ client = NULL;
}
}
else
+ {
file_set_error();
-
- release_object( client );
+ release_object( client );
+ client = NULL;
+ }
}
release_object( server );
+ return &client->obj;
}
-DECL_HANDLER(connect_named_pipe)
+static obj_handle_t named_pipe_device_ioctl( struct fd *fd, ioctl_code_t code, const async_data_t *async_data,
+ int blocking, const void *data, data_size_t size )
{
- struct pipe_server *server;
+ struct named_pipe_device *device = get_fd_user( fd );
- server = get_pipe_server_obj(current->process, req->handle, 0);
- if (!server)
- return;
-
- switch(server->state)
+ switch(code)
{
- case ps_idle_server:
- case ps_wait_connect:
- assert( !server->fd );
- server->state = ps_wait_open;
- create_async( current, NULL, &server->wait_q,
- req->func, req->event, NULL );
- async_terminate_queue( &server->pipe->waiters, STATUS_SUCCESS );
- break;
- case ps_connected_server:
- assert( server->fd );
- set_error( STATUS_PIPE_CONNECTED );
- break;
- case ps_disconnected_server:
- set_error( STATUS_PIPE_BUSY );
- break;
- case ps_wait_disconnect:
- set_error( STATUS_NO_DATA_DETECTED );
- break;
- case ps_wait_open:
- set_error( STATUS_INVALID_HANDLE );
- break;
- }
+ case FSCTL_PIPE_WAIT:
+ {
+ const FILE_PIPE_WAIT_FOR_BUFFER *buffer = data;
+ obj_handle_t wait_handle = 0;
+ struct named_pipe *pipe;
+ struct pipe_server *server;
+ struct unicode_str name;
+
+ if (size < sizeof(*buffer) ||
+ size < FIELD_OFFSET(FILE_PIPE_WAIT_FOR_BUFFER, Name[buffer->NameLength/sizeof(WCHAR)]))
+ {
+ set_error( STATUS_INVALID_PARAMETER );
+ return 0;
+ }
+ name.str = buffer->Name;
+ name.len = (buffer->NameLength / sizeof(WCHAR)) * sizeof(WCHAR);
+ if (!(pipe = (struct named_pipe *)find_object( device->pipes, &name, OBJ_CASE_INSENSITIVE )))
+ {
+ set_error( STATUS_PIPE_NOT_AVAILABLE );
+ return 0;
+ }
+ if (!(server = find_available_server( pipe )))
+ {
+ struct async *async;
+
+ if (!pipe->waiters && !(pipe->waiters = create_async_queue( NULL ))) goto done;
+
+ if (blocking)
+ {
+ async_data_t new_data = *async_data;
+ if (!(wait_handle = alloc_wait_event( current->process ))) goto done;
+ new_data.event = wait_handle;
+ if (!(async = create_async( current, pipe->waiters, &new_data )))
+ {
+ close_handle( current->process, wait_handle );
+ wait_handle = 0;
+ }
+ }
+ else async = create_async( current, pipe->waiters, async_data );
+
+ if (async)
+ {
+ timeout_t when = buffer->TimeoutSpecified ? buffer->Timeout.QuadPart : pipe->timeout;
+ async_set_timeout( async, when, STATUS_IO_TIMEOUT );
+ release_object( async );
+ set_error( STATUS_PENDING );
+ }
+ }
+ else release_object( server );
+
+ done:
+ release_object( pipe );
+ return wait_handle;
+ }
- release_object(server);
+ default:
+ return default_fd_ioctl( fd, code, async_data, blocking, data, size );
+ }
}
-DECL_HANDLER(wait_named_pipe)
+
+DECL_HANDLER(create_named_pipe)
{
struct named_pipe *pipe;
struct pipe_server *server;
+ struct unicode_str name;
+ struct directory *root = NULL;
- if (!(pipe = open_named_pipe( get_req_data(), get_req_data_size() )))
+ if (!req->sharing || (req->sharing & ~(FILE_SHARE_READ | FILE_SHARE_WRITE)) ||
+ (!(req->flags & NAMED_PIPE_MESSAGE_STREAM_WRITE) && (req->flags & NAMED_PIPE_MESSAGE_STREAM_READ)))
{
- set_error( STATUS_PIPE_NOT_AVAILABLE );
+ set_error( STATUS_INVALID_PARAMETER );
return;
}
- server = find_server( pipe, ps_wait_open );
- if (server)
+
+ reply->handle = 0;
+ get_req_unicode_str( &name );
+ if (req->rootdir && !(root = get_directory_obj( current->process, req->rootdir, 0 )))
+ return;
+
+ pipe = create_named_pipe( root, &name, req->attributes | OBJ_OPENIF );
+
+ if (root) release_object( root );
+ if (!pipe) return;
+
+ if (get_error() != STATUS_OBJECT_NAME_EXISTS)
{
- /* there's already a server waiting for a client to connect */
- thread_queue_apc( current, NULL, req->func, APC_ASYNC_IO,
- 1, req->overlapped, NULL, (void *)STATUS_SUCCESS );
- release_object( server );
+ /* initialize it if it didn't already exist */
+ pipe->instances = 0;
+ pipe->waiters = NULL;
+ list_init( &pipe->servers );
+ pipe->insize = req->insize;
+ pipe->outsize = req->outsize;
+ pipe->maxinstances = req->maxinstances;
+ pipe->timeout = req->timeout;
+ pipe->flags = req->flags;
+ pipe->sharing = req->sharing;
}
else
{
- int timeout;
- if (req->timeout == NMPWAIT_USE_DEFAULT_WAIT)
- timeout = pipe->timeout;
- else
- timeout = req->timeout;
+ if (pipe->maxinstances <= pipe->instances)
+ {
+ set_error( STATUS_INSTANCE_NOT_AVAILABLE );
+ release_object( pipe );
+ return;
+ }
+ if (pipe->sharing != req->sharing)
+ {
+ set_error( STATUS_ACCESS_DENIED );
+ release_object( pipe );
+ return;
+ }
+ clear_error(); /* clear the name collision */
+ }
- if (req->timeout == NMPWAIT_WAIT_FOREVER)
- create_async( current, NULL, &pipe->waiters,
- req->func, req->overlapped, NULL );
- else
- create_async( current, &timeout, &pipe->waiters,
- req->func, req->overlapped, NULL );
+ server = create_pipe_server( pipe, req->options );
+ if (server)
+ {
+ reply->handle = alloc_handle( current->process, server, req->access, req->attributes );
+ server->pipe->instances++;
+ release_object( server );
}
release_object( pipe );
}
-DECL_HANDLER(disconnect_named_pipe)
+DECL_HANDLER(get_named_pipe_info)
{
struct pipe_server *server;
+ struct pipe_client *client = NULL;
- reply->fd = -1;
- server = get_pipe_server_obj( current->process, req->handle, 0 );
+ server = get_pipe_server_obj( current->process, req->handle, FILE_READ_ATTRIBUTES );
if (!server)
- return;
- switch(server->state)
{
- case ps_connected_server:
- assert( server->fd );
- assert( server->client );
- assert( server->client->fd );
-
- notify_empty( server );
-
- /* Dump the client and server fds, but keep the pointers
- around - client loses all waiting data */
- server->state = ps_disconnected_server;
- do_disconnect( server );
- reply->fd = flush_cached_fd( current->process, req->handle );
- break;
-
- case ps_wait_disconnect:
- assert( !server->client );
- assert( server->fd );
- do_disconnect( server );
- server->state = ps_wait_connect;
- reply->fd = flush_cached_fd( current->process, req->handle );
- break;
+ if (get_error() != STATUS_OBJECT_TYPE_MISMATCH)
+ return;
- case ps_idle_server:
- case ps_wait_open:
- case ps_disconnected_server:
- case ps_wait_connect:
- set_error( STATUS_PIPE_DISCONNECTED );
- break;
+ clear_error();
+ client = (struct pipe_client *)get_handle_obj( current->process, req->handle,
+ 0, &pipe_client_ops );
+ if (!client) return;
+ server = client->server;
}
- release_object( server );
-}
-
-DECL_HANDLER(get_named_pipe_info)
-{
- struct pipe_server *server;
-
- server = get_pipe_server_obj( current->process, req->handle, 0 );
- if (!server)
- return;
reply->flags = server->pipe->flags;
+ reply->sharing = server->pipe->sharing;
reply->maxinstances = server->pipe->maxinstances;
+ reply->instances = server->pipe->instances;
reply->insize = server->pipe->insize;
reply->outsize = server->pipe->outsize;
- release_object(server);
+ if (client)
+ release_object(client);
+ else
+ {
+ reply->flags |= NAMED_PIPE_SERVER_END;
+ release_object(server);
+ }
}