2 * Server-side serial port communications management
4 * Copyright (C) 1998 Alexandre Julliard
5 * Copyright (C) 2000,2001 Mike McCormack
8 * This library is free software; you can redistribute it and/or
9 * modify it under the terms of the GNU Lesser General Public
10 * License as published by the Free Software Foundation; either
11 * version 2.1 of the License, or (at your option) any later version.
13 * This library is distributed in the hope that it will be useful,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16 * Lesser General Public License for more details.
18 * You should have received a copy of the GNU Lesser General Public
19 * License along with this library; if not, write to the Free Software
20 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
24 #include "wine/port.h"
33 #include <sys/types.h>
42 #ifdef HAVE_SYS_IOCTL_H
43 #include <sys/ioctl.h>
50 #define WIN32_NO_STATUS
59 static void serial_dump( struct object *obj, int verbose );
60 static struct fd *serial_get_fd( struct object *obj );
61 static unsigned int serial_map_access( struct object *obj, unsigned int access );
62 static void serial_destroy(struct object *obj);
64 static enum server_fd_type serial_get_info( struct fd *fd, int *flags );
65 static void serial_flush( struct fd *fd, struct event **event );
66 static void serial_queue_async( struct fd *fd, const async_data_t *data, int type, int count );
75 unsigned int readinterval;
76 unsigned int readconst;
77 unsigned int readmult;
78 unsigned int writeconst;
79 unsigned int writemult;
81 unsigned int eventmask;
83 struct termios original;
85 /* FIXME: add dcb, comm status, handler module, sharing */
88 static const struct object_ops serial_ops =
90 sizeof(struct serial), /* size */
91 serial_dump, /* dump */
92 add_queue, /* add_queue */
93 remove_queue, /* remove_queue */
94 default_fd_signaled, /* signaled */
95 no_satisfied, /* satisfied */
96 no_signal, /* signal */
97 serial_get_fd, /* get_fd */
98 serial_map_access, /* map_access */
99 no_lookup_name, /* lookup_name */
100 no_open_file, /* open_file */
101 fd_close_handle, /* close_handle */
102 serial_destroy /* destroy */
105 static const struct fd_ops serial_fd_ops =
107 default_fd_get_poll_events, /* get_poll_events */
108 default_poll_event, /* poll_event */
109 serial_flush, /* flush */
110 serial_get_info, /* get_file_info */
111 serial_queue_async, /* queue_async */
112 default_fd_reselect_async, /* reselect_async */
113 default_fd_cancel_async /* cancel_async */
116 /* check if the given fd is a serial port */
117 int is_serial_fd( struct fd *fd )
121 return !tcgetattr( get_unix_fd(fd), &tios );
124 /* create a serial object for a given fd */
125 struct object *create_serial( struct fd *fd, unsigned int options )
127 struct serial *serial;
128 int unix_fd = get_unix_fd( fd );
130 /* set the fd back to blocking if necessary */
131 if (options & (FILE_SYNCHRONOUS_IO_ALERT | FILE_SYNCHRONOUS_IO_NONALERT))
132 fcntl( unix_fd, F_SETFL, 0 );
134 if (!(serial = alloc_object( &serial_ops ))) return NULL;
136 serial->options = options;
137 serial->readinterval = 0;
138 serial->readmult = 0;
139 serial->readconst = 0;
140 serial->writemult = 0;
141 serial->writeconst = 0;
142 serial->eventmask = 0;
143 serial->fd = (struct fd *)grab_object( fd );
144 set_fd_user( fd, &serial_fd_ops, &serial->obj );
148 static struct fd *serial_get_fd( struct object *obj )
150 struct serial *serial = (struct serial *)obj;
151 return (struct fd *)grab_object( serial->fd );
154 static unsigned int serial_map_access( struct object *obj, unsigned int access )
156 if (access & GENERIC_READ) access |= FILE_GENERIC_READ;
157 if (access & GENERIC_WRITE) access |= FILE_GENERIC_WRITE;
158 if (access & GENERIC_EXECUTE) access |= FILE_GENERIC_EXECUTE;
159 if (access & GENERIC_ALL) access |= FILE_ALL_ACCESS;
160 return access & ~(GENERIC_READ | GENERIC_WRITE | GENERIC_EXECUTE | GENERIC_ALL);
163 static void serial_destroy( struct object *obj)
165 struct serial *serial = (struct serial *)obj;
166 release_object( serial->fd );
169 static void serial_dump( struct object *obj, int verbose )
171 struct serial *serial = (struct serial *)obj;
172 assert( obj->ops == &serial_ops );
173 fprintf( stderr, "Port fd=%p mask=%x\n", serial->fd, serial->eventmask );
176 static struct serial *get_serial_obj( struct process *process, obj_handle_t handle, unsigned int access )
178 return (struct serial *)get_handle_obj( process, handle, access, &serial_ops );
181 static enum server_fd_type serial_get_info( struct fd *fd, int *flags )
183 struct serial *serial = get_fd_user( fd );
184 assert( serial->obj.ops == &serial_ops );
187 if (!(serial->options & (FILE_SYNCHRONOUS_IO_ALERT | FILE_SYNCHRONOUS_IO_NONALERT)))
188 *flags |= FD_FLAG_OVERLAPPED;
189 else if (!(serial->readinterval == MAXDWORD &&
190 serial->readmult == 0 && serial->readconst == 0))
191 *flags |= FD_FLAG_TIMEOUT;
192 if (serial->readinterval == MAXDWORD &&
193 serial->readmult == 0 && serial->readconst == 0)
194 *flags |= FD_FLAG_AVAILABLE;
196 return FD_TYPE_SERIAL;
199 static void serial_queue_async( struct fd *fd, const async_data_t *data, int type, int count )
201 struct serial *serial = get_fd_user( fd );
205 assert(serial->obj.ops == &serial_ops);
209 case ASYNC_TYPE_READ:
210 timeout = serial->readconst + serial->readmult*count;
212 case ASYNC_TYPE_WRITE:
213 timeout = serial->writeconst + serial->writemult*count;
217 if ((async = fd_queue_async( fd, data, type, count )))
221 struct timeval when = current_time;
222 add_timeout( &when, timeout );
223 async_set_timeout( async, &when, STATUS_TIMEOUT );
225 release_object( async );
226 set_error( STATUS_PENDING );
230 static void serial_flush( struct fd *fd, struct event **event )
232 /* MSDN says: If hFile is a handle to a communications device,
233 * the function only flushes the transmit buffer.
235 if (tcflush( get_unix_fd(fd), TCOFLUSH ) == -1) file_set_error();
238 DECL_HANDLER(get_serial_info)
240 struct serial *serial;
242 if ((serial = get_serial_obj( current->process, req->handle, 0 )))
245 reply->readinterval = serial->readinterval;
246 reply->readconst = serial->readconst;
247 reply->readmult = serial->readmult;
248 reply->writeconst = serial->writeconst;
249 reply->writemult = serial->writemult;
252 reply->eventmask = serial->eventmask;
254 release_object( serial );
258 DECL_HANDLER(set_serial_info)
260 struct serial *serial;
262 if ((serial = get_serial_obj( current->process, req->handle, 0 )))
265 if (req->flags & SERIALINFO_SET_TIMEOUTS)
267 serial->readinterval = req->readinterval;
268 serial->readconst = req->readconst;
269 serial->readmult = req->readmult;
270 serial->writeconst = req->writeconst;
271 serial->writemult = req->writemult;
275 if (req->flags & SERIALINFO_SET_MASK)
277 serial->eventmask = req->eventmask;
278 if (!serial->eventmask)
280 fd_async_wake_up( serial->fd, ASYNC_TYPE_WAIT, STATUS_SUCCESS );
284 release_object( serial );