3 ** Copyright (C) 2005-2012 Mike Pall. See Copyright Notice in luajit.h
5 ** Major portions taken verbatim or adapted from the Lua interpreter.
6 ** Copyright (C) 1994-2011 Lua.org, PUC-Rio. See Copyright Notice in lua.h
26 /* Userdata payload for I/O file. */
27 typedef struct IOFileUD
{
28 FILE *fp
; /* File handle. */
29 uint32_t type
; /* File type. */
32 #define IOFILE_TYPE_FILE 0 /* Regular file. */
33 #define IOFILE_TYPE_PIPE 1 /* Pipe. */
34 #define IOFILE_TYPE_STDF 2 /* Standard file handle. */
35 #define IOFILE_TYPE_MASK 3
37 #define IOFILE_FLAG_CLOSE 4 /* Close after io.lines() iterator. */
39 #define IOSTDF_UD(L, id) (&gcref(G(L)->gcroot[(id)])->ud)
40 #define IOSTDF_IOF(L, id) ((IOFileUD *)uddata(IOSTDF_UD(L, (id))))
42 /* -- Open/close helpers -------------------------------------------------- */
44 static IOFileUD
*io_tofilep(lua_State
*L
)
46 if (!(L
->base
< L
->top
&& tvisudata(L
->base
) &&
47 udataV(L
->base
)->udtype
== UDTYPE_IO_FILE
))
48 lj_err_argtype(L
, 1, "FILE*");
49 return (IOFileUD
*)uddata(udataV(L
->base
));
52 static IOFileUD
*io_tofile(lua_State
*L
)
54 IOFileUD
*iof
= io_tofilep(L
);
56 lj_err_caller(L
, LJ_ERR_IOCLFL
);
60 static FILE *io_stdfile(lua_State
*L
, ptrdiff_t id
)
62 IOFileUD
*iof
= IOSTDF_IOF(L
, id
);
64 lj_err_caller(L
, LJ_ERR_IOSTDCL
);
68 static IOFileUD
*io_file_new(lua_State
*L
)
70 IOFileUD
*iof
= (IOFileUD
*)lua_newuserdata(L
, sizeof(IOFileUD
));
71 GCudata
*ud
= udataV(L
->top
-1);
72 ud
->udtype
= UDTYPE_IO_FILE
;
73 /* NOBARRIER: The GCudata is new (marked white). */
74 setgcrefr(ud
->metatable
, curr_func(L
)->c
.env
);
76 iof
->type
= IOFILE_TYPE_FILE
;
80 static IOFileUD
*io_file_open(lua_State
*L
, const char *mode
)
82 const char *fname
= strdata(lj_lib_checkstr(L
, 1));
83 IOFileUD
*iof
= io_file_new(L
);
84 iof
->fp
= fopen(fname
, mode
);
86 luaL_argerror(L
, 1, lj_str_pushf(L
, "%s: %s", fname
, strerror(errno
)));
90 static int io_file_close(lua_State
*L
, IOFileUD
*iof
)
93 if ((iof
->type
& IOFILE_TYPE_MASK
) == IOFILE_TYPE_FILE
) {
94 ok
= (fclose(iof
->fp
) == 0);
95 } else if ((iof
->type
& IOFILE_TYPE_MASK
) == IOFILE_TYPE_PIPE
) {
98 stat
= pclose(iof
->fp
);
99 #elif LJ_TARGET_WINDOWS
100 stat
= _pclose(iof
->fp
);
107 return luaL_execresult(L
, stat
);
112 lua_assert((iof
->type
& IOFILE_TYPE_MASK
) == IOFILE_TYPE_STDF
);
114 lua_pushliteral(L
, "cannot close standard file");
118 return luaL_fileresult(L
, ok
, NULL
);
121 /* -- Read/write helpers -------------------------------------------------- */
123 static int io_file_readnum(lua_State
*L
, FILE *fp
)
126 if (fscanf(fp
, LUA_NUMBER_SCAN
, &d
) == 1) {
128 int32_t i
= lj_num2int(d
);
129 if (d
== (lua_Number
)i
&& !tvismzero((cTValue
*)&d
)) {
130 setintV(L
->top
++, i
);
134 setnumV(L
->top
++, d
);
142 static int io_file_testeof(lua_State
*L
, FILE *fp
)
146 lua_pushlstring(L
, NULL
, 0);
150 static int io_file_readline(lua_State
*L
, FILE *fp
, size_t chop
)
153 luaL_buffinit(L
, &b
);
156 char *p
= luaL_prepbuffer(&b
);
157 if (fgets(p
, LUAL_BUFFERSIZE
, fp
) == NULL
) { /* EOF? */
159 return (strV(L
->top
-1)->len
> 0); /* Anything read? */
162 if (len
== 0 || p
[len
-1] != '\n') { /* Partial line? */
163 luaL_addsize(&b
, len
);
165 luaL_addsize(&b
, len
- chop
); /* Keep or remove EOL. */
167 return 1; /* Got at least an EOL. */
172 static int io_file_readchars(lua_State
*L
, FILE *fp
, size_t n
)
174 size_t rlen
; /* how much to read */
175 size_t nr
; /* number of chars actually read */
177 luaL_buffinit(L
, &b
);
178 rlen
= LUAL_BUFFERSIZE
; /* try to read that much each time */
180 char *p
= luaL_prepbuffer(&b
);
181 if (rlen
> n
) rlen
= n
; /* cannot read more than asked */
182 nr
= fread(p
, 1, rlen
, fp
);
183 luaL_addsize(&b
, nr
);
184 n
-= nr
; /* still have to read `n' chars */
185 } while (n
> 0 && nr
== rlen
); /* until end of count or eof */
186 luaL_pushresult(&b
); /* close buffer */
187 return (n
== 0 || strV(L
->top
-1)->len
> 0);
190 static int io_file_read(lua_State
*L
, FILE *fp
, int start
)
192 int ok
, n
, nargs
= (int)(L
->top
- L
->base
) - start
;
195 ok
= io_file_readline(L
, fp
, 1);
196 n
= start
+1; /* Return 1 result. */
198 /* The results plus the buffers go on top of the args. */
199 luaL_checkstack(L
, nargs
+LUA_MINSTACK
, "too many arguments");
201 for (n
= start
; nargs
-- && ok
; n
++) {
202 if (tvisstr(L
->base
+n
)) {
203 const char *p
= strVdata(L
->base
+n
);
205 lj_err_arg(L
, n
+1, LJ_ERR_INVOPT
);
207 ok
= io_file_readnum(L
, fp
);
208 else if ((p
[1] & ~0x20) == 'L')
209 ok
= io_file_readline(L
, fp
, (p
[1] == 'l'));
210 else if (p
[1] == 'a')
211 io_file_readchars(L
, fp
, ~((size_t)0));
213 lj_err_arg(L
, n
+1, LJ_ERR_INVFMT
);
214 } else if (tvisnumber(L
->base
+n
)) {
215 size_t len
= (size_t)lj_lib_checkint(L
, n
+1);
216 ok
= len
? io_file_readchars(L
, fp
, len
) : io_file_testeof(L
, fp
);
218 lj_err_arg(L
, n
+1, LJ_ERR_INVOPT
);
223 return luaL_fileresult(L
, 0, NULL
);
225 setnilV(L
->top
-1); /* Replace last result with nil. */
229 static int io_file_write(lua_State
*L
, FILE *fp
, int start
)
233 for (tv
= L
->base
+start
; tv
< L
->top
; tv
++) {
235 MSize len
= strV(tv
)->len
;
236 status
= status
&& (fwrite(strVdata(tv
), 1, len
, fp
) == len
);
237 } else if (tvisint(tv
)) {
238 char buf
[LJ_STR_INTBUF
];
239 char *p
= lj_str_bufint(buf
, intV(tv
));
240 size_t len
= (size_t)(buf
+LJ_STR_INTBUF
-p
);
241 status
= status
&& (fwrite(p
, 1, len
, fp
) == len
);
242 } else if (tvisnum(tv
)) {
243 status
= status
&& (fprintf(fp
, LUA_NUMBER_FMT
, numV(tv
)) > 0);
245 lj_err_argt(L
, (int)(tv
- L
->base
) + 1, LUA_TSTRING
);
248 if (LJ_52
&& status
) {
251 setudataV(L
, L
->base
, IOSTDF_UD(L
, GCROOT_IO_OUTPUT
));
254 return luaL_fileresult(L
, status
, NULL
);
257 static int io_file_iter(lua_State
*L
)
259 GCfunc
*fn
= curr_func(L
);
260 IOFileUD
*iof
= uddata(udataV(&fn
->c
.upvalue
[0]));
261 int n
= fn
->c
.nupvalues
- 1;
263 lj_err_caller(L
, LJ_ERR_IOCLFL
);
265 if (n
) { /* Copy upvalues with options to stack. */
266 if (n
> LUAI_MAXCSTACK
)
267 lj_err_caller(L
, LJ_ERR_STKOV
);
268 lj_state_checkstack(L
, (MSize
)n
);
269 memcpy(L
->top
, &fn
->c
.upvalue
[1], n
*sizeof(TValue
));
272 n
= io_file_read(L
, iof
->fp
, 0);
274 lj_err_callermsg(L
, strVdata(L
->top
-2));
275 if (tvisnil(L
->base
) && (iof
->type
& IOFILE_FLAG_CLOSE
)) {
276 io_file_close(L
, iof
); /* Return values are ignored. */
282 /* -- I/O file methods ---------------------------------------------------- */
284 #define LJLIB_MODULE_io_method
286 LJLIB_CF(io_method_close
)
288 IOFileUD
*iof
= L
->base
< L
->top
? io_tofile(L
) :
289 IOSTDF_IOF(L
, GCROOT_IO_OUTPUT
);
290 return io_file_close(L
, iof
);
293 LJLIB_CF(io_method_read
)
295 return io_file_read(L
, io_tofile(L
)->fp
, 1);
298 LJLIB_CF(io_method_write
) LJLIB_REC(io_write
0)
300 return io_file_write(L
, io_tofile(L
)->fp
, 1);
303 LJLIB_CF(io_method_flush
) LJLIB_REC(io_flush
0)
305 return luaL_fileresult(L
, fflush(io_tofile(L
)->fp
) == 0, NULL
);
308 LJLIB_CF(io_method_seek
)
310 FILE *fp
= io_tofile(L
)->fp
;
311 int opt
= lj_lib_checkopt(L
, 2, 1, "\3set\3cur\3end");
315 if (opt
== 0) opt
= SEEK_SET
;
316 else if (opt
== 1) opt
= SEEK_CUR
;
317 else if (opt
== 2) opt
= SEEK_END
;
321 ofs
= (int64_t)intV(o
);
323 ofs
= (int64_t)numV(o
);
324 else if (!tvisnil(o
))
325 lj_err_argt(L
, 3, LUA_TNUMBER
);
328 res
= fseeko(fp
, ofs
, opt
);
329 #elif _MSC_VER >= 1400
330 res
= _fseeki64(fp
, ofs
, opt
);
331 #elif defined(__MINGW32__)
332 res
= fseeko64(fp
, ofs
, opt
);
334 res
= fseek(fp
, (long)ofs
, opt
);
337 return luaL_fileresult(L
, 0, NULL
);
340 #elif _MSC_VER >= 1400
342 #elif defined(__MINGW32__)
345 ofs
= (int64_t)ftell(fp
);
347 setint64V(L
->top
-1, ofs
);
351 LJLIB_CF(io_method_setvbuf
)
353 FILE *fp
= io_tofile(L
)->fp
;
354 int opt
= lj_lib_checkopt(L
, 2, -1, "\4full\4line\2no");
355 size_t sz
= (size_t)lj_lib_optint(L
, 3, LUAL_BUFFERSIZE
);
356 if (opt
== 0) opt
= _IOFBF
;
357 else if (opt
== 1) opt
= _IOLBF
;
358 else if (opt
== 2) opt
= _IONBF
;
359 return luaL_fileresult(L
, setvbuf(fp
, NULL
, opt
, sz
) == 0, NULL
);
362 LJLIB_CF(io_method_lines
)
365 lua_pushcclosure(L
, io_file_iter
, (int)(L
->top
- L
->base
));
369 LJLIB_CF(io_method___gc
)
371 IOFileUD
*iof
= io_tofilep(L
);
372 if (iof
->fp
!= NULL
&& (iof
->type
& IOFILE_TYPE_MASK
) != IOFILE_TYPE_STDF
)
373 io_file_close(L
, iof
);
377 LJLIB_CF(io_method___tostring
)
379 IOFileUD
*iof
= io_tofilep(L
);
381 lua_pushfstring(L
, "file (%p)", iof
->fp
);
383 lua_pushliteral(L
, "file (closed)");
387 LJLIB_PUSH(top
-1) LJLIB_SET(__index
)
389 #include "lj_libdef.h"
391 /* -- I/O library functions ----------------------------------------------- */
393 #define LJLIB_MODULE_io
395 LJLIB_PUSH(top
-2) LJLIB_SET(!) /* Set environment. */
399 const char *fname
= strdata(lj_lib_checkstr(L
, 1));
400 GCstr
*s
= lj_lib_optstr(L
, 2);
401 const char *mode
= s
? strdata(s
) : "r";
402 IOFileUD
*iof
= io_file_new(L
);
403 iof
->fp
= fopen(fname
, mode
);
404 return iof
->fp
!= NULL
? 1 : luaL_fileresult(L
, 0, fname
);
409 #if LJ_TARGET_POSIX || LJ_TARGET_WINDOWS
410 const char *fname
= strdata(lj_lib_checkstr(L
, 1));
411 GCstr
*s
= lj_lib_optstr(L
, 2);
412 const char *mode
= s
? strdata(s
) : "r";
413 IOFileUD
*iof
= io_file_new(L
);
414 iof
->type
= IOFILE_TYPE_PIPE
;
417 iof
->fp
= popen(fname
, mode
);
419 iof
->fp
= _popen(fname
, mode
);
421 return iof
->fp
!= NULL
? 1 : luaL_fileresult(L
, 0, fname
);
423 return luaL_error(L
, LUA_QL("popen") " not supported");
429 IOFileUD
*iof
= io_file_new(L
);
431 iof
->fp
= NULL
; errno
= ENOSYS
;
435 return iof
->fp
!= NULL
? 1 : luaL_fileresult(L
, 0, NULL
);
440 return lj_cf_io_method_close(L
);
445 return io_file_read(L
, io_stdfile(L
, GCROOT_IO_INPUT
), 0);
448 LJLIB_CF(io_write
) LJLIB_REC(io_write GCROOT_IO_OUTPUT
)
450 return io_file_write(L
, io_stdfile(L
, GCROOT_IO_OUTPUT
), 0);
453 LJLIB_CF(io_flush
) LJLIB_REC(io_flush GCROOT_IO_OUTPUT
)
455 return luaL_fileresult(L
, fflush(io_stdfile(L
, GCROOT_IO_OUTPUT
)) == 0, NULL
);
458 static int io_std_getset(lua_State
*L
, ptrdiff_t id
, const char *mode
)
460 if (L
->base
< L
->top
&& !tvisnil(L
->base
)) {
461 if (tvisudata(L
->base
)) {
465 io_file_open(L
, mode
);
467 /* NOBARRIER: The standard I/O handles are GC roots. */
468 setgcref(G(L
)->gcroot
[id
], gcV(L
->top
-1));
470 setudataV(L
, L
->top
++, IOSTDF_UD(L
, id
));
477 return io_std_getset(L
, GCROOT_IO_INPUT
, "r");
482 return io_std_getset(L
, GCROOT_IO_OUTPUT
, "w");
487 if (L
->base
== L
->top
) setnilV(L
->top
++);
488 if (!tvisnil(L
->base
)) { /* io.lines(fname) */
489 IOFileUD
*iof
= io_file_open(L
, "r");
490 iof
->type
= IOFILE_TYPE_FILE
|IOFILE_FLAG_CLOSE
;
492 setudataV(L
, L
->base
, udataV(L
->top
));
493 } else { /* io.lines() iterates over stdin. */
494 setudataV(L
, L
->base
, IOSTDF_UD(L
, GCROOT_IO_INPUT
));
496 lua_pushcclosure(L
, io_file_iter
, (int)(L
->top
- L
->base
));
502 cTValue
*o
= lj_lib_checkany(L
, 1);
503 if (!(tvisudata(o
) && udataV(o
)->udtype
== UDTYPE_IO_FILE
))
505 else if (((IOFileUD
*)uddata(udataV(o
)))->fp
!= NULL
)
506 lua_pushliteral(L
, "file");
508 lua_pushliteral(L
, "closed file");
512 #include "lj_libdef.h"
514 /* ------------------------------------------------------------------------ */
516 static GCobj
*io_std_new(lua_State
*L
, FILE *fp
, const char *name
)
518 IOFileUD
*iof
= (IOFileUD
*)lua_newuserdata(L
, sizeof(IOFileUD
));
519 GCudata
*ud
= udataV(L
->top
-1);
520 ud
->udtype
= UDTYPE_IO_FILE
;
521 /* NOBARRIER: The GCudata is new (marked white). */
522 setgcref(ud
->metatable
, gcV(L
->top
-3));
524 iof
->type
= IOFILE_TYPE_STDF
;
525 lua_setfield(L
, -2, name
);
529 LUALIB_API
int luaopen_io(lua_State
*L
)
531 LJ_LIB_REG(L
, NULL
, io_method
);
532 copyTV(L
, L
->top
, L
->top
-1); L
->top
++;
533 lua_setfield(L
, LUA_REGISTRYINDEX
, LUA_FILEHANDLE
);
534 LJ_LIB_REG(L
, LUA_IOLIBNAME
, io
);
535 setgcref(G(L
)->gcroot
[GCROOT_IO_INPUT
], io_std_new(L
, stdin
, "stdin"));
536 setgcref(G(L
)->gcroot
[GCROOT_IO_OUTPUT
], io_std_new(L
, stdout
, "stdout"));
537 io_std_new(L
, stderr
, "stderr");