@@ -323,7 +323,7 @@ struct stTimeoutItem_t
323
323
324
324
enum
325
325
{
326
- eMaxTimeout = 40 * 1000 // 20s
326
+ eMaxTimeout = 40 * 1000 // 40s
327
327
};
328
328
stTimeoutItem_t *pPrev;
329
329
stTimeoutItem_t *pNext;
@@ -673,6 +673,8 @@ static uint32_t PollEvent2Epoll( short events )
673
673
if ( events & POLLOUT ) e |= EPOLLOUT;
674
674
if ( events & POLLHUP ) e |= EPOLLHUP;
675
675
if ( events & POLLERR ) e |= EPOLLERR;
676
+ if ( events & POLLRDNORM ) e |= EPOLLRDNORM;
677
+ if ( events & POLLWRNORM ) e |= EPOLLWRNORM;
676
678
return e;
677
679
}
678
680
static short EpollEvent2Poll ( uint32_t events )
@@ -682,16 +684,17 @@ static short EpollEvent2Poll( uint32_t events )
682
684
if ( events & EPOLLOUT ) e |= POLLOUT;
683
685
if ( events & EPOLLHUP ) e |= POLLHUP;
684
686
if ( events & EPOLLERR ) e |= POLLERR;
687
+ if ( events & EPOLLRDNORM ) e |= POLLRDNORM;
688
+ if ( events & EPOLLWRNORM ) e |= POLLWRNORM;
685
689
return e;
686
690
}
687
691
688
- static stCoRoutineEnv_t* g_arrCoEnvPerThread[ 102400 ] = { 0 };
692
+ static stCoRoutineEnv_t* g_arrCoEnvPerThread[ 204800 ] = { 0 };
689
693
void co_init_curr_thread_env ()
690
694
{
691
695
pid_t pid = GetPid ();
692
696
g_arrCoEnvPerThread[ pid ] = (stCoRoutineEnv_t*)calloc ( 1 ,sizeof (stCoRoutineEnv_t) );
693
697
stCoRoutineEnv_t *env = g_arrCoEnvPerThread[ pid ];
694
- printf (" init pid %ld env %p\n " ,(long )pid,env);
695
698
696
699
env->iCallStackSize = 0 ;
697
700
struct stCoRoutine_t *self = co_create_env ( env, NULL , NULL ,NULL );
@@ -1132,5 +1135,3 @@ stCoCondItem_t *co_cond_pop( stCoCond_t *link )
1132
1135
}
1133
1136
return p;
1134
1137
}
1135
-
1136
-
0 commit comments