copyleftie/gajim-plural
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

it is now possible to specify hostname / ip to bind with the sock plugin

Browse source
This commit is contained in:
Yann Leboulanger 2004-07-18 11:32:39 +00:00
parent 331056f179
commit 40a5e98f51
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
plugins/sock/sock.py
View file

@ -92,7 +92,6 @@ class plugin:
def read_queue(self): def read_queue(self):
while self.queueIN.empty() == 0: while self.queueIN.empty() == 0:
ev = self.queueIN.get() ev = self.queueIN.get()
# print 'sock recieved ', ev, ' from queue'
if ev[0] in self.message_types: if ev[0] in self.message_types:
for sock in self.message_types[ev[0]]: for sock in self.message_types[ev[0]]:
self.send_to_socket(ev, sock) self.send_to_socket(ev, sock)
@ -109,6 +108,7 @@ class plugin:
if sock == self.socket: if sock == self.socket:
conn, addr = self.socket.accept() conn, addr = self.socket.accept()
# Connected by addr # Connected by addr
print _("Connection from "), addr
self.active_socket.append(conn) self.active_socket.append(conn)
else: else:
try: try:
@ -118,13 +118,13 @@ class plugin:
break break
if not data: if not data:
# disconnected # disconnected
print _("disconnected")
self.active_socket.remove(sock) self.active_socket.remove(sock)
break break
while len(data) == 1024: while len(data) == 1024:
data += sock.recv(1024) data += sock.recv(1024)
list_ev = self.unparse_socket(data) list_ev = self.unparse_socket(data)
for ev in list_ev: for ev in list_ev:
# print 'sock recieved ', ev, ' from socket'
if ev[0] == 'REG_MESSAGE': if ev[0] == 'REG_MESSAGE':
self.handle_socket_reg_message(sock, ev[2]) self.handle_socket_reg_message(sock, ev[2])
ev = (ev[0], 'sock', ev[2]) ev = (ev[0], 'sock', ev[2])
@ -141,6 +141,8 @@ class plugin:
self.message_types = {} self.message_types = {}
#create socket #create socket
self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
if self.config.has_key('host'):
HOST = socket.gethostbyname(self.config['host'])
self.socket.bind((HOST, self.config['port'])) self.socket.bind((HOST, self.config['port']))
self.socket.listen(5) self.socket.listen(5)