xlxd 2.0.0

Added compatibility with protocols DMR Homebrew (MMDVM) and DMR Plus (dongle)
2026-08-10 21:43:42 -04:00 · 2017-08-22 20:23:57 +02:00
parent 41465e236d
commit 83278d1363
65 changed files with 6366 additions and 175 deletions
@@ -0,0 +1,107 @@
+//
+//  ctranscoder.h
+//  xlxd
+//
+//  Created by Jean-Luc Deltombe (LX3JL) on 13/04/2017.
+//  Copyright © 2015 Jean-Luc Deltombe (LX3JL). All rights reserved.
+//
+// ----------------------------------------------------------------------------
+//    This file is part of xlxd.
+//
+//    xlxd is free software: you can redistribute it and/or modify
+//    it under the terms of the GNU General Public License as published by
+//    the Free Software Foundation, either version 3 of the License, or
+//    (at your option) any later version.
+//
+//    xlxd is distributed in the hope that it will be useful,
+//    but WITHOUT ANY WARRANTY; without even the implied warranty of
+//    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+//    GNU General Public License for more details.
+//
+//    You should have received a copy of the GNU General Public License
+//    along with Foobar.  If not, see <http://www.gnu.org/licenses/>.
+// ----------------------------------------------------------------------------
+
+#ifndef ctranscoder_h
+#define ctranscoder_h
+
+#include "csemaphore.h"
+#include "ccodecstream.h"
+#include "cudpsocket.h"
+
+////////////////////////////////////////////////////////////////////////////////////////
+// define
+
+
+////////////////////////////////////////////////////////////////////////////////////////
+// class
+
+class CPacketStream;
+
+class CTranscoder
+{
+public:
+    // constructor
+    CTranscoder();
+    
+    // destructor
+    virtual ~CTranscoder();
+
+    // initialization
+    bool Init(void);
+    void Close(void);
+
+    // locks
+    void Lock(void)                     { m_Mutex.lock(); }
+    void Unlock(void)                   { m_Mutex.unlock(); }
+    
+    // manage streams
+    CCodecStream *GetStream(CPacketStream *, uint8);
+    void ReleaseStream(CCodecStream *);
+    
+    // task
+    static void Thread(CTranscoder *);
+    void Task(void);
+
+protected:
+    // keepalive helpers
+    void HandleKeepalives(void);
+
+    // packet decoding helpers
+    bool IsValidKeepAlivePacket(const CBuffer &);
+    bool IsValidStreamDescrPacket(const CBuffer &, uint16 *, uint16 *);
+    bool IsValidNoStreamAvailablePacket(const CBuffer&);
+
+    // packet encoding helpers
+    void EncodeKeepAlivePacket(CBuffer *);
+    void EncodeOpenstreamPacket(CBuffer *, uint8, uint8);
+    void EncodeClosestreamPacket(CBuffer *, uint16);
+    
+protected:
+    // streams
+    std::mutex                  m_Mutex;
+    std::vector<CCodecStream *> m_Streams;
+
+    // sync objects for Openstream
+    CSemaphore      m_SemaphoreOpenStream;
+    bool            m_bStreamOpened;
+    uint16          m_StreamidOpenStream;
+    uint16          m_PortOpenStream;
+    
+    // thread
+    bool            m_bStopThread;
+    std::thread     *m_pThread;
+
+    // socket
+    CIp             m_Ip;
+    CUdpSocket      m_Socket;
+    bool            m_bConnected;
+
+    // time
+    CTimePoint      m_LastKeepaliveTime;
+    CTimePoint      m_LastActivityTime;
+};
+
+
+////////////////////////////////////////////////////////////////////////////////////////
+#endif /* ctranscoder_h */