Skip to content

Instantly share code, notes, and snippets.

@SoniEx2
Last active May 26, 2017 21:54
Show Gist options
  • Save SoniEx2/b5636954d444bee9d032 to your computer and use it in GitHub Desktop.
Save SoniEx2/b5636954d444bee9d032 to your computer and use it in GitHub Desktop.
LuaJIT FFI/JIT-able IO lib
setfenv(1, setmetatable({}, {__index=getfenv()}))
local modules = require("tweaks").modules
local ffi = modules.ffi
local C = ffi.C
local function jitable_unpack(t, i, j, ...)
if i == j then return t[j], ... end
return jitable_unpack(t, i, j - 1, t[j], ...)
end
local function jitable_pack(...)
return select("#", ...), {...}
end
return
{
unpack = jitable_unpack,
pack = jitable_pack,
}
-- change environment
setfenv(1, setmetatable({}, {__index=getfenv()}))
local modules = require("tweaks").modules
local ffi = modules.ffi
local C = ffi.C
-- #include "lua.h"
-- #include "lauxlib.h"
-- #include "lualib.h"
-- Check whether 'mode' matches '[rwa]%+?b?'.
local function lua_checkmode_char(str, pos)
return string.sub(str, pos, pos)
end
local function lua_checkmode(mode)
local n = modules.cops.new(1)
return #mode ~= 0 and string.find("rwa", lua_checkmode_char(mode, n:poi()), 1, true) and -- good thing "plain" searches get JITted huh?
(lua_checkmode_char(mode, n.d) ~= '+' or n:pri()) and -- skip if char is '+'
(lua_checkmode_char(mode, n.d) ~= 'b' or n:pri()) and -- skip if char is 'b'
(n.d - 1) == #mode
end
--[[
-- TODO reimplement io.popen
/*
** {======================================================
** lua_popen spawns a new process connected to the current
** one through the file streams.
** =======================================================
*/
#if !defined(lua_popen) /* { */
#if defined(LUA_USE_POPEN) /* { */
#define lua_popen(L,c,m) ((void)L, fflush(NULL), popen(c,m))
#define lua_pclose(L,file) ((void)L, pclose(file))
#elif defined(LUA_WIN) /* }{ */
#define lua_popen(L,c,m) ((void)L, _popen(c,m))
#define lua_pclose(L,file) ((void)L, _pclose(file))
#else /* }{ */
#define lua_popen(L,c,m) ((void)((void)c, m), \
luaL_error(L, LUA_QL("popen") " not supported"), (FILE*)0)
#define lua_pclose(L,file) ((void)((void)L, file), -1)
#endif /* } */
#endif /* } */
/* }====================================================== */
--]]
--[[
-- TODO
/*
** {======================================================
** lua_fseek: configuration for longer offsets
** =======================================================
*/
#if !defined(lua_fseek) && !defined(LUA_ANSI) /* { */
#if defined(LUA_USE_POSIX) /* { */
#define l_fseek(f,o,w) fseeko(f,o,w)
#define l_ftell(f) ftello(f)
#define l_seeknum off_t
#elif defined(LUA_WIN) && !defined(_CRTIMP_TYPEINFO) \
&& defined(_MSC_VER) && (_MSC_VER >= 1400) /* }{ */
/* Windows (but not DDK) and Visual C++ 2005 or higher */
#define l_fseek(f,o,w) _fseeki64(f,o,w)
#define l_ftell(f) _ftelli64(f)
#define l_seeknum __int64
#endif /* } */
#endif /* } */
#if !defined(l_fseek) /* default definitions */
#define l_fseek(f,o,w) fseek(f,o,w)
#define l_ftell(f) ftell(f)
#define l_seeknum long
#endif
/* }====================================================== */
--]]
--IO_PREFIX = "_IO_"
--IO_INPUT = IO_PREFIX .. "input"
--IO_OUTPUT = IO_PREFIX .. "output"
local stdio = {}
--typedef SExIO_Stream LStream;
ffi.cdef[[
typedef struct FILE FILE;
typedef struct SExIO_CloseResult {
bool status;
char *msg;
int en;
} SExIO_CloseResult;
struct SExIO_Stream;
typedef struct SExIO_Stream {
FILE *f; /* stream (NULL for incompletely created streams) */
SExIO_CloseResult *(*closef)(struct SExIO_Stream *stream); /* to close stream (NULL for closed streams) */
} SExIO_Stream;
]]
local function tolstream(v)
return ffi.istype("SExIO_Stream", v) and v or error("bad argument (SExIO_Stream expected)")
end
local function isclosed(p)
return p.closef == nil
end
--[[
static int io_type (lua_State *L) {
LStream *p;
luaL_checkany(L, 1);
p = (LStream *)luaL_testudata(L, 1, LUA_FILEHANDLE);
if (p == NULL)
lua_pushnil(L); /* not a file */
else if (isclosed(p))
lua_pushliteral(L, "closed file");
else
lua_pushliteral(L, "file");
return 1;
}
--]]
local function io_type(p)
if not ffi.istype("SExIO_Stream", p) then
return nil
elseif isclosed(p) then
return "closed file"
else
return "file"
end
end
--[[
static int f_tostring (lua_State *L) {
LStream *p = tolstream(L);
if (isclosed(p))
lua_pushliteral(L, "file (closed)");
else
lua_pushfstring(L, "file (%p)", p->f);
return 1;
}
--]]
ffi.cdef[[
int snprintf(char *str, size_t size, const char *format, ...);
]]
local function f_tostring(p)
if isclosed(p) then
return "file (closed)"
else
local buf = ffi.new("char[?]", ffi.sizeof("void *") * 2)
C.snprintf(buf, ffi.sizeof("void *") * 2, "%p", p.f)
return "file (" .. ffi.string(buf, ffi.sizeof("void *") * 2) .. ")"
end
end
--[[
static FILE *tofile (lua_State *L) {
LStream *p = tolstream(L);
if (isclosed(p))
luaL_error(L, "attempt to use a closed file");
lua_assert(p->f);
return p->f;
}
--]]
local function tofile(p)
if isclosed(p) then
error("attempt to use a closed file")
end
-- assert(p.f ~= nil)
return p.f
end
--[[
/*
** When creating file handles, always creates a `closed' file handle
** before opening the actual file; so, if there is a memory error, the
** file is not left opened.
*/
static LStream *newprefile (lua_State *L) {
LStream *p = (LStream *)lua_newuserdata(L, sizeof(LStream));
p->closef = NULL; /* mark file handle as 'closed' */
luaL_setmetatable(L, LUA_FILEHANDLE);
return p;
}
--]]
local f_gc
local function newprefile()
local p = ffi.gc(ffi.new("SExIO_Stream"), f_gc);
p.closef = nil;
return p;
end
--[[
static int aux_close (lua_State *L) {
LStream *p = tolstream(L);
lua_CFunction cf = p->closef;
p->closef = NULL; /* mark stream as closed */
return (*cf)(L); /* close it */
}
--]]
local function aux_close(v)
local p = tolstream(v)
f = p.closef
p.closef = nil -- mark stream as closed
local res = f(v) -- close it
if res.status then return res.status end
return res.status, ffi.string(res.msg), tonumber(res.en)
end
--[[
static int io_close (lua_State *L) {
if (lua_isnone(L, 1)) /* no argument? */
lua_getfield(L, LUA_REGISTRYINDEX, IO_OUTPUT); /* use standard output */
tofile(L); /* make sure argument is an open stream */
return aux_close(L);
}
--]]
local function io_close(...)
local v = ...
if select('#', ...) == 0 then -- no argument?
v = stdio.IO_OUTPUT -- use standard output
end
tofile(v) -- make sure argument is an open stream
return aux_close(v)
end
--[[
static int f_gc (lua_State *L) {
LStream *p = tolstream(L);
if (!isclosed(p) && p->f != NULL)
aux_close(L); /* ignore closed and incompletely open files */
return 0;
}
--]]
function f_gc(v)
local p = tolstream(v)
if (not isclosed(p) and p.f ~= nil) then
aux_close(v)
end
end
--[[
/*
** function to close regular files
*/
static int io_fclose (lua_State *L) {
LStream *p = tolstream(L);
int res = fclose(p->f);
return luaL_fileresult(L, (res == 0), NULL);
}
--]]
ffi.cdef[[
int fclose(FILE *stream);
]]
local function io_fclose(v)
local p = tolstream(v)
local res = C.fclose(p.f)
return ffi.new("SExIO_CloseResult", modules.luaL.fileresult(res, nil))
end
--[[
static LStream *newfile (lua_State *L) {
LStream *p = newprefile(L);
p->f = NULL;
p->closef = &io_fclose;
return p;
}
--]]
local function newfile()
local p = newprefile()
p.f = nil
p.closef = io_fclose
return p
end
--[[
static void opencheck (lua_State *L, const char *fname, const char *mode) {
LStream *p = newfile(L);
p->f = fopen(fname, mode);
if (p->f == NULL)
luaL_error(L, "cannot open file " LUA_QS " (%s)", fname, strerror(errno));
}
--]]
local function opencheck(fname, mode)
local p = newfile()
p.f = C.fopen(fname, mode)
if p.f == nil then
error(string.format("cannot open file '%s' (%s)", fname, ffi.string(C.strerror(ffi.errno()))))
end
return p
end
--[[
static int io_open (lua_State *L) {
const char *filename = luaL_checkstring(L, 1);
const char *mode = luaL_optstring(L, 2, "r");
LStream *p = newfile(L);
const char *md = mode; /* to traverse/check mode */
luaL_argcheck(L, lua_checkmode(md), 2, "invalid mode");
p->f = fopen(filename, mode);
return (p->f == NULL) ? luaL_fileresult(L, 0, filename) : 1;
}
--]]
ffi.cdef[[
FILE *fopen(const char *path, const char *mode);
]]
local function io_open(filename, mode)
local p = newfile()
if not lua_checkmode(mode) then error("bad argument (invalid mode)") end
p.f = C.fopen(filename, mode)
if p.f == nil then
return modules.luaL.fileresult(false, filename)
end
return p
end
--[[
-- TODO
/*
** function to close 'popen' files
*/
static int io_pclose (lua_State *L) {
LStream *p = tolstream(L);
return luaL_execresult(L, lua_pclose(L, p->f));
}
static int io_popen (lua_State *L) {
const char *filename = luaL_checkstring(L, 1);
const char *mode = luaL_optstring(L, 2, "r");
LStream *p = newprefile(L);
p->f = lua_popen(L, filename, mode);
p->closef = &io_pclose;
return (p->f == NULL) ? luaL_fileresult(L, 0, filename) : 1;
}
--]]
--[[
static int io_tmpfile (lua_State *L) {
LStream *p = newfile(L);
p->f = tmpfile();
return (p->f == NULL) ? luaL_fileresult(L, 0, NULL) : 1;
}
--]]
ffi.cdef[[
FILE *tmpfile(void);
]]
local function io_tmpfile()
local p = newfile()
p.f = C.tmpfile()
if p.f == nil then
return fileresult(false, nil)
end
return p
end
--[[
-- TODO
static FILE *getiofile (lua_State *L, const char *findex) {
LStream *p;
lua_getfield(L, LUA_REGISTRYINDEX, findex);
p = (LStream *)lua_touserdata(L, -1);
if (isclosed(p))
luaL_error(L, "standard %s file is closed", findex + strlen(IO_PREFIX));
return p->f;
}
--]]
--[[
static int g_iofile (lua_State *L, const char *f, const char *mode) {
if (!lua_isnoneornil(L, 1)) {
const char *filename = lua_tostring(L, 1);
if (filename)
opencheck(L, filename, mode);
else {
tofile(L); /* check that it's a valid file handle */
lua_pushvalue(L, 1);
}
lua_setfield(L, LUA_REGISTRYINDEX, f);
}
/* return current value */
lua_getfield(L, LUA_REGISTRYINDEX, f);
return 1;
}
static int io_input (lua_State *L) {
return g_iofile(L, IO_INPUT, "r");
}
static int io_output (lua_State *L) {
return g_iofile(L, IO_OUTPUT, "w");
}
--]]
--static int io_readline (lua_State *L);
local make_io_readline
--[[
static void aux_lines (lua_State *L, int toclose) {
int i;
int n = lua_gettop(L) - 1; /* number of arguments to read */
/* ensure that arguments will fit here and into 'io_readline' stack */
luaL_argcheck(L, n <= LUA_MINSTACK - 3, LUA_MINSTACK - 3, "too many options");
lua_pushvalue(L, 1); /* file handle */
lua_pushinteger(L, n); /* number of arguments to read */
lua_pushboolean(L, toclose); /* close/not close file when finished */
for (i = 1; i <= n; i++) lua_pushvalue(L, i + 1); /* copy arguments */
lua_pushcclosure(L, io_readline, 3 + n);
}
--]]
local function aux_lines(p, toclose, ...)
return make_io_readline(p, toclose, ...)
end
--[[
static int f_lines (lua_State *L) {
tofile(L); /* check that it's a valid file handle */
aux_lines(L, 0);
return 1;
}
--]]
local function f_lines(p, ...)
tofile(p)
return aux_lines(p, false, ...)
end
--[[
static int io_lines (lua_State *L) {
int toclose;
if (lua_isnone(L, 1)) lua_pushnil(L); /* at least one argument */
if (lua_isnil(L, 1)) { /* no file name? */
lua_getfield(L, LUA_REGISTRYINDEX, IO_INPUT); /* get default input */
lua_replace(L, 1); /* put it at index 1 */
tofile(L); /* check that it's a valid file handle */
toclose = 0; /* do not close it after iteration */
}
else { /* open a new file */
const char *filename = luaL_checkstring(L, 1);
opencheck(L, filename, "r");
lua_replace(L, 1); /* put file at index 1 */
toclose = 1; /* close it after iteration */
}
aux_lines(L, toclose);
return 1;
}
--]]
local function io_lines(v, ...)
local toclose
local p
if v == nil then
p = tofile(stdio.IO_INPUT)
toclose = false
else
if type(v) ~= "string" then error("bad argument (string expected)") end
p = opencheck(filename, "r")
toclose = true
end
return aux_lines(p, toclose, ...)
end
--[[
/*
** {======================================================
** READ
** =======================================================
*/
static int read_number (lua_State *L, FILE *f) {
lua_Number d;
if (fscanf(f, LUA_NUMBER_SCAN, &d) == 1) {
lua_pushnumber(L, d);
return 1;
}
else {
lua_pushnil(L); /* "result" to be removed */
return 0; /* read fails */
}
}
--]]
ffi.cdef[[
int fscanf(FILE *stream, const char *format, ...);
void *malloc(size_t size);
void free(void *ptr);
]]
local function read_number(f)
-- ew, is this really needed?
local dptr = ffi.cast("double *", C.malloc(ffi.sizeof("double")))
if C.fscanf(f, "%1f", dptr) == 1 then
C.free(dptr)
return true, tonumber(dptr[0])
else
C.free(dptr)
return false, nil
end
end
--[[
static int test_eof (lua_State *L, FILE *f) {
int c = getc(f);
ungetc(c, f);
lua_pushlstring(L, NULL, 0);
return (c != EOF);
}
--]]
ffi.cdef[[
int fgetc(FILE *stream);
int ungetc(int c, FILE *stream);
]]
local function test_eof(f)
local c = C.fgetc(f)
C.ungetc(c, f)
local status = not (0 <= c and c <= 255) -- idk how else I'm supposed to get the value of "EOF", but let's NOT assume it's -1
if status then
return status, ""
else
return status, nil
end
end
--[[
static int read_line (lua_State *L, FILE *f, int chop) {
luaL_Buffer b;
luaL_buffinit(L, &b);
for (;;) {
size_t l;
char *p = luaL_prepbuffer(&b);
if (fgets(p, LUAL_BUFFERSIZE, f) == NULL) { /* eof? */
luaL_pushresult(&b); /* close buffer */
return (lua_rawlen(L, -1) > 0); /* check whether read something */
}
l = strlen(p);
if (l == 0 || p[l-1] != '\n')
luaL_addsize(&b, l);
else {
luaL_addsize(&b, l - chop); /* chop 'eol' if needed */
luaL_pushresult(&b); /* close buffer */
return 1; /* read at least an `eol' */
}
}
}
--]]
ffi.cdef[[
size_t strlen(const char *s);
char *fgets(char *s, int size, FILE *stream);
]]
local read_line = (function() -- in case you need extra locals
local p = ffi.new("char[?]", modules.luaL.buffersize) -- do this outside so we save on both GC AND allocations
ffi.fill(p, modules.luaL.buffersize)
local function read_line(f, chop)
local buffer = ""
while true do
local l
if C.fgets(p, modules.luaL.buffersize, f) == nil then
return #buffer > 0, buffer
end
l = C.strlen(p)
if l == 0 or p[l-1] ~= ffi.cast("char*", '\n')[0] then
buffer = buffer .. ffi.string(p, l)
else
buffer = buffer .. ffi.string(p, l - chop)
return true, buffer
end
end
end
return read_line
end)() -- call to generate function
-- TODO
--#define MAX_SIZE_T (~(size_t)0)
local MAX_SIZE_T = modules.bit.bnot(ffi.new("size_t", 0))
--[[
static void read_all (lua_State *L, FILE *f) {
size_t rlen = LUAL_BUFFERSIZE; /* how much to read in each cycle */
luaL_Buffer b;
luaL_buffinit(L, &b);
for (;;) {
char *p = luaL_prepbuffsize(&b, rlen);
size_t nr = fread(p, sizeof(char), rlen, f);
luaL_addsize(&b, nr);
if (nr < rlen) break; /* eof? */
else if (rlen <= (MAX_SIZE_T / 4)) /* avoid buffers too large */
rlen *= 2; /* double buffer size at each iteration */
}
luaL_pushresult(&b); /* close buffer */
}
--]]
ffi.cdef[[
size_t fread(void *ptr, size_t size, size_t nmemb, FILE *stream);
]]
local read_all = (function() -- in case you need extra locals
local t = {ffi.new("char[?]", modules.luaL.buffersize)}
local function read_all(f)
local rlen = modules.luaL.buffersize
local buffer = ""
local p = t[rlen / modules.luaL.buffersize]
if not p then
p = ffi.new("char[?]", rlen)
t[rlen / modules.luaL.buffersize] = p
end
while true do
local nr = C.fread(p, ffi.sizeof("char"), rlen, f)
buffer = buffer .. ffi.string(p, nr)
if nr < rlen then
break
elseif rlen <= (MAX_SIZE_T / 4) then
rlen = rlen * 2
end
end
return buffer
end
return read_all
end)() -- call to generate function
--[[
static int read_chars (lua_State *L, FILE *f, size_t n) {
size_t nr; /* number of chars actually read */
char *p;
luaL_Buffer b;
luaL_buffinit(L, &b);
p = luaL_prepbuffsize(&b, n); /* prepare buffer to read whole block */
nr = fread(p, sizeof(char), n, f); /* try to read 'n' chars */
luaL_addsize(&b, nr);
luaL_pushresult(&b); /* close buffer */
return (nr > 0); /* true iff read something */
}
--]]
local function read_chars(f, n)
local buffer = ""
local p = ffi.new("char[?]", n)
local nr = C.fread(p, ffi.sizeof("char"), n, f)
buffer = buffer .. ffi.string(p, nr)
return nr > 0, buffer
end
--[[
static int g_read (lua_State *L, FILE *f, int first) {
int nargs = lua_gettop(L) - 1;
int success;
int n;
clearerr(f);
if (nargs == 0) { /* no arguments? */
success = read_line(L, f, 1);
n = first+1; /* to return 1 result */
}
else { /* ensure stack space for all results and for auxlib's buffer */
luaL_checkstack(L, nargs+LUA_MINSTACK, "too many arguments");
success = 1;
for (n = first; nargs-- && success; n++) {
if (lua_type(L, n) == LUA_TNUMBER) {
size_t l = (size_t)lua_tointeger(L, n);
success = (l == 0) ? test_eof(L, f) : read_chars(L, f, l);
}
else {
const char *p = lua_tostring(L, n);
luaL_argcheck(L, p && p[0] == '*', n, "invalid option");
switch (p[1]) {
case 'n': /* number */
success = read_number(L, f);
break;
case 'l': /* line */
success = read_line(L, f, 1);
break;
case 'L': /* line with end-of-line */
success = read_line(L, f, 0);
break;
case 'a': /* file */
read_all(L, f); /* read entire file */
success = 1; /* always success */
break;
default:
return luaL_argerror(L, n, "invalid format");
}
}
}
}
if (ferror(f))
return luaL_fileresult(L, 0, NULL);
if (!success) {
lua_pop(L, 1); /* remove last result */
lua_pushnil(L); /* push nil instead */
}
return n - first;
}
--]]
ffi.cdef[[
int ferror(FILE *stream);
]]
local function g_read(f, t, nargs)
local t2 = {n=0}
if nargs == 0 then
return read_line(f, 1);
end
local success = true
for n=1, nargs do
if not success then break end
if type(t[n]) == "number" then
local l = ffi.cast("size_t", t[n])
if l == 0 then
t2.n = t2.n + 1
success, t2[t2.n] = test_eof(f)
else
t2.n = t2.n + 1
success, t2[t2.n] = read_chars(f, l)
end
else
if string.sub(t[n], 1, 1) ~= "*" then error("bad argument (invalid option)") end
local p1 = string.sub(t[n], 2, 2)
if p1 == "n" then
t2.n = t2.n + 1
success, t2[t2.n] = read_number(f)
elseif p1 == "l" then
t2.n = t2.n + 1
success, t2[t2.n] = read_line(f, 1)
elseif p1 == "L" then
t2.n = t2.n + 1
success, t2[t2.n] = read_line(f, 0)
elseif p1 == "a" then
t2.n = t2.n + 1
success, t2[t2.n] = true, read_all(f)
else
error("bad argument (invalid format)")
end
end
end
if C.ferror(f) ~= 0 then
return luaL.fileresult(0, nil)
end
if not success then
t2[t2.n] = nil
end
return modules.jitable.unpack(t2, 1, t2.n)
end
--[[
static int io_read (lua_State *L) {
return g_read(L, getiofile(L, IO_INPUT), 1);
}
--]]
local function io_read(...)
local nargs = select('#', ...)
local t = {...}
return g_read(stdio.IO_INPUT, t, nargs)
end
--[[
static int f_read (lua_State *L) {
return g_read(L, tofile(L), 2);
}
--]]
local function f_read(f, ...)
local nargs = select('#', ...)
local t = {...}
return g_read(tofile(f), t, nargs)
end
--[[
static int io_readline (lua_State *L) {
LStream *p = (LStream *)lua_touserdata(L, lua_upvalueindex(1));
int i;
int n = (int)lua_tointeger(L, lua_upvalueindex(2));
if (isclosed(p)) /* file is already closed? */
return luaL_error(L, "file is already closed");
lua_settop(L , 1);
for (i = 1; i <= n; i++) /* push arguments to 'g_read' */
lua_pushvalue(L, lua_upvalueindex(3 + i));
n = g_read(L, p->f, 2); /* 'n' is number of results */
lua_assert(n > 0); /* should return at least a nil */
if (!lua_isnil(L, -n)) /* read at least one value? */
return n; /* return them */
else { /* first result is nil: EOF or error */
if (n > 1) { /* is there error information? */
/* 2nd result is error message */
return luaL_error(L, "%s", lua_tostring(L, -n + 1));
}
if (lua_toboolean(L, lua_upvalueindex(3))) { /* generator created file? */
lua_settop(L, 0);
lua_pushvalue(L, lua_upvalueindex(1));
aux_close(L); /* close it */
}
return 0;
}
}
--]]
make_io_readline = (function()
function make_io_readline(p, toclose, ...)
local t = {...}
local tn = select('#', ...)
local function handle_return(...)
local n = select("#", ...)
-- lua_assert(n > 0)
if (...) ~= nil then
return ...
end
if n > 1 then
error(select(2, ...))
end
if toclose then
aux_close(p)
end
-- return
end
local function io_readline()
if isclosed(p) then
error("file is already closed")
end
return handle_return(g_read(p.f, t, tn))
end
return io_readline
end
return make_io_readline
end)()
--[[
/* }====================================================== */
--]]
--[[
-- TODO
static int g_write (lua_State *L, FILE *f, int arg) {
int nargs = lua_gettop(L) - arg;
int status = 1;
for (; nargs--; arg++) {
if (lua_type(L, arg) == LUA_TNUMBER) {
/* optimization: could be done exactly as for strings */
status = status &&
fprintf(f, LUA_NUMBER_FMT, lua_tonumber(L, arg)) > 0;
}
else {
size_t l;
const char *s = luaL_checklstring(L, arg, &l);
status = status && (fwrite(s, sizeof(char), l, f) == l);
}
}
if (status) return 1; /* file handle already on stack top */
else return luaL_fileresult(L, status, NULL);
}
static int io_write (lua_State *L) {
return g_write(L, getiofile(L, IO_OUTPUT), 1);
}
static int f_write (lua_State *L) {
FILE *f = tofile(L);
lua_pushvalue(L, 1); /* push file at the stack top (to be returned) */
return g_write(L, f, 2);
}
static int f_seek (lua_State *L) {
static const int mode[] = {SEEK_SET, SEEK_CUR, SEEK_END};
static const char *const modenames[] = {"set", "cur", "end", NULL};
FILE *f = tofile(L);
int op = luaL_checkoption(L, 2, "cur", modenames);
lua_Number p3 = luaL_optnumber(L, 3, 0);
l_seeknum offset = (l_seeknum)p3;
luaL_argcheck(L, (lua_Number)offset == p3, 3,
"not an integer in proper range");
op = l_fseek(f, offset, mode[op]);
if (op)
return luaL_fileresult(L, 0, NULL); /* error */
else {
lua_pushnumber(L, (lua_Number)l_ftell(f));
return 1;
}
}
static int f_setvbuf (lua_State *L) {
static const int mode[] = {_IONBF, _IOFBF, _IOLBF};
static const char *const modenames[] = {"no", "full", "line", NULL};
FILE *f = tofile(L);
int op = luaL_checkoption(L, 2, NULL, modenames);
lua_Integer sz = luaL_optinteger(L, 3, LUAL_BUFFERSIZE);
int res = setvbuf(f, NULL, mode[op], sz);
return luaL_fileresult(L, res == 0, NULL);
}
static int io_flush (lua_State *L) {
return luaL_fileresult(L, fflush(getiofile(L, IO_OUTPUT)) == 0, NULL);
}
static int f_flush (lua_State *L) {
return luaL_fileresult(L, fflush(tofile(L)) == 0, NULL);
}
--]]
--[[
/*
** functions for 'io' library
*/
static const luaL_Reg iolib[] = {
{"close", io_close},
{"flush", io_flush},
{"input", io_input},
{"lines", io_lines},
{"open", io_open},
{"output", io_output},
{"popen", io_popen},
{"read", io_read},
{"tmpfile", io_tmpfile},
{"type", io_type},
{"write", io_write},
{NULL, NULL}
};
--]]
local iolib = {
close = io_close,
flush = io_flush,
input = io_input,
lines = io_lines,
open = io_open,
output = io_output,
popen = io_popen,
read = io_read,
tmpfile = io_tmpfile,
type = io_type,
write = io_write,
}
--[[
/*
** methods for file handles
*/
static const luaL_Reg flib[] = {
{"close", io_close},
{"flush", f_flush},
{"lines", f_lines},
{"read", f_read},
{"seek", f_seek},
{"setvbuf", f_setvbuf},
{"write", f_write},
{"__gc", f_gc},
{"__tostring", f_tostring},
{NULL, NULL}
};
--]]
local flib = {
__index = {
close = io_close,
flush = f_flush,
lines = f_lines,
read = f_read,
seek = f_seek,
setvbuf = f_setvbuf,
write = f_write,
},
__tostring = f_tostring,
}
ffi.metatype("SExIO_Stream", flib)
--[[
static void createmeta (lua_State *L) {
luaL_newmetatable(L, LUA_FILEHANDLE); /* create metatable for file handles */
lua_pushvalue(L, -1); /* push metatable */
lua_setfield(L, -2, "__index"); /* metatable.__index = metatable */
luaL_setfuncs(L, flib, 0); /* add file methods to new metatable */
lua_pop(L, 1); /* pop new metatable */
}
--]]
--[[
/*
** function to (not) close the standard files stdin, stdout, and stderr
*/
static int io_noclose (lua_State *L) {
LStream *p = tolstream(L);
p->closef = &io_noclose; /* keep file opened */
lua_pushnil(L);
lua_pushliteral(L, "cannot close standard file");
return 2;
}
--]]
local function io_noclose(p)
p.closef = io_noclose
return ffi.new("SExIO_CloseResult", nil, "cannot close standard file")
end
--[[
static void createstdfile (lua_State *L, FILE *f, const char *k,
const char *fname) {
LStream *p = newprefile(L);
p->f = f;
p->closef = &io_noclose;
if (k != NULL) {
lua_pushvalue(L, -1);
lua_setfield(L, LUA_REGISTRYINDEX, k); /* add file to registry */
}
lua_setfield(L, -2, fname); /* add file to module */
}
--]]
local function createstdfile(f, k, fname, t)
local p = newprefile()
p.f = f
p.closef = io_noclose
if k ~= nil then
stdio[k] = p
end
t[fname] = p
end
--[[
LUAMOD_API int luaopen_io (lua_State *L) {
luaL_newlib(L, iolib); /* new module */
createmeta(L);
/* create (and set) default files */
createstdfile(L, stdin, IO_INPUT, "stdin");
createstdfile(L, stdout, IO_OUTPUT, "stdout");
createstdfile(L, stderr, NULL, "stderr");
return 1;
}
--]]
createstdfile(ffi.cast("FILE*", io.stdin), "IO_INPUT", "stdin", iolib)
createstdfile(ffi.cast("FILE*", io.stdout), "IO_OUTPUT", "stdout", iolib)
createstdfile(ffi.cast("FILE*", io.stderr), nil, "stderr", iolib)
return iolib
-- "dummy" lauxlib, implements only things required by liolib.lua
setfenv(1, setmetatable({}, {__index=getfenv()}))
local modules = require("tweaks").modules
local ffi = modules.ffi
local C = ffi.C
--[[
LUALIB_API int luaL_fileresult (lua_State *L, int stat, const char *fname) {
int en = errno; /* calls to Lua API may change this value */
if (stat) {
lua_pushboolean(L, 1);
return 1;
}
else {
lua_pushnil(L);
if (fname)
lua_pushfstring(L, "%s: %s", fname, strerror(en));
else
lua_pushstring(L, strerror(en));
lua_pushinteger(L, en);
return 3;
}
}
]]
ffi.cdef[[
char *strerror(int errnum);
]]
local function fileresult(stat, fname)
local en = ffi.errno()
if stat then
return true
end
io.write("Calling C.strerror(en)")
return nil, fname and (fname .. ": " .. ffi.string(C.strerror(en))) or ffi.string(C.strerror(en)), en
end
return
{
fileresult = fileresult,
buffersize = 8192,
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment