1 """Main loop for the MUFF Engine"""
3 # Copyright (c) 2005 mudpy, Jeremy Stanley <fungi@yuggoth.org>
6 # Redistribution and use in source and binary forms, with or without
7 # modification, are permitted provided that the following conditions
10 # - Redistributions of source code must retain the above copyright
11 # notice, this list of conditions and the following disclaimer.
12 # - Redistributions in binary form must reproduce the above
13 # copyright notice, this list of conditions and the following
14 # disclaimer in the documentation and/or other materials provided
15 # with the distribution.
17 # THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
18 # "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
19 # LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
20 # FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
21 # COPYRIGHT HOLDERS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
22 # INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
23 # BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
24 # LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
25 # CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
26 # LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
27 # ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
28 # POSSIBILITY OF SUCH DAMAGE.
34 for module in muff.__all__:
35 exec("import " + module)
38 while not muffvars.terminate_world:
39 if not muffvars.newsocket:
40 muffsock.initialize_server_socket()
41 time.sleep(muffconf.config_data.getfloat("general", "increment"))
42 if muffvars.reload_modules:
44 for module in muff.__all__:
45 exec("reload(muff." + module + ")")
46 muffvars.reload_modules = 0
47 user = muffsock.check_for_connection(muffvars.newsocket)
49 muffvars.userlist.append(user)
50 print len(muffvars.userlist),"connection(s)"
51 for each_user in muffvars.userlist:
55 input_data = each_user.connection.recv(1024)
59 each_user.partial_input += input_data
60 if each_user.partial_input and each_user.partial_input[-1] == "\n":
61 each_user.partial_input = filter(lambda x: x>=' ' and x<='~', each_user.partial_input)
62 each_user.partial_input = string.strip(each_user.partial_input)
63 each_user.input_queue.append(each_user.partial_input)
64 each_user.partial_input = ""
65 muffcmds.handle_user_input(each_user, each_user.input_queue[0])
66 each_user.input_queue.remove(each_user.input_queue[0])
67 muffsock.destroy_all_sockets()
68 print "Shutting down now."