src/tools/benchmark_tool/benchmark_tool/player/synced_external_player.py
def _play_data(self):
        """
        Play all the point cloud tracks available.

        When all data is played from the track, it is removed from the list.

        @return: None
        """
        for track in list(self._tracks):
            if not self._play_track(track):
                self._tracks.remove(track)

        for track in list(self._tracks):
            with track.callback_lock:
                time_now = self.node.get_clock().now().nanoseconds
                if track.clear_to_send is True:
                    if not self._play_track(track):
                        self._tracks.remove(track)
                elif (track.enable_guard is True) and \
                        (time_now - track.last_transmission) > track.timeout_ns:
                    # The data is not arrived yet, maybe the packet was lost,
                    # re-send the same packet
                    warning(self.node,
                            ("Response is not arrived on time. Timeout: %d ms. "
                             + "Triggering re-send.") % (track.timeout_ns // 10**6))

                    if self._frame_played > 0:
                        self._frame_played -= 1
                    track.enable_guard = False
                    track.clear_to_send = True

        Play all the point cloud tracks available.

        When all data is played from the track, it is removed from the list.

        @return: None
        
Play all the point cloud tracks available.
When all data is played from the track, it is removed from the list.
Play all the point cloud tracks available . When all data is played from the track it is removed from the list .
def _play_data(self):
        for track in list(self._tracks):
            if not self._play_track(track):
                self._tracks.remove(track)
        for track in list(self._tracks):
            with track.callback_lock:
                time_now = self.node.get_clock().now().nanoseconds
                if track.clear_to_send is True:
                    if not self._play_track(track):
                        self._tracks.remove(track)
                elif (track.enable_guard is True) and \
                        (time_now - track.last_transmission) > track.timeout_ns:
                    warning(self.node,
                            ("Response is not arrived on time. Timeout: %d ms. "
                             + "Triggering re-send.") % (track.timeout_ns // 10**6))
                    if self._frame_played > 0:
                        self._frame_played -= 1
                    track.enable_guard = False
                    track.clear_to_send = True
def _play_data ( self ) : for track in list ( self . _tracks ) : if not self . _play_track ( track ) : self . _tracks . remove ( track ) for track in list ( self . _tracks ) : with track . callback_lock : time_now = self . node . get_clock ( ) . now ( ) . nanoseconds if track . clear_to_send is True : if not self . _play_track ( track ) : self . _tracks . remove ( track ) elif ( track . enable_guard is True ) and ( time_now - track . last_transmission ) > track . timeout_ns : warning ( self . node , ( "Response is not arrived on time. Timeout: %d ms. " + "Triggering re-send." ) % ( track . timeout_ns // 10 ** 6 ) ) if self . _frame_played > 0 : self . _frame_played -= 1 track . enable_guard = False track . clear_to_send = True
Play all the point cloud tracks available.
Play all the point cloud tracks available .
"""
        Play all the point cloud tracks available.

        When all data is played from the track, it is removed from the list.

        @return: None
        """ # The data is not arrived yet, maybe the packet was lost, # re-send the same packet
None
self