Formerly ../mach/devstream.c.~14~
[kopensolaris-gnu/glibc.git] / mach / devstream.c
1 /* stdio on a Mach device port.
2    Translates \n to \r\n on output.
3
4 Copyright (C) 1992, 1993 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;
34   mach_msg_type_size_t nread;
35   char c;
36
37   if (f->__buffer == NULL)
38     {
39       buffer = &c;
40       to_read = 1;
41     }
42   else
43     {
44       buffer = f->__buffer;
45       to_read = f->__bufsize;
46     }
47
48   f->__eof = 0;
49
50   if (err = device_read_inband ((device_t) f->__cookie, 0, f->__target,
51                                 to_read, buffer, &nread))
52     {
53       f->__error = 1;
54       f->__bufp = f->__get_limit = f->__put_limit = f->__buffer;
55       errno = err;
56       return EOF;
57     }
58
59   if (f->__buffer == NULL)
60     return (unsigned char) c;
61
62   f->__get_limit = f->__buffer + nread;
63   f->__bufp = f->__buffer;
64   f->__put_limit = f->__buffer + (f->__mode.__write ? f->__bufsize : 0);
65   return (unsigned char) *f->__bufp++;
66 }
67
68
69 static void
70 output (FILE *f, int c)
71 {
72   inline void write_some (const char *p, size_t to_write)
73     {
74       kern_return_t err;
75       int wrote;
76       while (to_write > 0)
77         {
78           if (err = device_write_inband ((device_t) f->__cookie, 0,
79                                          f->__target, (char *)p, 
80                                          to_write, &wrote))
81             {
82               errno = err;
83               f->__error = 1;
84               break;
85             }
86           p += wrote;
87           to_write -= wrote;
88           f->__target += wrote;
89         }
90     }
91
92   if (f->__buffer != NULL)
93     {
94       if (f->__put_limit == f->__buffer)
95         {
96           /* Prime the stream for writing.  */
97           f->__put_limit = f->__buffer + f->__bufsize;
98           f->__bufp = f->__buffer;
99           if (c != EOF)
100             {
101               *f->__bufp++ = (unsigned char) c;
102               c = EOF;
103             }
104         }
105
106
107       /* Write out the buffer.  */
108
109       write_some (f->__buffer, f->__bufp - f->__buffer);
110
111       f->__bufp = f->__buffer;
112     }
113
114   if (c != EOF && !ferror (f))
115     {
116       if (f->__linebuf && (unsigned char) c == '\n')
117         {
118           static const char nl = '\n';
119           write_some (&nl, 1);
120         }
121       else
122         *f->__bufp++ = (unsigned char) c;
123     }
124 }
125
126
127
128 #if 0                           /* Translates \n to \r\n.  */
129 static void
130 output (FILE *f, int c)
131 {
132   void write_some (const char *p, size_t to_write)
133     {
134       kern_return_t err;
135       int wrote;
136       while (to_write > 0)
137         {
138           if (err = device_write_inband ((device_t) f->__cookie, 0,
139                                          f->__target, p, to_write, &wrote))
140             {
141               errno = err;
142               f->__error = 1;
143               break;
144             }
145           p += wrote;
146           to_write -= wrote;
147           f->__target += wrote;
148         }
149     }
150   void write_crlf (void)
151     {
152       static const char crlf[] = "\r\n";
153       write_some (crlf, 2);
154     }
155
156   if (f->__buffer == NULL)
157     {
158       /* The stream is unbuffered.  */
159
160       if (c == '\n')
161         write_crlf ();
162       else if (c != EOF)
163         {
164           char cc = (unsigned char) c;
165           write_some (&cc, 1);
166         }
167
168       return;
169     }
170
171   if (f->__put_limit == f->__buffer)
172     {
173       /* Prime the stream for writing.  */
174       f->__put_limit = f->__buffer + f->__bufsize;
175       f->__bufp = f->__buffer;
176       if (c != EOF)
177         {
178           *f->__bufp++ = (unsigned char) c;
179           c = EOF;
180         }
181     }
182
183   {
184     /* Search for newlines (LFs) in the buffer.  */
185
186     char *start = f->__buffer, *p = start;
187
188     while (!ferror (f) && (p = memchr (p, '\n', f->__bufp - start)))
189       {
190         /* Found one.  Replace it with a CR and write out through that CR.  */
191
192         *p = '\r';
193         write_some (start, p + 1 - start);
194
195         /* Change it back to an LF; the next iteration will write it out
196            first thing.  Start the next searching iteration one char later.  */
197
198         start = p;
199         *p++ = '\n';
200       }
201
202     /* Write the remainder of the buffer.  */
203
204     if (!ferror (f))
205       write_some (start, f->__bufp - start);
206   }
207
208   f->__bufp = f->__buffer;
209
210   if (c != EOF && !ferror (f))
211     {
212       if (f->__linebuf && (unsigned char) c == '\n')
213         write_crlf ();
214       else
215         *f->__bufp++ = (unsigned char) c;
216     }
217 }
218 #endif
219
220 FILE *
221 mach_open_devstream (mach_port_t dev, const char *mode)
222 {
223   FILE *stream = fopencookie ((void *) dev, mode, __default_io_functions);
224   if (stream == NULL)
225     return NULL;
226
227   stream->__room_funcs.__input = input;
228   stream->__room_funcs.__output = output;
229   stream->__io_funcs.__close = (__io_close_fn *) device_close;
230   stream->__seen = 1;
231
232   return stream;
233 }