]> git.vomp.tv Git - vompserver.git/blob - mvpclient.h
Active patch from pompase
[vompserver.git] / mvpclient.h
1 /*
2     Copyright 2004-2005 Chris Tallon
3
4     This file is part of VOMP.
5
6     VOMP is free software; you can redistribute it and/or modify
7     it under the terms of the GNU General Public License as published by
8     the Free Software Foundation; either version 2 of the License, or
9     (at your option) any later version.
10
11     VOMP is distributed in the hope that it will be useful,
12     but WITHOUT ANY WARRANTY; without even the implied warranty of
13     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14     GNU General Public License for more details.
15
16     You should have received a copy of the GNU General Public License
17     along with VOMP; if not, write to the Free Software
18     Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
19 */
20
21 #ifndef MVPCLIENT_H
22 #define MVPCLIENT_H
23
24 #include <stdio.h>
25 #include <pthread.h>
26 #include <signal.h>
27 #include <endian.h>
28
29 #include <unistd.h> // sleep
30
31 #include <vdr/recording.h>
32 #include <vdr/channels.h>
33 #include <vdr/videodir.h>
34 #include <vdr/plugin.h>
35 #include <vdr/timers.h>
36 #include <vdr/menu.h>
37
38 #include "defines.h"
39 #include "tcp.h"
40 #include "mvpreceiver.h"
41 #include "recplayer.h"
42 #include "config.h"
43
44 class MVPClient
45 {
46   public:
47     MVPClient(char* configDirExtra, int tsocket);
48     ~MVPClient();
49
50     int run();
51     // not for external use
52     void run2();
53     static int getNrClients();
54
55   private:
56     static int nr_clients;
57     pthread_t runThread;
58     int initted;
59     TCP tcp;
60     Config config;
61     MVPReceiver* lp;
62     bool loggedIn;
63     char* configDirExtra;
64
65
66     cRecordings* recordingManager;
67     RecPlayer* rp;
68     Log* log;
69
70     int processLogin(UCHAR* buffer, int length);
71     int processGetRecordingsList(UCHAR* data, int length);
72     int processDeleteRecording(UCHAR* data, int length);
73     int processMoveRecording(UCHAR* data, int length);
74     int processGetChannelsList(UCHAR* data, int length);
75     int processStartStreamingChannel(UCHAR* data, int length);
76     int processGetBlock(UCHAR* data, int length);
77     int processStopStreaming(UCHAR* data, int length);
78     int processStartStreamingRecording(UCHAR* data, int length);
79     int processGetChannelSchedule(UCHAR* data, int length);
80     int processConfigSave(UCHAR* data, int length);
81     int processConfigLoad(UCHAR* data, int length);
82     int processGetTimers(UCHAR* data, int length);
83     int processSetTimer(UCHAR* data, int length);
84     int processPositionFromFrameNumber(UCHAR* data, int length);
85     int processFrameNumberFromPosition(UCHAR* data, int length);
86     int processGetIFrame(UCHAR* data, int length);
87     int processGetRecInfo(UCHAR* data, int length);
88     int processGetMarks(UCHAR* data, int length);
89     int processGetChannelPids(UCHAR* data, int length);
90
91     int processReScanRecording(UCHAR* data, int length);           // FIXME obselete
92
93     void incClients();
94     void decClients();
95
96     cChannel* channelFromNumber(ULONG channelNumber);
97     void writeResumeData();
98     void cleanConfig();
99     void sendULONG(ULONG ul);
100
101     ULLONG ntohll(ULLONG a);
102     ULLONG htonll(ULLONG a);
103
104     void test(int num);
105     void test2();
106 };
107
108 #endif