Skip to content

Z
Zope
Commit 435912cb authored by 's avatar
Browse files
Options

un-freaking-screwed indenting on select_trigger. I promise I'll never 

touch it again.
parent 44190dce
Hide whitespace changes
Inline Side-by-side
Showing with 506 additions and 506 deletions
ZServer/medusa/select_trigger.py
View file @ 435912cb
# -*- Mode: Python; tab-width: 4 -*- # -*- Mode: Python; tab-width: 4 -*-
VERSION_STRING = "$Id: select_trigger.py,v 1.11 2000/05/22 16:28:42 brian Exp $" VERSION_STRING = "$Id: select_trigger.py,v 1.12 2000/05/22 18:28:55 brian Exp $"
import asyncore import asyncore
import asynchat import asynchat
...@@ -9,273 +9,273 @@ import os ...@@ -9,273 +9,273 @@ import os
import socket import socket
import string import string
import thread import thread
if os.name == 'posix': if os.name == 'posix':
class trigger (asyncore.file_dispatcher): class trigger (asyncore.file_dispatcher):
"Wake up a call to select() running in the main thread" "Wake up a call to select() running in the main thread"
# This is useful in a context where you are using Medusa's I/O # This is useful in a context where you are using Medusa's I/O
# subsystem to deliver data, but the data is generated by another # subsystem to deliver data, but the data is generated by another
# thread. Normally, if Medusa is in the middle of a call to # thread. Normally, if Medusa is in the middle of a call to
# select(), new output data generated by another thread will have # select(), new output data generated by another thread will have
# to sit until the call to select() either times out or returns. # to sit until the call to select() either times out or returns.
# If the trigger is 'pulled' by another thread, it should immediately # If the trigger is 'pulled' by another thread, it should immediately
# generate a READ event on the trigger object, which will force the # generate a READ event on the trigger object, which will force the
# select() invocation to return. # select() invocation to return.
# A common use for this facility: letting Medusa manage I/O for a # A common use for this facility: letting Medusa manage I/O for a
# large number of connections; but routing each request through a # large number of connections; but routing each request through a
# thread chosen from a fixed-size thread pool. When a thread is # thread chosen from a fixed-size thread pool. When a thread is
# acquired, a transaction is performed, but output data is # acquired, a transaction is performed, but output data is
# accumulated into buffers that will be emptied more efficiently # accumulated into buffers that will be emptied more efficiently
# by Medusa. [picture a server that can process database queries # by Medusa. [picture a server that can process database queries
# rapidly, but doesn't want to tie up threads waiting to send data # rapidly, but doesn't want to tie up threads waiting to send data
# to low-bandwidth connections] # to low-bandwidth connections]
# The other major feature provided by this class is the ability to # The other major feature provided by this class is the ability to
# move work back into the main thread: if you call pull_trigger() # move work back into the main thread: if you call pull_trigger()
# with a thunk argument, when select() wakes up and receives the # with a thunk argument, when select() wakes up and receives the
# event it will call your thunk from within that thread. The main # event it will call your thunk from within that thread. The main
# purpose of this is to remove the need to wrap thread locks around # purpose of this is to remove the need to wrap thread locks around
# Medusa's data structures, which normally do not need them. [To see # Medusa's data structures, which normally do not need them. [To see
# why this is true, imagine this scenario: A thread tries to push some # why this is true, imagine this scenario: A thread tries to push some
# new data onto a channel's outgoing data queue at the same time that # new data onto a channel's outgoing data queue at the same time that
# the main thread is trying to remove some] # the main thread is trying to remove some]
def __init__ (self): def __init__ (self):
r, w = os.pipe() r, w = os.pipe()
self.trigger = w self.trigger = w
asyncore.file_dispatcher.__init__ (self, r) asyncore.file_dispatcher.__init__ (self, r)
self.lock = thread.allocate_lock() self.lock = thread.allocate_lock()
self.thunks = [] self.thunks = []
def __repr__ (self): def __repr__ (self):
return '<select-trigger (pipe) at %x>' % id(self) return '<select-trigger (pipe) at %x>' % id(self)
def readable (self): def readable (self):
return 1 return 1
def writable (self): def writable (self):
return 0 return 0
def handle_connect (self): def handle_connect (self):
pass pass
def pull_trigger (self, thunk=None): def pull_trigger (self, thunk=None):
# print 'PULL_TRIGGER: ', len(self.thunks) # print 'PULL_TRIGGER: ', len(self.thunks)
if thunk: if thunk:
try: try:
self.lock.acquire() self.lock.acquire()
self.thunks.append (thunk) self.thunks.append (thunk)
finally: finally:
self.lock.release() self.lock.release()
os.write (self.trigger, 'x') os.write (self.trigger, 'x')
def handle_read (self): def handle_read (self):
self.recv (8192) self.recv (8192)
try: try:
self.lock.acquire() self.lock.acquire()
for thunk in self.thunks: for thunk in self.thunks:
try: try:
thunk() thunk()
except: except:
(file, fun, line), t, v, tbinfo = asyncore.compact_traceback() (file, fun, line), t, v, tbinfo = asyncore.compact_traceback()
print 'exception in trigger thunk: (%s:%s %s)' % (t, v, tbinfo) print 'exception in trigger thunk: (%s:%s %s)' % (t, v, tbinfo)
self.thunks = [] self.thunks = []
finally: finally:
self.lock.release() self.lock.release()
else: else:
# win32-safe version # win32-safe version
class trigger (asyncore.dispatcher): class trigger (asyncore.dispatcher):
address = ('127.9.9.9', 19999) address = ('127.9.9.9', 19999)
def __init__ (self): def __init__ (self):
a = socket.socket (socket.AF_INET, socket.SOCK_STREAM) a = socket.socket (socket.AF_INET, socket.SOCK_STREAM)
w = socket.socket (socket.AF_INET, socket.SOCK_STREAM) w = socket.socket (socket.AF_INET, socket.SOCK_STREAM)
# set TCP_NODELAY to true to avoid buffering # set TCP_NODELAY to true to avoid buffering
w.setsockopt(socket.IPPROTO_TCP, 1, 1) w.setsockopt(socket.IPPROTO_TCP, 1, 1)
# tricky: get a pair of connected sockets # tricky: get a pair of connected sockets
host='127.0.0.1' host='127.0.0.1'
port=19999 port=19999
while 1: while 1:
try:
self.address=(host, port)
a.bind(self.address)
break
except:
if port <= 19950:
raise 'Bind Error', 'Cannot bind trigger!'
port=port - 1
a.listen (1)
w.setblocking (0)
try:
w.connect (self.address)
except:
pass
r, addr = a.accept()
a.close()
w.setblocking (1)
self.trigger = w
asyncore.dispatcher.__init__ (self, r)
self.lock = thread.allocate_lock()
self.thunks = []
self._trigger_connected = 0
def __repr__ (self):
return '<select-trigger (loopback) at %x>' % id(self)
def readable (self):
return 1
def writable (self):
return 0
def handle_connect (self):
pass
def pull_trigger (self, thunk=None):
if thunk:
try: try:
self.lock.acquire() self.address=(host, port)
self.thunks.append (thunk) a.bind(self.address)
finally: break
self.lock.release() except:
self.trigger.send ('x') if port <= 19950:
raise 'Bind Error', 'Cannot bind trigger!'
def handle_read (self): port=port - 1
self.recv (8192)
try: a.listen (1)
self.lock.acquire() w.setblocking (0)
for thunk in self.thunks: try:
try: w.connect (self.address)
thunk() except:
except: pass
(file, fun, line), t, v, tbinfo = asyncore.compact_traceback() r, addr = a.accept()
print 'exception in trigger thunk: (%s:%s %s)' % (t, v, tbinfo) a.close()
self.thunks = [] w.setblocking (1)
finally: self.trigger = w
self.lock.release()
asyncore.dispatcher.__init__ (self, r)
self.lock = thread.allocate_lock()
self.thunks = []
self._trigger_connected = 0
def __repr__ (self):
return '<select-trigger (loopback) at %x>' % id(self)
def readable (self):
return 1
def writable (self):
return 0
def handle_connect (self):
pass
def pull_trigger (self, thunk=None):
if thunk:
try:
self.lock.acquire()
self.thunks.append (thunk)
finally:
self.lock.release()
self.trigger.send ('x')
def handle_read (self):
self.recv (8192)
try:
self.lock.acquire()
for thunk in self.thunks:
try:
thunk()
except:
(file, fun, line), t, v, tbinfo = asyncore.compact_traceback()
print 'exception in trigger thunk: (%s:%s %s)' % (t, v, tbinfo)
self.thunks = []
finally:
self.lock.release()
the_trigger = None the_trigger = None
class trigger_file: class trigger_file:
"A 'triggered' file object" "A 'triggered' file object"
buffer_size = 4096 buffer_size = 4096
def __init__ (self, parent): def __init__ (self, parent):
global the_trigger global the_trigger
if the_trigger is None: if the_trigger is None:
the_trigger = trigger() the_trigger = trigger()
self.parent = parent self.parent = parent
self.buffer = '' self.buffer = ''
def write (self, data): def write (self, data):
self.buffer = self.buffer + data self.buffer = self.buffer + data
if len(self.buffer) > self.buffer_size: if len(self.buffer) > self.buffer_size:
d, self.buffer = self.buffer, '' d, self.buffer = self.buffer, ''
the_trigger.pull_trigger ( the_trigger.pull_trigger (
lambda d=d,p=self.parent: p.push (d) lambda d=d,p=self.parent: p.push (d)
) )
def writeline (self, line): def writeline (self, line):
self.write (line+'\r\n') self.write (line+'\r\n')
def writelines (self, lines): def writelines (self, lines):
self.write ( self.write (
string.joinfields ( string.joinfields (
lines, lines,
'\r\n' '\r\n'
) + '\r\n' ) + '\r\n'
) )
def flush (self): def flush (self):
if self.buffer: if self.buffer:
d, self.buffer = self.buffer, '' d, self.buffer = self.buffer, ''
the_trigger.pull_trigger ( the_trigger.pull_trigger (
lambda p=self.parent,d=d: p.push (d) lambda p=self.parent,d=d: p.push (d)
) )
def softspace (self, *args): def softspace (self, *args):
pass pass
def close (self): def close (self):
# in a derived class, you may want to call trigger_close() instead. # in a derived class, you may want to call trigger_close() instead.
self.flush() self.flush()
self.parent = None self.parent = None
def trigger_close (self): def trigger_close (self):
d, self.buffer = self.buffer, '' d, self.buffer = self.buffer, ''
p, self.parent = self.parent, None p, self.parent = self.parent, None
the_trigger.pull_trigger ( the_trigger.pull_trigger (
lambda p=p,d=d: (p.push(d), p.close_when_done()) lambda p=p,d=d: (p.push(d), p.close_when_done())
) )
if __name__ == '__main__': if __name__ == '__main__':
import time import time
def thread_function (output_file, i, n): def thread_function (output_file, i, n):
print 'entering thread_function' print 'entering thread_function'
while n: while n:
time.sleep (5) time.sleep (5)
output_file.write ('%2d.%2d %s\r\n' % (i, n, output_file)) output_file.write ('%2d.%2d %s\r\n' % (i, n, output_file))
output_file.flush() output_file.flush()
n = n - 1 n = n - 1
output_file.close() output_file.close()
print 'exiting thread_function' print 'exiting thread_function'
class thread_parent (asynchat.async_chat): class thread_parent (asynchat.async_chat):
def __init__ (self, conn, addr): def __init__ (self, conn, addr):
self.addr = addr self.addr = addr
asynchat.async_chat.__init__ (self, conn) asynchat.async_chat.__init__ (self, conn)
self.set_terminator ('\r\n') self.set_terminator ('\r\n')
self.buffer = '' self.buffer = ''
self.count = 0 self.count = 0
def collect_incoming_data (self, data): def collect_incoming_data (self, data):
self.buffer = self.buffer + data self.buffer = self.buffer + data
def found_terminator (self): def found_terminator (self):
data, self.buffer = self.buffer, '' data, self.buffer = self.buffer, ''
if not data: if not data:
asyncore.close_all() asyncore.close_all()
print "done" print "done"
return return
n = string.atoi (string.split (data)[0]) n = string.atoi (string.split (data)[0])
tf = trigger_file (self) tf = trigger_file (self)
self.count = self.count + 1 self.count = self.count + 1
thread.start_new_thread (thread_function, (tf, self.count, n)) thread.start_new_thread (thread_function, (tf, self.count, n))
class thread_server (asyncore.dispatcher): class thread_server (asyncore.dispatcher):
def __init__ (self, family=socket.AF_INET, address=('', 9003)): def __init__ (self, family=socket.AF_INET, address=('', 9003)):
asyncore.dispatcher.__init__ (self) asyncore.dispatcher.__init__ (self)
self.create_socket (family, socket.SOCK_STREAM) self.create_socket (family, socket.SOCK_STREAM)
self.set_reuse_addr() self.set_reuse_addr()
self.bind (address) self.bind (address)
self.listen (5) self.listen (5)
def handle_accept (self): def handle_accept (self):
conn, addr = self.accept() conn, addr = self.accept()
tp = thread_parent (conn, addr) tp = thread_parent (conn, addr)
thread_server() thread_server()
#asyncore.loop(1.0, use_poll=1) #asyncore.loop(1.0, use_poll=1)
try: try:
asyncore.loop () asyncore.loop ()
except: except:
asyncore.close_all() asyncore.close_all()
lib/python/ZServer/medusa/select_trigger.py
View file @ 435912cb
# -*- Mode: Python; tab-width: 4 -*- # -*- Mode: Python; tab-width: 4 -*-
VERSION_STRING = "$Id: select_trigger.py,v 1.11 2000/05/22 16:28:42 brian Exp $" VERSION_STRING = "$Id: select_trigger.py,v 1.12 2000/05/22 18:28:55 brian Exp $"
import asyncore import asyncore
import asynchat import asynchat
...@@ -9,273 +9,273 @@ import os ...@@ -9,273 +9,273 @@ import os
import socket import socket
import string import string
import thread import thread
if os.name == 'posix': if os.name == 'posix':
class trigger (asyncore.file_dispatcher): class trigger (asyncore.file_dispatcher):
"Wake up a call to select() running in the main thread" "Wake up a call to select() running in the main thread"
# This is useful in a context where you are using Medusa's I/O # This is useful in a context where you are using Medusa's I/O
# subsystem to deliver data, but the data is generated by another # subsystem to deliver data, but the data is generated by another
# thread. Normally, if Medusa is in the middle of a call to # thread. Normally, if Medusa is in the middle of a call to
# select(), new output data generated by another thread will have # select(), new output data generated by another thread will have
# to sit until the call to select() either times out or returns. # to sit until the call to select() either times out or returns.
# If the trigger is 'pulled' by another thread, it should immediately # If the trigger is 'pulled' by another thread, it should immediately
# generate a READ event on the trigger object, which will force the # generate a READ event on the trigger object, which will force the
# select() invocation to return. # select() invocation to return.
# A common use for this facility: letting Medusa manage I/O for a # A common use for this facility: letting Medusa manage I/O for a
# large number of connections; but routing each request through a # large number of connections; but routing each request through a
# thread chosen from a fixed-size thread pool. When a thread is # thread chosen from a fixed-size thread pool. When a thread is
# acquired, a transaction is performed, but output data is # acquired, a transaction is performed, but output data is
# accumulated into buffers that will be emptied more efficiently # accumulated into buffers that will be emptied more efficiently
# by Medusa. [picture a server that can process database queries # by Medusa. [picture a server that can process database queries
# rapidly, but doesn't want to tie up threads waiting to send data # rapidly, but doesn't want to tie up threads waiting to send data
# to low-bandwidth connections] # to low-bandwidth connections]
# The other major feature provided by this class is the ability to # The other major feature provided by this class is the ability to
# move work back into the main thread: if you call pull_trigger() # move work back into the main thread: if you call pull_trigger()
# with a thunk argument, when select() wakes up and receives the # with a thunk argument, when select() wakes up and receives the
# event it will call your thunk from within that thread. The main # event it will call your thunk from within that thread. The main
# purpose of this is to remove the need to wrap thread locks around # purpose of this is to remove the need to wrap thread locks around
# Medusa's data structures, which normally do not need them. [To see # Medusa's data structures, which normally do not need them. [To see
# why this is true, imagine this scenario: A thread tries to push some # why this is true, imagine this scenario: A thread tries to push some
# new data onto a channel's outgoing data queue at the same time that # new data onto a channel's outgoing data queue at the same time that
# the main thread is trying to remove some] # the main thread is trying to remove some]
def __init__ (self): def __init__ (self):
r, w = os.pipe() r, w = os.pipe()
self.trigger = w self.trigger = w
asyncore.file_dispatcher.__init__ (self, r) asyncore.file_dispatcher.__init__ (self, r)
self.lock = thread.allocate_lock() self.lock = thread.allocate_lock()
self.thunks = [] self.thunks = []
def __repr__ (self): def __repr__ (self):
return '<select-trigger (pipe) at %x>' % id(self) return '<select-trigger (pipe) at %x>' % id(self)
def readable (self): def readable (self):
return 1 return 1
def writable (self): def writable (self):
return 0 return 0
def handle_connect (self): def handle_connect (self):
pass pass
def pull_trigger (self, thunk=None): def pull_trigger (self, thunk=None):
# print 'PULL_TRIGGER: ', len(self.thunks) # print 'PULL_TRIGGER: ', len(self.thunks)
if thunk: if thunk:
try: try:
self.lock.acquire() self.lock.acquire()
self.thunks.append (thunk) self.thunks.append (thunk)
finally: finally:
self.lock.release() self.lock.release()
os.write (self.trigger, 'x') os.write (self.trigger, 'x')
def handle_read (self): def handle_read (self):
self.recv (8192) self.recv (8192)
try: try:
self.lock.acquire() self.lock.acquire()
for thunk in self.thunks: for thunk in self.thunks:
try: try:
thunk() thunk()
except: except:
(file, fun, line), t, v, tbinfo = asyncore.compact_traceback() (file, fun, line), t, v, tbinfo = asyncore.compact_traceback()
print 'exception in trigger thunk: (%s:%s %s)' % (t, v, tbinfo) print 'exception in trigger thunk: (%s:%s %s)' % (t, v, tbinfo)
self.thunks = [] self.thunks = []
finally: finally:
self.lock.release() self.lock.release()
else: else:
# win32-safe version # win32-safe version
class trigger (asyncore.dispatcher): class trigger (asyncore.dispatcher):
address = ('127.9.9.9', 19999) address = ('127.9.9.9', 19999)
def __init__ (self): def __init__ (self):
a = socket.socket (socket.AF_INET, socket.SOCK_STREAM) a = socket.socket (socket.AF_INET, socket.SOCK_STREAM)
w = socket.socket (socket.AF_INET, socket.SOCK_STREAM) w = socket.socket (socket.AF_INET, socket.SOCK_STREAM)
# set TCP_NODELAY to true to avoid buffering # set TCP_NODELAY to true to avoid buffering
w.setsockopt(socket.IPPROTO_TCP, 1, 1) w.setsockopt(socket.IPPROTO_TCP, 1, 1)
# tricky: get a pair of connected sockets # tricky: get a pair of connected sockets
host='127.0.0.1' host='127.0.0.1'
port=19999 port=19999
while 1: while 1:
try:
self.address=(host, port)
a.bind(self.address)
break
except:
if port <= 19950:
raise 'Bind Error', 'Cannot bind trigger!'
port=port - 1
a.listen (1)
w.setblocking (0)
try:
w.connect (self.address)
except:
pass
r, addr = a.accept()
a.close()
w.setblocking (1)
self.trigger = w
asyncore.dispatcher.__init__ (self, r)
self.lock = thread.allocate_lock()
self.thunks = []
self._trigger_connected = 0
def __repr__ (self):
return '<select-trigger (loopback) at %x>' % id(self)
def readable (self):
return 1
def writable (self):
return 0
def handle_connect (self):
pass
def pull_trigger (self, thunk=None):
if thunk:
try: try:
self.lock.acquire() self.address=(host, port)
self.thunks.append (thunk) a.bind(self.address)
finally: break
self.lock.release() except:
self.trigger.send ('x') if port <= 19950:
raise 'Bind Error', 'Cannot bind trigger!'
def handle_read (self): port=port - 1
self.recv (8192)
try: a.listen (1)
self.lock.acquire() w.setblocking (0)
for thunk in self.thunks: try:
try: w.connect (self.address)
thunk() except:
except: pass
(file, fun, line), t, v, tbinfo = asyncore.compact_traceback() r, addr = a.accept()
print 'exception in trigger thunk: (%s:%s %s)' % (t, v, tbinfo) a.close()
self.thunks = [] w.setblocking (1)
finally: self.trigger = w
self.lock.release()
asyncore.dispatcher.__init__ (self, r)
self.lock = thread.allocate_lock()
self.thunks = []
self._trigger_connected = 0
def __repr__ (self):
return '<select-trigger (loopback) at %x>' % id(self)
def readable (self):
return 1
def writable (self):
return 0
def handle_connect (self):
pass
def pull_trigger (self, thunk=None):
if thunk:
try:
self.lock.acquire()
self.thunks.append (thunk)
finally:
self.lock.release()
self.trigger.send ('x')
def handle_read (self):
self.recv (8192)
try:
self.lock.acquire()
for thunk in self.thunks:
try:
thunk()
except:
(file, fun, line), t, v, tbinfo = asyncore.compact_traceback()
print 'exception in trigger thunk: (%s:%s %s)' % (t, v, tbinfo)
self.thunks = []
finally:
self.lock.release()
the_trigger = None the_trigger = None
class trigger_file: class trigger_file:
"A 'triggered' file object" "A 'triggered' file object"
buffer_size = 4096 buffer_size = 4096
def __init__ (self, parent): def __init__ (self, parent):
global the_trigger global the_trigger
if the_trigger is None: if the_trigger is None:
the_trigger = trigger() the_trigger = trigger()
self.parent = parent self.parent = parent
self.buffer = '' self.buffer = ''
def write (self, data): def write (self, data):
self.buffer = self.buffer + data self.buffer = self.buffer + data
if len(self.buffer) > self.buffer_size: if len(self.buffer) > self.buffer_size:
d, self.buffer = self.buffer, '' d, self.buffer = self.buffer, ''
the_trigger.pull_trigger ( the_trigger.pull_trigger (
lambda d=d,p=self.parent: p.push (d) lambda d=d,p=self.parent: p.push (d)
) )
def writeline (self, line): def writeline (self, line):
self.write (line+'\r\n') self.write (line+'\r\n')
def writelines (self, lines): def writelines (self, lines):
self.write ( self.write (
string.joinfields ( string.joinfields (
lines, lines,
'\r\n' '\r\n'
) + '\r\n' ) + '\r\n'
) )
def flush (self): def flush (self):
if self.buffer: if self.buffer:
d, self.buffer = self.buffer, '' d, self.buffer = self.buffer, ''
the_trigger.pull_trigger ( the_trigger.pull_trigger (
lambda p=self.parent,d=d: p.push (d) lambda p=self.parent,d=d: p.push (d)
) )
def softspace (self, *args): def softspace (self, *args):
pass pass
def close (self): def close (self):
# in a derived class, you may want to call trigger_close() instead. # in a derived class, you may want to call trigger_close() instead.
self.flush() self.flush()
self.parent = None self.parent = None
def trigger_close (self): def trigger_close (self):
d, self.buffer = self.buffer, '' d, self.buffer = self.buffer, ''
p, self.parent = self.parent, None p, self.parent = self.parent, None
the_trigger.pull_trigger ( the_trigger.pull_trigger (
lambda p=p,d=d: (p.push(d), p.close_when_done()) lambda p=p,d=d: (p.push(d), p.close_when_done())
) )
if __name__ == '__main__': if __name__ == '__main__':
import time import time
def thread_function (output_file, i, n): def thread_function (output_file, i, n):
print 'entering thread_function' print 'entering thread_function'
while n: while n:
time.sleep (5) time.sleep (5)
output_file.write ('%2d.%2d %s\r\n' % (i, n, output_file)) output_file.write ('%2d.%2d %s\r\n' % (i, n, output_file))
output_file.flush() output_file.flush()
n = n - 1 n = n - 1
output_file.close() output_file.close()
print 'exiting thread_function' print 'exiting thread_function'
class thread_parent (asynchat.async_chat): class thread_parent (asynchat.async_chat):
def __init__ (self, conn, addr): def __init__ (self, conn, addr):
self.addr = addr self.addr = addr
asynchat.async_chat.__init__ (self, conn) asynchat.async_chat.__init__ (self, conn)
self.set_terminator ('\r\n') self.set_terminator ('\r\n')
self.buffer = '' self.buffer = ''
self.count = 0 self.count = 0
def collect_incoming_data (self, data): def collect_incoming_data (self, data):
self.buffer = self.buffer + data self.buffer = self.buffer + data
def found_terminator (self): def found_terminator (self):
data, self.buffer = self.buffer, '' data, self.buffer = self.buffer, ''
if not data: if not data:
asyncore.close_all() asyncore.close_all()
print "done" print "done"
return return
n = string.atoi (string.split (data)[0]) n = string.atoi (string.split (data)[0])
tf = trigger_file (self) tf = trigger_file (self)
self.count = self.count + 1 self.count = self.count + 1
thread.start_new_thread (thread_function, (tf, self.count, n)) thread.start_new_thread (thread_function, (tf, self.count, n))
class thread_server (asyncore.dispatcher): class thread_server (asyncore.dispatcher):
def __init__ (self, family=socket.AF_INET, address=('', 9003)): def __init__ (self, family=socket.AF_INET, address=('', 9003)):
asyncore.dispatcher.__init__ (self) asyncore.dispatcher.__init__ (self)
self.create_socket (family, socket.SOCK_STREAM) self.create_socket (family, socket.SOCK_STREAM)
self.set_reuse_addr() self.set_reuse_addr()
self.bind (address) self.bind (address)
self.listen (5) self.listen (5)
def handle_accept (self): def handle_accept (self):
conn, addr = self.accept() conn, addr = self.accept()
tp = thread_parent (conn, addr) tp = thread_parent (conn, addr)
thread_server() thread_server()
#asyncore.loop(1.0, use_poll=1) #asyncore.loop(1.0, use_poll=1)
try: try:
asyncore.loop () asyncore.loop ()
except: except:
asyncore.close_all() asyncore.close_all()
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7