/dports/sysutils/pxp-agent/pxp-agent-1.15.16/lib/src/ |
H A D | pxp_schemas.cc | 9 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 D | agent.cc | 18 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 D | pxp_connector_v2.cc | 20 : 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 D | pxp_connector_v1.cc | 21 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 D | external_module.cc | 45 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 D | main.cpp | 41 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 D | main.cpp | 41 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 D | main.cpp | 48 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 D | main.cpp | 48 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 D | main.cpp | 48 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 D | main.cpp | 46 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 D | main.cpp | 46 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 D | main.cpp | 41 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 D | main.cpp | 42 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 D | common.h | 17 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 D | common.h | 17 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 D | common.h | 17 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 D | common.h | 18 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 D | main.cpp | 39 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 D | main.cpp | 44 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 D | pxp_schemas.hpp | 14 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 D | results_mutex.hpp | 31 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 D | main.cpp | 19 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 D | main.cpp | 25 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 D | main.cpp | 38 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()
|