Formerly ../mach/devstream.c.~6~
[kopensolaris-gnu/glibc.git] / mach / devstream.c
1 /* stdio on a Mach device port.
2    Translates \n to \r on output.
3
4 Copyright (C) 1992 Free Software Foundation, Inc.
5 This file is part of the GNU C Library.
6
7 The GNU C Library is free software; you can redistribute it and/or
8 modify it under the terms of the GNU Library General Public License as
9 published by the Free Software Foundation; either version 2 of the
10 License, or (at your option) any later version.
11
12 The GNU C Library is distributed in the hope that it will be useful,
13 but WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
15 Library General Public License for more details.
16
17 You should have received a copy of the GNU Library General Public
18 License along with the GNU C Library; see the file COPYING.LIB.  If
19 not, write to the Free Software Foundation, Inc., 675 Mass Ave,
20 Cambridge, MA 02139, USA.  */
21
22 #include <stdio.h>
23 #include <mach.h>
24 #include <device/device.h>
25 #include <errno.h>
26 #include <string.h>
27
28 static int
29 input (FILE *f)
30 {
31   kern_return_t err;
32   char *buffer;
33   size_t to_read, nread;
34   char c;
35
36   if (f->__buffer == NULL)
37     {
38       buffer = &c;
39       to_read = 1;
40     }
41   else
42     {
43       buffer = f->__buffer;
44       to_read = f->__bufsize;
45     }
46
47   f->__eof = 0;
48
49   if (err = device_read_inband ((device_t) f->__cookie, 0, f->__target,
50                                 to_read, buffer, &nread))
51     {
52       f->__error = 1;
53       f->__bufp = f->__get_limit = f->__put_limit = f->__buffer;
54       errno = err;
55       return EOF;
56     }
57
58   if (f->__buffer == NULL)
59     return (unsigned char) c;
60
61   f->__get_limit = f->__buffer + nread;
62   f->__bufp = f->__buffer;
63   f->__put_limit = f->__buffer + (f->__mode.__write ? f->__bufsize : 0);
64   return (unsigned char) *f->__bufp++;
65 }
66
67 static void
68 output (FILE *f, int c)
69 {
70   kern_return_t err;
71   size_t to_write;
72   int wrote;
73   char *p;
74
75   if (f->__buffer == NULL)
76     {
77       if (c != EOF)
78         {
79           char cc = (unsigned char) c;
80           if (cc == '\n')
81             cc = '\r';
82           if ((err = device_write_inband ((device_t) f->__cookie, 0,
83                                           f->__target, &cc, 1, &wrote)) ||
84               wrote != 1)
85             {
86               errno = err;
87               f->__error = 1;
88             }
89         }
90       ++f->__target;
91       return;
92     }
93
94   if (f->__put_limit == f->__buffer)
95     {
96       f->__put_limit = f->__buffer + f->__bufsize;
97       f->__bufp = f->__buffer;
98       if (c != EOF)
99         {
100           *f->__bufp++ = (unsigned char) c;
101           c = EOF;
102         }
103     }
104
105   to_write = f->__bufp - f->__buffer;
106   p = f->__buffer;
107   while (1)
108     {
109       char *p2 = memchr (p, '\n', to_write);
110       if (p2 == NULL)
111         break;
112       *p2++ = '\r';
113       to_write -= p2 - p;
114       p = p2;
115     }
116
117   to_write = f->__bufp - f->__buffer;
118   p = f->__buffer;
119   while (to_write > 0)
120     {
121       if (err = device_write_inband ((device_t) f->__cookie, 0, f->__target,
122                                      p, to_write, &wrote))
123         {
124           errno = EIO;
125           f->__error = 1;
126           break;
127         }
128       p += wrote;
129       to_write -= wrote;
130       f->__target += wrote;
131     }
132
133   f->__bufp = f->__buffer;
134
135   if (c != EOF && !ferror (f))
136     {
137       if (f->__linebuf && (unsigned char) c == '\n')
138         {
139           static const char nl = '\r';
140           if ((err = device_write_inband ((device_t) f->__cookie, 0,
141                                           f->__target, &nl, 1, &wrote)) ||
142               wrote != 1)
143             {
144               errno = EIO;
145               f->__error = 1;
146             }
147           else
148             ++f->__target;
149         }
150       else
151         *f->__bufp++ = (unsigned char) c;
152     }
153 }
154
155 FILE *
156 mach_open_devstream (device_t dev, const char *mode)
157 {
158   FILE *stream = fopencookie ((void *) dev, mode, __default_io_functions);
159   if (stream == NULL)
160     return NULL;
161
162   stream->__room_funcs.__input = input;
163   stream->__room_funcs.__output = output;
164   stream->__io_funcs.__close = device_close;
165   stream->__seen = 1;
166
167   return stream;
168 }