InterlockedIncrement64( &g_pm_stat.pdata[COMP_RECV] );\r
InterlockedExchangeAdd64( &g_pm_stat.pdata[BYTES_RECV],\r
lpOverlapped->InternalHigh );\r
+#endif\r
+#ifdef _DEBUG_\r
+ cl_atomic_inc(&g_ibsp.total_recv_compleated);\r
#endif\r
break;\r
#ifdef PERFMON_ENABLED\r
\r
IBSP_ERROR( (" send_count = %d\n", g_ibsp.send_count) );\r
\r
+ IBSP_ERROR( (" total_send_count = %d\n", g_ibsp.total_send_count) );\r
+\r
+ IBSP_ERROR( (" total_recv_count = %d\n", g_ibsp.total_recv_count) );\r
+\r
+ IBSP_ERROR( (" total_recv_compleated = %d\n", g_ibsp.total_recv_compleated) );\r
+\r
IBSP_ERROR(\r
(" number of QPs left = %d\n", g_ibsp.qp_num) );\r
IBSP_ERROR(\r
}\r
\r
cl_atomic_inc( &g_ibsp.recv_count );\r
+ cl_atomic_inc( &g_ibsp.total_recv_count );\r
\r
fzprint(("%s():%d:0x%x:0x%x: ov=0x%p h0=%d h1=%d h1_c=%d send=%d recv=%d\n",\r
__FUNCTION__, __LINE__, GetCurrentProcessId(),\r
}\r
\r
cl_atomic_inc( &g_ibsp.send_count );\r
+ cl_atomic_inc( &g_ibsp.total_send_count );\r
\r
fzprint(("%s():%d:0x%x:0x%x: ov=0x%p h0=%d h1=%d h1_c=%d send=%d recv=%d\n",\r
__FUNCTION__, __LINE__, GetCurrentProcessId(),\r
atomic32_t max_comp_count;\r
atomic32_t send_count;\r
atomic32_t recv_count;\r
+ atomic32_t total_send_count;\r
+ atomic32_t total_recv_count;\r
+ atomic32_t total_recv_compleated;\r
atomic32_t CloseSocket_count;\r
#endif\r
};\r