1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
|
/*
* Many concepts and protocol specification in this code are taken from
* the Boxee project. http://www.boxee.tv
*
* Copyright (C) 2011-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 "filesystem/PipeFile.h"
#include "interfaces/IActionListener.h"
#include "interfaces/IAnnouncer.h"
#include "threads/CriticalSection.h"
#include "threads/Thread.h"
#include <list>
#include <string>
#include <vector>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <shairplay/raop.h>
#include <sys/socket.h>
#include <sys/types.h>
class CDACP;
class CVariant;
class CAirTunesServer : public ANNOUNCEMENT::IAnnouncer, public IActionListener, public CThread
{
public:
// ANNOUNCEMENT::IAnnouncer
void Announce(ANNOUNCEMENT::AnnouncementFlag flag,
const std::string& sender,
const std::string& message,
const CVariant& data) override;
void RegisterActionListener(bool doRegister);
static void EnableActionProcessing(bool enable);
// IACtionListener
bool OnAction(const CAction &action) override;
//CThread
void Process() override;
static bool StartServer(int port, bool nonlocal, bool usePassword, const std::string &password="");
static void StopServer(bool bWait);
static bool IsRunning();
bool IsRAOPRunningInternal();
static void SetMetadataFromBuffer(const char *buffer, unsigned int size);
static void SetCoverArtFromBuffer(const char *buffer, unsigned int size);
static void SetupRemoteControl();
static void FreeDACPRemote();
private:
CAirTunesServer(int port, bool nonlocal);
~CAirTunesServer() override;
bool Initialize(const std::string &password);
void Deinitialize();
static void RefreshCoverArt(const char *outputFilename = NULL);
static void RefreshMetadata();
static void ResetMetadata();
static void InformPlayerAboutPlayTimes();
int m_port;
raop_t* m_pRaop = nullptr;
XFILE::CPipeFile *m_pPipe;
static CAirTunesServer *ServerInstance;
static std::string m_macAddress;
static CCriticalSection m_metadataLock;
static std::string m_metadata[3];//0 - album, 1 - title, 2 - artist
static bool m_streamStarted;
static CCriticalSection m_dacpLock;
static CDACP *m_pDACP;
static std::string m_dacp_id;
static std::string m_active_remote_header;
static CCriticalSection m_actionQueueLock;
static std::list<CAction> m_actionQueue;
static CEvent m_processActions;
static int m_sampleRate;
static unsigned int m_cachedStartTime;
static unsigned int m_cachedEndTime;
static unsigned int m_cachedCurrentTime;
class AudioOutputFunctions
{
public:
static void* audio_init(void *cls, int bits, int channels, int samplerate);
static void audio_set_volume(void *cls, void *session, float volume);
static void audio_set_metadata(void *cls, void *session, const void *buffer, int buflen);
static void audio_set_coverart(void *cls, void *session, const void *buffer, int buflen);
static void audio_process(void *cls, void *session, const void *buffer, int buflen);
static void audio_destroy(void *cls, void *session);
static void audio_remote_control_id(void *cls, const char *identifier, const char *active_remote_header);
static void audio_set_progress(void *cls, void *session, unsigned int start, unsigned int curr, unsigned int end);
};
};
|
