Home
last modified time | relevance | path

Searched refs:PCPClient (Results 1 – 25 of 137) sorted by relevance

123456

/dports/sysutils/pxp-agent/pxp-agent-1.15.16/lib/src/
H A Dpxp_schemas.cc9 using C_Type = PCPClient::ContentType;
10 using T_Constraint = PCPClient::TypeConstraint;
12 PCPClient::Schema BlockingRequestSchema() { in BlockingRequestSchema()
13 PCPClient::Schema schema { BLOCKING_REQUEST_TYPE, C_Type::Json }; in BlockingRequestSchema()
22 PCPClient::Schema BlockingResponseSchema() { in BlockingResponseSchema()
23 PCPClient::Schema schema { BLOCKING_RESPONSE_TYPE, C_Type::Json }; in BlockingResponseSchema()
30 PCPClient::Schema NonBlockingRequestSchema() { in NonBlockingRequestSchema()
41 PCPClient::Schema NonBlockingResponseSchema() { in NonBlockingResponseSchema()
49 PCPClient::Schema ProvisionalResponseSchema() { in ProvisionalResponseSchema()
56 PCPClient::Schema PXPErrorSchema() { in PXPErrorSchema()
[all …]
H A Dagent.cc18 namespace pcp_util = PCPClient::Util;
39 } catch (const PCPClient::connection_config_error& e) {
46 [this](const PCPClient::ParsedChunks& parsed_chunks) { in start()
52 [this](const PCPClient::ParsedChunks& parsed_chunks) { in start()
67 } catch (const PCPClient::connection_association_error& e) { in start()
85 } catch (const PCPClient::connection_config_error& e) { in start()
88 } catch (const PCPClient::connection_association_response_failure& e) { in start()
93 } catch (const PCPClient::connection_fatal_error& e) { in start()
100 void Agent::blockingRequestCallback(const PCPClient::ParsedChunks& parsed_chunks) { in blockingRequestCallback()
104 void Agent::nonBlockingRequestCallback(const PCPClient::ParsedChunks& parsed_chunks) { in nonBlockingRequestCallback()
H A Dpxp_connector_v2.cc20 : PCPClient::v2::Connector(agent_configuration.broker_ws_uris, in PXPConnectorV2()
44 } catch (PCPClient::connection_error& e) { in sendPCPError()
61 } catch (PCPClient::connection_error& e) { in sendProvisionalResponse()
82 } catch (PCPClient::connection_error& e) { in sendPXPError()
101 } catch (PCPClient::connection_error& e) { in sendPXPError()
140 } catch (PCPClient::connection_error& e) { in sendNonBlockingResponse()
151 PCPClient::v2::Connector::connect(max_connect_attempts); in connect()
157 PCPClient::v2::Connector::monitorConnection(max_connect_attempts, connection_check_interval_s); in monitorConnection()
160 void PXPConnectorV2::registerMessageCallback(const PCPClient::Schema& schema, in registerMessageCallback()
163 PCPClient::v2::Connector::registerMessageCallback(schema, callback); in registerMessageCallback()
[all …]
H A Dpxp_connector_v1.cc21 wrapDebug(const PCPClient::ParsedChunks& parsed_chunks) in wrapDebug()
39 : PCPClient::v1::Connector(agent_configuration.broker_ws_uris, in PXPConnectorV1()
71 } catch (PCPClient::connection_error& e) { in sendPCPError()
91 } catch (PCPClient::connection_error& e) { in sendProvisionalResponse()
113 } catch (PCPClient::connection_error& e) { in sendPXPError()
134 } catch (PCPClient::connection_error& e) { in sendPXPError()
176 } catch (PCPClient::connection_error& e) { in sendNonBlockingResponse()
187 PCPClient::v1::Connector::connect(max_connect_attempts); in connect()
196 void PXPConnectorV1::registerMessageCallback(const PCPClient::Schema& schema, in registerMessageCallback()
199 PCPClient::v1::Connector::registerMessageCallback(schema, callback); in registerMessageCallback()
[all …]
H A Dexternal_module.cc45 namespace pcp_util = PCPClient::Util;
52 PCPClient::Validator getMetadataValidator() in getMetadataValidator()
55 PCPClient::Schema metadata_schema { METADATA_SCHEMA_NAME, in getMetadataValidator()
57 using T_C = PCPClient::TypeConstraint; in getMetadataValidator()
63 PCPClient::Schema action_schema { ACTION_SCHEMA_NAME, in getMetadataValidator()
64 PCPClient::ContentType::Json }; in getMetadataValidator()
72 PCPClient::Validator validator {}; in getMetadataValidator()
193 const PCPClient::Validator ExternalModule::metadata_validator_ {
230 } catch (PCPClient::validation_error& e) { in getModuleMetadata()
244 } catch (PCPClient::schema_error& e) { in registerConfiguration()
[all …]
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/09/controller/
H A Dmain.cpp41 PCPClient::Schema response_schema_;
42 PCPClient::Schema inventory_response_schema_;
43 std::unique_ptr<PCPClient::Connector> connector_ptr_;
65 [this](const PCPClient::ParsedChunks& parsed_chunks) { in __anonb00cf6280102()
79 } catch (PCPClient::connection_config_error& e) {
89 } catch (PCPClient::connection_config_error& e) { in sendRequests()
92 } catch (PCPClient::connection_fatal_error& e) { in sendRequests()
124 } catch (PCPClient::connection_processing_error& e) { in sendRequests()
143 } catch (PCPClient::connection_processing_error& e) { in sendRequests()
161 } catch (PCPClient::connection_processing_error& e) { in sendRequests()
[all …]
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/10/controller/
H A Dmain.cpp41 PCPClient::Schema response_schema_;
42 PCPClient::Schema inventory_response_schema_;
43 std::unique_ptr<PCPClient::Connector> connector_ptr_;
65 [this](const PCPClient::ParsedChunks& parsed_chunks) { in __anon494472400102()
79 } catch (PCPClient::connection_config_error& e) {
89 } catch (PCPClient::connection_config_error& e) { in sendRequests()
92 } catch (PCPClient::connection_fatal_error& e) { in sendRequests()
125 } catch (PCPClient::connection_processing_error& e) { in sendRequests()
144 } catch (PCPClient::connection_processing_error& e) { in sendRequests()
162 } catch (PCPClient::connection_processing_error& e) { in sendRequests()
[all …]
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/08/agent/
H A Dmain.cpp48 PCPClient::Schema request_schema_;
49 PCPClient::Validator validator_;
50 std::unique_ptr<PCPClient::Connector> connector_ptr_;
65 PCPClient::Schema song_schema { SONG_SCHEMA,
72 } catch (PCPClient::connection_config_error& e) {
82 [this](const PCPClient::ParsedChunks& parsed_chunks) { in start()
90 } catch (PCPClient::connection_config_error& e) { in start()
93 } catch (PCPClient::connection_fatal_error& e) { in start()
113 } catch (PCPClient::connection_fatal_error& e) { in start()
133 } catch (PCPClient::validation_error& e) { in processRequest()
[all …]
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/09/agent/
H A Dmain.cpp48 PCPClient::Schema request_schema_;
49 PCPClient::Validator validator_;
50 std::unique_ptr<PCPClient::Connector> connector_ptr_;
65 PCPClient::Schema song_schema { SONG_SCHEMA,
72 } catch (PCPClient::connection_config_error& e) {
82 [this](const PCPClient::ParsedChunks& parsed_chunks) { in start()
90 } catch (PCPClient::connection_config_error& e) { in start()
93 } catch (PCPClient::connection_fatal_error& e) { in start()
113 } catch (PCPClient::connection_fatal_error& e) { in start()
133 } catch (PCPClient::validation_error& e) { in processRequest()
[all …]
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/10/agent/
H A Dmain.cpp48 PCPClient::Schema request_schema_;
49 PCPClient::Validator validator_;
50 std::unique_ptr<PCPClient::Connector> connector_ptr_;
65 PCPClient::Schema song_schema { SONG_SCHEMA,
72 } catch (PCPClient::connection_config_error& e) {
82 [this](const PCPClient::ParsedChunks& parsed_chunks) { in start()
90 } catch (PCPClient::connection_config_error& e) { in start()
93 } catch (PCPClient::connection_fatal_error& e) { in start()
114 } catch (PCPClient::connection_fatal_error& e) { in start()
134 } catch (PCPClient::validation_error& e) { in processRequest()
[all …]
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/05/agent/
H A Dmain.cpp46 PCPClient::Schema request_schema_;
47 std::unique_ptr<PCPClient::Connector> connector_ptr_;
49 void processRequest(const PCPClient::ParsedChunks& parsed_chunks);
56 PCPClient::ContentType::Json },
57 connector_ptr_ { new PCPClient::Connector { BROKER_URL,
63 using T_C = PCPClient::TypeConstraint;
66 } catch (PCPClient::connection_config_error& e) {
76 [this](const PCPClient::ParsedChunks& parsed_chunks) { in start()
84 } catch (PCPClient::connection_config_error& e) { in start()
87 } catch (PCPClient::connection_fatal_error& e) { in start()
[all …]
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/04/agent/
H A Dmain.cpp46 PCPClient::Schema request_schema_;
47 std::unique_ptr<PCPClient::Connector> connector_ptr_;
49 void processRequest(const PCPClient::ParsedChunks& parsed_chunks);
56 PCPClient::ContentType::Json },
57 connector_ptr_ { new PCPClient::Connector { BROKER_URL,
63 using T_C = PCPClient::TypeConstraint;
66 } catch (PCPClient::connection_config_error& e) {
76 [this](const PCPClient::ParsedChunks& parsed_chunks) { in start()
84 } catch (PCPClient::connection_config_error& e) { in start()
87 } catch (PCPClient::connection_fatal_error& e) { in start()
[all …]
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/08/controller/
H A Dmain.cpp41 PCPClient::Schema response_schema_;
42 std::unique_ptr<PCPClient::Connector> connector_ptr_;
45 void processError(const PCPClient::ParsedChunks& parsed_chunks);
52 connector_ptr_ { new PCPClient::Connector { BROKER_URL,
61 [this](const PCPClient::ParsedChunks& parsed_chunks) { in __anon5efffba70102()
66 [this](const PCPClient::ParsedChunks& parsed_chunks) { in __anon5efffba70202()
69 } catch (PCPClient::connection_config_error& e) {
79 } catch (PCPClient::connection_config_error& e) { in sendRequests()
82 } catch (PCPClient::connection_fatal_error& e) { in sendRequests()
114 } catch (PCPClient::connection_processing_error& e) { in sendRequests()
[all …]
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/06/agent/
H A Dmain.cpp42 PCPClient::Schema request_schema_;
43 std::unique_ptr<PCPClient::Connector> connector_ptr_;
45 void processRequest(const PCPClient::ParsedChunks& parsed_chunks);
52 connector_ptr_ { new PCPClient::Connector { BROKER_URL,
57 } catch (PCPClient::connection_config_error& e) {
67 [this](const PCPClient::ParsedChunks& parsed_chunks) { in start()
75 } catch (PCPClient::connection_config_error& e) { in start()
78 } catch (PCPClient::connection_fatal_error& e) { in start()
98 } catch (PCPClient::connection_fatal_error& e) { in start()
104 void Agent::processRequest(const PCPClient::ParsedChunks& parsed_chunks) { in processRequest()
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/07/
H A Dcommon.h17 using T_C = PCPClient::TypeConstraint;
19 static PCPClient::Schema getRequestMessageSchema() { in getRequestMessageSchema()
20 PCPClient::Schema schema { REQUEST_SCHEMA_NAME, in getRequestMessageSchema()
21 PCPClient::ContentType::Json }; in getRequestMessageSchema()
28 static PCPClient::Schema getResponseMessageSchema() { in getResponseMessageSchema()
29 PCPClient::Schema schema { RESPONSE_SCHEMA_NAME, in getResponseMessageSchema()
30 PCPClient::ContentType::Json }; in getResponseMessageSchema()
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/08/
H A Dcommon.h17 using T_C = PCPClient::TypeConstraint;
19 static PCPClient::Schema getRequestMessageSchema() { in getRequestMessageSchema()
20 PCPClient::Schema schema { REQUEST_SCHEMA_NAME, in getRequestMessageSchema()
21 PCPClient::ContentType::Json }; in getRequestMessageSchema()
28 static PCPClient::Schema getResponseMessageSchema() { in getResponseMessageSchema()
29 PCPClient::Schema schema { RESPONSE_SCHEMA_NAME, in getResponseMessageSchema()
30 PCPClient::ContentType::Json }; in getResponseMessageSchema()
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/09/
H A Dcommon.h17 using T_C = PCPClient::TypeConstraint;
19 static PCPClient::Schema getRequestMessageSchema() { in getRequestMessageSchema()
20 PCPClient::Schema schema { REQUEST_SCHEMA_NAME, in getRequestMessageSchema()
21 PCPClient::ContentType::Json }; in getRequestMessageSchema()
28 static PCPClient::Schema getResponseMessageSchema() { in getResponseMessageSchema()
29 PCPClient::Schema schema { RESPONSE_SCHEMA_NAME, in getResponseMessageSchema()
30 PCPClient::ContentType::Json }; in getResponseMessageSchema()
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/10/
H A Dcommon.h18 using T_C = PCPClient::TypeConstraint;
20 static PCPClient::Schema getRequestMessageSchema() { in getRequestMessageSchema()
21 PCPClient::Schema schema { REQUEST_SCHEMA_NAME, in getRequestMessageSchema()
22 PCPClient::ContentType::Json }; in getRequestMessageSchema()
29 static PCPClient::Schema getResponseMessageSchema() { in getResponseMessageSchema()
30 PCPClient::Schema schema { RESPONSE_SCHEMA_NAME, in getResponseMessageSchema()
31 PCPClient::ContentType::Json }; in getResponseMessageSchema()
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/07/controller/
H A Dmain.cpp39 PCPClient::Schema response_schema_;
40 std::unique_ptr<PCPClient::Connector> connector_ptr_;
42 void processResponse(const PCPClient::ParsedChunks& parsed_chunks);
49 connector_ptr_ { new PCPClient::Connector { BROKER_URL,
58 [this](const PCPClient::ParsedChunks& parsed_chunks) { in __anon0df301260102()
61 } catch (PCPClient::connection_config_error& e) {
71 } catch (PCPClient::connection_config_error& e) { in sendRequest()
74 } catch (PCPClient::connection_fatal_error& e) { in sendRequest()
106 } catch (PCPClient::connection_processing_error& e) { in sendRequest()
115 void Controller::processResponse(const PCPClient::ParsedChunks& parsed_chunks) { in processResponse()
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/07/agent/
H A Dmain.cpp44 PCPClient::Schema request_schema_;
45 std::unique_ptr<PCPClient::Connector> connector_ptr_;
47 void processRequest(const PCPClient::ParsedChunks& parsed_chunks);
54 connector_ptr_ { new PCPClient::Connector { BROKER_URL,
59 } catch (PCPClient::connection_config_error& e) {
69 [this](const PCPClient::ParsedChunks& parsed_chunks) { in start()
77 } catch (PCPClient::connection_config_error& e) { in start()
80 } catch (PCPClient::connection_fatal_error& e) { in start()
100 } catch (PCPClient::connection_fatal_error& e) { in start()
106 void Agent::processRequest(const PCPClient::ParsedChunks& parsed_chunks) { in processRequest()
[all …]
/dports/sysutils/pxp-agent/pxp-agent-1.15.16/lib/inc/pxp-agent/
H A Dpxp_schemas.hpp14 PCPClient::Schema BlockingRequestSchema();
15 PCPClient::Schema BlockingResponseSchema();
24 PCPClient::Schema NonBlockingRequestSchema();
25 PCPClient::Schema NonBlockingResponseSchema();
26 PCPClient::Schema ProvisionalResponseSchema();
31 PCPClient::Schema PXPErrorSchema();
H A Dresults_mutex.hpp31 using Mutex = PCPClient::Util::mutex;
32 using Mutex_Ptr = std::shared_ptr<PCPClient::Util::mutex>;
33 using Lock = PCPClient::Util::unique_lock<PCPClient::Util::mutex>;
34 using LockGuard = PCPClient::Util::lock_guard<PCPClient::Util::mutex>;
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/03/agent/
H A Dmain.cpp19 std::unique_ptr<PCPClient::Connector> connector_ptr; in main()
24 connector_ptr.reset(new PCPClient::Connector { BROKER_URL, in main()
30 } catch (PCPClient::connection_config_error& e) { in main()
42 } catch (PCPClient::connection_config_error& e) { in main()
45 } catch (PCPClient::connection_fatal_error& e) { in main()
64 } catch (PCPClient::connection_fatal_error& e) { in main()
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/05/controller/
H A Dmain.cpp25 std::unique_ptr<PCPClient::Connector> connector_ptr; in main()
30 connector_ptr.reset(new PCPClient::Connector { BROKER_URL, in main()
36 } catch (PCPClient::connection_config_error& e) { in main()
48 } catch (PCPClient::connection_config_error& e) { in main()
51 } catch (PCPClient::connection_fatal_error& e) { in main()
82 } catch (PCPClient::connection_processing_error& e) { in main()
/dports/net/cpp-pcp-client/cpp-pcp-client-1.7.7/tutorial/06/controller/
H A Dmain.cpp38 std::unique_ptr<PCPClient::Connector> connector_ptr_;
44 connector_ptr_ { new PCPClient::Connector { BROKER_URL,
49 } catch (PCPClient::connection_config_error& e) {
59 } catch (PCPClient::connection_config_error& e) { in sendRequest()
62 } catch (PCPClient::connection_fatal_error& e) { in sendRequest()
94 } catch (PCPClient::connection_processing_error& e) { in sendRequest()

123456