22 static inline void _proxy_advance_lastkb(lua_State *L, LIBEVENT_THREAD *t) {  in _proxy_advance_lastkb()  argument
28     if (new_kb > t->proxy_vm_last_kb) {  in _proxy_advance_lastkb()
29         new_kb = t->proxy_vm_last_kb + (new_kb - t->proxy_vm_last_kb) * 0.50;  in _proxy_advance_lastkb()
36     if (t->proxy_vm_negative_delta >= new_kb) {  in _proxy_advance_lastkb()
37         t->proxy_vm_negative_delta -= new_kb;  in _proxy_advance_lastkb()
40         new_kb -= t->proxy_vm_negative_delta;  in _proxy_advance_lastkb()
41         t->proxy_vm_negative_delta = 0;  in _proxy_advance_lastkb()
44     t->proxy_vm_last_kb = new_kb;  in _proxy_advance_lastkb()
49 void proxy_gc_poke(LIBEVENT_THREAD *t) {  in proxy_gc_poke()  argument
50     lua_State *L = t->L;  in proxy_gc_poke()
51     struct proxy_int_stats *is = t->proxy_int_stats;  in proxy_gc_poke()
52     int vm_kb = lua_gc(L, LUA_GCCOUNT) + t->proxy_vm_extra_kb;  in proxy_gc_poke()
53     if (t->proxy_vm_last_kb == 0) {  in proxy_gc_poke()
54         t->proxy_vm_last_kb = vm_kb;  in proxy_gc_poke()
56     WSTAT_L(t);  in proxy_gc_poke()
58     WSTAT_UL(t);  in proxy_gc_poke()
61     int last = t->proxy_vm_last_kb;  in proxy_gc_poke()
62     if (t->proxy_vm_gcrunning <= 0 && vm_kb > last * 2) {  in proxy_gc_poke()
63         t->proxy_vm_gcrunning = 1;  in proxy_gc_poke()
69     if (t->proxy_vm_gcrunning > 0) {  in proxy_gc_poke()
70         t->proxy_vm_needspoke = false;  in proxy_gc_poke()
71         int loops = t->proxy_vm_gcrunning;  in proxy_gc_poke()
83         int vm_kb_clean = vm_kb - t->proxy_vm_extra_kb;  in proxy_gc_poke()
86             t->proxy_vm_negative_delta += vm_kb_clean - vm_kb_after;  in proxy_gc_poke()
90             _proxy_advance_lastkb(L, t);  in proxy_gc_poke()
91             t->proxy_vm_extra_kb = 0;  in proxy_gc_poke()
92             t->proxy_vm_gcrunning = 0;  in proxy_gc_poke()
93             WSTAT_L(t);  in proxy_gc_poke()
95             WSTAT_UL(t);  in proxy_gc_poke()
100         if (t->proxy_vm_gcrunning && (last*2) + (last * t->proxy_vm_gcrunning*0.25) < vm_kb) {  in proxy_gc_poke()
101             t->proxy_vm_gcrunning++;  in proxy_gc_poke()
103         } else if (t->proxy_vm_gcrunning > 1) {  in proxy_gc_poke()
105             t->proxy_vm_gcrunning--;  in proxy_gc_poke()
117     LIBEVENT_THREAD *t = arg;  in proxy_gc_timerpoke()  local
119     evtimer_add(t->proxy_gc_timer, &next);  in proxy_gc_timerpoke()
121     if (!t->proxy_vm_needspoke) {  in proxy_gc_timerpoke()
122         t->proxy_vm_needspoke = true;  in proxy_gc_timerpoke()
128     if (t->proxy_vm_gcrunning == 0) {  in proxy_gc_timerpoke()
129         t->proxy_vm_gcrunning = -1;  in proxy_gc_timerpoke()
133     if (t->proxy_vm_gcrunning == -1 && lua_gc(t->L, LUA_GCSTEP, 0)) {  in proxy_gc_timerpoke()
134         _proxy_advance_lastkb(t->L, t);  in proxy_gc_timerpoke()
135         t->proxy_vm_extra_kb = 0;  in proxy_gc_timerpoke()
136         t->proxy_vm_gcrunning = 0;  in proxy_gc_timerpoke()
140 bool proxy_bufmem_checkadd(LIBEVENT_THREAD *t, int len) {  in proxy_bufmem_checkadd()  argument
142     pthread_mutex_lock(&t->proxy_limit_lock);  in proxy_bufmem_checkadd()
143     if (t->proxy_buffer_memory_used > t->proxy_buffer_memory_limit) {  in proxy_bufmem_checkadd()
146         t->proxy_buffer_memory_used += len;  in proxy_bufmem_checkadd()
148     pthread_mutex_unlock(&t->proxy_limit_lock);  in proxy_bufmem_checkadd()
195         LIBEVENT_THREAD *t = get_worker_thread(x);  in process_proxy_stats()  local
196         struct proxy_user_stats *tus = t->proxy_user_stats;  in process_proxy_stats()
197         struct proxy_int_stats *is = t->proxy_int_stats;  in process_proxy_stats()
198         WSTAT_L(t);  in process_proxy_stats()
209         WSTAT_UL(t);  in process_proxy_stats()
210         pthread_mutex_lock(&t->proxy_limit_lock);  in process_proxy_stats()
211         buffer_memory_used += t->proxy_buffer_memory_used;  in process_proxy_stats()
212         pthread_mutex_unlock(&t->proxy_limit_lock);  in process_proxy_stats()
413     proxy_event_thread_t *t = calloc(1, sizeof(proxy_event_thread_t));  in proxy_init()  local
414     ctx->proxy_io_thread = t;  in proxy_init()
415     proxy_init_event_thread(t, ctx, NULL);  in proxy_init()
417     pthread_create(&t->thread_id, NULL, proxy_event_thread, t);  in proxy_init()
418     thread_setname(t->thread_id, "mc-prx-io");  in proxy_init()
475     proxy_event_thread_t *t = calloc(1, sizeof(proxy_event_thread_t));  in proxy_thread_init()  local
476     thr->proxy_event_thread = t;  in proxy_thread_init()
477     proxy_init_event_thread(t, ctx, thr->base);  in proxy_thread_init()
1233 mcp_resp_t *mcp_prep_bare_resobj(lua_State *L, LIBEVENT_THREAD *t) {  in mcp_prep_bare_resobj()  argument
1238     r->thread = t;  in mcp_prep_bare_resobj()
1248 void mcp_set_resobj(mcp_resp_t *r, mcp_request_t *rq, mcp_backend_t *be, LIBEVENT_THREAD *t) {  in mcp_set_resobj()  argument
1252     r->thread = t;  in mcp_set_resobj()
1284 mcp_resp_t *mcp_prep_resobj(lua_State *L, mcp_request_t *rq, mcp_backend_t *be, LIBEVENT_THREAD *t)…  in mcp_prep_resobj()  argument
1286     mcp_set_resobj(r, rq, be, t);  in mcp_prep_resobj()
1448     enum mcp_memprofile_types t = mcp_memp_free;  in mcp_profile_alloc()  local
1452                 t = mcp_memp_string;  in mcp_profile_alloc()
1456                 t = mcp_memp_table;  in mcp_profile_alloc()
1460                 t = mcp_memp_func;  in mcp_profile_alloc()
1464                 t = mcp_memp_userdata;  in mcp_profile_alloc()
1468                 t = mcp_memp_thread;  in mcp_profile_alloc()
1472                 t = mcp_memp_default;  in mcp_profile_alloc()
1475         prof->allocs[t]++;  in mcp_profile_alloc()
1476         prof->alloc_bytes[t] += nsize;  in mcp_profile_alloc()