def onMultiFileSink(self, fn, *a, **k):
        with self.recordlock:
            self.moveSegments()
            d = os.path.join("/dev/shm/knvr_buffer/", self.name)
            ls = os.listdir(d)
            ls = list(sorted([i for i in ls if i.endswith(".ts")]))


            n = max(1,int((float(self.config.get('device.loop_record_length', 5))+2.5)/5))