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 void serial_destroy(struct object
*obj
);
63 static enum server_fd_type
serial_get_fd_type( struct fd
*fd
);
64 static void serial_queue_async( struct fd
*fd
, const async_data_t
*data
, int type
, int count
);
72 unsigned int readinterval
;
73 unsigned int readconst
;
74 unsigned int readmult
;
75 unsigned int writeconst
;
76 unsigned int writemult
;
78 unsigned int eventmask
;
79 unsigned int generation
; /* event mask change counter */
80 unsigned int pending_write
;
82 struct termios original
;
84 /* FIXME: add dcb, comm status, handler module, sharing */
87 static const struct object_ops serial_ops
=
89 sizeof(struct serial
), /* size */
90 serial_dump
, /* dump */
91 no_get_type
, /* get_type */
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 default_fd_map_access
, /* map_access */
99 default_get_sd
, /* get_sd */
100 default_set_sd
, /* set_sd */
101 no_lookup_name
, /* lookup_name */
102 no_open_file
, /* open_file */
103 fd_close_handle
, /* close_handle */
104 serial_destroy
/* destroy */
107 static const struct fd_ops serial_fd_ops
=
109 default_fd_get_poll_events
, /* get_poll_events */
110 default_poll_event
, /* poll_event */
111 no_flush
, /* flush */
112 serial_get_fd_type
, /* get_fd_type */
113 default_fd_ioctl
, /* ioctl */
114 serial_queue_async
, /* queue_async */
115 default_fd_reselect_async
, /* reselect_async */
116 default_fd_cancel_async
/* cancel_async */
119 /* check if the given fd is a serial port */
120 int is_serial_fd( struct fd
*fd
)
124 return !tcgetattr( get_unix_fd(fd
), &tios
);
127 /* create a serial object for a given fd */
128 struct object
*create_serial( struct fd
*fd
)
130 struct serial
*serial
;
132 if (!(serial
= alloc_object( &serial_ops
))) return NULL
;
134 serial
->readinterval
= 0;
135 serial
->readmult
= 0;
136 serial
->readconst
= 0;
137 serial
->writemult
= 0;
138 serial
->writeconst
= 0;
139 serial
->eventmask
= 0;
140 serial
->generation
= 0;
141 serial
->pending_write
= 0;
142 serial
->fd
= (struct fd
*)grab_object( fd
);
143 set_fd_user( fd
, &serial_fd_ops
, &serial
->obj
);
147 static struct fd
*serial_get_fd( struct object
*obj
)
149 struct serial
*serial
= (struct serial
*)obj
;
150 return (struct fd
*)grab_object( serial
->fd
);
153 static void serial_destroy( struct object
*obj
)
155 struct serial
*serial
= (struct serial
*)obj
;
156 release_object( serial
->fd
);
159 static void serial_dump( struct object
*obj
, int verbose
)
161 struct serial
*serial
= (struct serial
*)obj
;
162 assert( obj
->ops
== &serial_ops
);
163 fprintf( stderr
, "Port fd=%p mask=%x\n", serial
->fd
, serial
->eventmask
);
166 static struct serial
*get_serial_obj( struct process
*process
, obj_handle_t handle
, unsigned int access
)
168 return (struct serial
*)get_handle_obj( process
, handle
, access
, &serial_ops
);
171 static enum server_fd_type
serial_get_fd_type( struct fd
*fd
)
173 return FD_TYPE_SERIAL
;
176 static void serial_queue_async( struct fd
*fd
, const async_data_t
*data
, int type
, int count
)
178 struct serial
*serial
= get_fd_user( fd
);
179 timeout_t timeout
= 0;
182 assert(serial
->obj
.ops
== &serial_ops
);
186 case ASYNC_TYPE_READ
:
187 timeout
= serial
->readconst
+ (timeout_t
)serial
->readmult
*count
;
189 case ASYNC_TYPE_WRITE
:
190 timeout
= serial
->writeconst
+ (timeout_t
)serial
->writemult
*count
;
194 if ((async
= fd_queue_async( fd
, data
, type
)))
196 if (timeout
) async_set_timeout( async
, timeout
* -10000, STATUS_TIMEOUT
);
197 release_object( async
);
198 set_error( STATUS_PENDING
);
202 DECL_HANDLER(get_serial_info
)
204 struct serial
*serial
;
206 if ((serial
= get_serial_obj( current
->process
, req
->handle
, 0 )))
209 reply
->readinterval
= serial
->readinterval
;
210 reply
->readconst
= serial
->readconst
;
211 reply
->readmult
= serial
->readmult
;
212 reply
->writeconst
= serial
->writeconst
;
213 reply
->writemult
= serial
->writemult
;
216 reply
->eventmask
= serial
->eventmask
;
217 reply
->cookie
= serial
->generation
;
220 reply
->pending_write
= serial
->pending_write
;
221 if (req
->flags
& SERIALINFO_PENDING_WRITE
)
222 serial
->pending_write
= 0;
224 release_object( serial
);
228 DECL_HANDLER(set_serial_info
)
230 struct serial
*serial
;
232 if ((serial
= get_serial_obj( current
->process
, req
->handle
, 0 )))
235 if (req
->flags
& SERIALINFO_SET_TIMEOUTS
)
237 serial
->readinterval
= req
->readinterval
;
238 serial
->readconst
= req
->readconst
;
239 serial
->readmult
= req
->readmult
;
240 serial
->writeconst
= req
->writeconst
;
241 serial
->writemult
= req
->writemult
;
245 if (req
->flags
& SERIALINFO_PENDING_WRITE
)
246 serial
->pending_write
= 1;
249 if (req
->flags
& SERIALINFO_SET_MASK
)
251 serial
->eventmask
= req
->eventmask
;
252 serial
->generation
++;
253 fd_async_wake_up( serial
->fd
, ASYNC_TYPE_WAIT
, STATUS_SUCCESS
);
256 release_object( serial
);