diff --git a/src/ansys/dpf/gate/__init__.py b/src/ansys/dpf/gate/__init__.py index 299bfbdbbc4..6d52e414bf1 100644 --- a/src/ansys/dpf/gate/__init__.py +++ b/src/ansys/dpf/gate/__init__.py @@ -27,6 +27,8 @@ from .generated import external_operator_capi from .generated import f_e_model_abstract_api from .generated import f_e_model_capi +from .generated import fbs_ref_abstract_api +from .generated import fbs_ref_capi from .generated import field_abstract_api from .generated import field_capi from .generated import field_definition_abstract_api diff --git a/src/ansys/dpf/gate/generated/capi.py b/src/ansys/dpf/gate/generated/capi.py index 661fbfc20fc..337225a7203 100644 --- a/src/ansys/dpf/gate/generated/capi.py +++ b/src/ansys/dpf/gate/generated/capi.py @@ -5078,4 +5078,35 @@ def load_api(path): dll.Workflow_create_connection_map_for_object.argtypes = (ctypes.c_void_p, ctypes.POINTER(ctypes.c_int32), ctypes.POINTER(ctypes.c_wchar_p), ) dll.Workflow_create_connection_map_for_object.restype = ctypes.c_void_p + #------------------------------------------------------------------------------- + # FbsRef + #------------------------------------------------------------------------------- + if hasattr(dll, "FbsRef_new"): + dll.FbsRef_new.argtypes = (ctypes.c_void_p, ctypes.POINTER(ctypes.c_char), ctypes.c_void_p, ctypes.c_size_t, ctypes.POINTER(ctypes.c_int32), ctypes.POINTER(ctypes.c_wchar_p), ) + dll.FbsRef_new.restype = ctypes.c_void_p + + if hasattr(dll, "FbsRef_getFromDB"): + dll.FbsRef_getFromDB.argtypes = (ctypes.c_size_t, ctypes.POINTER(ctypes.c_int32), ctypes.POINTER(ctypes.c_wchar_p), ) + dll.FbsRef_getFromDB.restype = ctypes.c_void_p + + if hasattr(dll, "FbsRef_getID"): + dll.FbsRef_getID.argtypes = (ctypes.c_void_p, ctypes.POINTER(ctypes.c_int32), ctypes.POINTER(ctypes.c_wchar_p), ) + dll.FbsRef_getID.restype = ctypes.c_size_t + + if hasattr(dll, "Any_getAs_FbsRef"): + dll.Any_getAs_FbsRef.argtypes = (ctypes.c_void_p, ctypes.c_void_p, ctypes.POINTER(ctypes.c_char), ctypes.c_void_p, ctypes.POINTER(ctypes.c_size_t), ctypes.POINTER(ctypes.c_int32), ctypes.POINTER(ctypes.c_wchar_p), ) + dll.Any_getAs_FbsRef.restype = None + + if hasattr(dll, "FbsRef_StartOrGetThreadServer"): + dll.FbsRef_StartOrGetThreadServer.argtypes = (ctypes.c_bool, ctypes.POINTER(ctypes.c_char), ctypes.c_int32, ctypes.POINTER(ctypes.c_char), ctypes.POINTER(ctypes.c_int32), ctypes.POINTER(ctypes.c_wchar_p), ) + dll.FbsRef_StartOrGetThreadServer.restype = ctypes.c_void_p + + if hasattr(dll, "FbsRef_new_on_client"): + dll.FbsRef_new_on_client.argtypes = (ctypes.c_void_p, ctypes.c_void_p, ctypes.POINTER(ctypes.c_char), ctypes.c_void_p, ctypes.c_size_t, ctypes.POINTER(ctypes.c_int32), ctypes.POINTER(ctypes.c_wchar_p), ) + dll.FbsRef_new_on_client.restype = ctypes.c_void_p + + if hasattr(dll, "FbsRef_StartOrGetThreadServer_on_client"): + dll.FbsRef_StartOrGetThreadServer_on_client.argtypes = (ctypes.c_void_p, ctypes.c_bool, ctypes.POINTER(ctypes.c_char), ctypes.c_int32, ctypes.POINTER(ctypes.c_char), ctypes.POINTER(ctypes.c_int32), ctypes.POINTER(ctypes.c_wchar_p), ) + dll.FbsRef_StartOrGetThreadServer_on_client.restype = ctypes.c_void_p + diff --git a/src/ansys/dpf/gate/generated/fbs_ref_abstract_api.py b/src/ansys/dpf/gate/generated/fbs_ref_abstract_api.py new file mode 100644 index 00000000000..2fefee963c6 --- /dev/null +++ b/src/ansys/dpf/gate/generated/fbs_ref_abstract_api.py @@ -0,0 +1,41 @@ +#------------------------------------------------------------------------------- +# FbsRef +#------------------------------------------------------------------------------- + +class FbsRefAbstractAPI: + @staticmethod + def init_fbs_ref_environment(object): + pass + + @staticmethod + def finish_fbs_ref_environment(object): + pass + + @staticmethod + def fbs_ref_new(client, channel_address, req_slice, req_offset): + raise NotImplementedError + + @staticmethod + def fbs_ref_get_from_db(id): + raise NotImplementedError + + @staticmethod + def fbs_ref_get_id(obj): + raise NotImplementedError + + @staticmethod + def any_get_as_fbs_ref(obj, client, channel_address, req_slice, req_offset): + raise NotImplementedError + + @staticmethod + def fbs_ref_start_or_get_thread_server(get_existing, ip, port, address): + raise NotImplementedError + + @staticmethod + def fbs_ref_new_on_client(client, channel, channel_address, req_slice, req_offset): + raise NotImplementedError + + @staticmethod + def fbs_ref_start_or_get_thread_server_on_client(client, get_existing, ip, port, address): + raise NotImplementedError + diff --git a/src/ansys/dpf/gate/generated/fbs_ref_capi.py b/src/ansys/dpf/gate/generated/fbs_ref_capi.py new file mode 100644 index 00000000000..741a8b0e37f --- /dev/null +++ b/src/ansys/dpf/gate/generated/fbs_ref_capi.py @@ -0,0 +1,82 @@ +import ctypes +from ansys.dpf.gate import utils +from ansys.dpf.gate import errors +from ansys.dpf.gate.generated import capi +from ansys.dpf.gate.generated import fbs_ref_abstract_api +from ansys.dpf.gate.generated.data_processing_capi import DataProcessingCAPI + +#------------------------------------------------------------------------------- +# FbsRef +#------------------------------------------------------------------------------- + +class FbsRefCAPI(fbs_ref_abstract_api.FbsRefAbstractAPI): + + @staticmethod + def init_fbs_ref_environment(object): + # get core api + DataProcessingCAPI.init_data_processing_environment(object) + object._deleter_func = (DataProcessingCAPI.data_processing_delete_shared_object, lambda obj: obj) + + @staticmethod + def fbs_ref_new(client, channel_address, req_slice, req_offset): + errorSize = ctypes.c_int(0) + sError = ctypes.c_wchar_p() + res = capi.dll.FbsRef_new(client, utils.to_char_ptr(channel_address), req_slice, req_offset, ctypes.byref(utils.to_int32(errorSize)), ctypes.byref(sError)) + if errorSize.value != 0: + raise errors.DPFServerException(sError.value) + return res + + @staticmethod + def fbs_ref_get_from_db(id): + errorSize = ctypes.c_int(0) + sError = ctypes.c_wchar_p() + res = capi.dll.FbsRef_getFromDB(id, ctypes.byref(utils.to_int32(errorSize)), ctypes.byref(sError)) + if errorSize.value != 0: + raise errors.DPFServerException(sError.value) + return res + + @staticmethod + def fbs_ref_get_id(obj): + errorSize = ctypes.c_int(0) + sError = ctypes.c_wchar_p() + res = capi.dll.FbsRef_getID(obj._internal_obj if obj is not None else None, ctypes.byref(utils.to_int32(errorSize)), ctypes.byref(sError)) + if errorSize.value != 0: + raise errors.DPFServerException(sError.value) + return res + + @staticmethod + def any_get_as_fbs_ref(obj, client, channel_address, req_slice, req_offset): + errorSize = ctypes.c_int(0) + sError = ctypes.c_wchar_p() + res = capi.dll.Any_getAs_FbsRef(obj._internal_obj if obj is not None else None, client, utils.to_char_ptr(channel_address), req_slice, req_offset, ctypes.byref(utils.to_int32(errorSize)), ctypes.byref(sError)) + if errorSize.value != 0: + raise errors.DPFServerException(sError.value) + return res + + @staticmethod + def fbs_ref_start_or_get_thread_server(get_existing, ip, port, address): + errorSize = ctypes.c_int(0) + sError = ctypes.c_wchar_p() + res = capi.dll.FbsRef_StartOrGetThreadServer(get_existing, utils.to_char_ptr(ip), utils.to_int32(port), utils.to_char_ptr(address), ctypes.byref(utils.to_int32(errorSize)), ctypes.byref(sError)) + if errorSize.value != 0: + raise errors.DPFServerException(sError.value) + return res + + @staticmethod + def fbs_ref_new_on_client(client, channel, channel_address, req_slice, req_offset): + errorSize = ctypes.c_int(0) + sError = ctypes.c_wchar_p() + res = capi.dll.FbsRef_new_on_client(client._internal_obj if client is not None else None, channel, utils.to_char_ptr(channel_address), req_slice, req_offset, ctypes.byref(utils.to_int32(errorSize)), ctypes.byref(sError)) + if errorSize.value != 0: + raise errors.DPFServerException(sError.value) + return res + + @staticmethod + def fbs_ref_start_or_get_thread_server_on_client(client, get_existing, ip, port, address): + errorSize = ctypes.c_int(0) + sError = ctypes.c_wchar_p() + res = capi.dll.FbsRef_StartOrGetThreadServer_on_client(client._internal_obj if client is not None else None, get_existing, utils.to_char_ptr(ip), utils.to_int32(port), utils.to_char_ptr(address), ctypes.byref(utils.to_int32(errorSize)), ctypes.byref(sError)) + if errorSize.value != 0: + raise errors.DPFServerException(sError.value) + return res + diff --git a/src/ansys/dpf/gatebin/Ans.Dpf.GrpcClient.dll b/src/ansys/dpf/gatebin/Ans.Dpf.GrpcClient.dll index bb0ad960e5f..2602679f443 100644 Binary files a/src/ansys/dpf/gatebin/Ans.Dpf.GrpcClient.dll and b/src/ansys/dpf/gatebin/Ans.Dpf.GrpcClient.dll differ diff --git a/src/ansys/dpf/gatebin/DPFClientAPI.dll b/src/ansys/dpf/gatebin/DPFClientAPI.dll index a9fa6763c69..13dbe0d8ac0 100644 Binary files a/src/ansys/dpf/gatebin/DPFClientAPI.dll and b/src/ansys/dpf/gatebin/DPFClientAPI.dll differ diff --git a/src/ansys/dpf/gatebin/libAns.Dpf.GrpcClient.so b/src/ansys/dpf/gatebin/libAns.Dpf.GrpcClient.so index be676abf397..8d6b0cc7b92 100644 Binary files a/src/ansys/dpf/gatebin/libAns.Dpf.GrpcClient.so and b/src/ansys/dpf/gatebin/libAns.Dpf.GrpcClient.so differ diff --git a/src/ansys/dpf/gatebin/libDPFClientAPI.so b/src/ansys/dpf/gatebin/libDPFClientAPI.so index 857e3091e21..3fa1d068882 100644 Binary files a/src/ansys/dpf/gatebin/libDPFClientAPI.so and b/src/ansys/dpf/gatebin/libDPFClientAPI.so differ diff --git a/src/ansys/grpc/dpf/base_pb2.py b/src/ansys/grpc/dpf/base_pb2.py index 9cb417e37c1..19226414bee 100644 --- a/src/ansys/grpc/dpf/base_pb2.py +++ b/src/ansys/grpc/dpf/base_pb2.py @@ -14,7 +14,7 @@ -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\nbase.proto\x12\x15\x61nsys.api.dpf.base.v0\"\x07\n\x05\x45mpty\"6\n\x10\x45ntityIdentifier\x12\n\n\x02id\x18\x01 \x01(\x05\x12\x16\n\x0eserver_address\x18\x02 \x01(\t\"\"\n\x0c\x44oubleVector\x12\x12\n\nrep_double\x18\x01 \x03(\x01\" \n\x0b\x46loatVector\x12\x11\n\trep_float\x18\x01 \x03(\x02\"\x1c\n\tIntVector\x12\x0f\n\x07rep_int\x18\x01 \x03(\x05\"\x1f\n\nByteVector\x12\x11\n\trep_bytes\x18\x01 \x01(\x0c\"\x1a\n\x08PBString\x12\x0e\n\x06string\x18\x01 \x01(\t\"\"\n\x0cStringVector\x12\x12\n\nrep_string\x18\x01 \x03(\t\"4\n\x03Ids\x12-\n\x03ids\x18\x01 \x01(\x0b\x32 .ansys.api.dpf.base.v0.IntVector\"\x1c\n\x08Location\x12\x10\n\x08location\x18\x01 \x01(\t\"\x1e\n\rCountResponse\x12\r\n\x05\x63ount\x18\x01 \x01(\x05\"\x16\n\x05\x41rray\x12\r\n\x05\x61rray\x18\x01 \x01(\x0c\"V\n\rPluginRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0f\n\x07\x64llPath\x18\x02 \x01(\t\x12\x0e\n\x06symbol\x18\x03 \x01(\t\x12\x16\n\x0egenerate_files\x18\x04 \x01(\x08\"\x13\n\x11ServerInfoRequest\"\xef\x01\n\x12ServerInfoResponse\x12\x14\n\x0cmajorVersion\x18\x01 \x01(\x05\x12\x14\n\x0cminorVersion\x18\x02 \x01(\x05\x12\x11\n\tprocessId\x18\x03 \x01(\x04\x12\n\n\x02ip\x18\x04 \x01(\t\x12\x0c\n\x04port\x18\x05 \x01(\x05\x12M\n\nproperties\x18\x06 \x03(\x0b\x32\x39.ansys.api.dpf.base.v0.ServerInfoResponse.PropertiesEntry\x1a\x31\n\x0fPropertiesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"&\n\x0f\x44\x65scribeRequest\x12\x13\n\x0b\x64pf_type_id\x18\x01 \x01(\x05\"M\n\rDeleteRequest\x12<\n\x0b\x64pf_type_id\x18\x01 \x03(\x0b\x32\'.ansys.api.dpf.base.v0.EntityIdentifier\"S\n\x13\x44uplicateRefRequest\x12<\n\x0b\x64pf_type_id\x18\x01 \x01(\x0b\x32\'.ansys.api.dpf.base.v0.EntityIdentifier\"\'\n\x10\x44\x65scribeResponse\x12\x13\n\x0b\x64\x65scription\x18\x01 \x01(\t\"D\n\x15\x44\x65scribeArrayResponse\x12+\n\x05\x61rray\x18\x01 \x01(\x0b\x32\x1c.ansys.api.dpf.base.v0.Array\"X\n\x14\x44uplicateRefResponse\x12@\n\x0fnew_dpf_type_id\x18\x01 \x01(\x0b\x32\'.ansys.api.dpf.base.v0.EntityIdentifier\"2\n\x08\x46ileData\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\x12\x18\n\x10server_file_path\x18\x02 \x01(\t\"/\n\x13\x44ownloadFileRequest\x12\x18\n\x10server_file_path\x18\x01 \x01(\t\"E\n\x14\x44ownloadFileResponse\x12-\n\x04\x64\x61ta\x18\x01 \x01(\x0b\x32\x1f.ansys.api.dpf.base.v0.FileData\"r\n\x11UploadFileRequest\x12\x18\n\x10server_file_path\x18\x01 \x01(\t\x12\x14\n\x0cuse_temp_dir\x18\x02 \x01(\x08\x12-\n\x04\x64\x61ta\x18\x03 \x01(\x0b\x32\x1f.ansys.api.dpf.base.v0.FileData\".\n\x12UploadFileResponse\x12\x18\n\x10server_file_path\x18\x01 \x01(\t\"G\n\x10SerializeRequest\x12\x33\n\x02id\x18\x01 \x01(\x0b\x32\'.ansys.api.dpf.base.v0.EntityIdentifier\"\"\n\x11SerializeResponse\x12\r\n\x05\x61rray\x18\x01 \x01(\x0c\"c\n\x0e\x43onfigResponse\x12Q\n runtime_core_config_data_tree_id\x18\x01 \x01(\x0b\x32\'.ansys.api.dpf.base.v0.EntityIdentifier\">\n\x05\x45rror\x12\n\n\x02ok\x18\x01 \x01(\x08\x12\x12\n\nerror_code\x18\x02 \x01(\x05\x12\x15\n\rerror_message\x18\x03 \x01(\t\"\xac\x01\n\x15InitializationRequest\x12\x0f\n\x07\x63ontext\x18\x01 \x01(\x05\x12\x0b\n\x03xml\x18\x02 \x01(\t\x12\x14\n\x0c\x66orce_reinit\x18\x03 \x01(\x08\x12\x18\n\x0b\x61pi_version\x18\x04 \x01(\x05H\x00\x88\x01\x01\x12\x17\n\x0flicense_context\x18\x05 \x01(\x05\x12\x1c\n\x14\x65rror_on_plugin_load\x18\x06 \x01(\x05\x42\x0e\n\x0c_api_version\"E\n\x16InitializationResponse\x12+\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x1c.ansys.api.dpf.base.v0.Error*U\n\x0b\x43ountEntity\x12\x11\n\rNUM_COMPONENT\x10\x00\x12\x17\n\x13NUM_ELEMENTARY_DATA\x10\x01\x12\x0c\n\x08NUM_SETS\x10\x02\x12\x0c\n\x08NUM_DATA\x10\x03*\"\n\x07\x43omplex\x12\x08\n\x04REAL\x10\x00\x12\r\n\tIMAGINARY\x10\x01*;\n\x06Nature\x12\n\n\x06SCALAR\x10\x00\x12\n\n\x06VECTOR\x10\x01\x12\n\n\x06MATRIX\x10\x02\x12\r\n\tSYMMATRIX\x10\x05*\x94\x03\n\x04Type\x12\n\n\x06STRING\x10\x00\x12\x07\n\x03INT\x10\x01\x12\n\n\x06\x44OUBLE\x10\x02\x12\x08\n\x04\x42OOL\x10\x03\x12\t\n\x05\x46IELD\x10\x04\x12\x0e\n\nCOLLECTION\x10\x05\x12\x0b\n\x07SCOPING\x10\x06\x12\x10\n\x0c\x44\x41TA_SOURCES\x10\x07\x12\x11\n\rMESHED_REGION\x10\x08\x12\x15\n\x11TIME_FREQ_SUPPORT\x10\t\x12\x0f\n\x0bRESULT_INFO\x10\n\x12\x12\n\x0e\x43YCLIC_SUPPORT\x10\x0b\x12\x12\n\x0ePROPERTY_FIELD\x10\x0c\x12\x0c\n\x08WORKFLOW\x10\r\x12\x07\n\x03RUN\x10\x0e\x12\x07\n\x03\x41NY\x10\x0f\x12\x0b\n\x07VEC_INT\x10\x10\x12\x0e\n\nVEC_DOUBLE\x10\x11\x12\x0b\n\x07SUPPORT\x10\x12\x12\x0c\n\x08OPERATOR\x10\x13\x12\r\n\tDATA_TREE\x10\x14\x12\x0e\n\nVEC_STRING\x10\x15\x12\x10\n\x0cSTRING_FIELD\x10\x16\x12\x15\n\x11\x43USTOM_TYPE_FIELD\x10\x17\x12\x1a\n\x16GENERIC_DATA_CONTAINER\x10\x18\x12\x08\n\x04\x43HAR\x10\x19\x32\xfb\n\n\x0b\x42\x61seService\x12i\n\nInitialize\x12,.ansys.api.dpf.base.v0.InitializationRequest\x1a-.ansys.api.dpf.base.v0.InitializationResponse\x12\x64\n\rGetServerInfo\x12(.ansys.api.dpf.base.v0.ServerInfoRequest\x1a).ansys.api.dpf.base.v0.ServerInfoResponse\x12P\n\tGetConfig\x12\x1c.ansys.api.dpf.base.v0.Empty\x1a%.ansys.api.dpf.base.v0.ConfigResponse\x12J\n\x04Load\x12$.ansys.api.dpf.base.v0.PluginRequest\x1a\x1c.ansys.api.dpf.base.v0.Empty\x12[\n\x08\x44\x65scribe\x12&.ansys.api.dpf.base.v0.DescribeRequest\x1a\'.ansys.api.dpf.base.v0.DescribeResponse\x12j\n\x10\x44\x65scribeStreamed\x12&.ansys.api.dpf.base.v0.DescribeRequest\x1a,.ansys.api.dpf.base.v0.DescribeArrayResponse0\x01\x12L\n\x06\x44\x65lete\x12$.ansys.api.dpf.base.v0.DeleteRequest\x1a\x1c.ansys.api.dpf.base.v0.Empty\x12V\n\x0e\x44\x65leteStreamed\x12$.ansys.api.dpf.base.v0.DeleteRequest\x1a\x1c.ansys.api.dpf.base.v0.Empty(\x01\x12`\n\tSerialize\x12\'.ansys.api.dpf.base.v0.SerializeRequest\x1a(.ansys.api.dpf.base.v0.SerializeResponse0\x01\x12g\n\x0c\x44uplicateRef\x12*.ansys.api.dpf.base.v0.DuplicateRefRequest\x1a+.ansys.api.dpf.base.v0.DuplicateRefResponse\x12W\n\x0c\x43reateTmpDir\x12\x1c.ansys.api.dpf.base.v0.Empty\x1a).ansys.api.dpf.base.v0.UploadFileResponse\x12i\n\x0c\x44ownloadFile\x12*.ansys.api.dpf.base.v0.DownloadFileRequest\x1a+.ansys.api.dpf.base.v0.DownloadFileResponse0\x01\x12\x63\n\nUploadFile\x12(.ansys.api.dpf.base.v0.UploadFileRequest\x1a).ansys.api.dpf.base.v0.UploadFileResponse(\x01\x12M\n\x0fPrepareShutdown\x12\x1c.ansys.api.dpf.base.v0.Empty\x1a\x1c.ansys.api.dpf.base.v0.Empty\x12K\n\rReleaseServer\x12\x1c.ansys.api.dpf.base.v0.Empty\x1a\x1c.ansys.api.dpf.base.v0.EmptyB\x18\xaa\x02\x15\x41nsys.Api.Dpf.Base.V0b\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\nbase.proto\x12\x15\x61nsys.api.dpf.base.v0\"\x07\n\x05\x45mpty\"6\n\x10\x45ntityIdentifier\x12\n\n\x02id\x18\x01 \x01(\x05\x12\x16\n\x0eserver_address\x18\x02 \x01(\t\"\"\n\x0c\x44oubleVector\x12\x12\n\nrep_double\x18\x01 \x03(\x01\" \n\x0b\x46loatVector\x12\x11\n\trep_float\x18\x01 \x03(\x02\"\x1c\n\tIntVector\x12\x0f\n\x07rep_int\x18\x01 \x03(\x05\"\x1f\n\nByteVector\x12\x11\n\trep_bytes\x18\x01 \x01(\x0c\"\x1a\n\x08PBString\x12\x0e\n\x06string\x18\x01 \x01(\t\"\"\n\x0cStringVector\x12\x12\n\nrep_string\x18\x01 \x03(\t\"4\n\x03Ids\x12-\n\x03ids\x18\x01 \x01(\x0b\x32 .ansys.api.dpf.base.v0.IntVector\"\x1c\n\x08Location\x12\x10\n\x08location\x18\x01 \x01(\t\"\x1e\n\rCountResponse\x12\r\n\x05\x63ount\x18\x01 \x01(\x05\"\x16\n\x05\x41rray\x12\r\n\x05\x61rray\x18\x01 \x01(\x0c\"V\n\rPluginRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0f\n\x07\x64llPath\x18\x02 \x01(\t\x12\x0e\n\x06symbol\x18\x03 \x01(\t\x12\x16\n\x0egenerate_files\x18\x04 \x01(\x08\"\x13\n\x11ServerInfoRequest\"\xef\x01\n\x12ServerInfoResponse\x12\x14\n\x0cmajorVersion\x18\x01 \x01(\x05\x12\x14\n\x0cminorVersion\x18\x02 \x01(\x05\x12\x11\n\tprocessId\x18\x03 \x01(\x04\x12\n\n\x02ip\x18\x04 \x01(\t\x12\x0c\n\x04port\x18\x05 \x01(\x05\x12M\n\nproperties\x18\x06 \x03(\x0b\x32\x39.ansys.api.dpf.base.v0.ServerInfoResponse.PropertiesEntry\x1a\x31\n\x0fPropertiesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"&\n\x0f\x44\x65scribeRequest\x12\x13\n\x0b\x64pf_type_id\x18\x01 \x01(\x05\"M\n\rDeleteRequest\x12<\n\x0b\x64pf_type_id\x18\x01 \x03(\x0b\x32\'.ansys.api.dpf.base.v0.EntityIdentifier\"S\n\x13\x44uplicateRefRequest\x12<\n\x0b\x64pf_type_id\x18\x01 \x01(\x0b\x32\'.ansys.api.dpf.base.v0.EntityIdentifier\"\'\n\x10\x44\x65scribeResponse\x12\x13\n\x0b\x64\x65scription\x18\x01 \x01(\t\"D\n\x15\x44\x65scribeArrayResponse\x12+\n\x05\x61rray\x18\x01 \x01(\x0b\x32\x1c.ansys.api.dpf.base.v0.Array\"X\n\x14\x44uplicateRefResponse\x12@\n\x0fnew_dpf_type_id\x18\x01 \x01(\x0b\x32\'.ansys.api.dpf.base.v0.EntityIdentifier\"2\n\x08\x46ileData\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\x12\x18\n\x10server_file_path\x18\x02 \x01(\t\"/\n\x13\x44ownloadFileRequest\x12\x18\n\x10server_file_path\x18\x01 \x01(\t\"E\n\x14\x44ownloadFileResponse\x12-\n\x04\x64\x61ta\x18\x01 \x01(\x0b\x32\x1f.ansys.api.dpf.base.v0.FileData\"r\n\x11UploadFileRequest\x12\x18\n\x10server_file_path\x18\x01 \x01(\t\x12\x14\n\x0cuse_temp_dir\x18\x02 \x01(\x08\x12-\n\x04\x64\x61ta\x18\x03 \x01(\x0b\x32\x1f.ansys.api.dpf.base.v0.FileData\".\n\x12UploadFileResponse\x12\x18\n\x10server_file_path\x18\x01 \x01(\t\"G\n\x10SerializeRequest\x12\x33\n\x02id\x18\x01 \x01(\x0b\x32\'.ansys.api.dpf.base.v0.EntityIdentifier\"\"\n\x11SerializeResponse\x12\r\n\x05\x61rray\x18\x01 \x01(\x0c\"c\n\x0e\x43onfigResponse\x12Q\n runtime_core_config_data_tree_id\x18\x01 \x01(\x0b\x32\'.ansys.api.dpf.base.v0.EntityIdentifier\">\n\x05\x45rror\x12\n\n\x02ok\x18\x01 \x01(\x08\x12\x12\n\nerror_code\x18\x02 \x01(\x05\x12\x15\n\rerror_message\x18\x03 \x01(\t\"\xac\x01\n\x15InitializationRequest\x12\x0f\n\x07\x63ontext\x18\x01 \x01(\x05\x12\x0b\n\x03xml\x18\x02 \x01(\t\x12\x14\n\x0c\x66orce_reinit\x18\x03 \x01(\x08\x12\x18\n\x0b\x61pi_version\x18\x04 \x01(\x05H\x00\x88\x01\x01\x12\x17\n\x0flicense_context\x18\x05 \x01(\x05\x12\x1c\n\x14\x65rror_on_plugin_load\x18\x06 \x01(\x05\x42\x0e\n\x0c_api_version\"E\n\x16InitializationResponse\x12+\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x1c.ansys.api.dpf.base.v0.Error*U\n\x0b\x43ountEntity\x12\x11\n\rNUM_COMPONENT\x10\x00\x12\x17\n\x13NUM_ELEMENTARY_DATA\x10\x01\x12\x0c\n\x08NUM_SETS\x10\x02\x12\x0c\n\x08NUM_DATA\x10\x03*\"\n\x07\x43omplex\x12\x08\n\x04REAL\x10\x00\x12\r\n\tIMAGINARY\x10\x01*;\n\x06Nature\x12\n\n\x06SCALAR\x10\x00\x12\n\n\x06VECTOR\x10\x01\x12\n\n\x06MATRIX\x10\x02\x12\r\n\tSYMMATRIX\x10\x05*\xa1\x03\n\x04Type\x12\n\n\x06STRING\x10\x00\x12\x07\n\x03INT\x10\x01\x12\n\n\x06\x44OUBLE\x10\x02\x12\x08\n\x04\x42OOL\x10\x03\x12\t\n\x05\x46IELD\x10\x04\x12\x0e\n\nCOLLECTION\x10\x05\x12\x0b\n\x07SCOPING\x10\x06\x12\x10\n\x0c\x44\x41TA_SOURCES\x10\x07\x12\x11\n\rMESHED_REGION\x10\x08\x12\x15\n\x11TIME_FREQ_SUPPORT\x10\t\x12\x0f\n\x0bRESULT_INFO\x10\n\x12\x12\n\x0e\x43YCLIC_SUPPORT\x10\x0b\x12\x12\n\x0ePROPERTY_FIELD\x10\x0c\x12\x0c\n\x08WORKFLOW\x10\r\x12\x07\n\x03RUN\x10\x0e\x12\x07\n\x03\x41NY\x10\x0f\x12\x0b\n\x07VEC_INT\x10\x10\x12\x0e\n\nVEC_DOUBLE\x10\x11\x12\x0b\n\x07SUPPORT\x10\x12\x12\x0c\n\x08OPERATOR\x10\x13\x12\r\n\tDATA_TREE\x10\x14\x12\x0e\n\nVEC_STRING\x10\x15\x12\x10\n\x0cSTRING_FIELD\x10\x16\x12\x15\n\x11\x43USTOM_TYPE_FIELD\x10\x17\x12\x1a\n\x16GENERIC_DATA_CONTAINER\x10\x18\x12\x08\n\x04\x43HAR\x10\x19\x12\x0b\n\x07\x46\x42S_REF\x10\x1a\x32\xfb\n\n\x0b\x42\x61seService\x12i\n\nInitialize\x12,.ansys.api.dpf.base.v0.InitializationRequest\x1a-.ansys.api.dpf.base.v0.InitializationResponse\x12\x64\n\rGetServerInfo\x12(.ansys.api.dpf.base.v0.ServerInfoRequest\x1a).ansys.api.dpf.base.v0.ServerInfoResponse\x12P\n\tGetConfig\x12\x1c.ansys.api.dpf.base.v0.Empty\x1a%.ansys.api.dpf.base.v0.ConfigResponse\x12J\n\x04Load\x12$.ansys.api.dpf.base.v0.PluginRequest\x1a\x1c.ansys.api.dpf.base.v0.Empty\x12[\n\x08\x44\x65scribe\x12&.ansys.api.dpf.base.v0.DescribeRequest\x1a\'.ansys.api.dpf.base.v0.DescribeResponse\x12j\n\x10\x44\x65scribeStreamed\x12&.ansys.api.dpf.base.v0.DescribeRequest\x1a,.ansys.api.dpf.base.v0.DescribeArrayResponse0\x01\x12L\n\x06\x44\x65lete\x12$.ansys.api.dpf.base.v0.DeleteRequest\x1a\x1c.ansys.api.dpf.base.v0.Empty\x12V\n\x0e\x44\x65leteStreamed\x12$.ansys.api.dpf.base.v0.DeleteRequest\x1a\x1c.ansys.api.dpf.base.v0.Empty(\x01\x12`\n\tSerialize\x12\'.ansys.api.dpf.base.v0.SerializeRequest\x1a(.ansys.api.dpf.base.v0.SerializeResponse0\x01\x12g\n\x0c\x44uplicateRef\x12*.ansys.api.dpf.base.v0.DuplicateRefRequest\x1a+.ansys.api.dpf.base.v0.DuplicateRefResponse\x12W\n\x0c\x43reateTmpDir\x12\x1c.ansys.api.dpf.base.v0.Empty\x1a).ansys.api.dpf.base.v0.UploadFileResponse\x12i\n\x0c\x44ownloadFile\x12*.ansys.api.dpf.base.v0.DownloadFileRequest\x1a+.ansys.api.dpf.base.v0.DownloadFileResponse0\x01\x12\x63\n\nUploadFile\x12(.ansys.api.dpf.base.v0.UploadFileRequest\x1a).ansys.api.dpf.base.v0.UploadFileResponse(\x01\x12M\n\x0fPrepareShutdown\x12\x1c.ansys.api.dpf.base.v0.Empty\x1a\x1c.ansys.api.dpf.base.v0.Empty\x12K\n\rReleaseServer\x12\x1c.ansys.api.dpf.base.v0.Empty\x1a\x1c.ansys.api.dpf.base.v0.EmptyB\x18\xaa\x02\x15\x41nsys.Api.Dpf.Base.V0b\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -31,7 +31,7 @@ _globals['_NATURE']._serialized_start=2174 _globals['_NATURE']._serialized_end=2233 _globals['_TYPE']._serialized_start=2236 - _globals['_TYPE']._serialized_end=2640 + _globals['_TYPE']._serialized_end=2653 _globals['_EMPTY']._serialized_start=37 _globals['_EMPTY']._serialized_end=44 _globals['_ENTITYIDENTIFIER']._serialized_start=46 @@ -98,6 +98,6 @@ _globals['_INITIALIZATIONREQUEST']._serialized_end=1978 _globals['_INITIALIZATIONRESPONSE']._serialized_start=1980 _globals['_INITIALIZATIONRESPONSE']._serialized_end=2049 - _globals['_BASESERVICE']._serialized_start=2643 - _globals['_BASESERVICE']._serialized_end=4046 + _globals['_BASESERVICE']._serialized_start=2656 + _globals['_BASESERVICE']._serialized_end=4059 # @@protoc_insertion_point(module_scope) diff --git a/src/ansys/grpc/dpf/dpf_any_pb2.py b/src/ansys/grpc/dpf/dpf_any_pb2.py index 76e7101b20c..12bfbe3d26f 100644 --- a/src/ansys/grpc/dpf/dpf_any_pb2.py +++ b/src/ansys/grpc/dpf/dpf_any_pb2.py @@ -26,9 +26,10 @@ import ansys.grpc.dpf.operator_pb2 as operator__pb2 import ansys.grpc.dpf.generic_data_container_pb2 as generic__data__container__pb2 import ansys.grpc.dpf.data_tree_pb2 as data__tree__pb2 +import ansys.grpc.dpf.fbs_ref_pb2 as fbs__ref__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\rdpf_any.proto\x12\x18\x61nsys.api.dpf.dpf_any.v0\x1a\nbase.proto\x1a\x15\x64pf_any_message.proto\x1a\x18\x63ollection_message.proto\x1a\x0b\x66ield.proto\x1a\rscoping.proto\x1a\x12\x64\x61ta_sources.proto\x1a\x13meshed_region.proto\x1a\x17time_freq_support.proto\x1a\x14\x63yclic_support.proto\x1a\x16workflow_message.proto\x1a\x11result_info.proto\x1a\x0eoperator.proto\x1a\x1cgeneric_data_container.proto\x1a\x0f\x64\x61ta_tree.proto\"$\n\x0cListResponse\x12\x14\n\x0cwrapped_type\x18\x01 \x01(\t\"\\\n\x0bTypeRequest\x12\x35\n\x03\x61ny\x18\x01 \x01(\x0b\x32(.ansys.api.dpf.dpf_any_message.v0.DpfAny\x12\x16\n\x0erequested_type\x18\x02 \x01(\t\"\"\n\x0cTypeResponse\x12\x12\n\nis_type_of\x18\x01 \x01(\x08\"\x9e\x01\n\x0cGetAsRequest\x12\x35\n\x03\x61ny\x18\x01 \x01(\x0b\x32(.ansys.api.dpf.dpf_any_message.v0.DpfAny\x12)\n\x04type\x18\x02 \x01(\x0e\x32\x1b.ansys.api.dpf.base.v0.Type\x12,\n\x07subtype\x18\x03 \x01(\x0e\x32\x1b.ansys.api.dpf.base.v0.Type\"\xf1\x06\n\rGetAsResponse\x12.\n\x05\x66ield\x18\x01 \x01(\x0b\x32\x1d.ansys.api.dpf.field.v0.FieldH\x00\x12=\n\ncollection\x18\x02 \x01(\x0b\x32\'.ansys.api.dpf.collection.v0.CollectionH\x00\x12\x34\n\x07scoping\x18\x03 \x01(\x0b\x32!.ansys.api.dpf.scoping.v0.ScopingH\x00\x12\x42\n\x0c\x64\x61ta_sources\x18\x04 \x01(\x0b\x32*.ansys.api.dpf.data_sources.v0.DataSourcesH\x00\x12<\n\x04mesh\x18\x05 \x01(\x0b\x32,.ansys.api.dpf.meshed_region.v0.MeshedRegionH\x00\x12\x45\n\x0b\x63yc_support\x18\x06 \x01(\x0b\x32..ansys.api.dpf.cyclic_support.v0.CyclicSupportH\x00\x12P\n\x11time_freq_support\x18\x07 \x01(\x0b\x32\x33.ansys.api.dpf.time_freq_support.v0.TimeFreqSupportH\x00\x12?\n\x08workflow\x18\x08 \x01(\x0b\x32+.ansys.api.dpf.workflow_message.v0.WorkflowH\x00\x12;\n\x08operator\x18\t \x01(\x0b\x32\'.ansys.api.dpf.dpf_operator.v0.OperatorH\x00\x12?\n\x0bresult_info\x18\n \x01(\x0b\x32(.ansys.api.dpf.result_info.v0.ResultInfoH\x00\x12_\n\x16generic_data_container\x18\x0b \x01(\x0b\x32=.ansys.api.dpf.generic_data_container.v0.GenericDataContainerH\x00\x12\x39\n\tdata_tree\x18\x0f \x01(\x0b\x32$.ansys.api.dpf.data_tree.v0.DataTreeH\x00\x12\x11\n\x07int_val\x18\x0c \x01(\x05H\x00\x12\x14\n\nstring_val\x18\r \x01(\tH\x00\x12\x14\n\ndouble_val\x18\x0e \x01(\x01H\x00\x42\x06\n\x04\x64\x61ta\"\xe6\x01\n\rCreateRequest\x12)\n\x04type\x18\x01 \x01(\x0e\x32\x1b.ansys.api.dpf.base.v0.Type\x12\x35\n\x02id\x18\x02 \x01(\x0b\x32\'.ansys.api.dpf.base.v0.EntityIdentifierH\x00\x12\x11\n\x07int_val\x18\x03 \x01(\x05H\x00\x12\x14\n\nstring_val\x18\x04 \x01(\tH\x00\x12\x14\n\ndouble_val\x18\x05 \x01(\x01H\x00\x12,\n\x07subtype\x18\x06 \x01(\x0e\x32\x1b.ansys.api.dpf.base.v0.TypeB\x06\n\x04\x64\x61ta\"A\n\x12GetAsArrayResponse\x12+\n\x05\x61rray\x18\x01 \x01(\x0b\x32\x1c.ansys.api.dpf.base.v0.Array\"o\n\x15\x43reateStreamedRequest\x12)\n\x04type\x18\x01 \x01(\x0e\x32\x1b.ansys.api.dpf.base.v0.Type\x12+\n\x05\x61rray\x18\x02 \x01(\x0b\x32\x1c.ansys.api.dpf.base.v0.Array\"6\n\x07\x41llData\x12+\n\x05\x61rray\x18\x01 \x01(\x0b\x32\x1c.ansys.api.dpf.base.v0.Array\"P\n\x16\x43reateWithDataResponse\x12\x36\n\x04\x61nys\x18\x01 \x03(\x0b\x32(.ansys.api.dpf.dpf_any_message.v0.DpfAny2\xbc\x05\n\rDpfAnyService\x12[\n\x06\x43reate\x12\'.ansys.api.dpf.dpf_any.v0.CreateRequest\x1a(.ansys.api.dpf.dpf_any_message.v0.DpfAny\x12i\n\x0e\x43reateWithData\x12!.ansys.api.dpf.dpf_any.v0.AllData\x1a\x30.ansys.api.dpf.dpf_any.v0.CreateWithDataResponse(\x01\x30\x01\x12X\n\x04List\x12(.ansys.api.dpf.dpf_any_message.v0.DpfAny\x1a&.ansys.api.dpf.dpf_any.v0.ListResponse\x12W\n\x06IsType\x12%.ansys.api.dpf.dpf_any.v0.TypeRequest\x1a&.ansys.api.dpf.dpf_any.v0.TypeResponse\x12X\n\x05GetAs\x12&.ansys.api.dpf.dpf_any.v0.GetAsRequest\x1a\'.ansys.api.dpf.dpf_any.v0.GetAsResponse\x12m\n\x0e\x43reateStreamed\x12/.ansys.api.dpf.dpf_any.v0.CreateStreamedRequest\x1a(.ansys.api.dpf.dpf_any_message.v0.DpfAny(\x01\x12g\n\rGetAsStreamed\x12&.ansys.api.dpf.dpf_any.v0.GetAsRequest\x1a,.ansys.api.dpf.dpf_any.v0.GetAsArrayResponse0\x01\x42\x1a\xaa\x02\x17\x41nsys.Api.Dpf.DpfAny.V0b\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\rdpf_any.proto\x12\x18\x61nsys.api.dpf.dpf_any.v0\x1a\nbase.proto\x1a\x15\x64pf_any_message.proto\x1a\x18\x63ollection_message.proto\x1a\x0b\x66ield.proto\x1a\rscoping.proto\x1a\x12\x64\x61ta_sources.proto\x1a\x13meshed_region.proto\x1a\x17time_freq_support.proto\x1a\x14\x63yclic_support.proto\x1a\x16workflow_message.proto\x1a\x11result_info.proto\x1a\x0eoperator.proto\x1a\x1cgeneric_data_container.proto\x1a\x0f\x64\x61ta_tree.proto\x1a\rfbs_ref.proto\"$\n\x0cListResponse\x12\x14\n\x0cwrapped_type\x18\x01 \x01(\t\"\\\n\x0bTypeRequest\x12\x35\n\x03\x61ny\x18\x01 \x01(\x0b\x32(.ansys.api.dpf.dpf_any_message.v0.DpfAny\x12\x16\n\x0erequested_type\x18\x02 \x01(\t\"\"\n\x0cTypeResponse\x12\x12\n\nis_type_of\x18\x01 \x01(\x08\"\x9e\x01\n\x0cGetAsRequest\x12\x35\n\x03\x61ny\x18\x01 \x01(\x0b\x32(.ansys.api.dpf.dpf_any_message.v0.DpfAny\x12)\n\x04type\x18\x02 \x01(\x0e\x32\x1b.ansys.api.dpf.base.v0.Type\x12,\n\x07subtype\x18\x03 \x01(\x0e\x32\x1b.ansys.api.dpf.base.v0.Type\"\xa6\x07\n\rGetAsResponse\x12.\n\x05\x66ield\x18\x01 \x01(\x0b\x32\x1d.ansys.api.dpf.field.v0.FieldH\x00\x12=\n\ncollection\x18\x02 \x01(\x0b\x32\'.ansys.api.dpf.collection.v0.CollectionH\x00\x12\x34\n\x07scoping\x18\x03 \x01(\x0b\x32!.ansys.api.dpf.scoping.v0.ScopingH\x00\x12\x42\n\x0c\x64\x61ta_sources\x18\x04 \x01(\x0b\x32*.ansys.api.dpf.data_sources.v0.DataSourcesH\x00\x12<\n\x04mesh\x18\x05 \x01(\x0b\x32,.ansys.api.dpf.meshed_region.v0.MeshedRegionH\x00\x12\x45\n\x0b\x63yc_support\x18\x06 \x01(\x0b\x32..ansys.api.dpf.cyclic_support.v0.CyclicSupportH\x00\x12P\n\x11time_freq_support\x18\x07 \x01(\x0b\x32\x33.ansys.api.dpf.time_freq_support.v0.TimeFreqSupportH\x00\x12?\n\x08workflow\x18\x08 \x01(\x0b\x32+.ansys.api.dpf.workflow_message.v0.WorkflowH\x00\x12;\n\x08operator\x18\t \x01(\x0b\x32\'.ansys.api.dpf.dpf_operator.v0.OperatorH\x00\x12?\n\x0bresult_info\x18\n \x01(\x0b\x32(.ansys.api.dpf.result_info.v0.ResultInfoH\x00\x12_\n\x16generic_data_container\x18\x0b \x01(\x0b\x32=.ansys.api.dpf.generic_data_container.v0.GenericDataContainerH\x00\x12\x39\n\tdata_tree\x18\x0f \x01(\x0b\x32$.ansys.api.dpf.data_tree.v0.DataTreeH\x00\x12\x33\n\x07\x66\x62s_ref\x18\x10 \x01(\x0b\x32 .ansys.api.dpf.fbs_ref.v0.FBSRefH\x00\x12\x11\n\x07int_val\x18\x0c \x01(\x05H\x00\x12\x14\n\nstring_val\x18\r \x01(\tH\x00\x12\x14\n\ndouble_val\x18\x0e \x01(\x01H\x00\x42\x06\n\x04\x64\x61ta\"\xe6\x01\n\rCreateRequest\x12)\n\x04type\x18\x01 \x01(\x0e\x32\x1b.ansys.api.dpf.base.v0.Type\x12\x35\n\x02id\x18\x02 \x01(\x0b\x32\'.ansys.api.dpf.base.v0.EntityIdentifierH\x00\x12\x11\n\x07int_val\x18\x03 \x01(\x05H\x00\x12\x14\n\nstring_val\x18\x04 \x01(\tH\x00\x12\x14\n\ndouble_val\x18\x05 \x01(\x01H\x00\x12,\n\x07subtype\x18\x06 \x01(\x0e\x32\x1b.ansys.api.dpf.base.v0.TypeB\x06\n\x04\x64\x61ta\"A\n\x12GetAsArrayResponse\x12+\n\x05\x61rray\x18\x01 \x01(\x0b\x32\x1c.ansys.api.dpf.base.v0.Array\"o\n\x15\x43reateStreamedRequest\x12)\n\x04type\x18\x01 \x01(\x0e\x32\x1b.ansys.api.dpf.base.v0.Type\x12+\n\x05\x61rray\x18\x02 \x01(\x0b\x32\x1c.ansys.api.dpf.base.v0.Array\"6\n\x07\x41llData\x12+\n\x05\x61rray\x18\x01 \x01(\x0b\x32\x1c.ansys.api.dpf.base.v0.Array\"P\n\x16\x43reateWithDataResponse\x12\x36\n\x04\x61nys\x18\x01 \x03(\x0b\x32(.ansys.api.dpf.dpf_any_message.v0.DpfAny2\xbc\x05\n\rDpfAnyService\x12[\n\x06\x43reate\x12\'.ansys.api.dpf.dpf_any.v0.CreateRequest\x1a(.ansys.api.dpf.dpf_any_message.v0.DpfAny\x12i\n\x0e\x43reateWithData\x12!.ansys.api.dpf.dpf_any.v0.AllData\x1a\x30.ansys.api.dpf.dpf_any.v0.CreateWithDataResponse(\x01\x30\x01\x12X\n\x04List\x12(.ansys.api.dpf.dpf_any_message.v0.DpfAny\x1a&.ansys.api.dpf.dpf_any.v0.ListResponse\x12W\n\x06IsType\x12%.ansys.api.dpf.dpf_any.v0.TypeRequest\x1a&.ansys.api.dpf.dpf_any.v0.TypeResponse\x12X\n\x05GetAs\x12&.ansys.api.dpf.dpf_any.v0.GetAsRequest\x1a\'.ansys.api.dpf.dpf_any.v0.GetAsResponse\x12m\n\x0e\x43reateStreamed\x12/.ansys.api.dpf.dpf_any.v0.CreateStreamedRequest\x1a(.ansys.api.dpf.dpf_any_message.v0.DpfAny(\x01\x12g\n\rGetAsStreamed\x12&.ansys.api.dpf.dpf_any.v0.GetAsRequest\x1a,.ansys.api.dpf.dpf_any.v0.GetAsArrayResponse0\x01\x42\x1a\xaa\x02\x17\x41nsys.Api.Dpf.DpfAny.V0b\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -36,26 +37,26 @@ if _descriptor._USE_C_DESCRIPTORS == False: _globals['DESCRIPTOR']._options = None _globals['DESCRIPTOR']._serialized_options = b'\252\002\027Ansys.Api.Dpf.DpfAny.V0' - _globals['_LISTRESPONSE']._serialized_start=326 - _globals['_LISTRESPONSE']._serialized_end=362 - _globals['_TYPEREQUEST']._serialized_start=364 - _globals['_TYPEREQUEST']._serialized_end=456 - _globals['_TYPERESPONSE']._serialized_start=458 - _globals['_TYPERESPONSE']._serialized_end=492 - _globals['_GETASREQUEST']._serialized_start=495 - _globals['_GETASREQUEST']._serialized_end=653 - _globals['_GETASRESPONSE']._serialized_start=656 - _globals['_GETASRESPONSE']._serialized_end=1537 - _globals['_CREATEREQUEST']._serialized_start=1540 - _globals['_CREATEREQUEST']._serialized_end=1770 - _globals['_GETASARRAYRESPONSE']._serialized_start=1772 - _globals['_GETASARRAYRESPONSE']._serialized_end=1837 - _globals['_CREATESTREAMEDREQUEST']._serialized_start=1839 - _globals['_CREATESTREAMEDREQUEST']._serialized_end=1950 - _globals['_ALLDATA']._serialized_start=1952 - _globals['_ALLDATA']._serialized_end=2006 - _globals['_CREATEWITHDATARESPONSE']._serialized_start=2008 - _globals['_CREATEWITHDATARESPONSE']._serialized_end=2088 - _globals['_DPFANYSERVICE']._serialized_start=2091 - _globals['_DPFANYSERVICE']._serialized_end=2791 + _globals['_LISTRESPONSE']._serialized_start=341 + _globals['_LISTRESPONSE']._serialized_end=377 + _globals['_TYPEREQUEST']._serialized_start=379 + _globals['_TYPEREQUEST']._serialized_end=471 + _globals['_TYPERESPONSE']._serialized_start=473 + _globals['_TYPERESPONSE']._serialized_end=507 + _globals['_GETASREQUEST']._serialized_start=510 + _globals['_GETASREQUEST']._serialized_end=668 + _globals['_GETASRESPONSE']._serialized_start=671 + _globals['_GETASRESPONSE']._serialized_end=1605 + _globals['_CREATEREQUEST']._serialized_start=1608 + _globals['_CREATEREQUEST']._serialized_end=1838 + _globals['_GETASARRAYRESPONSE']._serialized_start=1840 + _globals['_GETASARRAYRESPONSE']._serialized_end=1905 + _globals['_CREATESTREAMEDREQUEST']._serialized_start=1907 + _globals['_CREATESTREAMEDREQUEST']._serialized_end=2018 + _globals['_ALLDATA']._serialized_start=2020 + _globals['_ALLDATA']._serialized_end=2074 + _globals['_CREATEWITHDATARESPONSE']._serialized_start=2076 + _globals['_CREATEWITHDATARESPONSE']._serialized_end=2156 + _globals['_DPFANYSERVICE']._serialized_start=2159 + _globals['_DPFANYSERVICE']._serialized_end=2859 # @@protoc_insertion_point(module_scope) diff --git a/src/ansys/grpc/dpf/fbs_ref_pb2.py b/src/ansys/grpc/dpf/fbs_ref_pb2.py new file mode 100644 index 00000000000..9fb73cf5a22 --- /dev/null +++ b/src/ansys/grpc/dpf/fbs_ref_pb2.py @@ -0,0 +1,36 @@ +# -*- coding: utf-8 -*- +# Generated by the protocol buffer compiler. DO NOT EDIT! +# source: fbs_ref.proto +# Protobuf Python Version: 4.25.1 +"""Generated protocol buffer code.""" +from google.protobuf import descriptor as _descriptor +from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import symbol_database as _symbol_database +from google.protobuf.internal import builder as _builder +# @@protoc_insertion_point(imports) + +_sym_db = _symbol_database.Default() + + +import ansys.grpc.dpf.base_pb2 as base__pb2 + + +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\rfbs_ref.proto\x12\x18\x61nsys.api.dpf.fbs_ref.v0\x1a\nbase.proto\"\x18\n\nFBSRefData\x12\n\n\x02id\x18\x01 \x01(\x04\"q\n\x06\x46\x42SRef\x12\x33\n\x02id\x18\x01 \x01(\x0b\x32\'.ansys.api.dpf.base.v0.EntityIdentifier\x12\x32\n\x04\x64\x61ta\x18\x02 \x01(\x0b\x32$.ansys.api.dpf.fbs_ref.v0.FBSRefData\"P\n\x1eStartFBSObjectDBServiceRequest\x12\n\n\x02ip\x18\x01 \x01(\t\x12\x0c\n\x04port\x18\x02 \x01(\x05\x12\x14\n\x0cget_existing\x18\x03 \x01(\x08\"g\n\x1fStartFBSObjectDBServiceResponse\x12\x0f\n\x07\x61\x64\x64ress\x18\x01 \x01(\t\x12\x33\n\x02id\x18\x02 \x01(\x0b\x32\'.ansys.api.dpf.base.v0.EntityIdentifier2\xe9\x01\n\rFBSRefService\x12P\n\x06\x43reate\x12$.ansys.api.dpf.fbs_ref.v0.FBSRefData\x1a .ansys.api.dpf.fbs_ref.v0.FBSRef\x12\x85\x01\n\x0eStartFbsServer\x12\x38.ansys.api.dpf.fbs_ref.v0.StartFBSObjectDBServiceRequest\x1a\x39.ansys.api.dpf.fbs_ref.v0.StartFBSObjectDBServiceResponseB\x1a\xaa\x02\x17\x41nsys.Api.Dpf.FBSRef.V0b\x06proto3') + +_globals = globals() +_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'fbs_ref_pb2', _globals) +if _descriptor._USE_C_DESCRIPTORS == False: + _globals['DESCRIPTOR']._options = None + _globals['DESCRIPTOR']._serialized_options = b'\252\002\027Ansys.Api.Dpf.FBSRef.V0' + _globals['_FBSREFDATA']._serialized_start=55 + _globals['_FBSREFDATA']._serialized_end=79 + _globals['_FBSREF']._serialized_start=81 + _globals['_FBSREF']._serialized_end=194 + _globals['_STARTFBSOBJECTDBSERVICEREQUEST']._serialized_start=196 + _globals['_STARTFBSOBJECTDBSERVICEREQUEST']._serialized_end=276 + _globals['_STARTFBSOBJECTDBSERVICERESPONSE']._serialized_start=278 + _globals['_STARTFBSOBJECTDBSERVICERESPONSE']._serialized_end=381 + _globals['_FBSREFSERVICE']._serialized_start=384 + _globals['_FBSREFSERVICE']._serialized_end=617 +# @@protoc_insertion_point(module_scope) diff --git a/src/ansys/grpc/dpf/fbs_ref_pb2_grpc.py b/src/ansys/grpc/dpf/fbs_ref_pb2_grpc.py new file mode 100644 index 00000000000..6a30dce4bad --- /dev/null +++ b/src/ansys/grpc/dpf/fbs_ref_pb2_grpc.py @@ -0,0 +1,103 @@ +# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! +"""Client and server classes corresponding to protobuf-defined services.""" +import grpc + +import ansys.grpc.dpf.fbs_ref_pb2 as fbs__ref__pb2 + + +class FBSRefServiceStub(object): + """Missing associated documentation comment in .proto file.""" + + def __init__(self, channel): + """Constructor. + + Args: + channel: A grpc.Channel. + """ + self.Create = channel.unary_unary( + '/ansys.api.dpf.fbs_ref.v0.FBSRefService/Create', + request_serializer=fbs__ref__pb2.FBSRefData.SerializeToString, + response_deserializer=fbs__ref__pb2.FBSRef.FromString, + ) + self.StartFbsServer = channel.unary_unary( + '/ansys.api.dpf.fbs_ref.v0.FBSRefService/StartFbsServer', + request_serializer=fbs__ref__pb2.StartFBSObjectDBServiceRequest.SerializeToString, + response_deserializer=fbs__ref__pb2.StartFBSObjectDBServiceResponse.FromString, + ) + + +class FBSRefServiceServicer(object): + """Missing associated documentation comment in .proto file.""" + + def Create(self, request, context): + """Put a fbs Reference in the DPF database. + Once put in the database the fbs Reference can be used like any DPF object + (in Operators, Workflows, GenericDataContainers...). + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def StartFbsServer(self, request, context): + """Start or return an already started fbs server. Useful when fbs objects need to be consumed by DPF. + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + +def add_FBSRefServiceServicer_to_server(servicer, server): + rpc_method_handlers = { + 'Create': grpc.unary_unary_rpc_method_handler( + servicer.Create, + request_deserializer=fbs__ref__pb2.FBSRefData.FromString, + response_serializer=fbs__ref__pb2.FBSRef.SerializeToString, + ), + 'StartFbsServer': grpc.unary_unary_rpc_method_handler( + servicer.StartFbsServer, + request_deserializer=fbs__ref__pb2.StartFBSObjectDBServiceRequest.FromString, + response_serializer=fbs__ref__pb2.StartFBSObjectDBServiceResponse.SerializeToString, + ), + } + generic_handler = grpc.method_handlers_generic_handler( + 'ansys.api.dpf.fbs_ref.v0.FBSRefService', rpc_method_handlers) + server.add_generic_rpc_handlers((generic_handler,)) + + + # This class is part of an EXPERIMENTAL API. +class FBSRefService(object): + """Missing associated documentation comment in .proto file.""" + + @staticmethod + def Create(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary(request, target, '/ansys.api.dpf.fbs_ref.v0.FBSRefService/Create', + fbs__ref__pb2.FBSRefData.SerializeToString, + fbs__ref__pb2.FBSRef.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def StartFbsServer(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary(request, target, '/ansys.api.dpf.fbs_ref.v0.FBSRefService/StartFbsServer', + fbs__ref__pb2.StartFBSObjectDBServiceRequest.SerializeToString, + fbs__ref__pb2.StartFBSObjectDBServiceResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata)