Browse Source

slink: bugfix for empty stream

master
miili 2 years ago
parent
commit
b870eba378
1 changed files with 5 additions and 3 deletions
  1. +5
    -3
      src/streaming/slink.py

+ 5
- 3
src/streaming/slink.py View File

@ -8,6 +8,7 @@ import subprocess
import time
import os
import signal
import select
import logging
import tempfile
@ -108,11 +109,12 @@ class SlowSlink(object):
def process(self):
try:
line = self.slink.stdout.read(RECORD_LENGTH)
if not line:
ready, _, _ = select.select([self.slink.stdout], [], [], .2)
if not ready:
return False
line = self.slink.stdout.read(RECORD_LENGTH)
with tempfile.NamedTemporaryFile(prefix='slink-stream') as f:
f.write(line)
f.flush()


Loading…
Cancel
Save