renatofilho@484: import lib
renatofilho@484: import time
renatofilho@484: import socket
renatofilho@484: 
renatofilho@484: class Server:
renatofilho@484: 
renatofilho@484:     def __init__(self, config):
renatofilho@484:         self.host = ''
renatofilho@484:         self.port = int(config.get("Comm", "port"))
renatofilho@484:         self.finish = 0
renatofilho@484: 
renatofilho@484:         self.tcp = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
renatofilho@484:         self.tcp.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
renatofilho@484:         self.tcp.bind( (self.host, self.port) )
renatofilho@484:         self.tcp.listen(1)
renatofilho@484: 
renatofilho@484:     def getMsg(self, size):
renatofilho@484:         return self.con.recv(size)
renatofilho@484: 
renatofilho@484:     def sendMsg(self, msg):
renatofilho@484:         self.con.send(msg + "\n")
renatofilho@484: 
renatofilho@484:     def Ack(self, command):
renatofilho@484:         msg = "[%s] Command %s received" % (lib.now(), command)
renatofilho@484:         self.sendMsg(msg)
renatofilho@484: 
renatofilho@484:     def getRequest(self):
renatofilho@484:         self.con, self.client = self.tcp.accept()
renatofilho@484:         print "[%s] Received request from ip=%s" % (lib.now(), self.client )
renatofilho@484:         return (self.con, self.client)
renatofilho@484: 
renatofilho@484:     def disconnect_client(self, connection):
renatofilho@484:         connection.close()
renatofilho@484: 
renatofilho@484:     def stop(self):
renatofilho@484:         self.tcp.close()