Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 8 additions & 8 deletions generated/nifake/nifake/_grpc_stub_interpreter.py
Original file line number Diff line number Diff line change
Expand Up @@ -77,10 +77,7 @@ def _invoke(self, func, request, metadata=None):
return response

def abort(self): # noqa: N802
self._invoke(
self._client.Abort,
grpc_types.AbortRequest(vi=self._vi),
)
raise NotImplementedError('abort is not supported over gRPC')

def accept_list_of_durations_in_seconds(self, delays): # noqa: N802
self._invoke(
Expand All @@ -95,6 +92,9 @@ def bool_array_output_function(self, number_of_elements): # noqa: N802
)
return response.an_array

def cached_read_status(self): # noqa: N802
raise NotImplementedError('cached_read_status is not supported over gRPC')

def configure_abc(self): # noqa: N802
self._invoke(
self._client.ConfigureAbc,
Expand Down Expand Up @@ -148,10 +148,7 @@ def function_with_3d_numpy_array_of_numpy_complex128_input_parameter(self, multi
raise NotImplementedError('numpy-specific methods are not supported over gRPC')

def function_with_intflag_parameter(self, flag): # noqa: N802
self._invoke(
self._client.FunctionWithIntflagParameter,
grpc_types.FunctionWithIntflagParameterRequest(vi=self._vi, flag=flag.value),
)
raise NotImplementedError('function_with_intflag_parameter is not supported over gRPC')

def function_with_repeated_capability_type(self, site_list): # noqa: N802
raise NotImplementedError('function_with_repeated_capability_type is not supported over gRPC')
Expand Down Expand Up @@ -394,6 +391,9 @@ def read_from_channel(self, channel_name, maximum_time): # noqa: N802
)
return response.reading

def read_status(self): # noqa: N802
raise NotImplementedError('read_status is not supported over gRPC')

def return_a_number_and_a_string(self): # noqa: N802
response = self._invoke(
self._client.ReturnANumberAndAString,
Expand Down
18 changes: 18 additions & 0 deletions generated/nifake/nifake/_library.py
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@ def __init__(self, ctypes_library):
self.niFake_Abort_cfunc = None
self.niFake_AcceptListOfDurationsInSeconds_cfunc = None
self.niFake_BoolArrayOutputFunction_cfunc = None
self.niFake_CachedReadStatus_cfunc = None
self.niFake_ConfigureABC_cfunc = None
self.niFake_CustomNestedStructRoundtrip_cfunc = None
self.niFake_DoubleAllTheNums_cfunc = None
Expand Down Expand Up @@ -78,6 +79,7 @@ def __init__(self, ctypes_library):
self.niFake_PoorlyNamedSimpleFunction_cfunc = None
self.niFake_Read_cfunc = None
self.niFake_ReadFromChannel_cfunc = None
self.niFake_ReadStatus_cfunc = None
self.niFake_ReturnANumberAndAString_cfunc = None
self.niFake_ReturnDurationInSeconds_cfunc = None
self.niFake_ReturnListOfDurationsInSeconds_cfunc = None
Expand Down Expand Up @@ -133,6 +135,14 @@ def niFake_BoolArrayOutputFunction(self, vi, number_of_elements, an_array): # n
self.niFake_BoolArrayOutputFunction_cfunc.restype = ViStatus # noqa: F405
return self.niFake_BoolArrayOutputFunction_cfunc(vi, number_of_elements, an_array)

def niFake_CachedReadStatus(self, vi, acq_backlog, acq_status): # noqa: N802
with self._func_lock:
if self.niFake_CachedReadStatus_cfunc is None:
self.niFake_CachedReadStatus_cfunc = self._get_library_function('niFake_CachedReadStatus')
self.niFake_CachedReadStatus_cfunc.argtypes = [ViSession, ctypes.POINTER(ViInt32), ctypes.POINTER(ViInt16)] # noqa: F405
self.niFake_CachedReadStatus_cfunc.restype = ViStatus # noqa: F405
return self.niFake_CachedReadStatus_cfunc(vi, acq_backlog, acq_status)

def niFake_ConfigureABC(self, vi): # noqa: N802
with self._func_lock:
if self.niFake_ConfigureABC_cfunc is None:
Expand Down Expand Up @@ -525,6 +535,14 @@ def niFake_ReadFromChannel(self, vi, channel_name, maximum_time, reading): # no
self.niFake_ReadFromChannel_cfunc.restype = ViStatus # noqa: F405
return self.niFake_ReadFromChannel_cfunc(vi, channel_name, maximum_time, reading)

def niFake_ReadStatus(self, vi, acquisition_backlog, acquisition_status): # noqa: N802
with self._func_lock:
if self.niFake_ReadStatus_cfunc is None:
self.niFake_ReadStatus_cfunc = self._get_library_function('niFake_ReadStatus')
self.niFake_ReadStatus_cfunc.argtypes = [ViSession, ctypes.POINTER(ViInt32), ctypes.POINTER(ViInt16)] # noqa: F405
self.niFake_ReadStatus_cfunc.restype = ViStatus # noqa: F405
return self.niFake_ReadStatus_cfunc(vi, acquisition_backlog, acquisition_status)

def niFake_ReturnANumberAndAString(self, vi, a_number, a_string): # noqa: N802
with self._func_lock:
if self.niFake_ReturnANumberAndAString_cfunc is None:
Expand Down
16 changes: 16 additions & 0 deletions generated/nifake/nifake/_library_interpreter.py
Original file line number Diff line number Diff line change
Expand Up @@ -150,6 +150,14 @@ def bool_array_output_function(self, number_of_elements): # noqa: N802
errors.handle_error(self, error_code, ignore_warnings=False, is_error_handling=False)
return [bool(an_array_ctype[i]) for i in range(number_of_elements_ctype.value)]

def cached_read_status(self): # noqa: N802
vi_ctype = _visatype.ViSession(self._vi) # case S110
acq_backlog_ctype = _visatype.ViInt32() # case S220
acq_status_ctype = _visatype.ViInt16() # case S220
error_code = self._library.niFake_CachedReadStatus(vi_ctype, None if acq_backlog_ctype is None else (ctypes.pointer(acq_backlog_ctype)), None if acq_status_ctype is None else (ctypes.pointer(acq_status_ctype)))
errors.handle_error(self, error_code, ignore_warnings=False, is_error_handling=False)
return int(acq_backlog_ctype.value), enums.AcquisitionStatus(acq_status_ctype.value)

def configure_abc(self): # noqa: N802
vi_ctype = _visatype.ViSession(self._vi) # case S110
error_code = self._library.niFake_ConfigureABC(vi_ctype)
Expand Down Expand Up @@ -596,6 +604,14 @@ def read_from_channel(self, channel_name, maximum_time): # noqa: N802
errors.handle_error(self, error_code, ignore_warnings=False, is_error_handling=False)
return float(reading_ctype.value)

def read_status(self): # noqa: N802
vi_ctype = _visatype.ViSession(self._vi) # case S110
acquisition_backlog_ctype = _visatype.ViInt32() # case S220
acquisition_status_ctype = _visatype.ViInt16() # case S220
error_code = self._library.niFake_ReadStatus(vi_ctype, None if acquisition_backlog_ctype is None else (ctypes.pointer(acquisition_backlog_ctype)), None if acquisition_status_ctype is None else (ctypes.pointer(acquisition_status_ctype)))
errors.handle_error(self, error_code, ignore_warnings=False, is_error_handling=False)
return int(acquisition_backlog_ctype.value), enums.AcquisitionStatus(acquisition_status_ctype.value)

def return_a_number_and_a_string(self): # noqa: N802
vi_ctype = _visatype.ViSession(self._vi) # case S110
a_number_ctype = _visatype.ViInt16() # case S220
Expand Down
8 changes: 8 additions & 0 deletions generated/nifake/nifake/enums.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,14 @@
from enum import IntFlag


class AcquisitionStatus(Enum):
RUNNING = 'NIFAKE_VAL_ACQUISITION_STATUS_RUNNING'
FINISHED_WITH_BACKLOG = 'NIFAKE_VAL_ACQUISITION_STATUS_FINISHED_WITH_BACKLOG'
FINISHED_WITH_NO_BACKLOG = 'NIFAKE_VAL_ACQUISITION_STATUS_FINISHED_WITH_NO_BACKLOG'
PAUSED = 'NIFAKE_VAL_ACQUISITION_STATUS_PAUSED'
NO_ACQUISITION_IN_PROGRESS = 'NIFAKE_VAL_ACQUISITION_STATUS_NO_ACQUISITION_IN_PROGRESS'


class Color(Enum):
RED = 1
r'''
Expand Down
31 changes: 31 additions & 0 deletions generated/nifake/nifake/session.py
Original file line number Diff line number Diff line change
Expand Up @@ -816,6 +816,21 @@ def bool_array_output_function(self, number_of_elements):
an_array = self._interpreter.bool_array_output_function(number_of_elements)
return an_array

@ivi_synchronized
def cached_read_status(self):
r'''cached_read_status

TBD

Returns:
acq_backlog (int):

acq_status (enums.AcquisitionStatus):

'''
acq_backlog, acq_status = self._interpreter.cached_read_status()
return acq_backlog, acq_status

@ivi_synchronized
def configure_abc(self):
r'''configure_abc
Expand Down Expand Up @@ -945,6 +960,7 @@ def fetch_waveform_into(self, waveform_data):
raise TypeError('waveform_data must be numpy.ndarray of dtype=float64, is ' + str(waveform_data.dtype))
self._interpreter.fetch_waveform_into(waveform_data)

@ivi_synchronized
def function_with_3d_numpy_array_of_numpy_complex128_input_parameter(self, multidimensional_array):
r'''function_with_3d_numpy_array_of_numpy_complex128_input_parameter

Expand Down Expand Up @@ -1504,6 +1520,21 @@ def read(self, maximum_time):
reading = self._interpreter.read(maximum_time)
return reading

@ivi_synchronized
def read_status(self):
r'''read_status

TBD

Returns:
acquisition_backlog (int):

acquisition_status (enums.AcquisitionStatus):

'''
acquisition_backlog, acquisition_status = self._interpreter.read_status()
return acquisition_backlog, acquisition_status

@ivi_synchronized
def return_a_number_and_a_string(self):
r'''return_a_number_and_a_string
Expand Down
42 changes: 42 additions & 0 deletions generated/nifake/nifake/unit_tests/_mock_helper.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,10 @@ def __init__(self):
self._defaults['BoolArrayOutputFunction'] = {}
self._defaults['BoolArrayOutputFunction']['return'] = 0
self._defaults['BoolArrayOutputFunction']['anArray'] = None
self._defaults['CachedReadStatus'] = {}
self._defaults['CachedReadStatus']['return'] = 0
self._defaults['CachedReadStatus']['acqBacklog'] = None
self._defaults['CachedReadStatus']['acqStatus'] = None
self._defaults['ConfigureABC'] = {}
self._defaults['ConfigureABC']['return'] = 0
self._defaults['CustomNestedStructRoundtrip'] = {}
Expand Down Expand Up @@ -166,6 +170,10 @@ def __init__(self):
self._defaults['ReadFromChannel'] = {}
self._defaults['ReadFromChannel']['return'] = 0
self._defaults['ReadFromChannel']['reading'] = None
self._defaults['ReadStatus'] = {}
self._defaults['ReadStatus']['return'] = 0
self._defaults['ReadStatus']['acquisitionBacklog'] = None
self._defaults['ReadStatus']['acquisitionStatus'] = None
self._defaults['ReturnANumberAndAString'] = {}
self._defaults['ReturnANumberAndAString']['return'] = 0
self._defaults['ReturnANumberAndAString']['aNumber'] = None
Expand Down Expand Up @@ -262,6 +270,21 @@ def niFake_BoolArrayOutputFunction(self, vi, number_of_elements, an_array): # n
an_array_ref[i] = test_value[i]
return self._defaults['BoolArrayOutputFunction']['return']

def niFake_CachedReadStatus(self, vi, acq_backlog, acq_status): # noqa: N802
if self._defaults['CachedReadStatus']['return'] != 0:
return self._defaults['CachedReadStatus']['return']
# acq_backlog
if self._defaults['CachedReadStatus']['acqBacklog'] is None:
raise MockFunctionCallError("niFake_CachedReadStatus", param='acqBacklog')
if acq_backlog is not None:
acq_backlog.contents.value = self._defaults['CachedReadStatus']['acqBacklog']
# acq_status
if self._defaults['CachedReadStatus']['acqStatus'] is None:
raise MockFunctionCallError("niFake_CachedReadStatus", param='acqStatus')
if acq_status is not None:
acq_status.contents.value = self._defaults['CachedReadStatus']['acqStatus']
return self._defaults['CachedReadStatus']['return']

def niFake_ConfigureABC(self, vi): # noqa: N802
if self._defaults['ConfigureABC']['return'] != 0:
return self._defaults['ConfigureABC']['return']
Expand Down Expand Up @@ -803,6 +826,21 @@ def niFake_ReadFromChannel(self, vi, channel_name, maximum_time, reading): # no
reading.contents.value = self._defaults['ReadFromChannel']['reading']
return self._defaults['ReadFromChannel']['return']

def niFake_ReadStatus(self, vi, acquisition_backlog, acquisition_status): # noqa: N802
if self._defaults['ReadStatus']['return'] != 0:
return self._defaults['ReadStatus']['return']
# acquisition_backlog
if self._defaults['ReadStatus']['acquisitionBacklog'] is None:
raise MockFunctionCallError("niFake_ReadStatus", param='acquisitionBacklog')
if acquisition_backlog is not None:
acquisition_backlog.contents.value = self._defaults['ReadStatus']['acquisitionBacklog']
# acquisition_status
if self._defaults['ReadStatus']['acquisitionStatus'] is None:
raise MockFunctionCallError("niFake_ReadStatus", param='acquisitionStatus')
if acquisition_status is not None:
acquisition_status.contents.value = self._defaults['ReadStatus']['acquisitionStatus']
return self._defaults['ReadStatus']['return']

def niFake_ReturnANumberAndAString(self, vi, a_number, a_string): # noqa: N802
if self._defaults['ReturnANumberAndAString']['return'] != 0:
return self._defaults['ReturnANumberAndAString']['return']
Expand Down Expand Up @@ -1036,6 +1074,8 @@ def set_side_effects_and_return_values(self, mock_library):
mock_library.niFake_AcceptListOfDurationsInSeconds.return_value = 0
mock_library.niFake_BoolArrayOutputFunction.side_effect = MockFunctionCallError("niFake_BoolArrayOutputFunction")
mock_library.niFake_BoolArrayOutputFunction.return_value = 0
mock_library.niFake_CachedReadStatus.side_effect = MockFunctionCallError("niFake_CachedReadStatus")
mock_library.niFake_CachedReadStatus.return_value = 0
mock_library.niFake_ConfigureABC.side_effect = MockFunctionCallError("niFake_ConfigureABC")
mock_library.niFake_ConfigureABC.return_value = 0
mock_library.niFake_CustomNestedStructRoundtrip.side_effect = MockFunctionCallError("niFake_CustomNestedStructRoundtrip")
Expand Down Expand Up @@ -1134,6 +1174,8 @@ def set_side_effects_and_return_values(self, mock_library):
mock_library.niFake_Read.return_value = 0
mock_library.niFake_ReadFromChannel.side_effect = MockFunctionCallError("niFake_ReadFromChannel")
mock_library.niFake_ReadFromChannel.return_value = 0
mock_library.niFake_ReadStatus.side_effect = MockFunctionCallError("niFake_ReadStatus")
mock_library.niFake_ReadStatus.return_value = 0
mock_library.niFake_ReturnANumberAndAString.side_effect = MockFunctionCallError("niFake_ReturnANumberAndAString")
mock_library.niFake_ReturnANumberAndAString.return_value = 0
mock_library.niFake_ReturnDurationInSeconds.side_effect = MockFunctionCallError("niFake_ReturnDurationInSeconds")
Expand Down
2 changes: 1 addition & 1 deletion src/nifake/metadata/attributes.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# -*- coding: utf-8 -*-
# This file is generated from NI-FAKE API metadata version 25.8.0d9999
# This file is generated from NI-FAKE API metadata version 25.8.0d100
attributes = {
1000000: {
'access': 'read-write',
Expand Down
4 changes: 2 additions & 2 deletions src/nifake/metadata/config.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
# -*- coding: utf-8 -*-
# This file is generated from NI-FAKE API metadata version 25.8.0d9999
# This file is generated from NI-FAKE API metadata version 25.8.0d100
config = {
'api_version': '25.8.0d9999',
'api_version': '25.8.0d100',
'c_function_prefix': 'niFake_',
'close_function': 'close',
'context_manager_name': {
Expand Down
38 changes: 37 additions & 1 deletion src/nifake/metadata/enums.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,30 @@
# -*- coding: utf-8 -*-
# This file is generated from NI-FAKE API metadata version 25.8.0d9999
# This file is generated from NI-FAKE API metadata version 25.8.0d100
enums = {
'AcquisitionStatus': {
'values': [
{
'name': 'NIFAKE_VAL_RUNNING',
'value': 'NIFAKE_VAL_ACQUISITION_STATUS_RUNNING'
},
{
'name': 'NIFAKE_VAL_FINISHED_WITH_BACKLOG',
'value': 'NIFAKE_VAL_ACQUISITION_STATUS_FINISHED_WITH_BACKLOG'
},
{
'name': 'NIFAKE_VAL_FINISHED_WITH_NO_BACKLOG',
'value': 'NIFAKE_VAL_ACQUISITION_STATUS_FINISHED_WITH_NO_BACKLOG'
},
{
'name': 'NIFAKE_VAL_PAUSED',
'value': 'NIFAKE_VAL_ACQUISITION_STATUS_PAUSED'
},
{
'name': 'NIFAKE_VAL_NO_ACQUISITION_IN_PROGRESS',
'value': 'NIFAKE_VAL_ACQUISITION_STATUS_NO_ACQUISITION_IN_PROGRESS'
}
]
},
'AltColor': {
'values': [
{
Expand Down Expand Up @@ -200,6 +224,18 @@
}
]
},
'ExtCalParts': {
'values': [
{
'name': 'NIFAKE_EXTCAL_PART1',
'value': 1
},
{
'name': 'NIFAKE_EXTCAL_PART2',
'value': 2
}
]
},
'FloatEnum': {
'values': [
{
Expand Down
Loading