Function ts_lua_create_vconn_ctx

plugins/lua/ts_lua_util.cc:696–743

}

ts_lua_vconn_ctx *
ts_lua_create_vconn_ctx(ts_lua_main_ctx *main_ctx, ts_lua_instance_conf *conf)
{
  ts_lua_vconn_ctx *vconn_ctx;

  vconn_ctx = TSRalloc<ts_lua_vconn_ctx>();
  memset(vconn_ctx, 0, sizeof(*vconn_ctx));

  lua_State *L = main_ctx->lua;
  lua_State *l = lua_newthread(L);

  lua_pushlightuserdata(L, conf);
  lua_rawget(L, LUA_REGISTRYINDEX);

  /* new globals table for coroutine */
  lua_newtable(l);
  lua_pushvalue(l, -1);
  lua_setfield(l, -2, "_G");
  lua_newtable(l);
  lua_xmove(L, l, 1);
  lua_setfield(l, -2, "__index");
  lua_setmetatable(l, -2);

  lua_replace(l, LUA_GLOBALSINDEX);

  // init coroutine
  vconn_ctx->ref = luaL_ref(L, LUA_REGISTRYINDEX);

  vconn_ctx->lua  = l;
  vconn_ctx->mctx = main_ctx;

  // update thread stats
  ts_lua_ctx_stats *const stats = main_ctx->stats;

  TSMutexLock(stats->mutexp);
  ++stats->threads;
  if (stats->threads_max < stats->threads) {
    stats->threads_max = stats->threads;
  }
  TSMutexUnlock(stats->mutexp);

  vconn_ctx->instance_conf = conf;

  ts_lua_set_vconn_ctx(l, vconn_ctx);
  ts_lua_create_context_table(l);

  return vconn_ctx;
}

void
ts_lua_destroy_vconn_ctx(ts_lua_vconn_ctx *vconn_ctx)