Lines Matching refs:g
1397 static void mcp_gobj_enqueue(proxy_ctx_t *ctx, struct mcp_globalobj_s *g) { in mcp_gobj_enqueue() argument
1399 STAILQ_INSERT_TAIL(&ctx->manager_head, g, next); in mcp_gobj_enqueue()
1406 void mcp_gobj_ref(lua_State *L, struct mcp_globalobj_s *g) { in mcp_gobj_ref() argument
1407 pthread_mutex_lock(&g->lock); in mcp_gobj_ref()
1408 if (g->self_ref == 0) { in mcp_gobj_ref()
1419 g->self_ref = -luaL_ref(L, LUA_REGISTRYINDEX); in mcp_gobj_ref()
1420 g->refcount++; in mcp_gobj_ref()
1422 mcp_gobj_enqueue(ctx, g); in mcp_gobj_ref()
1426 g->refcount++; in mcp_gobj_ref()
1427 pthread_mutex_unlock(&g->lock); in mcp_gobj_ref()
1430 void mcp_gobj_unref(proxy_ctx_t *ctx, struct mcp_globalobj_s *g) { in mcp_gobj_unref() argument
1431 pthread_mutex_lock(&g->lock); in mcp_gobj_unref()
1432 g->refcount--; in mcp_gobj_unref()
1433 if (g->refcount == 0) { in mcp_gobj_unref()
1434 mcp_gobj_enqueue(ctx, g); in mcp_gobj_unref()
1436 pthread_mutex_unlock(&g->lock); in mcp_gobj_unref()
1439 void mcp_gobj_finalize(struct mcp_globalobj_s *g) { in mcp_gobj_finalize() argument
1440 pthread_mutex_destroy(&g->lock); in mcp_gobj_finalize()
1630 p->beprefix, p->pool_size, p->pool_be_total, p->g.refcount, p->use_iothread); in dump_pool_info()