Merge pull request #156 from c-jimenez/release/v1.4.0

c-jimenez · web-flow · commit 61bbd45e3393 · 2023-10-01T17:57:21.000+02:00
Release/v1.4.0
diff --git a/CMakeLists.txt b/CMakeLists.txt
@@ -5,7 +5,7 @@
 cmake_minimum_required(VERSION 3.13)
 
 project(OpenOCPP DESCRIPTION "Open Source C++ implementation of the OCPP 1.6 protocol"
-                 VERSION 1.3.1
+                 VERSION 1.4.0
 )
 
 # Definitions for Version.h file
diff --git a/examples/common/DefaultCentralSystemEventsHandler.cpp b/examples/common/DefaultCentralSystemEventsHandler.cpp
@@ -66,6 +66,12 @@ bool DefaultCentralSystemEventsHandler::acceptConnection(const char* ip_address)
     return true;
 }
 
+/** @copydoc void ICentralSystemEventsHandler::clientFailedToConnect(const char*) */
+void DefaultCentralSystemEventsHandler::clientFailedToConnect(const char* ip_address)
+{
+    cout << "Client [" << ip_address << "] failed to connect" << endl;
+}
+
 /** @copydoc bool ICentralSystemEventsHandler::checkCredentials(const std::string&, const std::string&) */
 bool DefaultCentralSystemEventsHandler::checkCredentials(const std::string& chargepoint_id, const std::string& password)
 {
diff --git a/examples/common/DefaultCentralSystemEventsHandler.h b/examples/common/DefaultCentralSystemEventsHandler.h
@@ -48,6 +48,9 @@ class DefaultCentralSystemEventsHandler : public ocpp::centralsystem::ICentralSy
     /** @copydoc bool ICentralSystemEventsHandler::acceptConnection(const char*) */
     bool acceptConnection(const char* ip_address) override;
 
+    /** @copydoc void ICentralSystemEventsHandler::clientFailedToConnect(const char*) */
+    void clientFailedToConnect(const char* ip_address) override;
+
     /** @copydoc bool ICentralSystemEventsHandler::checkCredentials(const std::string&, const std::string&) */
     bool checkCredentials(const std::string& chargepoint_id, const std::string& password) override;
 
diff --git a/examples/common/DefaultChargePointEventsHandler.cpp b/examples/common/DefaultChargePointEventsHandler.cpp
@@ -691,9 +691,13 @@ ocpp::types::UpdateFirmwareStatusEnumType DefaultChargePointEventsHandler::check
     if (!ca_certificates.empty())
     {
         // Check signing certificate
-        if (signing_certificate.verify(ca_certificates))
+        for (const auto& cer : ca_certificates)
         {
-            ret = UpdateFirmwareStatusEnumType::Accepted;
+            if (signing_certificate.verify(cer.certificateChain()))
+            {
+                ret = UpdateFirmwareStatusEnumType::Accepted;
+                break;
+            }
         }
     }
     else
diff --git a/examples/common/DefaultLocalControllerEventsHandler.cpp b/examples/common/DefaultLocalControllerEventsHandler.cpp
@@ -48,6 +48,12 @@ bool DefaultLocalControllerEventsHandler::acceptConnection(const char* ip_addres
     return true;
 }
 
+/** @copydoc void ILocalControllerEventsHandler::clientFailedToConnect(const char*) */
+void DefaultLocalControllerEventsHandler::clientFailedToConnect(const char* ip_address)
+{
+    cout << "Client [" << ip_address << "] failed to connect" << endl;
+}
+
 /** @copydoc bool ILocalControllerEventsHandler::checkCredentials(const std::string&, const std::string&) */
 bool DefaultLocalControllerEventsHandler::checkCredentials(const std::string& chargepoint_id, const std::string& password)
 {
diff --git a/examples/common/DefaultLocalControllerEventsHandler.h b/examples/common/DefaultLocalControllerEventsHandler.h
@@ -46,6 +46,9 @@ class DefaultLocalControllerEventsHandler : public ocpp::localcontroller::ILocal
     /** @copydoc bool ILocalControllerEventsHandler::acceptConnection(const char*) */
     bool acceptConnection(const char* ip_address) override;
 
+    /** @copydoc void ILocalControllerEventsHandler::clientFailedToConnect(const char*) */
+    void clientFailedToConnect(const char* ip_address) override;
+
     /** @copydoc bool ILocalControllerEventsHandler::checkCredentials(const std::string&, const std::string&) */
     bool checkCredentials(const std::string& chargepoint_id, const std::string& password) override;
 
diff --git a/src/centralsystem/CentralSystem.cpp b/src/centralsystem/CentralSystem.cpp
@@ -300,6 +300,14 @@ void CentralSystem::rpcClientConnected(const std::string& chargepoint_id, std::s
     m_events_handler.chargePointConnected(chargepoint);
 }
 
+/** @copydoc void RpcServer::IListener::rpcClientFailedToConnect(const char*) */
+void CentralSystem::rpcClientFailedToConnect(const char* ip_address)
+{
+    // Notify failure => no additional processing is done here
+    // to keep this callback has fast as possible
+    return m_events_handler.clientFailedToConnect(ip_address);
+}
+
 /** @copydoc void RpcServer::IListener::rpcServerError() */
 void CentralSystem::rpcServerError()
 {
diff --git a/src/centralsystem/CentralSystem.h b/src/centralsystem/CentralSystem.h
@@ -78,6 +78,9 @@ class CentralSystem : public ICentralSystem, public ocpp::rpc::RpcServer::IListe
     /** @copydoc void RpcServer::IListener::rpcClientConnected(const std::string&, std::shared_ptr<Client>) */
     void rpcClientConnected(const std::string& chargepoint_id, std::shared_ptr<ocpp::rpc::RpcServer::Client> client) override;
 
+    /** @copydoc void RpcServer::IListener::rpcClientFailedToConnect(const char*) */
+    void rpcClientFailedToConnect(const char* ip_address) override;
+
     /** @copydoc void RpcServer::IListener::rpcServerError() */
     void rpcServerError() override;
 
diff --git a/src/centralsystem/interface/ICentralSystemEventsHandler.h b/src/centralsystem/interface/ICentralSystemEventsHandler.h
@@ -40,6 +40,12 @@ class ICentralSystemEventsHandler
      */
     virtual bool acceptConnection(const char* ip_address) = 0;
 
+    /**
+     * @brief Called when connection fails to established
+     * @param ip_address IP address of the client
+     */
+    virtual void clientFailedToConnect(const char* ip_address) = 0;
+
     /**
      * @brief Called to check the charge point credentials for HTTP basic authentication
      * @param chargepoint_id Charge Point identifier
diff --git a/src/chargepoint/ChargePoint.cpp b/src/chargepoint/ChargePoint.cpp
@@ -292,6 +292,7 @@ bool ChargePoint::start()
                                                                          *m_msg_dispatcher,
                                                                          *m_msg_sender,
                                                                          m_requests_fifo,
+                                                                         *m_status_manager,
                                                                          *m_authent_manager,
                                                                          *m_reservation_manager,
                                                                          *m_meter_values_manager,
diff --git a/src/chargepoint/iso15118/Iso15118Manager.cpp b/src/chargepoint/iso15118/Iso15118Manager.cpp
@@ -453,7 +453,7 @@ void Iso15118Manager::fillHashInfo(const ocpp::x509::Certificate& certificate, o
     // Compute hashes with SHA-256 algorithm
     Sha2 sha256;
     info.hashAlgorithm = HashAlgorithmEnumType::SHA256;
-    sha256.compute(certificate.issuerString().c_str(), certificate.issuerString().size());
+    sha256.compute(certificate.issuerDer().data(), certificate.issuerDer().size());
     info.issuerNameHash.assign(sha256.resultString());
     sha256.compute(&certificate.publicKey()[0], certificate.publicKey().size());
     info.issuerKeyHash.assign(sha256.resultString());
diff --git a/src/chargepoint/reservation/ReservationManager.cpp b/src/chargepoint/reservation/ReservationManager.cpp
@@ -132,18 +132,26 @@ ocpp::types::AuthorizationStatus ReservationManager::isTransactionAllowed(unsign
                 Connector& charge_point = m_connectors.getChargePointConnector();
                 if (charge_point.status == ChargePointStatus::Reserved)
                 {
-                    // At least 1 connector must stay available
-                    unsigned int available_count = 0;
-                    for (const Connector* c : m_connectors.getConnectors())
+                    // Ensure that the module functions properly even when the gun is inserted first by the user.
+                    if (m_connectors.getConnector(connector_id)->status == ChargePointStatus::Preparing)
                     {
-                        if (c->status == ChargePointStatus::Available)
-                        {
-                            available_count++;
-                        }
+                        ret = AuthorizationStatus::Accepted;
                     }
-                    if (available_count > 1)
+                    else
                     {
-                        ret = AuthorizationStatus::Accepted;
+                        // At least 1 connector must stay available
+                        unsigned int available_count = 0;
+                        for (const Connector* c : m_connectors.getConnectors())
+                        {
+                            if (c->status == ChargePointStatus::Available)
+                            {
+                                available_count++;
+                            }
+                        }
+                        if (available_count >= 1)
+                        {
+                            ret = AuthorizationStatus::Accepted;
+                        }
                     }
                 }
                 else
diff --git a/src/chargepoint/security/SecurityManager.cpp b/src/chargepoint/security/SecurityManager.cpp
@@ -774,7 +774,7 @@ void SecurityManager::fillHashInfo(const ocpp::x509::Certificate& certificate, o
     // Compute hashes with SHA-256 algorithm
     Sha2 sha256;
     info.hashAlgorithm = HashAlgorithmEnumType::SHA256;
-    sha256.compute(certificate.issuerString().c_str(), certificate.issuerString().size());
+    sha256.compute(certificate.issuerDer().data(), certificate.issuerDer().size());
     info.issuerNameHash.assign(sha256.resultString());
     sha256.compute(&certificate.publicKey()[0], certificate.publicKey().size());
     info.issuerKeyHash.assign(sha256.resultString());
diff --git a/src/chargepoint/transaction/TransactionManager.cpp b/src/chargepoint/transaction/TransactionManager.cpp
@@ -46,6 +46,7 @@ TransactionManager::TransactionManager(ocpp::config::IOcppConfig&
                                        ocpp::messages::IMessageDispatcher&             msg_dispatcher,
                                        ocpp::messages::GenericMessageSender&           msg_sender,
                                        ocpp::messages::IRequestFifo&                   requests_fifo,
+                                       IStatusManager&                                 status_manager,
                                        IAuthentManager&                                authent_manager,
                                        ReservationManager&                             reservation_manager,
                                        IMeterValuesManager&                            meter_values_manager,
@@ -56,6 +57,7 @@ TransactionManager::TransactionManager(ocpp::config::IOcppConfig&
       m_events_handler(events_handler),
       m_connectors(connectors),
       m_msg_sender(msg_sender),
+      m_status_manager(status_manager),
       m_authent_manager(authent_manager),
       m_reservation_manager(reservation_manager),
       m_meter_values_manager(meter_values_manager),
@@ -121,6 +123,9 @@ ocpp::types::AuthorizationStatus TransactionManager::startTransaction(unsigned i
 
                                 // Clear reservation
                                 m_reservation_manager.clearReservation(connector_id);
+
+                                // Reset charge point status to Available
+                                m_status_manager.updateConnectorStatus(Connectors::CONNECTOR_ID_CHARGE_POINT, ChargePointStatus::Available);
                             }
                         }
                     }
diff --git a/src/chargepoint/transaction/TransactionManager.h b/src/chargepoint/transaction/TransactionManager.h
@@ -49,6 +49,7 @@ class ReservationManager;
 class IChargePointEventsHandler;
 class IMeterValuesManager;
 class ISmartChargingManager;
+class IStatusManager;
 
 /** @brief Handle charge point transaction requests */
 class TransactionManager
@@ -64,6 +65,7 @@ class TransactionManager
                        ocpp::messages::IMessageDispatcher&             msg_dispatcher,
                        ocpp::messages::GenericMessageSender&           msg_sender,
                        ocpp::messages::IRequestFifo&                   requests_fifo,
+                       IStatusManager&                                 status_manager,
                        IAuthentManager&                                authent_manager,
                        ReservationManager&                             reservation_manager,
                        IMeterValuesManager&                            meter_values_manager,
@@ -120,6 +122,8 @@ class TransactionManager
     Connectors& m_connectors;
     /** @brief Message sender */
     ocpp::messages::GenericMessageSender& m_msg_sender;
+    /** @brief Status manager */
+    IStatusManager& m_status_manager;
     /** @brief Authentication manager */
     IAuthentManager& m_authent_manager;
     /** @brief Reservation manager */
diff --git a/src/localcontroller/LocalController.cpp b/src/localcontroller/LocalController.cpp
@@ -313,6 +313,14 @@ void LocalController::rpcClientConnected(const std::string& chargepoint_id, std:
     m_events_handler.chargePointConnected(chargepoint);
 }
 
+/** @copydoc void RpcServer::IListener::rpcClientFailedToConnect(const char*) */
+void LocalController::rpcClientFailedToConnect(const char* ip_address)
+{
+    // Notify failure => no additional processing is done here
+    // to keep this callback has fast as possible
+    return m_events_handler.clientFailedToConnect(ip_address);
+}
+
 /** @copydoc void RpcServer::IListener::rpcServerError() */
 void LocalController::rpcServerError()
 {
diff --git a/src/localcontroller/LocalController.h b/src/localcontroller/LocalController.h
@@ -78,6 +78,9 @@ class LocalController : public ILocalController, public ocpp::rpc::RpcServer::IL
     /** @copydoc void RpcServer::IListener::rpcClientConnected(const std::string&, std::shared_ptr<Client>) */
     void rpcClientConnected(const std::string& chargepoint_id, std::shared_ptr<ocpp::rpc::RpcServer::Client> client) override;
 
+    /** @copydoc void RpcServer::IListener::rpcClientFailedToConnect(const char*) */
+    void rpcClientFailedToConnect(const char* ip_address) override;
+
     /** @copydoc void RpcServer::IListener::rpcServerError() */
     void rpcServerError() override;
 
diff --git a/src/localcontroller/centralsystem/CentralSystemProxy.cpp b/src/localcontroller/centralsystem/CentralSystemProxy.cpp
@@ -100,6 +100,12 @@ void CentralSystemProxy::disconnect()
     m_rpc.stop();
 }
 
+/** @brief Indicate if the connection with the central system is active */
+bool CentralSystemProxy::isConnected() const
+{
+    return m_rpc.isConnected();
+}
+
 /** @copydoc bool ICentralSystemProxy::call(const ocpp::messages::BootNotificationReq&,
  *                                          ocpp::messages::BootNotificationConf&,
  *                                          std::string&,
diff --git a/src/localcontroller/centralsystem/CentralSystemProxy.h b/src/localcontroller/centralsystem/CentralSystemProxy.h
@@ -95,6 +95,9 @@ class CentralSystemProxy : public ICentralSystemProxy,
     /** @copydoc void ICentralSystemProxy::disconnect() */
     void disconnect() override;
 
+    /** @brief Indicate if the connection with the central system is active */
+    bool isConnected() const override;
+
     /** @copydoc void ICentralSystemProxy::registerListener(ILocalControllerProxyEventsHandler&) */
     void registerListener(ILocalControllerProxyEventsHandler& listener) override { m_listener = &listener; }
 
diff --git a/src/localcontroller/interface/ICentralSystemProxy.h b/src/localcontroller/interface/ICentralSystemProxy.h
@@ -105,6 +105,12 @@ class ICentralSystemProxy
     /** @brief Disconnect from the central system */
     virtual void disconnect() = 0;
 
+    /**
+     * @brief Indicate if the connection with the central system is active
+     * @return true if the connection is active, false otherwise
+     */
+    virtual bool isConnected() const = 0;
+
     /**
      * @brief Register a listener to the proxy events
      * @param listener Listener to the proxy events
diff --git a/src/localcontroller/interface/ILocalControllerEventsHandler.h b/src/localcontroller/interface/ILocalControllerEventsHandler.h
@@ -40,6 +40,12 @@ class ILocalControllerEventsHandler
      */
     virtual bool acceptConnection(const char* ip_address) = 0;
 
+    /**
+     * @brief Called when connection fails to established
+     * @param ip_address IP address of the client
+     */
+    virtual void clientFailedToConnect(const char* ip_address) = 0;
+
     /**
      * @brief Called to check the charge point credentials for HTTP basic authentication
      * @param chargepoint_id Charge Point identifier
diff --git a/src/messages/GetLog.cpp b/src/messages/GetLog.cpp
@@ -84,15 +84,15 @@ bool GetLogConfConverter::fromJson(const rapidjson::Value& json, GetLogConf& dat
     (void)error_code;
     (void)error_message;
     data.status = LogStatusEnumTypeHelper.fromString(json["status"].GetString());
-    extract(json, "fileName", data.fileName);
+    extract(json, "filename", data.fileName);
     return true;
 }
 
 /** @copydoc bool IMessageConverter<DataType>::toJson(DataType&, rapidjson::Document&, std::string&, std::string&) */
 bool GetLogConfConverter::toJson(const GetLogConf& data, rapidjson::Document& json)
 {
     fill(json, "status", LogStatusEnumTypeHelper.toString(data.status));
-    fill(json, "fileName", data.fileName);
+    fill(json, "filename", data.fileName);
     return true;
 }
 
diff --git a/src/rpc/RpcBase.cpp b/src/rpc/RpcBase.cpp
@@ -272,6 +272,14 @@ void RpcBase::stop()
     }
 }
 
+/** @brief Process the websocket disconnection event */
+void RpcBase::processDisconnected()
+{
+    // Disable queues
+    m_requests_queue.setEnable(false);
+    m_results_queue.setEnable(false);
+}
+
 /** @brief Process received data */
 void RpcBase::processReceivedData(const void* data, size_t size)
 {
diff --git a/src/rpc/RpcBase.h b/src/rpc/RpcBase.h
@@ -124,6 +124,8 @@ class RpcBase : public IRpc
     void start();
     /** @brief Stop RPC operations */
     void stop();
+    /** @brief Process the websocket disconnection event */
+    void processDisconnected();
     /** @brief Process received data */
     void processReceivedData(const void* data, size_t size);
     /** @brief Get the RPC listener */
diff --git a/src/rpc/RpcServer.cpp b/src/rpc/RpcServer.cpp
@@ -123,6 +123,12 @@ void RpcServer::wsClientConnected(const char* uri, std::shared_ptr<ocpp::websock
     m_listener->rpcClientConnected(chargepoint_id, rpc_client);
 }
 
+/** @copydoc void IWebsocketServer::IListener::wsClientFailedToConnect(const char*) */
+void RpcServer::wsClientFailedToConnect(const char* ip_address)
+{
+    m_listener->rpcClientFailedToConnect(ip_address);
+}
+
 /** @copydoc void IWebsocketServer::IListener::wsServerError() */
 void RpcServer::wsServerError()
 {
@@ -173,6 +179,10 @@ bool RpcServer::Client::isConnected() const
 /** @brief void IWebsocketServer::IClient::IListener::wsClientDisconnected() */
 void RpcServer::Client::wsClientDisconnected()
 {
+    // Process disconnection event
+    processDisconnected();
+
+    // Notify listener
     rpcListener()->rpcDisconnected();
 }
 
diff --git a/src/rpc/RpcServer.h b/src/rpc/RpcServer.h
@@ -78,6 +78,9 @@ class RpcServer : public ocpp::websockets::IWebsocketServer::IListener
     /** @copydoc void IWebsocketServer::IListener::wsClientConnected(const char*, std::shared_ptr<IClient>) */
     void wsClientConnected(const char* uri, std::shared_ptr<ocpp::websockets::IWebsocketServer::IClient> client) override;
 
+    /** @copydoc void IWebsocketServer::IListener::wsClientFailedToConnect(const char*) */
+    void wsClientFailedToConnect(const char* ip_address) override;
+
     /** @copydoc void IWebsocketServer::IListener::wsServerError() */
     void wsServerError() override;
 
@@ -111,6 +114,12 @@ class RpcServer : public ocpp::websockets::IWebsocketServer::IListener
          */
         virtual void rpcClientConnected(const std::string& chargepoint_id, std::shared_ptr<Client> client) = 0;
 
+        /**
+         * @brief Called when connection fails to established
+         * @param ip_address IP address of the client
+         */
+        virtual void rpcClientFailedToConnect(const char* ip_address) = 0;
+
         /** @brief Called on critical error */
         virtual void rpcServerError() = 0;
     };
diff --git a/src/tools/helpers/Timer.cpp b/src/tools/helpers/Timer.cpp
diff --git a/src/tools/helpers/Timer.h b/src/tools/helpers/Timer.h
diff --git a/src/tools/helpers/TimerPool.cpp b/src/tools/helpers/TimerPool.cpp
diff --git a/src/tools/helpers/TimerPool.h b/src/tools/helpers/TimerPool.h
diff --git a/src/tools/x509/Base64.cpp b/src/tools/x509/Base64.cpp
diff --git a/src/tools/x509/Certificate.cpp b/src/tools/x509/Certificate.cpp
diff --git a/src/tools/x509/Certificate.h b/src/tools/x509/Certificate.h
diff --git a/src/websockets/IWebsocketServer.h b/src/websockets/IWebsocketServer.h
diff --git a/src/websockets/libwebsockets/LibWebsocketServer.cpp b/src/websockets/libwebsockets/LibWebsocketServer.cpp
diff --git a/src/websockets/libwebsockets/LibWebsocketServer.h b/src/websockets/libwebsockets/LibWebsocketServer.h
diff --git a/tests/tools/test_x509.cpp b/tests/tools/test_x509.cpp

Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,7 @@`
`5`	`5`	`cmake_minimum_required(VERSION 3.13)`
`6`	`6`
`7`	`7`	`project(OpenOCPP DESCRIPTION "Open Source C++ implementation of the OCPP 1.6 protocol"`
`8`		`- VERSION 1.3.1`
	`8`	`+ VERSION 1.4.0`
`9`	`9`	`)`
`10`	`10`
`11`	`11`	`# Definitions for Version.h file`
Original file line number	Diff line number	Diff line change
`@@ -66,6 +66,12 @@ bool DefaultCentralSystemEventsHandler::acceptConnection(const char* ip_address)`
`66`	`66`	`return true;`
`67`	`67`	`}`
`68`	`68`
	`69`	`+/** @copydoc void ICentralSystemEventsHandler::clientFailedToConnect(const char) /`
	`70`	`+void DefaultCentralSystemEventsHandler::clientFailedToConnect(const char* ip_address)`
	`71`	`+{`
	`72`	`+ cout << "Client [" << ip_address << "] failed to connect" << endl;`
	`73`	`+}`
	`74`	`+`
`69`	`75`	`/** @copydoc bool ICentralSystemEventsHandler::checkCredentials(const std::string&, const std::string&) */`
`70`	`76`	`bool DefaultCentralSystemEventsHandler::checkCredentials(const std::string& chargepoint_id, const std::string& password)`
`71`	`77`	`{`
Original file line number	Diff line number	Diff line change
`@@ -691,9 +691,13 @@ ocpp::types::UpdateFirmwareStatusEnumType DefaultChargePointEventsHandler::check`
`691`	`691`	`if (!ca_certificates.empty())`
`692`	`692`	`{`
`693`	`693`	`// Check signing certificate`
`694`		`- if (signing_certificate.verify(ca_certificates))`
	`694`	`+ for (const auto& cer : ca_certificates)`
`695`	`695`	`{`
`696`		`- ret = UpdateFirmwareStatusEnumType::Accepted;`
	`696`	`+ if (signing_certificate.verify(cer.certificateChain()))`
	`697`	`+ {`
	`698`	`+ ret = UpdateFirmwareStatusEnumType::Accepted;`
	`699`	`+ break;`
	`700`	`+ }`
`697`	`701`	`}`
`698`	`702`	`}`
`699`	`703`	`else`
Original file line number	Diff line number	Diff line change
`@@ -48,6 +48,12 @@ bool DefaultLocalControllerEventsHandler::acceptConnection(const char* ip_addres`
`48`	`48`	`return true;`
`49`	`49`	`}`
`50`	`50`
	`51`	`+/** @copydoc void ILocalControllerEventsHandler::clientFailedToConnect(const char) /`
	`52`	`+void DefaultLocalControllerEventsHandler::clientFailedToConnect(const char* ip_address)`
	`53`	`+{`
	`54`	`+ cout << "Client [" << ip_address << "] failed to connect" << endl;`
	`55`	`+}`
	`56`	`+`
`51`	`57`	`/** @copydoc bool ILocalControllerEventsHandler::checkCredentials(const std::string&, const std::string&) */`
`52`	`58`	`bool DefaultLocalControllerEventsHandler::checkCredentials(const std::string& chargepoint_id, const std::string& password)`
`53`	`59`	`{`
Original file line number	Diff line number	Diff line change
`@@ -300,6 +300,14 @@ void CentralSystem::rpcClientConnected(const std::string& chargepoint_id, std::s`
`300`	`300`	`m_events_handler.chargePointConnected(chargepoint);`
`301`	`301`	`}`
`302`	`302`
	`303`	`+/** @copydoc void RpcServer::IListener::rpcClientFailedToConnect(const char) /`
	`304`	`+void CentralSystem::rpcClientFailedToConnect(const char* ip_address)`
	`305`	`+{`
	`306`	`+ // Notify failure => no additional processing is done here`
	`307`	`+ // to keep this callback has fast as possible`
	`308`	`+ return m_events_handler.clientFailedToConnect(ip_address);`
	`309`	`+}`
	`310`	`+`
`303`	`311`	`/** @copydoc void RpcServer::IListener::rpcServerError() */`
`304`	`312`	`void CentralSystem::rpcServerError()`
`305`	`313`	`{`