Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Add initial auto-generation support for streaming APIs #1114

Merged
merged 36 commits into from
Nov 12, 2024
Merged

Add initial auto-generation support for streaming APIs #1114

Show file tree
Hide file tree
Changes from 28 commits
Commits
Show all changes
36 commits
Select commit Hold shift + click to select a range
9b1f514
adding support for sideband streaming
asumit Oct 24, 2024
2a45cc7
updating grpc-sideband submodule to latest
asumit Oct 25, 2024
59e91ce
adding data_moniker source and generated files to Integration and Sys…
asumit Oct 25, 2024
a3aedc1
Initial auto-generation
amehra-ni Oct 28, 2024
cbfd8e8
update grpc-streaming_type
amehra-ni Oct 28, 2024
8de6fc9
adding sideband_address to the server_config.json
asumit Oct 29, 2024
165405f
adding the sideband_streaming functionality under a feature toggle
asumit Oct 29, 2024
4bf5785
Fix some format changes
amehra-ni Oct 30, 2024
b7d8f15
adding RT specific scheduling under feature toggle
asumit Nov 1, 2024
3dc83c8
Fixing some build issues
amehra-ni Nov 4, 2024
329ca43
include copy at top
amehra-ni Nov 4, 2024
25ce023
resolve minor comments
amehra-ni Nov 4, 2024
b2858b2
add feature toggle helper
amehra-ni Nov 4, 2024
4521034
Merge branch 'users/sagrahar/add-sideband-support' of https://github.…
amehra-ni Nov 5, 2024
0771d7f
fixing minor comments
amehra-ni Nov 5, 2024
b8e5c49
resolving comments
amehra-ni Nov 5, 2024
a90f681
review comments
amehra-ni Nov 5, 2024
b4e473d
review comments
amehra-ni Nov 6, 2024
19ddbb3
update filter streaming functions
amehra-ni Nov 6, 2024
9f02326
use streaming_functions_to_generate
amehra-ni Nov 6, 2024
98bec2e
move define_streaming_api_body under else block
amehra-ni Nov 6, 2024
564e7e7
Merge branch 'main' of https://github.com/ni/grpc-device into users/a…
amehra-ni Nov 6, 2024
9b370e2
Resolve merge conflicts
amehra-ni Nov 6, 2024
9a5b281
fix build
amehra-ni Nov 6, 2024
903fa1f
resolve comments
amehra-ni Nov 7, 2024
e5c9879
remove unused functions
amehra-ni Nov 7, 2024
b6f207d
delete[] array
amehra-ni Nov 8, 2024
b45ead6
use vector instead of raw array
amehra-ni Nov 8, 2024
cd8f8c9
Fix indentation
amehra-ni Nov 9, 2024
c2464b0
include boolean functions
amehra-ni Nov 11, 2024
62afa43
Revert "include boolean functions"
amehra-ni Nov 11, 2024
0ac96fc
fix indentation
amehra-ni Nov 11, 2024
83d45bb
Add boolean functions
amehra-ni Nov 11, 2024
ca85ec1
Move RegisterMonikerEndpoints inside of driver specific registrar
amehra-ni Nov 11, 2024
0dd6460
remove unused code
amehra-ni Nov 12, 2024
81e05ec
revert register_all_services.cpp.mako
amehra-ni Nov 12, 2024
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
397 changes: 397 additions & 0 deletions generated/nifpga/nifpga.proto
View file
Open in desktop

Large diffs are not rendered by default.

584 changes: 584 additions & 0 deletions generated/nifpga/nifpga_client.cpp
View file
Open in desktop

Large diffs are not rendered by default.

32 changes: 32 additions & 0 deletions generated/nifpga/nifpga_client.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -41,14 +41,22 @@ OpenResponse open(const StubPtr& stub, const std::string& bitfile, const std::st
ReadArrayBoolResponse read_array_bool(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
ReadArrayDblResponse read_array_dbl(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
ReadArrayI16Response read_array_i16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
BeginReadArrayI16Response begin_read_array_i16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
ReadArrayI32Response read_array_i32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
BeginReadArrayI32Response begin_read_array_i32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
ReadArrayI64Response read_array_i64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
BeginReadArrayI64Response begin_read_array_i64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
ReadArrayI8Response read_array_i8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
BeginReadArrayI8Response begin_read_array_i8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
ReadArraySglResponse read_array_sgl(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
ReadArrayU16Response read_array_u16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
BeginReadArrayU16Response begin_read_array_u16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
ReadArrayU32Response read_array_u32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
BeginReadArrayU32Response begin_read_array_u32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
ReadArrayU64Response read_array_u64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
BeginReadArrayU64Response begin_read_array_u64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
ReadArrayU8Response read_array_u8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
BeginReadArrayU8Response begin_read_array_u8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator, const pb::uint32& size);
ReadBoolResponse read_bool(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
ReadDblResponse read_dbl(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
ReadFifoBoolResponse read_fifo_bool(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& fifo, const pb::uint32& number_of_elements, const pb::uint32& timeout);
Expand All @@ -63,14 +71,22 @@ ReadFifoU32Response read_fifo_u32(const StubPtr& stub, const nidevice_grpc::Sess
ReadFifoU64Response read_fifo_u64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& fifo, const pb::uint32& number_of_elements, const pb::uint32& timeout);
ReadFifoU8Response read_fifo_u8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& fifo, const pb::uint32& number_of_elements, const pb::uint32& timeout);
ReadI16Response read_i16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
BeginReadI16Response begin_read_i16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
ReadI32Response read_i32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
BeginReadI32Response begin_read_i32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
ReadI64Response read_i64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
BeginReadI64Response begin_read_i64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
ReadI8Response read_i8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
BeginReadI8Response begin_read_i8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
ReadSglResponse read_sgl(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
ReadU16Response read_u16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
BeginReadU16Response begin_read_u16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
ReadU32Response read_u32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
BeginReadU32Response begin_read_u32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
ReadU64Response read_u64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
BeginReadU64Response begin_read_u64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
ReadU8Response read_u8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
BeginReadU8Response begin_read_u8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& indicator);
ReleaseFifoElementsResponse release_fifo_elements(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& fifo, const pb::uint32& elements);
ResetResponse reset(const StubPtr& stub, const nidevice_grpc::Session& session);
RunResponse run(const StubPtr& stub, const nidevice_grpc::Session& session, const simple_variant<RunAttribute, pb::uint32>& attribute);
Expand All @@ -85,14 +101,22 @@ WaitOnIrqsResponse wait_on_irqs(const StubPtr& stub, const nidevice_grpc::Sessio
WriteArrayBoolResponse write_array_bool(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const std::vector<bool>& array);
WriteArrayDblResponse write_array_dbl(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const std::vector<double>& array);
WriteArrayI16Response write_array_i16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const std::vector<pb::int32>& array);
BeginWriteArrayI16Response begin_write_array_i16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);
WriteArrayI32Response write_array_i32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const std::vector<pb::int32>& array);
BeginWriteArrayI32Response begin_write_array_i32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);
WriteArrayI64Response write_array_i64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const std::vector<pb::int64>& array);
BeginWriteArrayI64Response begin_write_array_i64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);
WriteArrayI8Response write_array_i8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const std::vector<pb::int32>& array);
BeginWriteArrayI8Response begin_write_array_i8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);
WriteArraySglResponse write_array_sgl(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const std::vector<float>& array);
WriteArrayU16Response write_array_u16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const std::vector<pb::uint32>& array);
BeginWriteArrayU16Response begin_write_array_u16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);
WriteArrayU32Response write_array_u32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const std::vector<pb::uint32>& array);
BeginWriteArrayU32Response begin_write_array_u32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);
WriteArrayU64Response write_array_u64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const std::vector<pb::uint64>& array);
BeginWriteArrayU64Response begin_write_array_u64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);
WriteArrayU8Response write_array_u8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const std::vector<pb::uint32>& array);
BeginWriteArrayU8Response begin_write_array_u8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);
WriteBoolResponse write_bool(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const bool& value);
WriteDblResponse write_dbl(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const double& value);
WriteFifoBoolResponse write_fifo_bool(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& fifo, const std::vector<bool>& data, const pb::uint32& timeout);
Expand All @@ -107,14 +131,22 @@ WriteFifoU32Response write_fifo_u32(const StubPtr& stub, const nidevice_grpc::Se
WriteFifoU64Response write_fifo_u64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& fifo, const std::vector<pb::uint64>& data, const pb::uint32& timeout);
WriteFifoU8Response write_fifo_u8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& fifo, const std::vector<pb::uint32>& data, const pb::uint32& timeout);
WriteI16Response write_i16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const pb::int32& value);
BeginWriteI16Response begin_write_i16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);
WriteI32Response write_i32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const pb::int32& value);
BeginWriteI32Response begin_write_i32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);
WriteI64Response write_i64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const pb::int64& value);
BeginWriteI64Response begin_write_i64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);
WriteI8Response write_i8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const pb::int32& value);
BeginWriteI8Response begin_write_i8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);
WriteSglResponse write_sgl(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const float& value);
WriteU16Response write_u16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const pb::uint32& value);
BeginWriteU16Response begin_write_u16(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);
WriteU32Response write_u32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const pb::uint32& value);
BeginWriteU32Response begin_write_u32(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);
WriteU64Response write_u64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const pb::uint64& value);
BeginWriteU64Response begin_write_u64(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);
WriteU8Response write_u8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control, const pb::uint32& value);
BeginWriteU8Response begin_write_u8(const StubPtr& stub, const nidevice_grpc::Session& session, const pb::uint32& control);

} // namespace nifpga_grpc::experimental::client

Expand Down
Loading
Loading