[Quickfix-users] Quickfix python SocketAcceptor blocks main thread

SourceForge Headquarters 225 Broadway Suite 1600 San Diego, CA 92101 +1 (858) 422-6466

<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en"><title></title><head><meta http-equiv="Content-type" content="text/html; charset=UTF-8" /><style type="text/css"> html, body {overflow-x: visible; } html { width:100%; height:100%;margin:0px; padding:0px; overflow-y: auto; overflow-x: auto; }body { font-size: 100.01%; font-family : Verdana, Geneva, Arial, Helvetica, sans-serif; background-color:transparent; overflow:show; background-image:none; margin:0px; padding:5px; }p { margin:0px; padding:0px; } body { font-size: 12px; font-family : Verdana, Geneva, Arial, Helvetica, sans-serif; } p { margin: 0; padding: 0; } blockquote { padding-left: 5px; margin-left: 5px; margin-bottom: 0px; margin-top: 0px; } blockquote.quote { border-left: 1px solid #CCC; padding-left: 5px; margin-left: 5px; } .misspelled { background: transparent url(//webmailerng.1und1.de/static_resource/mailclient/widgets/basic/parts/maileditor/spellchecking_underline.gif) repeat-x scroll center bottom; } .correct {} .unknown {} .ignored {}</style></head><body id="bodyElement" style="">
Hi, I tried to use the the executor.py sample. I modified it a little: ...&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; file = sys.argv[1] &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; settings = fix.SessionSettings( file ) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; application = Application() &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; storeFactory = fix.FileStoreFactory( settings ) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logFactory = fix.FileLogFactory( settings ) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; acceptor = fix.SocketAcceptor( application, storeFactory, settings, logFactory ) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; acceptor.start() &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; while 1:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp; &nbsp;&nbsp; time.sleep(10)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp; &nbsp; print 'AFTER SLEEP' &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; acceptor.stop() .... The result: print is never executed, it blocks unlimited in time.sleep(10). Even without sleep, the loop blocks after a few seconds. I checked the process with truss: /2:&nbsp;&nbsp;&nbsp;&nbsp; pollsys(0xFDDF9498, 2, 0xFDDFB500, 0x00000000)&nbsp; = 0 /2:&nbsp;&nbsp;&nbsp;&nbsp; times(0xFDDFB480)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; = 708582828 /1:&nbsp;&nbsp;&nbsp;&nbsp; lwp_park(0x00000000, 0)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; (sleeping...) /2:&nbsp;&nbsp;&nbsp;&nbsp; pollsys(0xFDDF9498, 2, 0xFDDFB500, 0x00000000)&nbsp; = 0 /2:&nbsp;&nbsp;&nbsp;&nbsp; times(0xFDDFB480)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; = 708582928 /2:&nbsp;&nbsp;&nbsp;&nbsp; pollsys(0xFDDF9498, 2, 0xFDDFB500, 0x00000000)&nbsp; = 0 It looks as if the thread, started by acceptor.start() blocks the main thread. Without acceptor.start() the code works as expected. Is this a bug or as designed? Did I something wrong? Thanks Max BTW:There is a mistake in the sample, sessionID and message are in the wrong order: &nbsp;&nbsp;&nbsp; def toAdmin(self, sessionID, message): return &nbsp;&nbsp;&nbsp; def fromAdmin(self, sessionID, message): return &nbsp;&nbsp;&nbsp; def toApp(self, sessionID, message): return <basefont size="2" face="Verdana"></body></html>