ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/server/server/evthread.C
(Generate patch)

Comparing deliantra/server/server/evthread.C (file contents):
Revision 1.4 by root, Sun Apr 6 16:13:23 2008 UTC vs.
Revision 1.5 by root, Thu May 29 03:27:37 2008 UTC

… …
86aio2_cb (EV_P_ ev_idle *w, int revents) 86aio2_cb (EV_P_ ev_idle *w, int revents)
87{ 87{
88 CALL_BEGIN (0); 88 CALL_BEGIN (0);
89 CALL_CALL ("IO::AIO::poll_cb", G_SCALAR); 89 CALL_CALL ("IO::AIO::poll_cb", G_SCALAR);
90 90
91 fprintf (stderr, "pollcb %d\n", count ? TOPi : 0);//D
91 if (count > 0 && TOPi > 0) 92 if (count > 0 && TOPi < 0)
92 ev_idle_start (EV_A, w); 93 ev_idle_start (EV_A, w);
93 else 94 else
94 ev_idle_stop (EV_A, w); 95 ev_idle_stop (EV_A, w);
95 96
96 CALL_END; 97 CALL_END;
… …
104 105
105static void 106static void
106aio1_cb (EV_P_ ev_io *w, int revents) 107aio1_cb (EV_P_ ev_io *w, int revents)
107{ 108{
108 char dummy; 109 char dummy;
110 ev_io_stop (EV_A, w);//D
111 return;
109 112
110 if (read (w->fd, &dummy, 1) > 0) 113 if (read (w->fd, &dummy, 1) > 0)
111 { 114 {
115 fprintf (stderr, "async\n");//D
112 ev_async_send (EV_DEFAULT_UC, &async_watcher); 116 ev_async_send (EV_DEFAULT_UC, &async_watcher);
113 coroapi::cede_pending = 1; 117 coroapi::cede_pending = 1;
114 } 118 }
115} 119}
116 120

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines