mirror of
https://github.com/reactos/wine.git
synced 2025-02-21 13:23:25 +00:00
62a8b43301
Added user APCs support. Many changes to the xterm console to make use of the server (not finished yet). Moved some other small stuff to the server.
80 lines
3.0 KiB
C
80 lines
3.0 KiB
C
/*
|
|
* Wine server threads
|
|
*
|
|
* Copyright (C) 1998 Alexandre Julliard
|
|
*/
|
|
|
|
#ifndef __WINE_SERVER_THREAD_H
|
|
#define __WINE_SERVER_THREAD_H
|
|
|
|
#ifndef __WINE_SERVER__
|
|
#error This file can only be used in the Wine server
|
|
#endif
|
|
|
|
#include "server/object.h"
|
|
|
|
/* thread structure */
|
|
|
|
struct process;
|
|
struct thread_wait;
|
|
struct thread_apc;
|
|
struct mutex;
|
|
|
|
enum run_state { STARTING, RUNNING, TERMINATED };
|
|
|
|
struct thread
|
|
{
|
|
struct object obj; /* object header */
|
|
struct thread *next; /* system-wide thread list */
|
|
struct thread *prev;
|
|
struct thread *proc_next; /* per-process thread list */
|
|
struct thread *proc_prev;
|
|
struct process *process;
|
|
struct mutex *mutex; /* list of currently owned mutexes */
|
|
struct thread_wait *wait; /* current wait condition if sleeping */
|
|
struct thread_apc *apc; /* list of async procedure calls */
|
|
int apc_count; /* number of outstanding APCs */
|
|
int error; /* current error code */
|
|
enum run_state state; /* running state */
|
|
int exit_code; /* thread exit code */
|
|
int client_fd; /* client fd for socket communications */
|
|
int unix_pid; /* Unix pid of client */
|
|
int priority; /* priority level */
|
|
int affinity; /* affinity mask */
|
|
int suspend; /* suspend count */
|
|
enum request last_req; /* last request received (for debugging) */
|
|
char *name;
|
|
};
|
|
|
|
extern struct thread *current;
|
|
|
|
/* thread functions */
|
|
|
|
extern struct thread *create_thread( int fd, void *pid, int *thread_handle,
|
|
int *process_handle );
|
|
extern struct thread *get_thread_from_id( void *id );
|
|
extern struct thread *get_thread_from_handle( int handle, unsigned int access );
|
|
extern void get_thread_info( struct thread *thread,
|
|
struct get_thread_info_reply *reply );
|
|
extern void set_thread_info( struct thread *thread,
|
|
struct set_thread_info_request *req );
|
|
extern int suspend_thread( struct thread *thread );
|
|
extern int resume_thread( struct thread *thread );
|
|
extern int send_reply( struct thread *thread, int pass_fd,
|
|
int n, ... /* arg_1, len_1, ..., arg_n, len_n */ );
|
|
extern int add_queue( struct object *obj, struct wait_queue_entry *entry );
|
|
extern void remove_queue( struct object *obj, struct wait_queue_entry *entry );
|
|
extern int thread_queue_apc( struct thread *thread, void *func, void *param );
|
|
extern void kill_thread( struct thread *thread, int exit_code );
|
|
extern void thread_killed( struct thread *thread, int exit_code );
|
|
extern void thread_timeout(void);
|
|
extern void sleep_on( struct thread *thread, int count, int *handles,
|
|
int flags, int timeout );
|
|
extern void wake_up( struct object *obj, int max );
|
|
|
|
#define GET_ERROR() (current->error)
|
|
#define SET_ERROR(err) (current->error = (err))
|
|
#define CLEAR_ERROR() (current->error = 0)
|
|
|
|
#endif /* __WINE_SERVER_THREAD_H */
|