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 e         if (err = device_write_inband ((device_t) f->__cookie, 0,
  79                                          f->__target, p, to_write, &wrote))
  80             {
  81               errno = err;
  82               f->__error = 1;
  83               break;
  84             }
  85           p += wrote;
  86           to_write -= wrote;
  87           f->__target += wrote;
  88         }
  89     }
  90
  91   if (f->__buffer != NULL)
  92     {
  93       if (f->__put_limit == f->__buffer)
  94         {
  95           /* Prime the stream for writing.  */
  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
 106       /* Write out the buffer.  */
 107
 108       write_some (start, f->__bufp - start);
 109
 110       f->__bufp = f->__buffer;
 111     }
 112
 113   if (c != EOF && !ferror (f))
 114     {
 115       if (f->__linebuf && (unsigned char) c == '\n')
 116         {
 117           static const char nl = '\n';
 118           write_some (&nl, 1);
 119         }
 120       else
 121         *f->__bufp++ = (unsigned char) c;
 122     }
 123 }
 124
 125
 126
 127 #if 0                           /* Translates \n to \r\n.  */
 128 static void
 129 output (FILE *f, int c)
 130 {
 131   void write_some (const char *p, size_t to_write)
 132     {
 133       kern_return_t err;
 134       int wrote;
 135       while (to_write > 0)
 136         {
 137           if (err = device_write_inband ((device_t) f->__cookie, 0,
 138                                          f->__target, p, to_write, &wrote))
 139             {
 140               errno = err;
 141               f->__error = 1;
 142               break;
 143             }
 144           p += wrote;
 145           to_write -= wrote;
 146           f->__target += wrote;
 147         }
 148     }
 149   void write_crlf (void)
 150     {
 151       static const char crlf[] = "\r\n";
 152       write_some (crlf, 2);
 153     }
 154
 155   if (f->__buffer == NULL)
 156     {
 157       /* The stream is unbuffered.  */
 158
 159       if (c == '\n')
 160         write_crlf ();
 161       else if (c != EOF)
 162         {
 163           char cc = (unsigned char) c;
 164           write_some (&cc, 1);
 165         }
 166
 167       return;
 168     }
 169
 170   if (f->__put_limit == f->__buffer)
 171     {
 172       /* Prime the stream for writing.  */
 173       f->__put_limit = f->__buffer + f->__bufsize;
 174       f->__bufp = f->__buffer;
 175       if (c != EOF)
 176         {
 177           *f->__bufp++ = (unsigned char) c;
 178           c = EOF;
 179         }
 180     }
 181
 182   {
 183     /* Search for newlines (LFs) in the buffer.  */
 184
 185     char *start = f->__buffer, *p = start;
 186
 187     while (!ferror (f) && (p = memchr (p, '\n', f->__bufp - start)))
 188       {
 189         /* Found one.  Replace it with a CR and write out through that CR.  */
 190
 191         *p = '\r';
 192         write_some (start, p + 1 - start);
 193
 194         /* Change it back to an LF; the next iteration will write it out
 195            first thing.  Start the next searching iteration one char later.  */
 196
 197         start = p;
 198         *p++ = '\n';
 199       }
 200
 201     /* Write the remainder of the buffer.  */
 202
 203     if (!ferror (f))
 204       write_some (start, f->__bufp - start);
 205   }
 206
 207   f->__bufp = f->__buffer;
 208
 209   if (c != EOF && !ferror (f))
 210     {
 211       if (f->__linebuf && (unsigned char) c == '\n')
 212         write_crlf ();
 213       else
 214         *f->__bufp++ = (unsigned char) c;
 215     }
 216 }
 217 #endif
 218
 219 FILE *
 220 mach_open_devstream (mach_port_t dev, const char *mode)
 221 {
 222   FILE *stream = fopencookie ((void *) dev, mode, __default_io_functions);
 223   if (stream == NULL)
 224     return NULL;
 225
 226   stream->__room_funcs.__input = input;
 227   stream->__room_funcs.__output = output;
 228   stream->__io_funcs.__close = (__io_close_fn *) device_close;
 229   stream->__seen = 1;
 230
 231   return stream;
 232 }