uniworx/k8s-gitlab-borg
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 4 Wiki Activity

read from buffers directly

Browse Source
This commit is contained in:
Gregor Kleen 2023-05-29 17:14:24 +02:00
parent b757e4bc23
commit 1003ca01bd
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
k8s_gitlab_borg/__main__.py
View File

@ -510,7 +510,7 @@ def main():
if event & select.POLLIN or event & select.POLLPRI: if event & select.POLLIN or event & select.POLLPRI:
if rfd == proc.stdout.fileno(): if rfd == proc.stdout.fileno():
logger.debug("Reading from stdout...") logger.debug("Reading from stdout...")
if chunk := proc.stdout.read(PIPE_BUF): if chunk := proc.stdout.buffer.read(PIPE_BUF):
logger.debug("Done, length %d", len(chunk)) logger.debug("Done, length %d", len(chunk))
stdout_line_buffer.extend(chunk) stdout_line_buffer.extend(chunk)
while True: while True:
@ -524,7 +524,7 @@ def main():
break break
if rfd == proc.stderr.fileno(): if rfd == proc.stderr.fileno():
logger.debug("Reading from stderr...") logger.debug("Reading from stderr...")
if chunk := proc.stderr.read(PIPE_BUF): if chunk := proc.stderr.buffer.read(PIPE_BUF):
logger.debug("Done, length %d", len(chunk)) logger.debug("Done, length %d", len(chunk))
stderr_line_buffer.extend(chunk) stderr_line_buffer.extend(chunk)
while True: while True: