Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(0)  |  Call(0)  |  Derive(0)  |  Import(0)

src/m/a/marine-integrations-HEAD/mi/instrument/rbr/xr_420_thermistor_24/ooicore/driver.py   marine-integrations(Download)
                          Status.HIGH_SPEED_PROFILING_MODE]:
                next_state = ProtocolStates.AUTOSAMPLE
                result = ResourceAgentState.STREAMING
                # Command device to update parameters and send a config change event.
                # do this here because it shouldn't be done on entry to autosample everytime, 
 
        next_state = ProtocolStates.AUTOSAMPLE        
        next_agent_state = ResourceAgentState.STREAMING
 
        return (next_state, (next_agent_state, result))

src/m/a/marine-integrations-HEAD/mi/instrument/seabird/sbe26plus/driver.py   marine-integrations(Download)
        if logging == True:
            next_state = ProtocolState.AUTOSAMPLE
            result = ResourceAgentState.STREAMING
        elif logging == False:
            next_state = ProtocolState.COMMAND
 
        next_state = ProtocolState.AUTOSAMPLE
        next_agent_state = ResourceAgentState.STREAMING
 
        return (next_state, (next_agent_state, result))

src/m/a/marine-integrations-HEAD/mi/instrument/nobska/mavs4/ooicore/driver.py   marine-integrations(Download)
 
        next_state = ProtocolStates.AUTOSAMPLE        
        next_agent_state = ResourceAgentState.STREAMING
 
        return (next_state, (next_agent_state, result))

src/m/a/marine-integrations-HEAD/mi/dataset/simple_dataset_agent.py   marine-integrations(Download)
    def __init__(self, *args, **kwargs):
        super(TwoDelegateDatasetAgent,self).__init__(*args, **kwargs)
        self._fsm.add_handler(ResourceAgentState.STREAMING, ResourceAgentEvent.EXECUTE_RESOURCE, self._handler_streaming_execute_resource)
        log.warn("DRIVER: __init__")
 

src/m/a/marine-integrations-HEAD/mi/idk/run_instrument.py   marine-integrations(Download)
            command.
            """
            if state != ResourceAgentState.STREAMING:    
                cmd = AgentCommand(command=ResourceAgentEvent.RUN)
                retval = self._ia_client.execute_agent(cmd)

src/m/a/marine-integrations-HEAD/mi/instrument/wetlabs/ac_s/ooicore/test/test_driver.py   marine-integrations(Download)
        # will always go back to autosample for this instrument
        self.assert_reset()
        self.assert_discover(ResourceAgentState.STREAMING)
 
 
        ##################
 
        capabilities[AgentCapabilityType.AGENT_COMMAND] = self._common_agent_commands(ResourceAgentState.STREAMING)
        capabilities[AgentCapabilityType.RESOURCE_COMMAND] =  [
            DriverEvent.STOP_AUTOSAMPLE,

src/m/a/marine-integrations-HEAD/mi/instrument/star_asimet/bulkmet/metbk_a/test/test_driver.py   marine-integrations(Download)
        ##################
 
        capabilities[AgentCapabilityType.AGENT_COMMAND] = self._common_agent_commands(ResourceAgentState.STREAMING)
        capabilities[AgentCapabilityType.RESOURCE_COMMAND] =  [
            ProtocolEvent.GET, 

src/m/a/marine-integrations-HEAD/mi/instrument/seabird/sbe54tps/test/test_driver.py   marine-integrations(Download)
 
        # verify the setting got restored.
        self.assert_state_change(ResourceAgentState.STREAMING, ProtocolState.AUTOSAMPLE, 10)
        self.tcp_client.send_data("%sStart%s" % (NEWLINE, NEWLINE))
        gevent.sleep(3)
        self.tcp_client.send_data("%sStart%s" % (NEWLINE, NEWLINE))
        gevent.sleep(3)
        self.assert_state_change(ResourceAgentState.STREAMING, ProtocolState.AUTOSAMPLE, 60)
 
        ###
            gevent.sleep(15)
 
        self.assert_state_change(ResourceAgentState.STREAMING, ProtocolState.AUTOSAMPLE, 75)
 
        ###
        gevent.sleep(3)
        self.tcp_client.disconnect()
        self.assert_state_change(ResourceAgentState.STREAMING, ProtocolState.AUTOSAMPLE, 30)
 
    def test_direct_access_telnet_timeout(self):
        self.tcp_client.disconnect()
 
        self.assert_state_change(ResourceAgentState.STREAMING, ProtocolState.AUTOSAMPLE, 30)
 
    def test_sample_interval_set(self):

src/m/a/marine-integrations-HEAD/mi/instrument/seabird/sbe37smb/ooicore/test/test_driver.py   marine-integrations(Download)
 
        # verify the setting got restored.
        self.assert_state_change(ResourceAgentState.STREAMING, SBE37ProtocolState.AUTOSAMPLE, 10)
        self.assert_get_parameter(SBE37Parameter.INTERVAL, 10)
 
        self.tcp_client.disconnect()
        log.debug("DA server tcp client disconnected")
        self.assert_state_change(ResourceAgentState.STREAMING, SBE37ProtocolState.AUTOSAMPLE, 90)
 
 
 
        state = self.instrument_agent_client.get_agent_state()
        self.assertEqual(state, ResourceAgentState.STREAMING)
 
        # Get exposed capabilities in current state.
 
        state = self.instrument_agent_client.get_agent_state()
        self.assertEqual(state, ResourceAgentState.STREAMING)
 
        # Assert we got 3 samples.

src/m/a/marine-integrations-HEAD/mi/instrument/seabird/sbe26plus/test/test_driver.py   marine-integrations(Download)
        # First test in command mode
        ####
        self.assert_resource_command(ProtocolEvent.START_AUTOSAMPLE, agent_state=ResourceAgentState.STREAMING, delay=1)
        self.assert_resource_command(ProtocolEvent.STOP_AUTOSAMPLE, agent_state=ResourceAgentState.COMMAND, delay=1)
        self.assert_resource_command(ProtocolEvent.ACQUIRE_SAMPLE, regex=r' +([\-\d.]+) +([\-\d.]+) +([\-\d.]+)')
        ####
        # Put us in streaming
        self.assert_resource_command(ProtocolEvent.START_AUTOSAMPLE, agent_state=ResourceAgentState.STREAMING, delay=1)
 
        self.assert_resource_command(ProtocolEvent.SCHEDULED_CLOCK_SYNC)

  1 | 2  Next