lib_buffer.c 8.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356
  1. /*
  2. ** Buffer library.
  3. ** Copyright (C) 2005-2021 Mike Pall. See Copyright Notice in luajit.h
  4. */
  5. #define lib_buffer_c
  6. #define LUA_LIB
  7. #include "lua.h"
  8. #include "lauxlib.h"
  9. #include "lualib.h"
  10. #include "lj_obj.h"
  11. #if LJ_HASBUFFER
  12. #include "lj_gc.h"
  13. #include "lj_err.h"
  14. #include "lj_buf.h"
  15. #include "lj_str.h"
  16. #include "lj_tab.h"
  17. #include "lj_udata.h"
  18. #include "lj_meta.h"
  19. #if LJ_HASFFI
  20. #include "lj_ctype.h"
  21. #include "lj_cdata.h"
  22. #include "lj_cconv.h"
  23. #endif
  24. #include "lj_strfmt.h"
  25. #include "lj_serialize.h"
  26. #include "lj_lib.h"
  27. /* -- Helper functions ---------------------------------------------------- */
  28. /* Check that the first argument is a string buffer. */
  29. static SBufExt *buffer_tobuf(lua_State *L)
  30. {
  31. if (!(L->base < L->top && tvisbuf(L->base)))
  32. lj_err_argtype(L, 1, "buffer");
  33. return bufV(L->base);
  34. }
  35. /* Ditto, but for writers. */
  36. static LJ_AINLINE SBufExt *buffer_tobufw(lua_State *L)
  37. {
  38. SBufExt *sbx = buffer_tobuf(L);
  39. setsbufXL_(sbx, L);
  40. return sbx;
  41. }
  42. #define buffer_toudata(sbx) ((GCudata *)(sbx)-1)
  43. /* -- Buffer methods ------------------------------------------------------ */
  44. #define LJLIB_MODULE_buffer_method
  45. LJLIB_CF(buffer_method_free)
  46. {
  47. SBufExt *sbx = buffer_tobuf(L);
  48. lj_bufx_free(L, sbx);
  49. L->top = L->base+1; /* Chain buffer object. */
  50. return 1;
  51. }
  52. LJLIB_CF(buffer_method_reset) LJLIB_REC(.)
  53. {
  54. SBufExt *sbx = buffer_tobuf(L);
  55. lj_bufx_reset(sbx);
  56. L->top = L->base+1; /* Chain buffer object. */
  57. return 1;
  58. }
  59. LJLIB_CF(buffer_method_skip) LJLIB_REC(.)
  60. {
  61. SBufExt *sbx = buffer_tobuf(L);
  62. MSize n = (MSize)lj_lib_checkintrange(L, 2, 0, LJ_MAX_BUF);
  63. MSize len = sbufxlen(sbx);
  64. if (n < len) {
  65. sbx->r += n;
  66. } else {
  67. sbx->r = sbx->w = sbx->b;
  68. }
  69. L->top = L->base+1; /* Chain buffer object. */
  70. return 1;
  71. }
  72. LJLIB_CF(buffer_method_set) LJLIB_REC(.)
  73. {
  74. SBufExt *sbx = buffer_tobuf(L);
  75. GCobj *ref;
  76. const char *p;
  77. MSize len;
  78. #if LJ_HASFFI
  79. if (tviscdata(L->base+1)) {
  80. CTState *cts = ctype_cts(L);
  81. lj_cconv_ct_tv(cts, ctype_get(cts, CTID_P_CVOID), (uint8_t *)&p,
  82. L->base+1, CCF_ARG(2));
  83. len = (MSize)lj_lib_checkintrange(L, 3, 0, LJ_MAX_BUF);
  84. } else
  85. #endif
  86. {
  87. GCstr *str = lj_lib_checkstrx(L, 2);
  88. p = strdata(str);
  89. len = str->len;
  90. }
  91. lj_bufx_free(L, sbx);
  92. lj_bufx_set_cow(L, sbx, p, len);
  93. ref = gcV(L->base+1);
  94. setgcref(sbx->cowref, ref);
  95. lj_gc_objbarrier(L, buffer_toudata(sbx), ref);
  96. L->top = L->base+1; /* Chain buffer object. */
  97. return 1;
  98. }
  99. LJLIB_CF(buffer_method_put) LJLIB_REC(.)
  100. {
  101. SBufExt *sbx = buffer_tobufw(L);
  102. ptrdiff_t arg, narg = L->top - L->base;
  103. for (arg = 1; arg < narg; arg++) {
  104. cTValue *o = &L->base[arg], *mo = NULL;
  105. retry:
  106. if (tvisstr(o)) {
  107. lj_buf_putstr((SBuf *)sbx, strV(o));
  108. } else if (tvisint(o)) {
  109. lj_strfmt_putint((SBuf *)sbx, intV(o));
  110. } else if (tvisnum(o)) {
  111. lj_strfmt_putfnum((SBuf *)sbx, STRFMT_G14, numV(o));
  112. } else if (tvisbuf(o)) {
  113. SBufExt *sbx2 = bufV(o);
  114. if (sbx2 == sbx) lj_err_arg(L, arg+1, LJ_ERR_BUFFER_SELF);
  115. lj_buf_putmem((SBuf *)sbx, sbx2->r, sbufxlen(sbx2));
  116. } else if (!mo && !tvisnil(mo = lj_meta_lookup(L, o, MM_tostring))) {
  117. /* Call __tostring metamethod inline. */
  118. copyTV(L, L->top++, mo);
  119. copyTV(L, L->top++, o);
  120. lua_call(L, 1, 1);
  121. o = &L->base[arg]; /* The stack may have been reallocated. */
  122. copyTV(L, &L->base[arg], L->top-1);
  123. L->top = L->base + narg;
  124. goto retry; /* Retry with the result. */
  125. } else {
  126. lj_err_argtype(L, arg+1, "string/number/__tostring");
  127. }
  128. /* Probably not useful to inline other __tostring MMs, e.g. FFI numbers. */
  129. }
  130. L->top = L->base+1; /* Chain buffer object. */
  131. lj_gc_check(L);
  132. return 1;
  133. }
  134. LJLIB_CF(buffer_method_putf) LJLIB_REC(.)
  135. {
  136. SBufExt *sbx = buffer_tobufw(L);
  137. lj_strfmt_putarg(L, (SBuf *)sbx, 2, 2);
  138. L->top = L->base+1; /* Chain buffer object. */
  139. lj_gc_check(L);
  140. return 1;
  141. }
  142. LJLIB_CF(buffer_method_get) LJLIB_REC(.)
  143. {
  144. SBufExt *sbx = buffer_tobuf(L);
  145. ptrdiff_t arg, narg = L->top - L->base;
  146. if (narg == 1) {
  147. narg++;
  148. setnilV(L->top++); /* get() is the same as get(nil). */
  149. }
  150. for (arg = 1; arg < narg; arg++) {
  151. TValue *o = &L->base[arg];
  152. MSize n = tvisnil(o) ? LJ_MAX_BUF :
  153. (MSize) lj_lib_checkintrange(L, arg+1, 0, LJ_MAX_BUF);
  154. MSize len = sbufxlen(sbx);
  155. if (n > len) n = len;
  156. setstrV(L, o, lj_str_new(L, sbx->r, n));
  157. sbx->r += n;
  158. }
  159. if (sbx->r == sbx->w) sbx->r = sbx->w = sbx->b;
  160. lj_gc_check(L);
  161. return narg-1;
  162. }
  163. #if LJ_HASFFI
  164. LJLIB_CF(buffer_method_putcdata) LJLIB_REC(.)
  165. {
  166. SBufExt *sbx = buffer_tobufw(L);
  167. const char *p;
  168. MSize len;
  169. if (tviscdata(L->base+1)) {
  170. CTState *cts = ctype_cts(L);
  171. lj_cconv_ct_tv(cts, ctype_get(cts, CTID_P_CVOID), (uint8_t *)&p,
  172. L->base+1, CCF_ARG(2));
  173. } else {
  174. lj_err_argtype(L, 2, "cdata");
  175. }
  176. len = (MSize)lj_lib_checkintrange(L, 3, 0, LJ_MAX_BUF);
  177. lj_buf_putmem((SBuf *)sbx, p, len);
  178. L->top = L->base+1; /* Chain buffer object. */
  179. return 1;
  180. }
  181. LJLIB_CF(buffer_method_reserve) LJLIB_REC(.)
  182. {
  183. SBufExt *sbx = buffer_tobufw(L);
  184. MSize sz = (MSize)lj_lib_checkintrange(L, 2, 0, LJ_MAX_BUF);
  185. GCcdata *cd;
  186. lj_buf_more((SBuf *)sbx, sz);
  187. ctype_loadffi(L);
  188. cd = lj_cdata_new_(L, CTID_P_UINT8, CTSIZE_PTR);
  189. *(void **)cdataptr(cd) = sbx->w;
  190. setcdataV(L, L->top++, cd);
  191. setintV(L->top++, sbufleft(sbx));
  192. return 2;
  193. }
  194. LJLIB_CF(buffer_method_commit) LJLIB_REC(.)
  195. {
  196. SBufExt *sbx = buffer_tobuf(L);
  197. MSize len = (MSize)lj_lib_checkintrange(L, 2, 0, LJ_MAX_BUF);
  198. if (len > sbufleft(sbx)) lj_err_arg(L, 2, LJ_ERR_NUMRNG);
  199. sbx->w += len;
  200. L->top = L->base+1; /* Chain buffer object. */
  201. return 1;
  202. }
  203. LJLIB_CF(buffer_method_ref) LJLIB_REC(.)
  204. {
  205. SBufExt *sbx = buffer_tobuf(L);
  206. GCcdata *cd;
  207. ctype_loadffi(L);
  208. cd = lj_cdata_new_(L, CTID_P_UINT8, CTSIZE_PTR);
  209. *(void **)cdataptr(cd) = sbx->r;
  210. setcdataV(L, L->top++, cd);
  211. setintV(L->top++, sbufxlen(sbx));
  212. return 2;
  213. }
  214. #endif
  215. LJLIB_CF(buffer_method_encode) LJLIB_REC(.)
  216. {
  217. SBufExt *sbx = buffer_tobufw(L);
  218. cTValue *o = lj_lib_checkany(L, 2);
  219. lj_serialize_put(sbx, o);
  220. lj_gc_check(L);
  221. L->top = L->base+1; /* Chain buffer object. */
  222. return 1;
  223. }
  224. LJLIB_CF(buffer_method_decode) LJLIB_REC(.)
  225. {
  226. SBufExt *sbx = buffer_tobufw(L);
  227. setnilV(L->top++);
  228. sbx->r = lj_serialize_get(sbx, L->top-1);
  229. lj_gc_check(L);
  230. return 1;
  231. }
  232. LJLIB_CF(buffer_method___gc)
  233. {
  234. SBufExt *sbx = buffer_tobuf(L);
  235. lj_bufx_free(L, sbx);
  236. return 0;
  237. }
  238. LJLIB_CF(buffer_method___tostring) LJLIB_REC(.)
  239. {
  240. SBufExt *sbx = buffer_tobuf(L);
  241. setstrV(L, L->top-1, lj_str_new(L, sbx->r, sbufxlen(sbx)));
  242. lj_gc_check(L);
  243. return 1;
  244. }
  245. LJLIB_CF(buffer_method___len) LJLIB_REC(.)
  246. {
  247. SBufExt *sbx = buffer_tobuf(L);
  248. setintV(L->top-1, (int32_t)sbufxlen(sbx));
  249. return 1;
  250. }
  251. LJLIB_PUSH("buffer") LJLIB_SET(__metatable)
  252. LJLIB_PUSH(top-1) LJLIB_SET(__index)
  253. /* -- Buffer library functions -------------------------------------------- */
  254. #define LJLIB_MODULE_buffer
  255. LJLIB_PUSH(top-2) LJLIB_SET(!) /* Set environment. */
  256. LJLIB_CF(buffer_new)
  257. {
  258. MSize sz = 0;
  259. int targ = 1;
  260. GCtab *env, *dict_str = NULL, *dict_mt = NULL;
  261. GCudata *ud;
  262. SBufExt *sbx;
  263. if (L->base < L->top && !tvistab(L->base)) {
  264. targ = 2;
  265. if (!tvisnil(L->base))
  266. sz = (MSize)lj_lib_checkintrange(L, 1, 0, LJ_MAX_BUF);
  267. }
  268. if (L->base+targ-1 < L->top) {
  269. GCtab *options = lj_lib_checktab(L, targ);
  270. cTValue *opt_dict, *opt_mt;
  271. opt_dict = lj_tab_getstr(options, lj_str_newlit(L, "dict"));
  272. if (opt_dict && tvistab(opt_dict)) {
  273. dict_str = tabV(opt_dict);
  274. lj_serialize_dict_prep_str(L, dict_str);
  275. }
  276. opt_mt = lj_tab_getstr(options, lj_str_newlit(L, "metatable"));
  277. if (opt_mt && tvistab(opt_mt)) {
  278. dict_mt = tabV(opt_mt);
  279. lj_serialize_dict_prep_mt(L, dict_mt);
  280. }
  281. }
  282. env = tabref(curr_func(L)->c.env);
  283. ud = lj_udata_new(L, sizeof(SBufExt), env);
  284. ud->udtype = UDTYPE_BUFFER;
  285. /* NOBARRIER: The GCudata is new (marked white). */
  286. setgcref(ud->metatable, obj2gco(env));
  287. setudataV(L, L->top++, ud);
  288. sbx = (SBufExt *)uddata(ud);
  289. lj_bufx_init(L, sbx);
  290. setgcref(sbx->dict_str, obj2gco(dict_str));
  291. setgcref(sbx->dict_mt, obj2gco(dict_mt));
  292. if (sz > 0) lj_buf_need2((SBuf *)sbx, sz);
  293. return 1;
  294. }
  295. LJLIB_CF(buffer_encode) LJLIB_REC(.)
  296. {
  297. cTValue *o = lj_lib_checkany(L, 1);
  298. setstrV(L, L->top++, lj_serialize_encode(L, o));
  299. lj_gc_check(L);
  300. return 1;
  301. }
  302. LJLIB_CF(buffer_decode) LJLIB_REC(.)
  303. {
  304. GCstr *str = lj_lib_checkstrx(L, 1);
  305. setnilV(L->top++);
  306. lj_serialize_decode(L, L->top-1, str);
  307. return 1;
  308. }
  309. /* ------------------------------------------------------------------------ */
  310. #include "lj_libdef.h"
  311. int luaopen_string_buffer(lua_State *L)
  312. {
  313. LJ_LIB_REG(L, NULL, buffer_method);
  314. lua_getfield(L, -1, "__tostring");
  315. lua_setfield(L, -2, "tostring");
  316. LJ_LIB_REG(L, NULL, buffer);
  317. return 1;
  318. }
  319. #endif