--- deliantra/server/socket/loop.C 2006/12/17 19:07:23 1.27 +++ deliantra/server/socket/loop.C 2007/01/02 11:08:36 1.35 @@ -48,7 +48,7 @@ #include #define MAX_QUEUE_DEPTH 500 //TODO -#define MAX_QUEUE_BACKLOG 5. //TODO +#define MAX_QUEUE_BACKLOG 3. //TODO void client::reset_state () @@ -88,7 +88,7 @@ bool skipping = false; while (!cmd_queue.empty () - && !(pl && pl->state == ST_PLAYING && pl->ob && pl->ob->speed_left < 0)) + && !(state == ST_PLAYING && pl->ob && pl->ob->speed_left < 0)) { command &cmd = cmd_queue.front (); @@ -118,8 +118,7 @@ flush_sockets (void) { for (sockvec::iterator i = clients.begin (); i != clients.end (); ++i) - if ((*i)->status != Ns_Dead) - (*i)->flush (); + (*i)->flush (); } /** @@ -137,62 +136,13 @@ write_cs_stats (); #endif - /* Go through the players. Let the loop set the next pl value, - * since we may remove some - */ - //TODO: must be handled cleanly elsewhere - for (player *pl = first_player; pl; ) + //TODO: should not be done here, either + for (int i = 0; i < clients.size (); ++i) { - player *npl = pl->next; - - //TODO: must be handled cleanly elsewhere - if (!pl->socket || pl->socket->status == Ns_Dead) - { - save_player (pl->ob, 0); - - if (!QUERY_FLAG (pl->ob, FLAG_REMOVED)) - { - terminate_all_pets (pl->ob); - pl->ob->remove (); - } - - leave (pl, 1); - final_free_player (pl); - } - - pl = npl; - } - - for (sockvec::iterator i = clients.begin (); i != clients.end (); ) - { - client *s = *i; - - if (s->status == Ns_Dead) - { - clients.erase (i); - delete s; - } - else - ++i; - } - - /* We need to do some of the processing below regardless */ - - /* Check for any input on the sockets */ - for (sockvec::iterator i = clients.begin (); i != clients.end (); ++i) - { - client *s = *i; + client *s = clients [i]; player *pl = s->pl; - s->handle_packet (); - - for (int i = 16; --i; ) //D - if (!//D - s->handle_command () - ) break;//D - - //TODO: should not be done here, either - if (s->status != Ns_Dead && pl) + if (pl && pl->ns && !pl->ns->destroyed ()) { /* Update the players stats once per tick. More efficient than * sending them whenever they change, and probably just as useful @@ -212,6 +162,8 @@ if (s->update_look) esrv_draw_look (pl->ob); } + + s->refcnt_chk (); } }