Mercurial > traipse_dev
view orpg/tools/server_probe.py @ 227:81d0bfd5e800 alpha
Traipse Alpha 'OpenRPG' {100612-00}
Traipse is a distribution of OpenRPG that is designed to be easy to setup and go. Traipse also makes it easy for
developers to work on code without fear of sacrifice. 'Ornery-Orc' continues the trend of 'Grumpy' and adds fixes to
the code. 'Ornery-Orc's main goal is to offer more advanced features and enhance the productivity of the user.
Update Summary (Preparing to close updates)
New Features:
New to Map, can re-order Grid, Miniatures, and Whiteboard layer draw order
Fixes:
Fix to InterParse that was causing an Infernal Loop with Namespace Internal
Fix to XML data, removed old Minidom and switched to Element Tree
Fix to Server that was causing eternal attempt to find a Server ID, in Register Rooms thread
Fix to metaservers.xml file not being created
author | sirebral |
---|---|
date | Sat, 12 Jun 2010 03:50:37 -0500 |
parents | 4385a7d0efd1 |
children |
line wrap: on
line source
#!/usr/bin/env python # Copyright (C) 2000-2001 The OpenRPG Project # # openrpg-dev@lists.sourceforge.net # # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation; either version 2 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program; if not, write to the Free Software # Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. # -- # # File: server_probe.py # Author: Chris Davis # Maintainer: # Version: # $Id: server_probe.py,v Traipse 'Ornery-Orc' prof.ebral Exp $ # # Description: This is a periodic maintenance script for removing # Unresponsive servers from the meta list. # from threading import Event from orpg.networking import mplay_client from orpg.networking import meta_server_lib import time class server_probe: def __init__(self): self.evts = { } self.evts['on_receive'] = self.on_receive self.evts['on_mplay_event'] = self.on_mplay_event self.evts['on_group_event'] = self.on_group_event self.evts['on_player_event'] = self.on_player_event self.evts['on_status_event'] = self.on_status_event self.session = mplay_client.mplay_client("Server Probe",self.evts) self.removed=0 self.ok =0 self.lock = Event() def probe_servers(self): names = [] addresses = [] node_list = None try: xml_dom = meta_server_lib.get_server_list(); node_list = xml_dom.getElementsByTagName('server') for n in node_list: address = n.getAttribute('address') name = n.getAttribute( 'name' ) id = n.getAttribute('id') if address not in addresses and name not in names: names.append( name ) addresses.append( address ) self.probe_server(address,id) else: # If we are here, we found a duplicate print "Duplicate entry, \"" + name + "\", is being removed." self.removed = self.removed + 1 meta_server_lib.remove_server(id) except: print "An exception has occured. Attempting to ignore it..." print "\n\nServers probe done " if node_list != None: print "Total Servers:" + str(len(node_list)) print "servers removed: " + str(self.removed) print "servers ok: " + str(self.ok) def probe_server(self,address,id): print "trying server: " + address if address == "asdfasdf": # replace with address of server to force from list print "Forced removal of server!!!!!!!!!!" meta_server_lib.remove_server(id) else: if self.session.connect(address): self.lock.wait( timeout=20 ) self.session.start_disconnect() while self.session.is_connected(): time.sleep( 1 ) self.session.check_my_status() print "server: " + address + " ok\n" self.ok = self.ok + 1 print "disconnected from valid server." else: print "**********>failed connnection!" print "**********>removng server " + address + "\n" self.removed = self.removed + 1 meta_server_lib.remove_server(id) ## meta_server_lib.post_failed_connection( id ) while self.session.is_connected(): time.sleep(1) def on_receive( self, evt, data ): """Not used """ self.lock.set() def on_mplay_event( self, evt ): """Not used """ self.lock.set() def on_group_event( self, evt ): """Not used """ self.lock.set() def on_player_event( self, evt ): """Disconnects from the server if a 'new player' event is generated. """ self.lock.set() def on_status_event( self, evt ): """Not used """ self.lock.set() if __name__ == "__main__": probe = server_probe() probe.probe_servers()