Browse Source

Test

etomic
jl777 7 years ago
parent
commit
3d49071cb0
  1. 4
      iguana/exchanges/LP_network.c
  2. 4
      iguana/exchanges/stats.c

4
iguana/exchanges/LP_network.c

@ -274,7 +274,7 @@ void gc_loop(void *arg)
{ {
flag = 0; flag = 0;
LP_millistats_update(&LP_gcloop_stats); LP_millistats_update(&LP_gcloop_stats);
portable_mutex_lock(&LP_gcmutex); //portable_mutex_lock(&LP_gcmutex);
DL_FOREACH_SAFE(LP_garbage_collector,req,rtmp) DL_FOREACH_SAFE(LP_garbage_collector,req,rtmp)
{ {
DL_DELETE(LP_garbage_collector,req); DL_DELETE(LP_garbage_collector,req);
@ -282,7 +282,7 @@ void gc_loop(void *arg)
free(req); free(req);
flag++; flag++;
} }
portable_mutex_unlock(&LP_gcmutex); //portable_mutex_unlock(&LP_gcmutex);
if ( flag == 0 ) if ( flag == 0 )
usleep(5000); usleep(5000);
else printf("gc_loop.%d\n",flag); else printf("gc_loop.%d\n",flag);

4
iguana/exchanges/stats.c

@ -733,10 +733,10 @@ void LP_rpc_processreq(void *_ptr)
free(space); free(space);
free(jsonbuf); free(jsonbuf);
closesocket(sock); closesocket(sock);
portable_mutex_lock(&LP_gcmutex); //portable_mutex_lock(&LP_gcmutex);
DL_APPEND(LP_garbage_collector,req); DL_APPEND(LP_garbage_collector,req);
spawned--; spawned--;
portable_mutex_unlock(&LP_gcmutex); //portable_mutex_unlock(&LP_gcmutex);
} }
extern int32_t IAMLP; extern int32_t IAMLP;

Loading…
Cancel
Save