server/console.c

   1 /*
   2  * Server-side console management
   3  *
   4  * Copyright (C) 1998 Alexandre Julliard
   5  *
   6  * FIXME: all this stuff is a hack to avoid breaking
   7  *        the client-side console support.
   8  */
   9
  10 #include <assert.h>
  11 #include <fcntl.h>
  12 #include <string.h>
  13 #include <stdio.h>
  14 #include <stdlib.h>
  15 #include <sys/errno.h>
  16 #include <sys/stat.h>
  17 #include <sys/time.h>
  18 #include <sys/types.h>
  19 #include <time.h>
  20 #include <unistd.h>
  21
  22 #include "winerror.h"
  23 #include "winnt.h"
  24 #include "server/thread.h"
  25
  26 struct console
  27 {
  28     struct object  obj;             /* object header */
  29     int            fd;              /* Unix file descriptor */
  30     int            is_read;         /* is this the read or write part? */
  31 };
  32
  33 static void console_dump( struct object *obj, int verbose );
  34 static int console_add_queue( struct object *obj, struct wait_queue_entry *entry );
  35 static void console_remove_queue( struct object *obj, struct wait_queue_entry *entry );
  36 static int console_signaled( struct object *obj, struct thread *thread );
  37 static int console_get_read_fd( struct object *obj );
  38 static int console_get_write_fd( struct object *obj );
  39 static int console_get_info( struct object *obj, struct get_file_info_reply *reply );
  40 static void console_destroy( struct object *obj );
  41
  42 static const struct object_ops console_ops =
  43 {
  44     console_dump,
  45     console_add_queue,
  46     console_remove_queue,
  47     console_signaled,
  48     no_satisfied,
  49     console_get_read_fd,
  50     console_get_write_fd,
  51     no_flush,
  52     console_get_info,
  53     console_destroy
  54 };
  55
  56 static const struct select_ops select_ops =
  57 {
  58     default_select_event,
  59     NULL   /* we never set a timeout on a console */
  60 };
  61
  62 int create_console( int fd, struct object *obj[2] )
  63 {
  64     struct console *console_read, *console_write;
  65     int read_fd, write_fd;
  66
  67     if ((read_fd = (fd != -1) ? dup(fd) : dup(0)) == -1)
  68     {
  69         file_set_error();
  70         return 0;
  71     }
  72     if ((write_fd = (fd != -1) ? dup(fd) : dup(0)) == -1)
  73     {
  74         file_set_error();
  75         close( read_fd );
  76         return 0;
  77     }
  78     if (!(console_read = mem_alloc( sizeof(struct console) )))
  79     {
  80         close( read_fd );
  81         close( write_fd );
  82         return 0;
  83     }
  84     if (!(console_write = mem_alloc( sizeof(struct console) )))
  85     {
  86         close( read_fd );
  87         close( write_fd );
  88         free( console_read );
  89         return 0;
  90     }
  91     init_object( &console_read->obj, &console_ops, NULL );
  92     init_object( &console_write->obj, &console_ops, NULL );
  93     console_read->fd       = read_fd;
  94     console_read->is_read  = 1;
  95     console_write->fd      = write_fd;
  96     console_write->is_read = 0;
  97     CLEAR_ERROR();
  98     obj[0] = &console_read->obj;
  99     obj[1] = &console_write->obj;
 100     return 1;
 101 }
 102
 103 int set_console_fd( int handle, int fd )
 104 {
 105     struct console *console;
 106
 107     if (!(console = (struct console *)get_handle_obj( current->process, handle,
 108                                                       0, &console_ops )))
 109         return 0;
 110     if ((fd = dup(fd)) == -1)
 111     {
 112         file_set_error();
 113         release_object( console );
 114         return 0;
 115     }
 116     close( console->fd );
 117     console->fd = fd;
 118     release_object( console );
 119     return 1;
 120 }
 121
 122 static void console_dump( struct object *obj, int verbose )
 123 {
 124     struct console *console = (struct console *)obj;
 125     assert( obj->ops == &console_ops );
 126     fprintf( stderr, "Console %s fd=%d\n",
 127              console->is_read ? "input" : "output", console->fd );
 128 }
 129
 130 static int console_add_queue( struct object *obj, struct wait_queue_entry *entry )
 131 {
 132     struct console *console = (struct console *)obj;
 133     assert( obj->ops == &console_ops );
 134     if (!obj->head)  /* first on the queue */
 135     {
 136         if (!add_select_user( console->fd,
 137                               console->is_read ? READ_EVENT : WRITE_EVENT,
 138                               &select_ops, console ))
 139         {
 140             SET_ERROR( ERROR_OUTOFMEMORY );
 141             return 0;
 142         }
 143     }
 144     add_queue( obj, entry );
 145     return 1;
 146 }
 147
 148 static void console_remove_queue( struct object *obj, struct wait_queue_entry *entry )
 149 {
 150     struct console *console = (struct console *)grab_object(obj);
 151     assert( obj->ops == &console_ops );
 152
 153     remove_queue( obj, entry );
 154     if (!obj->head)  /* last on the queue is gone */
 155         remove_select_user( console->fd );
 156     release_object( obj );
 157 }
 158
 159 static int console_signaled( struct object *obj, struct thread *thread )
 160 {
 161     fd_set fds;
 162     struct timeval tv = { 0, 0 };
 163     struct console *console = (struct console *)obj;
 164     assert( obj->ops == &console_ops );
 165
 166     FD_ZERO( &fds );
 167     FD_SET( console->fd, &fds );
 168     if (console->is_read)
 169         return select( console->fd + 1, &fds, NULL, NULL, &tv ) > 0;
 170     else
 171         return select( console->fd + 1, NULL, &fds, NULL, &tv ) > 0;
 172 }
 173
 174 static int console_get_read_fd( struct object *obj )
 175 {
 176     struct console *console = (struct console *)obj;
 177     assert( obj->ops == &console_ops );
 178
 179     if (!console->is_read)
 180     {
 181         SET_ERROR( ERROR_ACCESS_DENIED );
 182         return -1;
 183     }
 184     return dup( console->fd );
 185 }
 186
 187 static int console_get_write_fd( struct object *obj )
 188 {
 189     struct console *console = (struct console *)obj;
 190     assert( obj->ops == &console_ops );
 191
 192     if (console->is_read)
 193     {
 194         SET_ERROR( ERROR_ACCESS_DENIED );
 195         return -1;
 196     }
 197     return dup( console->fd );
 198 }
 199
 200 static int console_get_info( struct object *obj, struct get_file_info_reply *reply )
 201 {
 202     memset( reply, 0, sizeof(*reply) );
 203     reply->type = FILE_TYPE_CHAR;
 204     return 1;
 205 }
 206
 207 static void console_destroy( struct object *obj )
 208 {
 209     struct console *console = (struct console *)obj;
 210     assert( obj->ops == &console_ops );
 211     close( console->fd );
 212     free( console );
 213 }