Adding upstream version 2:20.4+dfsg.upstream/2%20.4+dfsg

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 81 insertions, 0 deletions

diff --git a/xbmc/network/EventServer.h b/xbmc/network/EventServer.h
new file mode 100644
index 0000000..8e529af
--- /dev/null
+++ b/xbmc/network/EventServer.h
@@ -0,0 +1,81 @@
+/*
+ *  Copyright (C) 2005-2018 Team Kodi
+ *  This file is part of Kodi - https://kodi.tv
+ *
+ *  SPDX-License-Identifier: GPL-2.0-or-later
+ *  See LICENSES/README.md for more information.
+ */
+
+#pragma once
+
+#include "EventClient.h"
+#include "Socket.h"
+#include "threads/CriticalSection.h"
+#include "threads/Thread.h"
+
+#include <atomic>
+#include <map>
+#include <mutex>
+#include <queue>
+#include <vector>
+
+namespace EVENTSERVER
+{
+
+  /**********************************************************************/
+  /* UDP Event Server Class                                             */
+  /**********************************************************************/
+  class CEventServer : private CThread
+  {
+  public:
+    static void RemoveInstance();
+    static CEventServer* GetInstance();
+
+    CEventServer();
+    ~CEventServer() override = default;
+
+    // IRunnable entry point for thread
+    void  Process() override;
+
+    bool Running()
+    {
+      return m_bRunning;
+    }
+
+    void RefreshSettings()
+    {
+      std::unique_lock<CCriticalSection> lock(m_critSection);
+      m_bRefreshSettings = true;
+    }
+
+    // start / stop server
+    void StartServer();
+    void StopServer(bool bWait);
+
+    // get events
+    unsigned int GetButtonCode(std::string& strMapName, bool& isAxis, float& amount, bool &isJoystick);
+    bool ExecuteNextAction();
+    bool GetMousePos(float &x, float &y);
+    int GetNumberOfClients();
+
+  protected:
+    void Cleanup();
+    void Run();
+    void ProcessPacket(SOCKETS::CAddress& addr, int packetSize);
+    void ProcessEvents();
+    void RefreshClients();
+
+    std::map<unsigned long, std::unique_ptr<EVENTCLIENT::CEventClient>> m_clients;
+    static std::unique_ptr<CEventServer> m_pInstance;
+    std::unique_ptr<SOCKETS::CUDPSocket> m_pSocket;
+    int              m_iPort;
+    int              m_iListenTimeout;
+    int              m_iMaxClients;
+    std::vector<uint8_t> m_pPacketBuffer;
+    std::atomic<bool> m_bRunning = false;
+    CCriticalSection m_critSection;
+    bool             m_bRefreshSettings;
+  };
+
+}
+