]> git.vomp.tv Git - vompclient.git/blob - vdr.h
Some fixes on cancellation points
[vompclient.git] / vdr.h
1 /*\r
2     Copyright 2004-2005 Chris Tallon\r
3 \r
4     This file is part of VOMP.\r
5 \r
6     VOMP is free software; you can redistribute it and/or modify\r
7     it under the terms of the GNU General Public License as published by\r
8     the Free Software Foundation; either version 2 of the License, or\r
9     (at your option) any later version.\r
10 \r
11     VOMP is distributed in the hope that it will be useful,\r
12     but WITHOUT ANY WARRANTY; without even the implied warranty of\r
13     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the\r
14     GNU General Public License for more details.\r
15 \r
16     You should have received a copy of the GNU General Public License\r
17     along with VOMP; if not, write to the Free Software\r
18     Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.\r
19 */\r
20 \r
21 \r
22 // FIXME - This and the protocol are overly complicated now. Sorry.\r
23 //         I'll clean it up in a couple of releases time...\r
24 \r
25 \r
26 #ifndef VDR_H\r
27 #define VDR_H\r
28 \r
29 #include <stdio.h>\r
30 #include <time.h>\r
31 #include <vector>\r
32 #include <algorithm>\r
33 \r
34 #include "threadsystem.h"\r
35 \r
36 #include "defines.h"\r
37 #include "rectimer.h"\r
38 #include "mark.h"\r
39 #include "mediaprovider.h"\r
40 #include "eventdispatcher.h"\r
41 #include "i18n.h"\r
42 #include "log.h"\r
43 \r
44 class TCP;\r
45 class Log;\r
46 class RecInfo;\r
47 class Event;\r
48 class Channel;\r
49 class VDR_RequestPacket;\r
50 class VDR_ResponsePacket;\r
51 class SerializeBuffer;\r
52 \r
53 using namespace std;\r
54 \r
55 typedef vector<Event*> EventList;\r
56 typedef vector<Channel*> ChannelList;\r
57 typedef vector<RecTimer*> RecTimerList;\r
58 \r
59 struct VDRServer\r
60 {\r
61   char* ip;\r
62   char* name;\r
63 };\r
64 \r
65 struct RecTimerSorter     // : public binary_function<double, double, bool>\r
66 {\r
67   bool operator() (const RecTimer* a, const RecTimer* b)\r
68   {\r
69     return a->startTime < b->startTime;\r
70   }\r
71 };\r
72 \r
73 struct ServerSorter\r
74 {\r
75   bool operator() (const VDRServer& a, const VDRServer& b)\r
76   {\r
77     if (strcmp(b.name, a.name) > 0) return true;\r
78     return false;\r
79   }\r
80 };\r
81 \r
82 class RecMan;\r
83 \r
84 class StreamReceiver\r
85 {\r
86   public:\r
87     virtual void streamReceive(ULONG, void*, ULONG)=0;\r
88 };\r
89 \r
90 class VDR_PacketReceiver : public EDReceiver // implementation in vdr.cc\r
91 {\r
92   public:\r
93     virtual bool call(void* userTag);\r
94 \r
95   friend class VDR;\r
96   protected:\r
97 //    ULONG requestTime;\r
98     ULONG receiverChannel;\r
99     \r
100     // If receiverChannel == 1:\r
101     ULONG requestSerialNumber;      // set by RequestResponse, used in ed_cb_find\r
102     VDR_ResponsePacket* save_vresp; // set by ed_cb_call, used in RequestResponse\r
103         \r
104     // If receiverChannel == 2:\r
105     ULONG streamID;\r
106     StreamReceiver* streamReceiver;\r
107 };\r
108 \r
109 class VDR : public Thread_TYPE, public EventDispatcher, public MediaProvider, public ExternLogger\r
110 {\r
111 \r
112   public:\r
113     const static ULONG VIDEO = 1;\r
114     const static ULONG RADIO = 2;\r
115   \r
116     const static ULONG CHANNEL_REQUEST_RESPONSE = 1;\r
117     const static ULONG CHANNEL_STREAM = 2;\r
118     const static ULONG CHANNEL_KEEPALIVE = 3;\r
119     const static ULONG CHANNEL_NETLOG = 4;\r
120   \r
121     VDR();\r
122     ~VDR();\r
123     static VDR* getInstance();\r
124 \r
125     int init(int port);\r
126     int shutdown();\r
127 \r
128     void findServers(vector<VDRServer>& servers);\r
129     void cancelFindingServer();\r
130     void setServerIP(char*);\r
131     void setReceiveWindow(size_t size);\r
132     int connect();\r
133     void disconnect();\r
134     bool isConnected() { return connected; }\r
135     ULONG getChannelNumberWidth() { return channelNumberWidth; }\r
136 \r
137     // protocol functions\r
138     // for the following, if result == false then the connection has died\r
139     //  doLogin\r
140     //  getRecordingList\r
141     //  getChannelsList\r
142     //  getChannelSchedule\r
143     //  getRecTimersList\r
144     // isConnected can be called after the following to determine if still ok\r
145     //  deleteRecording\r
146     //  streamRecording\r
147     //  positionFromFrameNumber\r
148     //  streamChannel\r
149     //  getBlock\r
150     //  stopStreaming\r
151     //  configLoad\r
152     //  configSave\r
153     //  setEventTimer\r
154 \r
155     int           doLogin(unsigned int* v_server,unsigned int* v_client);\r
156     bool          getRecordingsList(RecMan* recman);\r
157     RecInfo*      getRecInfo(char* fileName);\r
158     int           deleteRecording(char* fileName);\r
159     char*         moveRecording(char* fileName, char* newPath);\r
160     ULLONG        streamRecording(char* fileName, ULONG* lengthFrames, bool* IsPesRecording);\r
161     ULLONG        positionFromFrameNumber(ULONG frameNumber);\r
162     ULONG         frameNumberFromPosition(ULLONG position);\r
163     bool          getNextIFrame(ULONG frameNumber, ULONG direction, ULLONG* rfilePosition, ULONG* rframeNumber, ULONG* rframeLength);\r
164                   // Direction: 0=backwards, 1=forwards\r
165     MarkList*     getMarks(char* fileName);\r
166     int           deleteTimer(RecTimer* delTimer);\r
167     ChannelList*  getChannelsList(ULONG type);\r
168     int           streamChannel(ULONG number, StreamReceiver*);\r
169     int           streamChannel(ULONG number);\r
170     void          getChannelPids(Channel* channel);\r
171     UCHAR*        getBlock(ULLONG position, UINT maxAmount, UINT* amountReceived);\r
172                   //get image blocks separate - we can do this in parallel\r
173     int           stopStreaming();\r
174     EventList*    getChannelSchedule(ULONG number);\r
175     EventList*    getChannelSchedule(ULONG number, time_t start, ULONG duration);\r
176     int           configSave(const char* section, const char* key, const char* value);\r
177     char*         configLoad(const char* section, const char* key);\r
178     ULONG         setEventTimer(char* timerString);\r
179     RecTimerList* getRecTimersList();\r
180     bool          LogExtern(const char* buffer);\r
181     \r
182     bool setCharset(int charset); // 1 latin 2 UTF-8\r
183 \r
184     /**\r
185       * the MediaProvider functions\r
186       *\r
187       */\r
188     virtual MediaList* getRootList();\r
189     virtual MediaList* getMediaList(const MediaURI * parent);\r
190     virtual int        openMedium(ULONG channel,const MediaURI *uri,ULLONG * size, ULONG xsize,ULONG ysize);\r
191     virtual int getMediaBlock(ULONG channel, unsigned long long offset, unsigned long len, unsigned long * outlen,\r
192         unsigned char ** buffer);\r
193     virtual int getMediaInfo(ULONG channel, struct MediaInfo * result);\r
194     virtual int closeMediaChannel(ULONG channel);\r
195 \r
196 \r
197     I18n::lang_code_list getLanguageList();\r
198     int           getLanguageContent(const string code, I18n::trans_table&);\r
199 \r
200     // end protocol functions\r
201 \r
202 \r
203     // obselete\r
204     ULLONG     rescanRecording(ULONG* lengthFrames);                    // FIXME obselete\r
205 \r
206 \r
207 \r
208   private:\r
209     static VDR* instance;\r
210 \r
211     VDR_ResponsePacket* RequestResponse(VDR_RequestPacket* request);\r
212     UCHAR* getBlock(ULLONG position, UINT maxAmount, UINT* amountReceived, ULONG cmd);\r
213     \r
214     void connectionDied();\r
215     bool sendKA(ULONG timeStamp);\r
216     \r
217     Log* logger;\r
218     int initted;\r
219     int findingServer;\r
220     TCP* tcp;\r
221     int port;\r
222     char serverIP[16];\r
223     bool connected;\r
224     ULONG maxChannelNumber;\r
225     ULONG channelNumberWidth;\r
226     VDR_PacketReceiver* TEMP_SINGLE_VDR_PR;\r
227 \r
228 \r
229     ULONG providerId;\r
230     ULONG subRange;\r
231     SerializeBuffer * doRequestResponse(SerializeBuffer *in,int cmd);\r
232   protected:\r
233   \r
234     // Thread\r
235     void threadMethod();\r
236     void threadPostStopCleanup() {};\r
237 \r
238     // EventDispatcher\r
239     virtual bool ed_cb_find(EDReceiver* edr, void* userTag);\r
240 };\r
241 \r
242 #endif\r
243 \r
244 /*\r
245 \r
246 index.vdr file format for video:\r
247 \r
248 For every video frame:\r
249 {\r
250   File offset    4 bytes\r
251   Picture type   1 byte\r
252   File number    1 byte\r
253   Zero           2 bytes\r
254 }\r
255 \r
256 Picture types:\r
257 \r
258 #define NO_PICTURE 0\r
259 #define I_FRAME    1\r
260 #define P_FRAME    2\r
261 #define B_FRAME    3\r
262 \r
263 \r
264 \r
265 Packet formats\r
266 \r
267 Packet format for an RR channel request:\r
268 \r
269 4 bytes = channel ID = 1 (request/response channel)\r
270 4 bytes = request ID (from serialNumber)\r
271 4 bytes = opcode\r
272 4 bytes = length of the rest of the packet\r
273 ? bytes = rest of packet. depends on packet\r
274 \r
275 \r
276 Packet format for an RR channel response:\r
277 \r
278 4 bytes = channel ID = 1 (request/response channel)\r
279 4 bytes = request ID (from serialNumber)\r
280 4 bytes = length of the rest of the packet\r
281 ? bytes = rest of packet. depends on packet\r
282 \r
283 \r
284 Packet format for a stream packet:\r
285 \r
286 4 bytes = channel ID = 2 (stream channel)\r
287 4 bytes = stream ID (from requestID)\r
288 4 bytes = length of the stream data (rest of packet)\r
289 ? bytes = stream data\r
290 \r
291 */\r
292 \r