pith/pipe.c

   1 #if !defined(lint) && !defined(DOS)
   2 static char rcsid[] = "$Id: pipe.c 761 2007-10-23 22:35:18Z hubert@u.washington.edu $";
   3 #endif
   4 /*
   5  * ========================================================================
   6  * Copyright 2013-2017 Eduardo Chappa
   7  * Copyright 2006 University of Washington
   8  *
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *     http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * ========================================================================
  16  */
  17
  18 #include "../pith/headers.h"
  19 #include "../pith/pipe.h"
  20 #include "../pith/status.h"
  21
  22
  23 /* Internal prototypes */
  24
  25
  26
  27 /*
  28  * pipe_* functions introduced so out.f, in.f don't need to be used
  29  * by whatever's setting up the pipe.
  30  * Should be similar on unix and windows, but since we're faking piping
  31  * in windows, closing the write pipe would signify that the child
  32  * process can start running.  This makes it possible for PIPE_WRITE
  33  * and PIPE_READ flags to be simultaneously set across all platforms.
  34  * Unix piping should eventually have NON_BLOCKING_IO stuff rolled up
  35  * into it.
  36  */
  37
  38 int
  39 pipe_putc(int c, PIPE_S *syspipe)
  40 {
  41     if(!syspipe || !syspipe->out.f)
  42       return -1;
  43
  44     return(fputc(c, syspipe->out.f));
  45 }
  46
  47 int
  48 pipe_puts(char *str, PIPE_S *syspipe)
  49 {
  50     if(!syspipe || !syspipe->out.f)
  51       return -1;
  52
  53     return(fputs(str, syspipe->out.f));
  54 }
  55
  56 char *
  57 pipe_gets(char *str, int size, PIPE_S *syspipe)
  58 {
  59     if(!syspipe || !syspipe->in.f)
  60       return NULL;
  61
  62     return(fgets(str, size, syspipe->in.f));
  63 }
  64
  65 int
  66 pipe_readc(unsigned char *c, PIPE_S *syspipe)
  67 {
  68     int rv = 0;
  69
  70     if(!syspipe || !syspipe->in.f)
  71       return -1;
  72
  73     do {
  74         errno = 0;
  75         clearerr(syspipe->in.f);
  76         rv = fread(c, sizeof(unsigned char), (size_t)1, syspipe->in.f);
  77     } while(!rv && ferror(syspipe->in.f) && errno == EINTR);
  78
  79     return(rv);
  80 }
  81
  82 int
  83 pipe_writec(int c, PIPE_S *syspipe)
  84 {
  85     unsigned char ch = (unsigned char)c;
  86     int rv = 0;
  87
  88     if(!syspipe || !syspipe->out.f)
  89       return -1;
  90
  91     do
  92       rv = fwrite(&ch, sizeof(unsigned char), (size_t)1, syspipe->out.f);
  93     while(!rv && ferror(syspipe->out.f) && errno == EINTR);
  94
  95     return(rv);
  96 }
  97
  98
  99 void
 100 pipe_report_error(char *errormsg)
 101 {
 102     q_status_message(SM_ORDER, 3, 3, errormsg);
 103 }