diff --git a/app/adaptiveorbit.py b/app/adaptiveorbit.py index 1aba1ef..b10cece 100644 --- a/app/adaptiveorbit.py +++ b/app/adaptiveorbit.py @@ -39,7 +39,7 @@ class AdaptiveOrbit: def initBSStream(self,channels): print("Initializing BSstream") - bs = BSCache(100000,100000) # 1000 second time out, capazity for 1000 second. + bs = BSCache(100000,receive_timeout=100000) # 1000 second time out, capazity for 1000 second. bs.get_vars(channels) return bs diff --git a/app/dispersiontools.py b/app/dispersiontools.py index c1789a8..35746c5 100644 --- a/app/dispersiontools.py +++ b/app/dispersiontools.py @@ -79,7 +79,7 @@ class Dispersion: self.scale = scl # define stream print('Getting BSCache') - self.bsc = BSCache(100000,10000) # 100 second timeout, size for 100 second data taken + self.bsc = BSCache(100000, receive_timeout=10000) # 1000 second timeout, size for 100 second data taken self.bsc.get_vars(self.sensor) # this starts the stream into the cache print('Getting BSCache done') diff --git a/app/spectralanalysis.py b/app/spectralanalysis.py index 2165eef..49a9f19 100644 --- a/app/spectralanalysis.py +++ b/app/spectralanalysis.py @@ -20,7 +20,7 @@ names = ['PSSS', 'PMOS Maloja', 'PMOS Furka', 'PSSS LB', 'PSSS incl gasd', 'PSSS class SpectralAnalysis: def __init__(self): - self.bs = BSCache(100000,10000) # 100 second timeout, size for 100 second data taken + self.bs = BSCache(100000,receive_timeout=10000) # 100 second timeout, size for 10 second data taken self.bs.stop() self.channel = None self.channels = [channel_dict[x] for x in names] @@ -64,8 +64,8 @@ class SpectralAnalysis: class SpectralAnalysis2: def __init__(self): - self.bs1 = BSCache(100000, 10000) - self.bs2 = BSCache(100000, 10000) + self.bs1 = BSCache(100000, receive_timeout=10000) + self.bs2 = BSCache(100000, receive_timeout=10000) self.bs1.stop() self.bs2.stop() self.hasBStream=False diff --git a/app/xtcavstabilizer.py b/app/xtcavstabilizer.py index f053977..5748c39 100644 --- a/app/xtcavstabilizer.py +++ b/app/xtcavstabilizer.py @@ -18,7 +18,7 @@ class XTCAVStabilizer: self.PVPhase = PV('SATMA02-RSYS:SET-BEAM-PHASE') # the BS channels - self.bs = BSCache(100000,10000) # 100 second timeout, size for 100 second data taken + self.bs = BSCache(100000, receive_timeout=10000) # 100 second timeout, size for 10 second data taken self.channels = ['SATBD02-DBPM040:X2','SATMA02-RLLE-DSP:PHASE-VS','SATBD02-DBPM040:X2-VALID'] self.validation = self.channels[2] self.bs.get_vars(self.channels) # this starts the stream into the cache diff --git a/util/simplecapture.py b/util/simplecapture.py index 3eef006..24478d3 100644 --- a/util/simplecapture.py +++ b/util/simplecapture.py @@ -5,7 +5,7 @@ from bstrd import BSCache class SimpleCapture: def __init__(self): self.chn=None - self.bs = BSCache(100000,100000) # 1000 second time out, capazity for 1000 second. + self.bs = BSCache(100000, receive_timeout=100000) # 1000 second time out, capazity for 1000 second. self.abort=False def terminate(self):