123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911 |
- #ifdef __cplusplus
- extern "C" {
- #endif
- #include "lua.h"
- #include "lualib.h"
- #include "lauxlib.h"
- #ifdef __cplusplus
- }
- #endif
- #if defined(__APPLE__)
- #include <malloc/malloc.h>
- #else
- #include <malloc.h>
- #endif
- #ifndef _MSC_VER
- #include <stdbool.h>
- #else
- #define alloca _alloca
- #endif
- #include <string.h>
- #include <stdlib.h>
- #include <stdint.h>
- #include "pbc.h"
- static inline void *
- checkuserdata(lua_State *L, int index) {
- void * ud = lua_touserdata(L,index);
- if (ud == NULL) {
- luaL_error(L, "userdata %d is nil",index);
- }
- return ud;
- }
- static int
- _env_new(lua_State *L) {
- struct pbc_env * env = pbc_new();
- lua_pushlightuserdata(L, env);
- return 1;
- }
- static int
- _env_register(lua_State *L) {
- struct pbc_env * env = (struct pbc_env *)checkuserdata(L,1);
- size_t sz = 0;
- const char * buffer = luaL_checklstring(L, 2 , &sz);
- struct pbc_slice slice;
- slice.buffer = (void *)buffer;
- slice.len = (int)sz;
- int ret = pbc_register(env, &slice);
- if (ret) {
- return luaL_error(L, "register fail");
- }
- return 0;
- }
- static int
- _env_enum_id(lua_State *L) {
- struct pbc_env * env = (struct pbc_env *)checkuserdata(L,1);
- size_t sz = 0;
- const char* enum_type = luaL_checklstring(L, 2, &sz);
- const char* enum_name = luaL_checklstring(L, 3, &sz);
- int32_t enum_id = pbc_enum_id(env, enum_type, enum_name);
- if (enum_id < 0)
- return 0;
- lua_pushinteger(L, enum_id);
- return 1;
- }
- static int
- _rmessage_new(lua_State *L) {
- struct pbc_env * env = (struct pbc_env *)checkuserdata(L,1);
- const char * type_name = luaL_checkstring(L,2);
- struct pbc_slice slice;
- if (lua_isstring(L,3)) {
- size_t sz = 0;
- slice.buffer = (void *)lua_tolstring(L,3,&sz);
- slice.len = (int)sz;
- } else {
- slice.buffer = lua_touserdata(L,3);
- slice.len = luaL_checkinteger(L,4);
- }
- struct pbc_rmessage * m = pbc_rmessage_new(env, type_name, &slice);
- if (m==NULL)
- return 0;
- lua_pushlightuserdata(L,m);
- return 1;
- }
- static int
- _rmessage_delete(lua_State *L) {
- struct pbc_rmessage * m = (struct pbc_rmessage *)checkuserdata(L,1);
- pbc_rmessage_delete(m);
- return 0;
- }
- static int
- _rmessage_int(lua_State *L) {
- struct pbc_rmessage * m = (struct pbc_rmessage *)checkuserdata(L,1);
- const char * key = luaL_checkstring(L,2);
- int index = luaL_checkinteger(L,3);
- uint32_t hi,low;
- low = pbc_rmessage_integer(m, key, index, &hi);
- int64_t v = (int64_t)((uint64_t)hi << 32 | (uint64_t)low);
- lua_pushinteger(L,v);
- return 1;
- }
- static int
- _rmessage_real(lua_State *L) {
- struct pbc_rmessage * m = (struct pbc_rmessage *)checkuserdata(L,1);
- const char * key = luaL_checkstring(L,2);
- int index = luaL_checkinteger(L,3);
- double v = pbc_rmessage_real(m, key, index);
- lua_pushnumber(L,v);
- return 1;
- }
- static int
- _rmessage_string(lua_State *L) {
- struct pbc_rmessage * m = (struct pbc_rmessage *)checkuserdata(L,1);
- const char * key = luaL_checkstring(L,2);
- int index = lua_tointeger(L,3);
- int sz = 0;
- const char * v = pbc_rmessage_string(m,key,index,&sz);
- lua_pushlstring(L,v,sz);
- return 1;
- }
- static int
- _rmessage_message(lua_State *L) {
- struct pbc_rmessage * m = (struct pbc_rmessage *)checkuserdata(L,1);
- const char * key = luaL_checkstring(L,2);
- int index = lua_tointeger(L,3);
- struct pbc_rmessage * v = pbc_rmessage_message(m,key,index);
- lua_pushlightuserdata(L,v);
- return 1;
- }
- static int
- _rmessage_size(lua_State *L) {
- struct pbc_rmessage * m = (struct pbc_rmessage *)checkuserdata(L,1);
- const char * key = luaL_checkstring(L,2);
- int sz = pbc_rmessage_size(m, key);
- lua_pushinteger(L, sz);
- return 1;
- }
- static int
- _env_type(lua_State *L) {
- lua_settop(L,3);
- struct pbc_env * env = (struct pbc_env *)checkuserdata(L,1);
- const char * type_name = luaL_checkstring(L,2);
- if (lua_isnil(L,3)) {
- int ret = pbc_type(env, type_name, NULL, NULL);
- lua_pushboolean(L,ret);
- return 1;
- }
- const char * key = luaL_checkstring(L,3);
- const char * type = NULL;
- int ret = pbc_type(env, type_name, key, &type);
- lua_pushinteger(L,ret);
- if (type == NULL) {
- return 1;
- } {
- lua_pushstring(L, type);
- return 2;
- }
- }
- static int
- _wmessage_new(lua_State *L) {
- struct pbc_env * env = (struct pbc_env *)checkuserdata(L,1);
- const char * type_name = luaL_checkstring(L,2);
- struct pbc_wmessage * ret = pbc_wmessage_new(env, type_name);
- lua_pushlightuserdata(L,ret);
- return 1;
- }
- static int
- _wmessage_delete(lua_State *L) {
- struct pbc_wmessage * m = (struct pbc_wmessage *)lua_touserdata(L,1);
- pbc_wmessage_delete(m);
- return 0;
- }
- static int
- _wmessage_real(lua_State *L) {
- struct pbc_wmessage * m = (struct pbc_wmessage *)checkuserdata(L,1);
- const char * key = luaL_checkstring(L,2);
- double number = luaL_checknumber(L,3);
- pbc_wmessage_real(m, key, number);
- return 0;
- }
- static int
- _wmessage_string(lua_State *L) {
- struct pbc_wmessage * m = (struct pbc_wmessage *)checkuserdata(L,1);
- const char * key = luaL_checkstring(L,2);
- size_t len = 0;
- const char * v = luaL_checklstring(L,3,&len);
- int err = pbc_wmessage_string(m, key, v, (int)len);
- if (err) {
- return luaL_error(L, "Write string error : %s", v);
- }
- return 0;
- }
- static int
- _wmessage_message(lua_State *L) {
- struct pbc_wmessage * m = (struct pbc_wmessage *)checkuserdata(L,1);
- const char * key = luaL_checkstring(L,2);
- struct pbc_wmessage * ret = pbc_wmessage_message(m, key);
- lua_pushlightuserdata(L, ret);
- return 1;
- }
- static int
- _wmessage_int(lua_State *L) {
- struct pbc_wmessage * m = (struct pbc_wmessage *)checkuserdata(L,1);
- const char * key = luaL_checkstring(L,2);
- int64_t number;
- // compat float for some historical reasons.
- if (lua_isinteger(L, 3)) {
- number = lua_tointeger(L,3);
- } else {
- number = (int64_t)lua_tonumber(L,3);
- }
- uint32_t hi = (uint32_t)(number >> 32);
- pbc_wmessage_integer(m, key, (uint32_t)number, hi);
- return 0;
- }
- static int
- _wmessage_buffer(lua_State *L) {
- struct pbc_slice slice;
- struct pbc_wmessage * m = (struct pbc_wmessage *)checkuserdata(L,1);
- pbc_wmessage_buffer(m , &slice);
- lua_pushlightuserdata(L, slice.buffer);
- lua_pushinteger(L, slice.len);
- return 2;
- }
- static int
- _wmessage_buffer_string(lua_State *L) {
- struct pbc_slice slice;
- struct pbc_wmessage * m = (struct pbc_wmessage *)checkuserdata(L,1);
- pbc_wmessage_buffer(m , &slice);
- lua_pushlstring(L, (const char *)slice.buffer, slice.len);
- return 1;
- }
- /*
- lightuserdata env
- */
- static int
- _last_error(lua_State *L) {
- struct pbc_env * env = (struct pbc_env *)checkuserdata(L, 1);
- const char * err = pbc_error(env);
- lua_pushstring(L,err);
- return 1;
- }
- /*
- lightuserdata env
- string message
- string format
- */
- static int
- _pattern_new(lua_State *L) {
- struct pbc_env * env = (struct pbc_env *)checkuserdata(L, 1);
- const char * message = luaL_checkstring(L,2);
- const char * format = luaL_checkstring(L,3);
- struct pbc_pattern * pat = pbc_pattern_new(env, message, format);
- if (pat == NULL) {
- return luaL_error(L, "create patten %s (%s) failed", message , format);
- }
- lua_pushlightuserdata(L,pat);
- return 1;
- }
- static int
- _pattern_delete(lua_State *L) {
- struct pbc_pattern * pat = (struct pbc_pattern *)lua_touserdata(L,1);
- pbc_pattern_delete(pat);
-
- return 0;
- }
- static void *
- _push_value(lua_State *L, char * ptr, char type) {
- switch(type) {
- case 'd': {
- uint64_t v = *(uint64_t*)ptr;
- ptr += 8;
- lua_pushinteger(L, v);
- break;
- }
- case 'i': {
- int32_t v = *(int32_t*)ptr;
- ptr += 4;
- lua_pushinteger(L,v);
- break;
- }
- case 'b': {
- int32_t v = *(int32_t*)ptr;
- ptr += 4;
- lua_pushboolean(L,v);
- break;
- }
- case 'r': {
- double v = *(double *)ptr;
- ptr += 8;
- lua_pushnumber(L,v);
- break;
- }
- case 's': {
- struct pbc_slice * slice = (struct pbc_slice *)ptr;
- lua_pushlstring(L,(const char *)slice->buffer, slice->len);
- ptr += sizeof(struct pbc_slice);
- break;
- }
- case 'm': {
- struct pbc_slice * slice = (struct pbc_slice *)ptr;
- lua_createtable(L,2,0);
- lua_pushlightuserdata(L, slice->buffer);
- lua_rawseti(L,-2,1);
- lua_pushinteger(L,slice->len);
- lua_rawseti(L,-2,2);
- ptr += sizeof(struct pbc_slice);
- break;
- }
- }
- return ptr;
- }
- static void
- _push_array(lua_State *L, pbc_array array, char type, int index) {
- switch (type) {
- case 'I': {
- int v = pbc_array_integer(array, index, NULL);
- lua_pushinteger(L, v);
- break;
- }
- case 'D': {
- uint32_t hi = 0;
- uint32_t low = pbc_array_integer(array, index, &hi);
- uint64_t v = (uint64_t)hi << 32 | (uint64_t)low;
- lua_pushinteger(L, v);
- break;
- }
- case 'B': {
- int v = pbc_array_integer(array, index, NULL);
- lua_pushboolean(L, v);
- break;
- }
- case 'X': {
- uint32_t hi = 0;
- uint32_t low = pbc_array_integer(array, index, &hi);
- uint64_t v = (uint64_t)low | (uint64_t)hi << 32;
- lua_pushlstring(L, (char *)&v, 8);
- break;
- }
- case 'R': {
- double v = pbc_array_real(array, index);
- lua_pushnumber(L, v);
- break;
- }
- case 'S': {
- struct pbc_slice * slice = pbc_array_slice(array, index);
- lua_pushlstring(L, (const char *)slice->buffer,slice->len);
- break;
- }
- case 'M': {
- struct pbc_slice * slice = pbc_array_slice(array, index);
- lua_createtable(L,2,0);
- lua_pushlightuserdata(L,slice->buffer);
- lua_rawseti(L,-2,1);
- lua_pushinteger(L,slice->len);
- lua_rawseti(L,-2,2);
- break;
- }
- }
- lua_rawseti(L,-2,index+1);
- }
- /*
- lightuserdata pattern
- string format "ixrsmb"
- integer size
- lightuserdata buffer
- integer buffer_len
- */
- static int
- _pattern_unpack(lua_State *L) {
- struct pbc_pattern * pat = (struct pbc_pattern *)checkuserdata(L, 1);
- if (pat == NULL) {
- return luaL_error(L, "unpack pattern is NULL");
- }
- size_t format_sz = 0;
- const char * format = lua_tolstring(L,2,&format_sz);
- int size = lua_tointeger(L,3);
- struct pbc_slice slice;
- if (lua_isstring(L,4)) {
- size_t buffer_len = 0;
- const char *buffer = luaL_checklstring(L,4,&buffer_len);
- slice.buffer = (void *)buffer;
- slice.len = buffer_len;
- } else {
- if (!lua_isuserdata(L,4)) {
- return luaL_error(L, "Need a userdata");
- }
- slice.buffer = lua_touserdata(L,4);
- slice.len = luaL_checkinteger(L,5);
- }
-
- char * temp = (char *)alloca(size);
- int ret = pbc_pattern_unpack(pat, &slice, temp);
- if (ret < 0) {
- return 0;
- }
- lua_checkstack(L, format_sz + 3);
- int i;
- char * ptr = temp;
- bool array = false;
- for (i=0;i<format_sz;i++) {
- char type = format[i];
- if (type >= 'a' && type <='z') {
- ptr = (char *)_push_value(L,ptr,type);
- } else {
- array = true;
- int n = pbc_array_size((struct _pbc_array *)ptr);
- lua_createtable(L,n,0);
- int j;
- for (j=0;j<n;j++) {
- _push_array(L,(struct _pbc_array *)ptr, type, j);
- }
- ptr += sizeof(pbc_array);
- }
- }
- if (array) {
- pbc_pattern_close_arrays(pat, temp);
- }
- return format_sz;
- }
- static char *
- _get_value(lua_State *L, int index, char * ptr, char type) {
- switch(type) {
- case 'i': {
- int32_t v = luaL_checkinteger(L, index);
- memcpy(ptr, &v, 4);
- return ptr + 4;
- }
- case 'd': {
- int64_t v = (int64_t)luaL_checkinteger(L, index);
- memcpy(ptr, &v, 8);
- return ptr + 8;
- }
- case 'b': {
- int32_t v = lua_toboolean(L, index);
- memcpy(ptr, &v, 4);
- return ptr + 4;
- }
- case 'r': {
- double v = luaL_checknumber(L, index);
- memcpy(ptr, &v, 8);
- return ptr + 8;
- }
- case 's': {
- size_t sz = 0;
- const char * str = luaL_checklstring(L, index, &sz);
- struct pbc_slice * slice = (struct pbc_slice *)ptr;
- slice->buffer = (void*)str;
- slice->len = sz;
- return ptr + sizeof(struct pbc_slice);
- }
- case 'm': {
- struct pbc_slice * slice = (struct pbc_slice *)ptr;
- if (lua_istable(L,index)) {
- lua_rawgeti(L,index,1);
- slice->buffer = lua_touserdata(L,-1);
- lua_rawgeti(L,index,2);
- slice->len = lua_tointeger(L,-1);
- lua_pop(L,2);
- } else {
- size_t sz = 0;
- const char * buffer = luaL_checklstring(L, index, &sz);
- slice->buffer = (void *)buffer;
- slice->len = sz;
- }
- return ptr + sizeof(struct pbc_slice);
- }
- default:
- luaL_error(L,"unknown format %c", type);
- return ptr;
- }
- }
- static void
- _get_array_value(lua_State *L, pbc_array array, char type) {
- switch(type) {
- case 'I': {
- int32_t v = luaL_checkinteger(L, -1);
- uint32_t hi = 0;
- if (v<0) {
- hi = ~0;
- }
- pbc_array_push_integer(array, v, hi);
- break;
- }
- case 'D' : {
- uint64_t v = (uint64_t)luaL_checknumber(L, -1);
- pbc_array_push_integer(array, (uint32_t)v, (uint32_t)(v >> 32));
- break;
- }
- case 'B': {
- int32_t v = lua_toboolean(L, -1);
- pbc_array_push_integer(array, v ? 1: 0, 0);
- break;
- }
- case 'R': {
- double v = luaL_checknumber(L, -1);
- pbc_array_push_real(array, v);
- break;
- }
- case 'S': {
- size_t sz = 0;
- const char * str = luaL_checklstring(L, -1, &sz);
- struct pbc_slice slice;
- slice.buffer = (void*)str;
- slice.len = sz;
- pbc_array_push_slice(array, &slice);
- break;
- }
- case 'M': {
- struct pbc_slice slice;
- if (lua_istable(L,-1)) {
- lua_rawgeti(L,-1,1);
- slice.buffer = lua_touserdata(L,-1);
- lua_rawgeti(L,-2,2);
- slice.len = lua_tointeger(L,-1);
- lua_pop(L,2);
- } else {
- size_t sz = 0;
- const char * buffer = luaL_checklstring(L, -1, &sz);
- slice.buffer = (void *)buffer;
- slice.len = sz;
- }
- pbc_array_push_slice(array, &slice);
- break;
- }
- }
- }
- /*
- lightuserdata pattern
- string format "ixrsmbp"
- integer size
- */
- static int
- _pattern_pack(lua_State *L) {
- struct pbc_pattern * pat = (struct pbc_pattern *)checkuserdata(L,1);
- if (pat == NULL) {
- return luaL_error(L, "pack pattern is NULL");
- }
- size_t format_sz = 0;
- const char * format = lua_tolstring(L,2,&format_sz);
- int size = lua_tointeger(L,3);
- char * data = (char *)alloca(size);
- // A trick , we don't need default value. zero buffer for array and message field.
- // pbc_pattern_set_default(pat, data);
- memset(data, 0 , size);
- char * ptr = data;
- int i;
- for (i=0;i<format_sz;i++) {
- if (format[i] >= 'a' && format[i] <='z') {
- ptr = _get_value(L, 4+i, ptr, format[i]);
- } else {
- if (!lua_istable(L,4+i)) {
- luaL_error(L,"need table for array type");
- }
- int j;
- int n = lua_rawlen(L,4+i);
- for (j=0;j<n;j++) {
- lua_rawgeti(L,4+i,j+1);
- _get_array_value(L,(struct _pbc_array *)ptr,format[i]);
- lua_pop(L,1);
- }
- ptr += sizeof(pbc_array);
- }
- }
- luaL_Buffer b;
- luaL_buffinit(L, &b);
- int cap = 128;
- for (;;) {
- char * temp = (char *)luaL_prepbuffsize(&b , cap);
- struct pbc_slice slice;
- slice.buffer = temp;
- slice.len = cap;
- int ret = pbc_pattern_pack(pat, data, &slice);
- if (ret < 0) {
- cap = cap * 2;
- continue;
- }
- luaL_addsize(&b , slice.len);
- break;
- }
- luaL_pushresult(&b);
- pbc_pattern_close_arrays(pat, data);
- return 1;
- }
- static int
- _pattern_size(lua_State *L) {
- size_t sz =0;
- const char *format = luaL_checklstring(L,1,&sz);
- int i;
- int size = 0;
- for (i=0;i<sz;i++) {
- switch(format[i]) {
- case 'b':
- case 'i':
- size += 4;
- break;
- case 'r':
- case 'd':
- size += 8;
- break;
- case 's':
- case 'm':
- size += sizeof(struct pbc_slice);
- break;
- default:
- size += sizeof(pbc_array);
- break;
- }
- }
- lua_pushinteger(L,size);
- return 1;
- }
- /*
- -3 table key
- -2 table id
- -1 value
- */
- static void
- new_array(lua_State *L, int id, const char *key) {
- lua_rawgeti(L, -2 , id);
- if (lua_isnil(L, -1)) {
- lua_pop(L,1);
- lua_newtable(L); // table.key table.id value array
- lua_pushvalue(L,-1);
- lua_pushvalue(L,-1); // table.key table.id value array array array
- lua_setfield(L, -6 , key);
- lua_rawseti(L, -4, id);
- }
- }
- static void
- push_value(lua_State *L, int type, const char * type_name, union pbc_value *v) {
- switch(type) {
- case PBC_FIXED32:
- case PBC_INT:
- lua_pushinteger(L, (int)v->i.low);
- break;
- case PBC_REAL:
- lua_pushnumber(L, v->f);
- break;
- case PBC_BOOL:
- lua_pushboolean(L, v->i.low);
- break;
- case PBC_ENUM:
- lua_pushstring(L, v->e.name);
- break;
- case PBC_BYTES:
- case PBC_STRING:
- lua_pushlstring(L, (const char *)v->s.buffer , v->s.len);
- break;
- case PBC_MESSAGE:
- lua_pushvalue(L, -3);
- lua_pushstring(L, type_name);
- lua_pushlstring(L, (const char *)v->s.buffer , v->s.len);
- lua_call(L, 2 , 1);
- break;
- case PBC_FIXED64:
- case PBC_UINT:
- case PBC_INT64: {
- uint64_t v64 = (uint64_t)(v->i.hi) << 32 | (uint64_t)(v->i.low);
- lua_pushinteger(L,v64);
- break;
- }
- default:
- luaL_error(L, "Unknown type %s", type_name);
- break;
- }
- }
- /*
- -3: function decode
- -2: table key
- -1: table id
- */
- static void
- decode_cb(void *ud, int type, const char * type_name, union pbc_value *v, int id, const char *key) {
- lua_State *L = (lua_State *)ud;
- if (key == NULL) {
- // undefined field
- return;
- }
- if (type & PBC_REPEATED) {
- push_value(L, type & ~PBC_REPEATED, type_name, v);
- new_array(L, id , key); // func.decode table.key table.id value array
- int n = lua_rawlen(L,-1);
- lua_insert(L, -2); // func.decode table.key table.id array value
- lua_rawseti(L, -2 , n+1); // func.decode table.key table.id array
- lua_pop(L,1);
- } else {
- push_value(L, type, type_name, v);
- lua_setfield(L, -3 , key);
- }
- }
- /*
- :1 lightuserdata env
- :2 function decode_message
- :3 table target
- :4 string type
- :5 string data
- :5 lightuserdata pointer
- :6 integer len
- table
- */
- static int
- _decode(lua_State *L) {
- struct pbc_env * env = (struct pbc_env *)checkuserdata(L,1);
- luaL_checktype(L, 2 , LUA_TFUNCTION);
- luaL_checktype(L, 3 , LUA_TTABLE);
- const char * type = luaL_checkstring(L,4);
- struct pbc_slice slice;
- if (lua_type(L,5) == LUA_TSTRING) {
- size_t len;
- slice.buffer = (void *)luaL_checklstring(L,5,&len);
- slice.len = (int)len;
- } else {
- slice.buffer = checkuserdata(L,5);
- slice.len = luaL_checkinteger(L,6);
- }
- lua_pushvalue(L, 2);
- lua_pushvalue(L, 3);
- lua_newtable(L);
- int n = pbc_decode(env, type, &slice, decode_cb, L);
- if (n<0) {
- lua_pushboolean(L,0);
- } else {
- lua_pushboolean(L,1);
- }
- return 1;
- }
- struct gcobj {
- struct pbc_env * env;
- int size_pat;
- int cap_pat;
- struct pbc_pattern ** pat;
- int size_msg;
- int cap_msg;
- struct pbc_rmessage ** msg;
- };
- static int
- _clear_gcobj(lua_State *L) {
- struct gcobj * obj = (struct gcobj *)lua_touserdata(L,1);
- int i;
- for (i=0;i<obj->size_pat;i++) {
- pbc_pattern_delete(obj->pat[i]);
- }
- for (i=0;i<obj->size_msg;i++) {
- pbc_rmessage_delete(obj->msg[i]);
- }
- free(obj->pat);
- free(obj->msg);
- obj->pat = NULL;
- obj->msg = NULL;
- if (obj->env) {
- pbc_delete(obj->env);
- obj->env = NULL;
- }
- return 0;
- }
- static int
- _gc(lua_State *L) {
- struct gcobj * obj;
- lua_settop(L,1);
- obj = (struct gcobj *)lua_newuserdata(L,sizeof(*obj));
- obj->env = (struct pbc_env *)lua_touserdata(L,1);
- obj->size_pat = 0;
- obj->cap_pat = 4;
- obj->size_msg = 0;
- obj->cap_msg = 4;
- obj->pat = (struct pbc_pattern **)malloc(obj->cap_pat * sizeof(struct pbc_pattern *));
- obj->msg = (struct pbc_rmessage **)malloc(obj->cap_msg * sizeof(struct pbc_rmessage *));
- lua_createtable(L,0,1);
- lua_pushcfunction(L, _clear_gcobj);
- lua_setfield(L,-2,"__gc");
- lua_setmetatable(L,-2);
- return 1;
- }
- static int
- _add_pattern(lua_State *L) {
- struct gcobj * obj = (struct gcobj *)lua_touserdata(L,1);
- if (obj->size_pat >= obj->cap_pat) {
- obj->cap_pat *= 2;
- obj->pat = (struct pbc_pattern **)realloc(obj->pat, obj->cap_pat * sizeof(struct pbc_pattern *));
- }
- struct pbc_pattern * pat = (struct pbc_pattern *)lua_touserdata(L,2);
- obj->pat[obj->size_pat++] = pat;
- return 0;
- }
- static int
- _add_rmessage(lua_State *L) {
- struct gcobj * obj = (struct gcobj *)lua_touserdata(L,1);
- if (obj->size_msg >= obj->cap_msg) {
- obj->cap_msg *= 2;
- obj->msg = (struct pbc_rmessage **)realloc(obj->msg, obj->cap_msg * sizeof(struct pbc_rmessage *));
- }
- struct pbc_rmessage * msg = (struct pbc_rmessage *)lua_touserdata(L,2);
- obj->msg[obj->size_msg++] = msg;
- return 0;
- }
- int
- luaopen_protobuf_c(lua_State *L) {
- luaL_Reg reg[] = {
- {"_env_new" , _env_new },
- {"_env_register" , _env_register },
- {"_env_type", _env_type },
- {"_rmessage_new" , _rmessage_new },
- {"_rmessage_delete" , _rmessage_delete },
- {"_rmessage_int", _rmessage_int },
- {"_rmessage_real" , _rmessage_real },
- {"_rmessage_string" , _rmessage_string },
- {"_rmessage_message" , _rmessage_message },
- {"_rmessage_size" , _rmessage_size },
- {"_wmessage_new", _wmessage_new },
- {"_wmessage_delete", _wmessage_delete },
- {"_wmessage_real", _wmessage_real },
- {"_wmessage_string", _wmessage_string },
- {"_wmessage_message", _wmessage_message },
- {"_wmessage_int", _wmessage_int },
- {"_wmessage_buffer", _wmessage_buffer },
- {"_wmessage_buffer_string", _wmessage_buffer_string },
- {"_pattern_new", _pattern_new },
- {"_pattern_delete", _pattern_delete },
- {"_pattern_size", _pattern_size },
- {"_pattern_unpack", _pattern_unpack },
- {"_pattern_pack", _pattern_pack },
- {"_last_error", _last_error },
- {"_decode", _decode },
- {"_gc", _gc },
- {"_add_pattern", _add_pattern },
- {"_add_rmessage", _add_rmessage },
- {"_env_enum_id", _env_enum_id},
- {NULL,NULL},
- };
- luaL_checkversion(L);
- luaL_newlib(L, reg);
- return 1;
- }
|