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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
24 #include "wine/port.h"
33 #include <sys/types.h>
42 #ifdef HAVE_SYS_IOCTL_H
43 #include <sys/ioctl.h>
60 static void serial_dump( struct object
*obj
, int verbose
);
61 static struct fd
*serial_get_fd( struct object
*obj
);
62 static void serial_destroy(struct object
*obj
);
64 static int serial_get_poll_events( struct fd
*fd
);
65 static void serial_poll_event( struct fd
*fd
, int event
);
66 static int serial_get_info( struct fd
*fd
);
67 static int serial_flush( struct fd
*fd
, struct event
**event
);
68 static void serial_queue_async( struct fd
*fd
, void *apc
, void *user
, void *iosb
, int type
, int count
);
69 static void serial_cancel_async( struct fd
*fd
);
78 unsigned int readinterval
;
79 unsigned int readconst
;
80 unsigned int readmult
;
81 unsigned int writeconst
;
82 unsigned int writemult
;
84 unsigned int eventmask
;
85 unsigned int commerror
;
87 struct termios original
;
93 /* FIXME: add dcb, comm status, handler module, sharing */
96 static const struct object_ops serial_ops
=
98 sizeof(struct serial
), /* size */
99 serial_dump
, /* dump */
100 default_fd_add_queue
, /* add_queue */
101 default_fd_remove_queue
, /* remove_queue */
102 default_fd_signaled
, /* signaled */
103 no_satisfied
, /* satisfied */
104 serial_get_fd
, /* get_fd */
105 serial_destroy
/* destroy */
108 static const struct fd_ops serial_fd_ops
=
110 serial_get_poll_events
, /* get_poll_events */
111 serial_poll_event
, /* poll_event */
112 serial_flush
, /* flush */
113 serial_get_info
, /* get_file_info */
114 serial_queue_async
, /* queue_async */
115 serial_cancel_async
/* cancel_async */
118 /* check if the given fd is a serial port */
119 int is_serial_fd( struct fd
*fd
)
123 return !tcgetattr( get_unix_fd(fd
), &tios
);
126 /* create a serial object for a given fd */
127 struct object
*create_serial( struct fd
*fd
, unsigned int options
)
129 struct serial
*serial
;
132 if ((unix_fd
= dup( get_unix_fd(fd
) )) == -1) return NULL
;
134 /* set the fd back to blocking if necessary */
135 if (options
& (FILE_SYNCHRONOUS_IO_ALERT
| FILE_SYNCHRONOUS_IO_NONALERT
))
136 fcntl( unix_fd
, F_SETFL
, 0 );
138 if (!(serial
= alloc_object( &serial_ops
)))
143 serial
->options
= options
;
144 serial
->readinterval
= 0;
145 serial
->readmult
= 0;
146 serial
->readconst
= 0;
147 serial
->writemult
= 0;
148 serial
->writeconst
= 0;
149 serial
->eventmask
= 0;
150 serial
->commerror
= 0;
151 list_init( &serial
->read_q
);
152 list_init( &serial
->write_q
);
153 list_init( &serial
->wait_q
);
154 if (!(serial
->fd
= create_anonymous_fd( &serial_fd_ops
, unix_fd
, &serial
->obj
)))
156 release_object( serial
);
162 static struct fd
*serial_get_fd( struct object
*obj
)
164 struct serial
*serial
= (struct serial
*)obj
;
165 return (struct fd
*)grab_object( serial
->fd
);
168 static void serial_destroy( struct object
*obj
)
170 struct serial
*serial
= (struct serial
*)obj
;
172 async_terminate_queue( &serial
->read_q
, STATUS_CANCELLED
);
173 async_terminate_queue( &serial
->write_q
, STATUS_CANCELLED
);
174 async_terminate_queue( &serial
->wait_q
, STATUS_CANCELLED
);
175 if (serial
->fd
) release_object( serial
->fd
);
178 static void serial_dump( struct object
*obj
, int verbose
)
180 struct serial
*serial
= (struct serial
*)obj
;
181 assert( obj
->ops
== &serial_ops
);
182 fprintf( stderr
, "Port fd=%p mask=%x\n", serial
->fd
, serial
->eventmask
);
185 static struct serial
*get_serial_obj( struct process
*process
, obj_handle_t handle
, unsigned int access
)
187 return (struct serial
*)get_handle_obj( process
, handle
, access
, &serial_ops
);
190 static int serial_get_poll_events( struct fd
*fd
)
192 struct serial
*serial
= get_fd_user( fd
);
194 assert( serial
->obj
.ops
== &serial_ops
);
196 if (!list_empty( &serial
->read_q
)) events
|= POLLIN
;
197 if (!list_empty( &serial
->write_q
)) events
|= POLLOUT
;
198 if (!list_empty( &serial
->wait_q
)) events
|= POLLIN
;
200 /* fprintf(stderr,"poll events are %04x\n",events); */
205 static int serial_get_info( struct fd
*fd
)
208 struct serial
*serial
= get_fd_user( fd
);
209 assert( serial
->obj
.ops
== &serial_ops
);
211 if (!(serial
->options
& (FILE_SYNCHRONOUS_IO_ALERT
| FILE_SYNCHRONOUS_IO_NONALERT
)))
212 flags
|= FD_FLAG_OVERLAPPED
;
213 else if (!(serial
->readinterval
== MAXDWORD
&&
214 serial
->readmult
== 0 && serial
->readconst
== 0))
215 flags
|= FD_FLAG_TIMEOUT
;
216 if (serial
->readinterval
== MAXDWORD
&&
217 serial
->readmult
== 0 && serial
->readconst
== 0)
218 flags
|= FD_FLAG_AVAILABLE
;
223 static void serial_poll_event(struct fd
*fd
, int event
)
225 struct serial
*serial
= get_fd_user( fd
);
227 /* fprintf(stderr,"Poll event %02x\n",event); */
229 if (!list_empty( &serial
->read_q
) && (POLLIN
& event
) )
230 async_terminate_head( &serial
->read_q
, STATUS_ALERTED
);
232 if (!list_empty( &serial
->write_q
) && (POLLOUT
& event
) )
233 async_terminate_head( &serial
->write_q
, STATUS_ALERTED
);
235 if (!list_empty( &serial
->wait_q
) && (POLLIN
& event
) )
236 async_terminate_head( &serial
->wait_q
, STATUS_ALERTED
);
238 set_fd_events( fd
, serial_get_poll_events(fd
) );
241 static void serial_queue_async( struct fd
*fd
, void *apc
, void *user
, void *iosb
,
242 int type
, int count
)
244 struct serial
*serial
= get_fd_user( fd
);
249 assert(serial
->obj
.ops
== &serial_ops
);
253 case ASYNC_TYPE_READ
:
254 queue
= &serial
->read_q
;
255 timeout
= serial
->readconst
+ serial
->readmult
*count
;
257 case ASYNC_TYPE_WAIT
:
258 queue
= &serial
->wait_q
;
261 case ASYNC_TYPE_WRITE
:
262 queue
= &serial
->write_q
;
263 timeout
= serial
->writeconst
+ serial
->writemult
*count
;
266 set_error(STATUS_INVALID_PARAMETER
);
270 if (!create_async( fd
, current
, timeout
, queue
, apc
, user
, iosb
))
273 /* Check if the new pending request can be served immediately */
274 events
= check_fd_events( fd
, serial_get_poll_events( fd
) );
277 /* serial_poll_event() calls set_select_events() */
278 serial_poll_event( fd
, events
);
282 set_fd_events( fd
, serial_get_poll_events( fd
) );
285 static void serial_cancel_async( struct fd
*fd
)
287 struct serial
*serial
= get_fd_user( fd
);
288 assert(serial
->obj
.ops
== &serial_ops
);
290 async_terminate_queue( &serial
->read_q
, STATUS_CANCELLED
);
291 async_terminate_queue( &serial
->write_q
, STATUS_CANCELLED
);
292 async_terminate_queue( &serial
->wait_q
, STATUS_CANCELLED
);
295 static int serial_flush( struct fd
*fd
, struct event
**event
)
297 /* MSDN says: If hFile is a handle to a communications device,
298 * the function only flushes the transmit buffer.
300 int ret
= (tcflush( get_unix_fd(fd
), TCOFLUSH
) != -1);
301 if (!ret
) file_set_error();
305 DECL_HANDLER(get_serial_info
)
307 struct serial
*serial
;
309 if ((serial
= get_serial_obj( current
->process
, req
->handle
, 0 )))
312 reply
->readinterval
= serial
->readinterval
;
313 reply
->readconst
= serial
->readconst
;
314 reply
->readmult
= serial
->readmult
;
315 reply
->writeconst
= serial
->writeconst
;
316 reply
->writemult
= serial
->writemult
;
319 reply
->eventmask
= serial
->eventmask
;
321 /* comm port error status */
322 reply
->commerror
= serial
->commerror
;
324 release_object( serial
);
328 DECL_HANDLER(set_serial_info
)
330 struct serial
*serial
;
332 if ((serial
= get_serial_obj( current
->process
, req
->handle
, 0 )))
335 if (req
->flags
& SERIALINFO_SET_TIMEOUTS
)
337 serial
->readinterval
= req
->readinterval
;
338 serial
->readconst
= req
->readconst
;
339 serial
->readmult
= req
->readmult
;
340 serial
->writeconst
= req
->writeconst
;
341 serial
->writemult
= req
->writemult
;
345 if (req
->flags
& SERIALINFO_SET_MASK
)
347 serial
->eventmask
= req
->eventmask
;
348 if (!serial
->eventmask
)
350 async_terminate_queue( &serial
->wait_q
, STATUS_SUCCESS
);
354 /* comm port error status */
355 if (req
->flags
& SERIALINFO_SET_ERROR
)
357 serial
->commerror
= req
->commerror
;
360 release_object( serial
);