rusefi
/
lua
mirror of https://github.com/rusefi/lua.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

new option for "writeto" and "readfrom", to allow piped I/O on 

machines that support it.
This commit is contained in:
Roberto Ierusalimschy 1995-10-04 10:53:10 -03:00
parent e0621e6115
commit ec785a1d65
1 changed files with 38 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

69
iolib.c
View File

@ -3,7 +3,7 @@
** Input/output library to LUA ** Input/output library to LUA
*/ */
char *rcs_iolib="$Id: iolib.c,v 1.20 1995/02/02 18:54:58 roberto Exp roberto $"; char *rcs_iolib="$Id: iolib.c,v 1.21 1995/02/06 19:36:13 roberto Exp roberto $";
#include <stdio.h> #include <stdio.h>
#include <ctype.h> #include <ctype.h>
@ -18,6 +18,32 @@ char *rcs_iolib="$Id: iolib.c,v 1.20 1995/02/02 18:54:58 roberto Exp roberto $";
static FILE *in=stdin, *out=stdout; static FILE *in=stdin, *out=stdout;
#ifndef POPEN
#define popen(x,y) NULL /* that is, popen always fails */
#define pclose(x) (-1)
#endif
static void closeread (void)
{
if (in != stdin)
{
if (pclose(in) == -1)
fclose(in);
in = stdin;
}
}
static void closewrite (void)
{
if (out != stdout)
{
if (pclose(out) == -1)
fclose(out);
out = stdout;
}
}
/* /*
** Open a file to read. ** Open a file to read.
** LUA interface: ** LUA interface:
@ -31,11 +57,7 @@ static void io_readfrom (void)
lua_Object o = lua_getparam (1); lua_Object o = lua_getparam (1);
if (o == LUA_NOOBJECT) /* restore standart input */ if (o == LUA_NOOBJECT) /* restore standart input */
{ {
if (in != stdin) closeread();
{
fclose (in);
in = stdin;
}
lua_pushnumber (1); lua_pushnumber (1);
} }
else else
@ -47,14 +69,15 @@ static void io_readfrom (void)
} }
else else
{ {
FILE *fp = fopen (lua_getstring(o),"r"); char *s = lua_getstring(o);
FILE *fp = (*s == '|') ? popen(s+1, "r") : fopen(s, "r");
if (fp == NULL) if (fp == NULL)
{ {
lua_pushnumber (0); lua_pushnumber (0);
} }
else else
{ {
if (in != stdin) fclose (in); closeread();
in = fp; in = fp;
lua_pushnumber (1); lua_pushnumber (1);
} }
@ -76,11 +99,7 @@ static void io_writeto (void)
lua_Object o = lua_getparam (1); lua_Object o = lua_getparam (1);
if (o == LUA_NOOBJECT) /* restore standart output */ if (o == LUA_NOOBJECT) /* restore standart output */
{ {
if (out != stdout) closewrite();
{
fclose (out);
out = stdout;
}
lua_pushnumber (1); lua_pushnumber (1);
} }
else else
@ -92,14 +111,15 @@ static void io_writeto (void)
} }
else else
{ {
FILE *fp = fopen (lua_getstring(o),"w"); char *s = lua_getstring(o);
FILE *fp = (*s == '|') ? popen(s+1,"w") : fopen(s,"w");
if (fp == NULL) if (fp == NULL)
{ {
lua_pushnumber (0); lua_pushnumber (0);
} }
else else
{ {
if (out != stdout) fclose (out); closewrite();
out = fp; out = fp;
lua_pushnumber (1); lua_pushnumber (1);
} }
@ -120,24 +140,13 @@ static void io_writeto (void)
static void io_appendto (void) static void io_appendto (void)
{ {
lua_Object o = lua_getparam (1); lua_Object o = lua_getparam (1);
if (o == LUA_NOOBJECT) /* restore standart output */ if (!lua_isstring (o))
{ {
if (out != stdout) lua_error ("incorrect argument to function 'appendto`");
{ lua_pushnumber (0);
fclose (out);
out = stdout;
}
lua_pushnumber (1);
} }
else else
{ {
if (!lua_isstring (o))
{
lua_error ("incorrect argument to function 'appendto`");
lua_pushnumber (0);
}
else
{
int r; int r;
FILE *fp; FILE *fp;
struct stat st; struct stat st;
@ -154,12 +163,10 @@ static void io_appendto (void)
out = fp; out = fp;
lua_pushnumber (r); lua_pushnumber (r);
} }
}
} }
} }
/* /*
** Read a variable. On error put nil on stack. ** Read a variable. On error put nil on stack.
** LUA interface: ** LUA interface: