May 2015 - Wine-commits - list.winehq.org

Alexandre Julliard : server: Add a trace for the supported socket ioctl.
by Alexandre Julliard 06 May '15

06 May '15

Module: wine Branch: master Commit: 62802339a5506e72a4c72911cd8205ecf4956224 URL: http://source.winehq.org/git/wine.git/?a=commit;h=62802339a5506e72a4c72911c… Author: Alexandre Julliard <julliard(a)winehq.org> Date: Wed May 6 09:26:14 2015 +0900 server: Add a trace for the supported socket ioctl. --- server/trace.c | 3 +++ 1 file changed, 3 insertions(+) diff --git a/server/trace.c b/server/trace.c index 61c0c9f..e257afb 100644 --- a/server/trace.c +++ b/server/trace.c @@ -39,6 +39,8 @@ #include "winuser.h" #include "winioctl.h" #include "ddk/wdm.h" +#define USE_WS_PREFIX +#include "winsock2.h" #include "file.h" #include "request.h" #include "unicode.h" @@ -115,6 +117,7 @@ static void dump_ioctl_code( const char *prefix, const ioctl_code_t *code ) CASE(FSCTL_PIPE_DISCONNECT); CASE(FSCTL_PIPE_LISTEN); CASE(FSCTL_PIPE_WAIT); + CASE(WS_SIO_ADDRESS_LIST_CHANGE); default: fprintf( stderr, "%s%08x", prefix, *code ); break; #undef CASE }

1 0

Alexandre Julliard : server: Allow cancelling async I/ O for all object types.
by Alexandre Julliard 06 May '15

06 May '15

Module: wine Branch: master Commit: 83e3a9c9ba6efa583a0d7b641409c9a457fa8bfe URL: http://source.winehq.org/git/wine.git/?a=commit;h=83e3a9c9ba6efa583a0d7b641… Author: Alexandre Julliard <julliard(a)winehq.org> Date: Wed May 6 13:48:05 2015 +0900 server: Allow cancelling async I/O for all object types. --- server/fd.c | 8 ++++---- server/file.h | 4 ++-- server/sock.c | 9 +++++---- 3 files changed, 11 insertions(+), 10 deletions(-) diff --git a/server/fd.c b/server/fd.c index e7f151a..1253b3d 100644 --- a/server/fd.c +++ b/server/fd.c @@ -2100,15 +2100,14 @@ void default_fd_reselect_async( struct fd *fd, struct async_queue *queue ) } /* default cancel_async() fd routine */ -void default_fd_cancel_async( struct fd *fd, struct process *process, struct thread *thread, client_ptr_t iosb ) +int default_fd_cancel_async( struct fd *fd, struct process *process, struct thread *thread, client_ptr_t iosb ) { int n = 0; n += async_wake_up_by( fd->read_q, process, thread, iosb, STATUS_CANCELLED ); n += async_wake_up_by( fd->write_q, process, thread, iosb, STATUS_CANCELLED ); n += async_wake_up_by( fd->wait_q, process, thread, iosb, STATUS_CANCELLED ); - if (!n && iosb) - set_error( STATUS_NOT_FOUND ); + return n; } static inline int is_valid_mounted_device( struct stat *st ) @@ -2377,7 +2376,8 @@ DECL_HANDLER(cancel_async) if (fd) { - if (get_unix_fd( fd ) != -1) fd->fd_ops->cancel_async( fd, current->process, thread, req->iosb ); + int count = fd->fd_ops->cancel_async( fd, current->process, thread, req->iosb ); + if (!count && req->iosb) set_error( STATUS_NOT_FOUND ); release_object( fd ); } } diff --git a/server/file.h b/server/file.h index 7e8b12e..603b686 100644 --- a/server/file.h +++ b/server/file.h @@ -52,7 +52,7 @@ struct fd_ops /* selected events for async i/o need an update */ void (*reselect_async)( struct fd *, struct async_queue *queue ); /* cancel an async operation */ - void (*cancel_async)(struct fd *, struct process *process, struct thread *thread, client_ptr_t iosb); + int (*cancel_async)(struct fd *, struct process *process, struct thread *thread, client_ptr_t iosb); }; /* file descriptor functions */ @@ -98,7 +98,7 @@ extern obj_handle_t default_fd_ioctl( struct fd *fd, ioctl_code_t code, const as extern void no_fd_queue_async( struct fd *fd, const async_data_t *data, int type, int count ); extern void default_fd_queue_async( struct fd *fd, const async_data_t *data, int type, int count ); extern void default_fd_reselect_async( struct fd *fd, struct async_queue *queue ); -extern void default_fd_cancel_async( struct fd *fd, struct process *process, struct thread *thread, client_ptr_t iosb ); +extern int default_fd_cancel_async( struct fd *fd, struct process *process, struct thread *thread, client_ptr_t iosb ); extern void main_loop(void); extern void remove_process_locks( struct process *process ); diff --git a/server/sock.c b/server/sock.c index 337006f..c4dcf6f 100644 --- a/server/sock.c +++ b/server/sock.c @@ -133,7 +133,7 @@ static enum server_fd_type sock_get_fd_type( struct fd *fd ); static obj_handle_t sock_ioctl( struct fd *fd, ioctl_code_t code, const async_data_t *async, int blocking ); static void sock_queue_async( struct fd *fd, const async_data_t *data, int type, int count ); static void sock_reselect_async( struct fd *fd, struct async_queue *queue ); -static void sock_cancel_async( struct fd *fd, struct process *process, struct thread *thread, client_ptr_t iosb ); +static int sock_cancel_async( struct fd *fd, struct process *process, struct thread *thread, client_ptr_t iosb ); static int sock_get_ntstatus( int err ); static int sock_get_error( int err ); @@ -609,16 +609,17 @@ static void sock_reselect_async( struct fd *fd, struct async_queue *queue ) sock_reselect( sock ); } -static void sock_cancel_async( struct fd *fd, struct process *process, struct thread *thread, client_ptr_t iosb ) +static int sock_cancel_async( struct fd *fd, struct process *process, struct thread *thread, client_ptr_t iosb ) { struct sock *sock = get_fd_user( fd ); int n = 0; + assert( sock->obj.ops == &sock_ops ); n += async_wake_up_by( sock->read_q, process, thread, iosb, STATUS_CANCELLED ); n += async_wake_up_by( sock->write_q, process, thread, iosb, STATUS_CANCELLED ); - if (!n && iosb) - set_error( STATUS_NOT_FOUND ); + n += async_wake_up_by( sock->ifchange_q, process, thread, iosb, STATUS_CANCELLED ); + return n; } static struct fd *sock_get_fd( struct object *obj )

1 0

Alexandre Julliard : server: Make the APC callback optional in async calls.
by Alexandre Julliard 06 May '15

06 May '15

Module: wine Branch: master Commit: 481517178ff7dd542966d7f11f3d61b3fc8a0776 URL: http://source.winehq.org/git/wine.git/?a=commit;h=481517178ff7dd542966d7f11… Author: Alexandre Julliard <julliard(a)winehq.org> Date: Wed May 6 17:10:31 2015 +0900 server: Make the APC callback optional in async calls. --- server/async.c | 24 +++++++++++++++--------- 1 file changed, 15 insertions(+), 9 deletions(-) diff --git a/server/async.c b/server/async.c index a8f3b05..e1650fe 100644 --- a/server/async.c +++ b/server/async.c @@ -145,8 +145,6 @@ static void async_queue_destroy( struct object *obj ) /* notifies client thread of new status of its async request */ void async_terminate( struct async *async, unsigned int status ) { - apc_call_t data; - assert( status != STATUS_PENDING ); if (async->status != STATUS_PENDING) @@ -156,14 +154,22 @@ void async_terminate( struct async *async, unsigned int status ) return; } - memset( &data, 0, sizeof(data) ); - data.type = APC_ASYNC_IO; - data.async_io.func = async->data.callback; - data.async_io.user = async->data.arg; - data.async_io.sb = async->data.iosb; - data.async_io.status = status; - thread_queue_apc( async->thread, &async->obj, &data ); async->status = status; + + if (async->data.callback) + { + apc_call_t data; + + memset( &data, 0, sizeof(data) ); + data.type = APC_ASYNC_IO; + data.async_io.func = async->data.callback; + data.async_io.user = async->data.arg; + data.async_io.sb = async->data.iosb; + data.async_io.status = status; + thread_queue_apc( async->thread, &async->obj, &data ); + } + else async_set_result( &async->obj, STATUS_SUCCESS, 0, 0, 0 ); + async_reselect( async ); release_object( async ); /* so that it gets destroyed when the async is done */ }

1 0

Alexandre Julliard : server: Implement flush requests for device files.
by Alexandre Julliard 06 May '15

06 May '15

Module: wine Branch: master Commit: 6073e75a6a4b0dbb1a9ff74c01f373d1af80a5e6 URL: http://source.winehq.org/git/wine.git/?a=commit;h=6073e75a6a4b0dbb1a9ff74c0… Author: Alexandre Julliard <julliard(a)winehq.org> Date: Wed May 6 17:13:51 2015 +0900 server: Implement flush requests for device files. --- server/device.c | 20 +++++++++++++++++++- server/trace.c | 3 +++ 2 files changed, 22 insertions(+), 1 deletion(-) diff --git a/server/device.c b/server/device.c index 2707faf..a2fc1cb 100644 --- a/server/device.c +++ b/server/device.c @@ -131,6 +131,7 @@ static obj_handle_t device_read( struct fd *fd, const async_data_t *async_data, file_pos_t pos ); static obj_handle_t device_write( struct fd *fd, const async_data_t *async_data, int blocking, file_pos_t pos, data_size_t *written ); +static obj_handle_t device_flush( struct fd *fd, const async_data_t *async_data, int blocking ); static obj_handle_t device_ioctl( struct fd *fd, ioctl_code_t code, const async_data_t *async_data, int blocking ); @@ -161,7 +162,7 @@ static const struct fd_ops device_fd_ops = device_get_fd_type, /* get_fd_type */ device_read, /* read */ device_write, /* write */ - no_fd_flush, /* flush */ + device_flush, /* flush */ device_ioctl, /* ioctl */ default_fd_queue_async, /* queue_async */ default_fd_reselect_async, /* reselect_async */ @@ -388,6 +389,23 @@ static obj_handle_t device_write( struct fd *fd, const async_data_t *async_data, return handle; } +static obj_handle_t device_flush( struct fd *fd, const async_data_t *async_data, int blocking ) +{ + struct device *device = get_fd_user( fd ); + struct irp_call *irp; + obj_handle_t handle; + irp_params_t params; + + params.major = IRP_MJ_FLUSH_BUFFERS; + + irp = create_irp( device, &params, NULL, 0, 0 ); + if (!irp) return 0; + + handle = queue_irp( device, irp, async_data, blocking ); + release_object( irp ); + return handle; +} + static obj_handle_t device_ioctl( struct fd *fd, ioctl_code_t code, const async_data_t *async_data, int blocking ) { diff --git a/server/trace.c b/server/trace.c index e257afb..e4b6af5 100644 --- a/server/trace.c +++ b/server/trace.c @@ -326,6 +326,9 @@ static void dump_irp_params( const char *prefix, const irp_params_t *data ) dump_uint64( ",pos=", &data->write.pos ); fputc( '}', stderr ); break; + case IRP_MJ_FLUSH_BUFFERS: + fprintf( stderr, "%s{major=FLUSH_BUFFERS}", prefix ); + break; case IRP_MJ_DEVICE_CONTROL: fprintf( stderr, "%s{major=DEVICE_CONTROL", prefix ); dump_ioctl_code( ",code=", &data->ioctl.code );

1 0

Alexandre Julliard : ntdll: Fallback to server calls for read and write on objects without a file descriptor.
by Alexandre Julliard 06 May '15

06 May '15

Module: wine Branch: master Commit: c07a0561dbaba98305aa2bf8744d5c65a2043094 URL: http://source.winehq.org/git/wine.git/?a=commit;h=c07a0561dbaba98305aa2bf87… Author: Alexandre Julliard <julliard(a)winehq.org> Date: Tue May 5 13:35:57 2015 +0900 ntdll: Fallback to server calls for read and write on objects without a file descriptor. --- dlls/ntdll/file.c | 179 ++++++++++++++++++++++++++++++++++++++++++------------ 1 file changed, 140 insertions(+), 39 deletions(-) diff --git a/dlls/ntdll/file.c b/dlls/ntdll/file.c index d25c792..e43ef41 100644 --- a/dlls/ntdll/file.c +++ b/dlls/ntdll/file.c @@ -353,6 +353,14 @@ struct async_fileio_write unsigned int count; }; +struct async_irp +{ + struct async_fileio io; + HANDLE event; /* async event */ + void *buffer; /* buffer for output */ + ULONG size; /* size of buffer */ +}; + static struct async_fileio *fileio_freelist; static void release_fileio( struct async_fileio *io ) @@ -387,6 +395,33 @@ static struct async_fileio *alloc_fileio( DWORD size, HANDLE handle, PIO_APC_ROU return io; } +/* callback for irp async I/O completion */ +static NTSTATUS irp_completion( void *user, IO_STATUS_BLOCK *io, NTSTATUS status, void **apc, void **arg ) +{ + struct async_irp *async = user; + + if (status == STATUS_ALERTED) + { + SERVER_START_REQ( get_irp_result ) + { + req->handle = wine_server_obj_handle( async->io.handle ); + req->user_arg = wine_server_client_ptr( async ); + wine_server_set_reply( req, async->buffer, async->size ); + status = wine_server_call( req ); + if (status != STATUS_PENDING) io->Information = reply->size; + } + SERVER_END_REQ; + } + if (status != STATUS_PENDING) + { + io->u.Status = status; + *apc = async->io.apc; + *arg = async->io.apc_arg; + release_fileio( &async->io ); + } + return status; +} + /*********************************************************************** * FILE_GetNtStatus(void) * @@ -499,6 +534,102 @@ static NTSTATUS FILE_AsyncReadService( void *user, IO_STATUS_BLOCK *iosb, return status; } +/* do a read call through the server */ +static NTSTATUS server_read_file( HANDLE handle, HANDLE event, PIO_APC_ROUTINE apc, void *apc_context, + IO_STATUS_BLOCK *io, void *buffer, ULONG size, + LARGE_INTEGER *offset, ULONG *key ) +{ + struct async_irp *async; + NTSTATUS status; + HANDLE wait_handle; + ULONG options; + ULONG_PTR cvalue = apc ? 0 : (ULONG_PTR)apc_context; + + if (!(async = (struct async_irp *)alloc_fileio( sizeof(*async), handle, apc, apc_context ))) + return STATUS_NO_MEMORY; + + async->event = event; + async->buffer = buffer; + async->size = size; + + SERVER_START_REQ( read ) + { + req->blocking = !apc && !event && !cvalue; + req->async.handle = wine_server_obj_handle( handle ); + req->async.callback = wine_server_client_ptr( irp_completion ); + req->async.iosb = wine_server_client_ptr( io ); + req->async.arg = wine_server_client_ptr( async ); + req->async.event = wine_server_obj_handle( event ); + req->async.cvalue = cvalue; + req->pos = offset ? offset->QuadPart : 0; + wine_server_set_reply( req, buffer, size ); + status = wine_server_call( req ); + wait_handle = wine_server_ptr_handle( reply->wait ); + options = reply->options; + if (status != STATUS_PENDING) io->Information = wine_server_reply_size( reply ); + } + SERVER_END_REQ; + + if (status != STATUS_PENDING) RtlFreeHeap( GetProcessHeap(), 0, async ); + + if (wait_handle) + { + NtWaitForSingleObject( wait_handle, (options & FILE_SYNCHRONOUS_IO_ALERT), NULL ); + status = io->u.Status; + NtClose( wait_handle ); + } + + return status; +} + +/* do a write call through the server */ +static NTSTATUS server_write_file( HANDLE handle, HANDLE event, PIO_APC_ROUTINE apc, void *apc_context, + IO_STATUS_BLOCK *io, const void *buffer, ULONG size, + LARGE_INTEGER *offset, ULONG *key ) +{ + struct async_irp *async; + NTSTATUS status; + HANDLE wait_handle; + ULONG options; + ULONG_PTR cvalue = apc ? 0 : (ULONG_PTR)apc_context; + + if (!(async = (struct async_irp *)alloc_fileio( sizeof(*async), handle, apc, apc_context ))) + return STATUS_NO_MEMORY; + + async->event = event; + async->buffer = NULL; + async->size = 0; + + SERVER_START_REQ( write ) + { + req->blocking = !apc && !event && !cvalue; + req->async.handle = wine_server_obj_handle( handle ); + req->async.callback = wine_server_client_ptr( irp_completion ); + req->async.iosb = wine_server_client_ptr( io ); + req->async.arg = wine_server_client_ptr( async ); + req->async.event = wine_server_obj_handle( event ); + req->async.cvalue = cvalue; + req->pos = offset ? offset->QuadPart : 0; + wine_server_add_data( req, buffer, size ); + status = wine_server_call( req ); + wait_handle = wine_server_ptr_handle( reply->wait ); + options = reply->options; + if (status != STATUS_PENDING) io->Information = reply->size; + } + SERVER_END_REQ; + + if (status != STATUS_PENDING) RtlFreeHeap( GetProcessHeap(), 0, async ); + + if (wait_handle) + { + NtWaitForSingleObject( wait_handle, (options & FILE_SYNCHRONOUS_IO_ALERT), NULL ); + status = io->u.Status; + NtClose( wait_handle ); + } + + return status; +} + struct io_timeouts { int interval; /* max interval between two bytes */ @@ -675,6 +806,9 @@ NTSTATUS WINAPI NtReadFile(HANDLE hFile, HANDLE hEvent, status = server_get_unix_fd( hFile, FILE_READ_DATA, &unix_handle, &needs_close, &type, &options ); + if (status == STATUS_BAD_DEVICE_TYPE) + return server_read_file( hFile, hEvent, apc, apc_user, io_status, buffer, length, offset, key ); + if (status) return status; async_read = !(options & (FILE_SYNCHRONOUS_IO_ALERT | FILE_SYNCHRONOUS_IO_NONALERT)); @@ -1056,6 +1190,9 @@ NTSTATUS WINAPI NtWriteFile(HANDLE hFile, HANDLE hEvent, status = server_get_unix_fd( hFile, FILE_WRITE_DATA, &unix_handle, &needs_close, &type, &options ); + if (status == STATUS_BAD_DEVICE_TYPE) + return server_write_file( hFile, hEvent, apc, apc_user, io_status, buffer, length, offset, key ); + if (status == STATUS_ACCESS_DENIED) { status = server_get_unix_fd( hFile, FILE_APPEND_DATA, &unix_handle, @@ -1352,42 +1489,6 @@ NTSTATUS WINAPI NtWriteFileGather( HANDLE file, HANDLE event, PIO_APC_ROUTINE ap } -struct async_ioctl -{ - struct async_fileio io; - HANDLE event; /* async event */ - void *buffer; /* buffer for output */ - ULONG size; /* size of buffer */ -}; - -/* callback for ioctl async I/O completion */ -static NTSTATUS ioctl_completion( void *user, IO_STATUS_BLOCK *io, - NTSTATUS status, void **apc, void **arg ) -{ - struct async_ioctl *async = user; - - if (status == STATUS_ALERTED) - { - SERVER_START_REQ( get_irp_result ) - { - req->handle = wine_server_obj_handle( async->io.handle ); - req->user_arg = wine_server_client_ptr( async ); - wine_server_set_reply( req, async->buffer, async->size ); - status = wine_server_call( req ); - if (status != STATUS_PENDING) io->Information = wine_server_reply_size( reply ); - } - SERVER_END_REQ; - } - if (status != STATUS_PENDING) - { - io->u.Status = status; - *apc = async->io.apc; - *arg = async->io.apc_arg; - release_fileio( &async->io ); - } - return status; -} - /* do an ioctl call through the server */ static NTSTATUS server_ioctl_file( HANDLE handle, HANDLE event, PIO_APC_ROUTINE apc, PVOID apc_context, @@ -1395,13 +1496,13 @@ static NTSTATUS server_ioctl_file( HANDLE handle, HANDLE event, const void *in_buffer, ULONG in_size, PVOID out_buffer, ULONG out_size ) { - struct async_ioctl *async; + struct async_irp *async; NTSTATUS status; HANDLE wait_handle; ULONG options; ULONG_PTR cvalue = apc ? 0 : (ULONG_PTR)apc_context; - if (!(async = (struct async_ioctl *)alloc_fileio( sizeof(*async), handle, apc, apc_context ))) + if (!(async = (struct async_irp *)alloc_fileio( sizeof(*async), handle, apc, apc_context ))) return STATUS_NO_MEMORY; async->event = event; async->buffer = out_buffer; @@ -1412,7 +1513,7 @@ static NTSTATUS server_ioctl_file( HANDLE handle, HANDLE event, req->code = code; req->blocking = !apc && !event && !cvalue; req->async.handle = wine_server_obj_handle( handle ); - req->async.callback = wine_server_client_ptr( ioctl_completion ); + req->async.callback = wine_server_client_ptr( irp_completion ); req->async.iosb = wine_server_client_ptr( io ); req->async.arg = wine_server_client_ptr( async ); req->async.event = wine_server_obj_handle( event );

1 0

Alexandre Julliard : ntoskrnl: Flesh out IoBuildSynchronousFsdRequest implementation.
by Alexandre Julliard 06 May '15

06 May '15

Module: wine Branch: master Commit: a78f8f298a92237d08f9ed68586d490c3375c67d URL: http://source.winehq.org/git/wine.git/?a=commit;h=a78f8f298a92237d08f9ed685… Author: Alexandre Julliard <julliard(a)winehq.org> Date: Tue May 5 14:22:52 2015 +0900 ntoskrnl: Flesh out IoBuildSynchronousFsdRequest implementation. --- dlls/ntoskrnl.exe/ntoskrnl.c | 24 +++++++++++++++++++----- include/ddk/wdm.h | 1 + 2 files changed, 20 insertions(+), 5 deletions(-) diff --git a/dlls/ntoskrnl.exe/ntoskrnl.c b/dlls/ntoskrnl.exe/ntoskrnl.c index 7f6a1c7..f8e1f18 100644 --- a/dlls/ntoskrnl.exe/ntoskrnl.c +++ b/dlls/ntoskrnl.exe/ntoskrnl.c @@ -549,16 +549,30 @@ PIRP WINAPI IoBuildSynchronousFsdRequest(ULONG majorfunc, PDEVICE_OBJECT device, PIRP irp; PIO_STACK_LOCATION irpsp; - FIXME("(%d %p %p %d %p %p %p) stub\n", majorfunc, device, buffer, length, startoffset, event, iosb); + TRACE("(%d %p %p %d %p %p %p)\n", majorfunc, device, buffer, length, startoffset, event, iosb); - irp = IoAllocateIrp( device->StackSize, FALSE ); - if (irp == NULL) - return NULL; + if (!(irp = IoAllocateIrp( device->StackSize, FALSE ))) return NULL; irpsp = IoGetNextIrpStackLocation( irp ); irpsp->MajorFunction = majorfunc; - /*irpsp->Parameters.DeviceIoControl.IoControlCode = IoControlCode;*/ + irpsp->DeviceObject = device; + irpsp->CompletionRoutine = NULL; + + irp->AssociatedIrp.SystemBuffer = buffer; + if (device->Flags & DO_DIRECT_IO) IoAllocateMdl( buffer, length, FALSE, FALSE, irp ); + switch (majorfunc) + { + case IRP_MJ_READ: + irpsp->Parameters.Read.Length = length; + irpsp->Parameters.Read.ByteOffset = *startoffset; + break; + case IRP_MJ_WRITE: + irpsp->Parameters.Write.Length = length; + irpsp->Parameters.Write.ByteOffset = *startoffset; + break; + } + irp->RequestorMode = KernelMode; irp->UserIosb = iosb; irp->UserEvent = event; irp->UserBuffer = buffer; diff --git a/include/ddk/wdm.h b/include/ddk/wdm.h index c234375..10832cf 100644 --- a/include/ddk/wdm.h +++ b/include/ddk/wdm.h @@ -1201,6 +1201,7 @@ PVOID WINAPI IoAllocateErrorLogEntry(PVOID,UCHAR); PIRP WINAPI IoAllocateIrp(CCHAR,BOOLEAN); PMDL WINAPI IoAllocateMdl(PVOID,ULONG,BOOLEAN,BOOLEAN,IRP*); PIRP WINAPI IoBuildDeviceIoControlRequest(ULONG,DEVICE_OBJECT*,PVOID,ULONG,PVOID,ULONG,BOOLEAN,PKEVENT,IO_STATUS_BLOCK*); +PIRP WINAPI IoBuildSynchronousFsdRequest(ULONG,DEVICE_OBJECT*,PVOID,ULONG,PLARGE_INTEGER,PKEVENT,IO_STATUS_BLOCK*); NTSTATUS WINAPI IoCallDriver(DEVICE_OBJECT*,IRP*); VOID WINAPI IoCompleteRequest(IRP*,UCHAR); NTSTATUS WINAPI IoCreateDevice(DRIVER_OBJECT*,ULONG,UNICODE_STRING*,DEVICE_TYPE,ULONG,BOOLEAN,DEVICE_OBJECT**);

1 0

Alexandre Julliard : ntoskrnl: Add support for read and write requests.
by Alexandre Julliard 06 May '15

06 May '15

Module: wine Branch: master Commit: 2cd717a604ace11de820d85211ea1e5143c21fa9 URL: http://source.winehq.org/git/wine.git/?a=commit;h=2cd717a604ace11de820d8521… Author: Alexandre Julliard <julliard(a)winehq.org> Date: Tue May 5 14:24:00 2015 +0900 ntoskrnl: Add support for read and write requests. --- dlls/ntoskrnl.exe/ntoskrnl.c | 159 ++++++++++++++++++++++++++++++++++--------- 1 file changed, 125 insertions(+), 34 deletions(-) diff --git a/dlls/ntoskrnl.exe/ntoskrnl.c b/dlls/ntoskrnl.exe/ntoskrnl.c index f8e1f18..de99970 100644 --- a/dlls/ntoskrnl.exe/ntoskrnl.c +++ b/dlls/ntoskrnl.exe/ntoskrnl.c @@ -128,26 +128,96 @@ static HANDLE get_device_manager(void) return ret; } -/* process an ioctl request for a given device */ -static NTSTATUS process_ioctl( DEVICE_OBJECT *device, ULONG code, void *in_buff, - ULONG in_size, ULONG out_size, HANDLE ioctl ) +static NTSTATUS dispatch_irp( DEVICE_OBJECT *device, IRP *irp ) { - IRP *irp; - void *out_buff = NULL; - FILE_OBJECT file; LARGE_INTEGER count; + FILE_OBJECT file; - TRACE( "ioctl %x device %p in_size %u out_size %u\n", code, device, in_size, out_size ); + irp->RequestorMode = UserMode; + irp->Tail.Overlay.OriginalFileObject = &file; - /* so we can spot things that we should initialize */ memset( &file, 0x88, sizeof(file) ); + file.FsContext = NULL; + file.FsContext2 = NULL; + + KeQueryTickCount( &count ); /* update the global KeTickCount */ + + device->CurrentIrp = irp; + + IoCallDriver( device, irp ); + + device->CurrentIrp = NULL; + + return STATUS_SUCCESS; +} + +/* process a read request for a given device */ +static NTSTATUS dispatch_read( DEVICE_OBJECT *device, const irp_params_t *params, + void *in_buff, ULONG in_size, ULONG out_size, HANDLE irp_handle ) +{ + IRP *irp; + void *out_buff; + LARGE_INTEGER offset; + IO_STACK_LOCATION *irpsp; + + TRACE( "device %p size %u\n", device, out_size ); + + if (!(out_buff = HeapAlloc( GetProcessHeap(), 0, out_size ))) return STATUS_NO_MEMORY; + + offset.QuadPart = params->read.pos; - if ((code & 3) == METHOD_BUFFERED) out_size = max( in_size, out_size ); + /* note: we abuse UserIosb to store the server irp handle */ + if (!(irp = IoBuildSynchronousFsdRequest( IRP_MJ_READ, device, out_buff, out_size, + &offset, NULL, irp_handle ))) + { + HeapFree( GetProcessHeap(), 0, out_buff ); + return STATUS_NO_MEMORY; + } + + irpsp = IoGetNextIrpStackLocation( irp ); + irpsp->Parameters.Read.Key = params->read.key; + + return dispatch_irp( device, irp ); +} + +/* process a write request for a given device */ +static NTSTATUS dispatch_write( DEVICE_OBJECT *device, const irp_params_t *params, + void *in_buff, ULONG in_size, ULONG out_size, HANDLE irp_handle ) +{ + IRP *irp; + LARGE_INTEGER offset; + IO_STACK_LOCATION *irpsp; + + TRACE( "device %p size %u\n", device, in_size ); + + offset.QuadPart = params->write.pos; + + /* note: we abuse UserIosb to store the server irp handle */ + if (!(irp = IoBuildSynchronousFsdRequest( IRP_MJ_WRITE, device, in_buff, in_size, + &offset, NULL, irp_handle ))) + return STATUS_NO_MEMORY; + + irpsp = IoGetNextIrpStackLocation( irp ); + irpsp->Parameters.Write.Key = params->write.key; + + return dispatch_irp( device, irp ); +} + +/* process an ioctl request for a given device */ +static NTSTATUS dispatch_ioctl( DEVICE_OBJECT *device, const irp_params_t *params, + void *in_buff, ULONG in_size, ULONG out_size, HANDLE irp_handle ) +{ + IRP *irp; + void *out_buff = NULL; + + TRACE( "ioctl %x device %p in_size %u out_size %u\n", params->ioctl.code, device, in_size, out_size ); + + if ((params->ioctl.code & 3) == METHOD_BUFFERED) out_size = max( in_size, out_size ); if (out_size) { if (!(out_buff = HeapAlloc( GetProcessHeap(), 0, out_size ))) return STATUS_NO_MEMORY; - if ((code & 3) == METHOD_BUFFERED) + if ((params->ioctl.code & 3) == METHOD_BUFFERED) { memcpy( out_buff, in_buff, in_size ); in_buff = out_buff; @@ -155,29 +225,50 @@ static NTSTATUS process_ioctl( DEVICE_OBJECT *device, ULONG code, void *in_buff, } /* note: we abuse UserIosb to store the server handle to the ioctl */ - irp = IoBuildDeviceIoControlRequest( code, device, in_buff, in_size, out_buff, out_size, - FALSE, NULL, (IO_STATUS_BLOCK *)ioctl ); + irp = IoBuildDeviceIoControlRequest( params->ioctl.code, device, in_buff, in_size, out_buff, out_size, + FALSE, NULL, irp_handle ); if (!irp) { HeapFree( GetProcessHeap(), 0, out_buff ); return STATUS_NO_MEMORY; } - irp->RequestorMode = UserMode; - irp->Tail.Overlay.OriginalFileObject = &file; - - file.FsContext = NULL; - file.FsContext2 = NULL; - - KeQueryTickCount( &count ); /* update the global KeTickCount */ - - device->CurrentIrp = irp; - - IoCallDriver( device, irp ); - - device->CurrentIrp = NULL; - - return STATUS_SUCCESS; -} + return dispatch_irp( device, irp ); +} + +typedef NTSTATUS (*dispatch_func)( DEVICE_OBJECT *device, const irp_params_t *params, + void *in_buff, ULONG in_size, ULONG out_size, HANDLE irp_handle ); + +static const dispatch_func dispatch_funcs[IRP_MJ_MAXIMUM_FUNCTION + 1] = +{ + NULL, /* IRP_MJ_CREATE */ + NULL, /* IRP_MJ_CREATE_NAMED_PIPE */ + NULL, /* IRP_MJ_CLOSE */ + dispatch_read, /* IRP_MJ_READ */ + dispatch_write, /* IRP_MJ_WRITE */ + NULL, /* IRP_MJ_QUERY_INFORMATION */ + NULL, /* IRP_MJ_SET_INFORMATION */ + NULL, /* IRP_MJ_QUERY_EA */ + NULL, /* IRP_MJ_SET_EA */ + NULL, /* IRP_MJ_FLUSH_BUFFERS */ + NULL, /* IRP_MJ_QUERY_VOLUME_INFORMATION */ + NULL, /* IRP_MJ_SET_VOLUME_INFORMATION */ + NULL, /* IRP_MJ_DIRECTORY_CONTROL */ + NULL, /* IRP_MJ_FILE_SYSTEM_CONTROL */ + dispatch_ioctl, /* IRP_MJ_DEVICE_CONTROL */ + NULL, /* IRP_MJ_INTERNAL_DEVICE_CONTROL */ + NULL, /* IRP_MJ_SHUTDOWN */ + NULL, /* IRP_MJ_LOCK_CONTROL */ + NULL, /* IRP_MJ_CLEANUP */ + NULL, /* IRP_MJ_CREATE_MAILSLOT */ + NULL, /* IRP_MJ_QUERY_SECURITY */ + NULL, /* IRP_MJ_SET_SECURITY */ + NULL, /* IRP_MJ_POWER */ + NULL, /* IRP_MJ_SYSTEM_CONTROL */ + NULL, /* IRP_MJ_DEVICE_CHANGE */ + NULL, /* IRP_MJ_QUERY_QUOTA */ + NULL, /* IRP_MJ_SET_QUOTA */ + NULL, /* IRP_MJ_PNP */ +}; /*********************************************************************** @@ -235,16 +326,16 @@ NTSTATUS CDECL wine_ntoskrnl_main_loop( HANDLE stop_event ) switch(status) { case STATUS_SUCCESS: - switch (irp_params.major) + if (irp_params.major > IRP_MJ_MAXIMUM_FUNCTION || + !dispatch_funcs[irp_params.major] || + !device->DriverObject->MajorFunction[irp_params.major]) { - case IRP_MJ_DEVICE_CONTROL: - status = process_ioctl( device, irp_params.ioctl.code, in_buff, in_size, out_size, irp ); - break; - default: - FIXME( "unsupported request %u\n", irp_params.major ); + WARN( "unsupported request %u\n", irp_params.major ); status = STATUS_NOT_SUPPORTED; break; } + status = dispatch_funcs[irp_params.major]( device, &irp_params, + in_buff, in_size, out_size, irp ); if (status == STATUS_SUCCESS) irp = 0; /* status reported by IoCompleteRequest */ break; case STATUS_BUFFER_OVERFLOW:

1 0

Alexandre Julliard : ntoskrnl: Add support for flush requests.
by Alexandre Julliard 06 May '15

06 May '15

Module: wine Branch: master Commit: a38aaf4365ac37de5112821bc90e84684b842919 URL: http://source.winehq.org/git/wine.git/?a=commit;h=a38aaf4365ac37de5112821bc… Author: Alexandre Julliard <julliard(a)winehq.org> Date: Wed May 6 17:14:31 2015 +0900 ntoskrnl: Add support for flush requests. --- dlls/ntoskrnl.exe/ntoskrnl.c | 18 +++++++++++++++++- 1 file changed, 17 insertions(+), 1 deletion(-) diff --git a/dlls/ntoskrnl.exe/ntoskrnl.c b/dlls/ntoskrnl.exe/ntoskrnl.c index de99970..2051939 100644 --- a/dlls/ntoskrnl.exe/ntoskrnl.c +++ b/dlls/ntoskrnl.exe/ntoskrnl.c @@ -203,6 +203,22 @@ static NTSTATUS dispatch_write( DEVICE_OBJECT *device, const irp_params_t *param return dispatch_irp( device, irp ); } +/* process a flush request for a given device */ +static NTSTATUS dispatch_flush( DEVICE_OBJECT *device, const irp_params_t *params, + void *in_buff, ULONG in_size, ULONG out_size, HANDLE irp_handle ) +{ + IRP *irp; + + TRACE( "device %p\n", device ); + + /* note: we abuse UserIosb to store the server irp handle */ + if (!(irp = IoBuildSynchronousFsdRequest( IRP_MJ_FLUSH_BUFFERS, device, in_buff, in_size, + NULL, NULL, irp_handle ))) + return STATUS_NO_MEMORY; + + return dispatch_irp( device, irp ); +} + /* process an ioctl request for a given device */ static NTSTATUS dispatch_ioctl( DEVICE_OBJECT *device, const irp_params_t *params, void *in_buff, ULONG in_size, ULONG out_size, HANDLE irp_handle ) @@ -249,7 +265,7 @@ static const dispatch_func dispatch_funcs[IRP_MJ_MAXIMUM_FUNCTION + 1] = NULL, /* IRP_MJ_SET_INFORMATION */ NULL, /* IRP_MJ_QUERY_EA */ NULL, /* IRP_MJ_SET_EA */ - NULL, /* IRP_MJ_FLUSH_BUFFERS */ + dispatch_flush, /* IRP_MJ_FLUSH_BUFFERS */ NULL, /* IRP_MJ_QUERY_VOLUME_INFORMATION */ NULL, /* IRP_MJ_SET_VOLUME_INFORMATION */ NULL, /* IRP_MJ_DIRECTORY_CONTROL */

1 0

Nikolay Sivov : shell32: Implement Application property of IShellFolderViewDual.
by Alexandre Julliard 06 May '15

06 May '15

Module: wine Branch: master Commit: ce87d64ab4414e5786c6d05a1001a0a312c1284e URL: http://source.winehq.org/git/wine.git/?a=commit;h=ce87d64ab4414e5786c6d05a1… Author: Nikolay Sivov <nsivov(a)codeweavers.com> Date: Wed May 6 08:35:47 2015 +0300 shell32: Implement Application property of IShellFolderViewDual. --- dlls/shell32/shlview.c | 9 +++- dlls/shell32/tests/shelldispatch.c | 87 ++++++++++++++++++++++++++------------ include/shldisp.idl | 18 +++++--- 3 files changed, 78 insertions(+), 36 deletions(-) diff --git a/dlls/shell32/shlview.c b/dlls/shell32/shlview.c index 8352157..6ddb937 100644 --- a/dlls/shell32/shlview.c +++ b/dlls/shell32/shlview.c @@ -3518,8 +3518,13 @@ static HRESULT WINAPI shellfolderviewdual_get_Application(IShellFolderViewDual3 IDispatch **disp) { IShellViewImpl *This = impl_from_IShellFolderViewDual3(iface); - FIXME("%p %p\n", This, disp); - return E_NOTIMPL; + + TRACE("%p %p\n", This, disp); + + if (!disp) + return E_INVALIDARG; + + return IShellDispatch_Constructor(NULL, &IID_IDispatch, (void**)disp); } static HRESULT WINAPI shellfolderviewdual_get_Parent(IShellFolderViewDual3 *iface, IDispatch **disp) diff --git a/dlls/shell32/tests/shelldispatch.c b/dlls/shell32/tests/shelldispatch.c index b7773ad..f034132 100644 --- a/dlls/shell32/tests/shelldispatch.c +++ b/dlls/shell32/tests/shelldispatch.c @@ -364,8 +364,42 @@ static void test_service(void) IShellDispatch2_Release(sd); } +static void test_dispatch_typeinfo(IDispatch *disp, REFIID *riid) +{ + ITypeInfo *typeinfo; + TYPEATTR *typeattr; + UINT count; + HRESULT hr; + + count = 10; + hr = IDispatch_GetTypeInfoCount(disp, &count); + ok(hr == S_OK, "got 0x%08x\n", hr); + ok(count == 1, "got %u\n", count); + + hr = IDispatch_GetTypeInfo(disp, 0, LOCALE_SYSTEM_DEFAULT, &typeinfo); + ok(hr == S_OK, "got 0x%08x\n", hr); + + hr = ITypeInfo_GetTypeAttr(typeinfo, &typeattr); + ok(hr == S_OK, "got 0x%08x\n", hr); + while (!IsEqualGUID(*riid, &IID_NULL)) { + if (IsEqualGUID(&typeattr->guid, *riid)) + break; + riid++; + } + ok(IsEqualGUID(&typeattr->guid, *riid), "unexpected type guid %s\n", wine_dbgstr_guid(&typeattr->guid)); + + ITypeInfo_ReleaseTypeAttr(typeinfo, typeattr); + ITypeInfo_Release(typeinfo); +} + static void test_ShellFolderViewDual(void) { + static const REFIID shelldisp_riids[] = { + &IID_IShellDispatch6, + &IID_IShellDispatch5, + &IID_IShellDispatch4, + &IID_NULL + }; IShellFolderViewDual *viewdual; IShellFolder *desktop, *tmpdir; IShellView *view, *view2; @@ -399,6 +433,18 @@ static void test_ShellFolderViewDual(void) hr = IShellFolderViewDual_QueryInterface(viewdual, &IID_IShellView, (void**)&view2); ok(hr == E_NOINTERFACE, "got 0x%08x\n", hr); + /* get_Application() */ + +if (0) /* crashes on pre-vista */ { + hr = IShellFolderViewDual_get_Application(viewdual, NULL); + ok(hr == E_INVALIDARG, "got 0x%08x\n", hr); +} + hr = IShellFolderViewDual_get_Application(viewdual, &disp2); + ok(hr == S_OK, "got 0x%08x\n", hr); + ok(disp2 != (IDispatch*)viewdual, "got %p, %p\n", disp2, viewdual); + test_dispatch_typeinfo(disp2, shelldisp_riids); + IDispatch_Release(disp2); + IShellFolderViewDual_Release(viewdual); IDispatch_Release(disp); @@ -510,35 +556,29 @@ todo_wine { ok(ret == 0, "got %d\n", ret); } else { + static const REFIID browser_riids[] = { + &IID_IWebBrowser2, + &IID_NULL + }; + + static const REFIID viewdual_riids[] = { + &IID_IShellFolderViewDual3, + &IID_NULL + }; + IShellFolderViewDual *view; IShellBrowser *sb, *sb2; IServiceProvider *sp; IDispatch *doc, *app; - ITypeInfo *typeinfo; - TYPEATTR *typeattr; IWebBrowser2 *wb; IShellView *sv; IUnknown *unk; - UINT count; ok(disp != NULL, "got %p\n", disp); ok(ret != HandleToUlong(hwnd), "got %d\n", ret); /* IDispatch-related tests */ - count = 10; - hr = IDispatch_GetTypeInfoCount(disp, &count); - ok(hr == S_OK, "got 0x%08x\n", hr); - ok(count == 1, "got %u\n", count); - - hr = IDispatch_GetTypeInfo(disp, 0, LOCALE_SYSTEM_DEFAULT, &typeinfo); - ok(hr == S_OK, "got 0x%08x\n", hr); - - hr = ITypeInfo_GetTypeAttr(typeinfo, &typeattr); - ok(hr == S_OK, "got 0x%08x\n", hr); - ok(IsEqualGUID(&typeattr->guid, &IID_IWebBrowser2), "type guid %s\n", wine_dbgstr_guid(&typeattr->guid)); - - ITypeInfo_ReleaseTypeAttr(typeinfo, typeattr); - ITypeInfo_Release(typeinfo); + test_dispatch_typeinfo(disp, browser_riids); /* IWebBrowser2 */ hr = IDispatch_QueryInterface(disp, &IID_IWebBrowser2, (void**)&wb); @@ -556,18 +596,9 @@ todo_wine hr = IWebBrowser2_get_Document(wb, &doc); todo_wine ok(hr == S_OK, "got 0x%08x\n", hr); -if (hr == S_OK) { - hr = IDispatch_GetTypeInfo(doc, 0, LOCALE_SYSTEM_DEFAULT, &typeinfo); - ok(hr == S_OK, "got 0x%08x\n", hr); +if (hr == S_OK) + test_dispatch_typeinfo(doc, viewdual_riids); - hr = ITypeInfo_GetTypeAttr(typeinfo, &typeattr); - ok(hr == S_OK, "got 0x%08x\n", hr); - ok(IsEqualGUID(&typeattr->guid, &IID_IShellFolderViewDual3), "type guid %s\n", wine_dbgstr_guid(&typeattr->guid)); - IDispatch_Release(doc); - - ITypeInfo_ReleaseTypeAttr(typeinfo, typeattr); - ITypeInfo_Release(typeinfo); -} IWebBrowser2_Release(wb); /* IServiceProvider */ diff --git a/include/shldisp.idl b/include/shldisp.idl index 506c5d2..56be778 100644 --- a/include/shldisp.idl +++ b/include/shldisp.idl @@ -403,7 +403,6 @@ interface FolderItemVerbs : IDispatch * IShellDispatch interface */ [ - object, uuid(d8f015c0-c278-11ce-a49e-444553540000), oleautomation, hidden, @@ -465,7 +464,6 @@ interface IShellDispatch : IDispatch } [ - object, uuid(a4c6892c-3ba9-11d2-9dea-00c04fb16162), oleautomation, hidden, @@ -486,7 +484,6 @@ interface IShellDispatch2 : IShellDispatch } [ - object, uuid(177160ca-bb5a-411c-841d-bd38facdeaa0), oleautomation, hidden, @@ -498,7 +495,6 @@ interface IShellDispatch3 : IShellDispatch2 } [ - object, uuid(efd84b2d-4bcf-4298-be25-eb542a59fbda), oleautomation, hidden, @@ -513,7 +509,6 @@ interface IShellDispatch4 : IShellDispatch3 } [ - object, uuid(866738b9-6cf2-4de8-8767-f794ebe74f4e), oleautomation, hidden, @@ -525,11 +520,22 @@ interface IShellDispatch5 : IShellDispatch4 } [ + uuid(286e6f1b-7113-4355-9562-96b7e9d64c54), + oleautomation, + hidden, + dual, +] +interface IShellDispatch6 : IShellDispatch5 +{ + HRESULT SearchCommand(void); +} + +[ uuid(13709620-c279-11ce-a49e-444553540000) ] coclass Shell { - [default] interface IShellDispatch2; + [default] interface IShellDispatch6; } [

1 0

Nikolay Sivov : shell32: Update to IShellDispatch6.
by Alexandre Julliard 06 May '15

06 May '15

Module: wine Branch: master Commit: c2ecf3b0bf1c906f20ae5dd6e6a80a1a5b42b866 URL: http://source.winehq.org/git/wine.git/?a=commit;h=c2ecf3b0bf1c906f20ae5dd6e… Author: Nikolay Sivov <nsivov(a)codeweavers.com> Date: Wed May 6 08:38:53 2015 +0300 shell32: Update to IShellDispatch6. --- dlls/shell32/shelldispatch.c | 142 +++++++++++++++++++++++-------------------- 1 file changed, 75 insertions(+), 67 deletions(-) Diff: http://source.winehq.org/git/wine.git/?a=commitdiff;h=c2ecf3b0bf1c906f20ae5…

1 0