Protected pubfreq mechanics if streams left unconfigured.

ooici · Jan 7, 2013 · d670b75 · d670b75
1 parent a0ed266
commit d670b75
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/ion/agents/instrument/instrument_agent.py b/ion/agents/instrument/instrument_agent.py
@@ -837,11 +837,12 @@ def _async_driver_event_sample(self, val, ts):
             log.error('Instrument agent %s received sample with bad \
                 stream name %s.', self._proc_name, stream_name)
 
-        state = self._fsm.get_current_state()
-        pubfreq = self.aparam_pubfreq[stream_name]
+        else:
+            state = self._fsm.get_current_state()
+            pubfreq = self.aparam_pubfreq[stream_name]
 
-        if state != ResourceAgentState.STREAMING or pubfreq == 0:
-            self._publish_stream_buffer(stream_name)
+            if state != ResourceAgentState.STREAMING or pubfreq == 0:
+                self._publish_stream_buffer(stream_name)
 
     def _publish_stream_buffer(self, stream_name):
         """