-
- Downloads
[Consumer] Added network_type argument (can be "tcp" or "fabric")
Showing
- consumer/api/cpp/include/consumer/data_broker.h 2 additions, 2 deletionsconsumer/api/cpp/include/consumer/data_broker.h
- consumer/api/cpp/src/data_broker.cpp 13 additions, 3 deletionsconsumer/api/cpp/src/data_broker.cpp
- consumer/api/cpp/src/server_data_broker.cpp 13 additions, 4 deletionsconsumer/api/cpp/src/server_data_broker.cpp
- consumer/api/cpp/src/server_data_broker.h 2 additions, 1 deletionconsumer/api/cpp/src/server_data_broker.h
- consumer/api/cpp/unittests/test_consumer_api.cpp 21 additions, 2 deletionsconsumer/api/cpp/unittests/test_consumer_api.cpp
- consumer/api/cpp/unittests/test_server_broker.cpp 4 additions, 4 deletionsconsumer/api/cpp/unittests/test_server_broker.cpp
- consumer/api/python/asapo_consumer.pxd 1 addition, 2 deletionsconsumer/api/python/asapo_consumer.pxd
- consumer/api/python/asapo_consumer.pyx.in 7 additions, 4 deletionsconsumer/api/python/asapo_consumer.pyx.in
- examples/consumer/getnext_broker/getnext_broker.cpp 17 additions, 11 deletionsexamples/consumer/getnext_broker/getnext_broker.cpp
- examples/consumer/getnext_broker_python/getnext.py 2 additions, 2 deletionsexamples/consumer/getnext_broker_python/getnext.py
- examples/pipeline/in_to_out/in_to_out.cpp 14 additions, 12 deletionsexamples/pipeline/in_to_out/in_to_out.cpp
- examples/pipeline/in_to_out_python/in_to_out.py 3 additions, 5 deletionsexamples/pipeline/in_to_out_python/in_to_out.py
- tests/automatic/consumer/consumer_api/consumer_api.cpp 13 additions, 6 deletionstests/automatic/consumer/consumer_api/consumer_api.cpp
- tests/automatic/consumer/next_multithread_broker/next_multithread_broker.cpp 15 additions, 7 deletions...sumer/next_multithread_broker/next_multithread_broker.cpp
- tests/automatic/curl_http_client/curl_http_client_command/curl_httpclient_command.cpp 8 additions, 4 deletions...ient/curl_http_client_command/curl_httpclient_command.cpp
- tests/automatic/full_chain/send_recv_substreams/send_recv_substreams.cpp 10 additions, 4 deletions.../full_chain/send_recv_substreams/send_recv_substreams.cpp
- tests/automatic/high_avail/services_restart/CMakeLists.txt 1 addition, 1 deletiontests/automatic/high_avail/services_restart/CMakeLists.txt
- tests/manual/performance_broker_receiver/getlast_broker.cpp 13 additions, 11 deletionstests/manual/performance_broker_receiver/getlast_broker.cpp
Loading
Please register or sign in to comment