Fixed a serious output bug, buffers weren't being cleared after flushed.
So I obviously feel much better about this version, looks like it works how it should.
This commit is contained in:
parent
97da25ce38
commit
3eb7a78339
|
@ -116,10 +116,11 @@ class Console( threading.Thread ):
|
||||||
if pid in self.buffers:
|
if pid in self.buffers:
|
||||||
for line in self.buffers[ pid ]:
|
for line in self.buffers[ pid ]:
|
||||||
print( line )
|
print( line )
|
||||||
|
self.buffers.pop( pid, None )
|
||||||
elif event == Console.MSG.CLEAR:
|
elif event == Console.MSG.CLEAR:
|
||||||
pid = data[ 1 ]
|
pid = data[ 1 ]
|
||||||
if pid in self.buffers:
|
if pid in self.buffers:
|
||||||
del self.buffers[ pid ]
|
self.buffers.pop( pid, None )
|
||||||
|
|
||||||
class Worker( threading.Thread ):
|
class Worker( threading.Thread ):
|
||||||
def __init__( self, console, queue, files_to_ignore ):
|
def __init__( self, console, queue, files_to_ignore ):
|
||||||
|
@ -173,7 +174,7 @@ class Worker( threading.Thread ):
|
||||||
files = []
|
files = []
|
||||||
command = "p4 fstat *"
|
command = "p4 fstat *"
|
||||||
|
|
||||||
proc = subprocess.Popen( command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, cwd=directory )
|
proc = subprocess.Popen( command.split( ), stdout=subprocess.PIPE, stderr=subprocess.PIPE, cwd=directory )
|
||||||
(out, err) = proc.communicate()
|
(out, err) = proc.communicate()
|
||||||
|
|
||||||
for line in err.decode('utf-8').split( os.linesep ):
|
for line in err.decode('utf-8').split( os.linesep ):
|
||||||
|
|
Loading…
Reference in New Issue