]> git.vomp.tv Git - vompserver.git/blob - mvpclient.c
Stop logging
[vompserver.git] / mvpclient.c
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 #include "mvpclient.h"
22
23 MVPClient::MVPClient(int tsocket)
24  : tcp(tsocket)
25 {
26   lp = NULL;
27   rp = NULL;
28   recordingManager = NULL;
29   log = Log::getInstance();
30
31   // Get IP address of client for config module
32
33   char ipa[20];
34   struct sockaddr_in peer;
35   socklen_t salen = sizeof(struct sockaddr);
36   if(getpeername(tsocket, (struct sockaddr*)&peer, &salen) == 0)
37   {
38     strcpy(ipa, inet_ntoa(peer.sin_addr));
39   }
40   else
41   {
42     ipa[0] = '\0';
43     log->log("Client", Log::DEBUG, "Cannot get peer name!");
44   }
45
46   const char* configDir = cPlugin::ConfigDirectory();
47   if (!configDir)
48   {
49     log->log("Client", Log::DEBUG, "No config dir!");
50     return;
51   }
52
53   char configFileName[PATH_MAX];
54   snprintf(configFileName, PATH_MAX - strlen(configDir) - strlen(ipa) - 20, "%s/vomp-%s.conf", configDir, ipa);
55   config.init(configFileName);
56
57   log->log("Client", Log::DEBUG, "Config file name: %s", configFileName);
58
59 //  processGetChannelSchedule(NULL, 0);
60
61 //test();
62
63 }
64
65 MVPClient::~MVPClient()
66 {
67   log->log("Client", Log::DEBUG, "MVP client destructor");
68   if (lp)
69   {
70     delete lp;
71     lp = NULL;
72   }
73   else if (rp)
74   {
75     writeResumeData();
76
77     delete rp;
78     delete recordingManager;
79     rp = NULL;
80     recordingManager = NULL;
81   }
82
83   cleanConfig();
84 }
85
86 cChannel* MVPClient::channelFromNumber(unsigned long channelNumber)
87 {
88   cChannel* channel = NULL;
89
90   for (channel = Channels.First(); channel; channel = Channels.Next(channel))
91   {
92     if (!channel->GroupSep())
93     {
94       log->log("Client", Log::DEBUG, "Looking for channel %lu::: number: %i name: '%s'", channelNumber, channel->Number(), channel->Name());
95
96       if (channel->Number() == (int)channelNumber)
97       {
98         int vpid = channel->Vpid();
99 #if VDRVERSNUM < 10300
100         int apid1 = channel->Apid1();
101 #else
102         int apid1 = channel->Apid(0);
103 #endif
104         log->log("Client", Log::DEBUG, "Found channel number %lu, vpid = %i, apid1 = %i", channelNumber, vpid, apid1);
105         return channel;
106       }
107     }
108   }
109
110   if (!channel)
111   {
112     log->log("Client", Log::DEBUG, "Channel not found");
113   }
114
115   return channel;
116 }
117
118
119 void MVPClient::writeResumeData()
120 {
121   config.setValueLongLong("ResumeData", (char*)rp->getCurrentRecording()->FileName(), rp->getLastPosition());
122 }
123
124 void MVPClient::sendULONG(ULONG ul)
125 {
126   unsigned char sendBuffer[8];
127   *(unsigned long*)&sendBuffer[0] = htonl(4);
128   *(unsigned long*)&sendBuffer[4] = htonl(ul);
129
130   tcp.sendPacket(sendBuffer, 8);
131   log->log("Client", Log::DEBUG, "written ULONG %lu", ul);
132 }
133
134 void MVPClientStartThread(void* arg)
135 {
136   MVPClient* m = (MVPClient*)arg;
137   m->run2();
138   // Nothing external to this class has a reference to it
139   // This is the end of the thread.. so delete m
140   delete m;
141   pthread_exit(NULL);
142 }
143
144 int MVPClient::run()
145 {
146   if (pthread_create(&runThread, NULL, (void*(*)(void*))MVPClientStartThread, (void *)this) == -1) return 0;
147   log->log("Client", Log::DEBUG, "MVPClient run success");
148   return 1;
149 }
150
151 void MVPClient::run2()
152 {
153   // Thread stuff
154   sigset_t sigset;
155   sigfillset(&sigset);
156   pthread_sigmask(SIG_BLOCK, &sigset, NULL);
157   pthread_detach(runThread);  // Detach
158
159   tcp.disableReadTimeout();
160
161   tcp.setSoKeepTime(3);
162   tcp.setNonBlocking();
163
164   unsigned char* buffer;
165   unsigned char* data;
166   int packetLength;
167   unsigned long opcode;
168
169   while(1)
170   {
171     log->log("Client", Log::DEBUG, "Waiting");
172     buffer = (unsigned char*)tcp.receivePacket();
173     log->log("Client", Log::DEBUG, "Received packet, length = %u", tcp.getDataLength());
174     if (buffer == NULL)
175     {
176       log->log("Client", Log::DEBUG, "Detected connection closed");
177       break;
178     }
179
180     packetLength = tcp.getDataLength() - 4;
181     opcode = ntohl(*(unsigned long*)buffer);
182     data = buffer + 4;
183
184
185     switch(opcode)
186     {
187       case 1:
188         processLogin(data, packetLength);
189         break;
190       case 2:
191         processGetRecordingsList(data, packetLength);
192         break;
193       case 3:
194         processDeleteRecording(data, packetLength);
195         break;
196       case 4:
197         processGetSummary(data, packetLength);
198         break;
199       case 5:
200         processGetChannelsList(data, packetLength);
201         break;
202       case 6:
203         processStartStreamingChannel(data, packetLength);
204         break;
205       case 7:
206         processGetBlock(data, packetLength);
207         break;
208       case 8:
209         processStopStreaming(data, packetLength);
210         break;
211       case 9:
212         processStartStreamingRecording(data, packetLength);
213         break;
214       case 10:
215         processGetChannelSchedule(data, packetLength);
216         break;
217       case 11:
218         processConfigSave(data, packetLength);
219         break;
220       case 12:
221         processConfigLoad(data, packetLength);
222         break;
223       case 13:
224         processReScanRecording(data, packetLength);
225         break;
226     }
227
228     free(buffer);
229   }
230 }
231
232 void MVPClient::processLogin(unsigned char* buffer, int length)
233 {
234   time_t timeNow = time(NULL);
235   struct tm* timeStruct = localtime(&timeNow);
236   int timeOffset = timeStruct->tm_gmtoff;
237
238   unsigned char sendBuffer[12];
239   *(unsigned long*)&sendBuffer[0] = htonl(8);
240   *(unsigned long*)&sendBuffer[4] = htonl(timeNow);
241   *(signed int*)&sendBuffer[8] = htonl(timeOffset);
242
243   tcp.sendPacket(sendBuffer, 12);
244   log->log("Client", Log::DEBUG, "written login reply");
245 }
246
247 void MVPClient::processGetRecordingsList(unsigned char* data, int length)
248 {
249   unsigned char* sendBuffer = new unsigned char[50000]; // hope this is enough
250   int count = 4; // leave space for the packet length
251   char* point;
252
253
254   int FreeMB;
255   int Percent = VideoDiskSpace(&FreeMB);
256   int Total = (FreeMB / (100 - Percent)) * 100;
257
258   *(unsigned long*)&sendBuffer[count] = htonl(Total);
259   count += sizeof(unsigned long);
260   *(unsigned long*)&sendBuffer[count] = htonl(FreeMB);
261   count += sizeof(unsigned long);
262   *(unsigned long*)&sendBuffer[count] = htonl(Percent);
263   count += sizeof(unsigned long);
264
265
266   cRecordings Recordings;
267   Recordings.Load();
268
269   for (cRecording *recording = Recordings.First(); recording; recording = Recordings.Next(recording))
270   {
271     if (count > 49000) break; // just how big is that hard disk?!
272     *(unsigned long*)&sendBuffer[count] = htonl(recording->start);// + timeOffset);
273     count += 4;
274
275     point = (char*)recording->Name();
276     strcpy((char*)&sendBuffer[count], point);
277     count += strlen(point) + 1;
278
279     point = (char*)recording->FileName();
280     strcpy((char*)&sendBuffer[count], point);
281     count += strlen(point) + 1;
282   }
283
284   *(unsigned long*)&sendBuffer[0] = htonl(count - 4); // -4 :  take off the size field
285
286   log->log("Client", Log::DEBUG, "recorded size as %u", ntohl(*(unsigned long*)&sendBuffer[0]));
287
288   tcp.sendPacket(sendBuffer, count);
289   delete[] sendBuffer;
290   log->log("Client", Log::DEBUG, "Written list");
291 }
292
293 void MVPClient::processDeleteRecording(unsigned char* data, int length)
294 {
295   // data is a pointer to the fileName string
296
297   cRecordings Recordings;
298   Recordings.Load(); // probably have to do this
299
300   cRecording* recording = Recordings.GetByName((char*)data);
301
302   log->log("Client", Log::DEBUG, "recording pointer %p", recording);
303
304   if (recording)
305   {
306     log->log("Client", Log::DEBUG, "deleting recording: %s", recording->Name());
307     recording->Delete();
308     sendULONG(1);
309   }
310   else
311   {
312     sendULONG(0);
313   }
314 }
315
316 void MVPClient::processGetSummary(unsigned char* data, int length)
317 {
318   // data is a pointer to the fileName string
319
320   cRecordings Recordings;
321   Recordings.Load(); // probably have to do this
322
323   cRecording *recording = Recordings.GetByName((char*)data);
324
325   log->log("Client", Log::DEBUG, "recording pointer %p", recording);
326
327   if (recording)
328   {
329     unsigned char* sendBuffer = new unsigned char[50000]; // hope this is enough
330     int count = 4; // leave space for the packet length
331
332     char* point;
333 #if VDRVERSNUM < 10300
334     point = (char*)recording->Summary();
335 #else
336     const cRecordingInfo *Info = recording->Info();
337     point = (char*)Info->ShortText();
338     log->log("Client", Log::DEBUG, "info pointer %p summary pointer %p", Info, point);
339     if (isempty(point))
340     {
341       point = (char*)Info->Description();
342       log->log("Client", Log::DEBUG, "description pointer %p", point);
343     }
344 #endif
345     strcpy((char*)&sendBuffer[count], point);
346     count += strlen(point) + 1;
347     *(unsigned long*)&sendBuffer[0] = htonl(count - 4); // -4 :  take off the size field
348
349     log->log("Client", Log::DEBUG, "recorded size as %u", ntohl(*(unsigned long*)&sendBuffer[0]));
350
351     tcp.sendPacket(sendBuffer, count);
352     delete[] sendBuffer;
353     log->log("Client", Log::DEBUG, "Written summary");
354
355
356   }
357   else
358   {
359     sendULONG(0);
360   }
361 }
362
363 void MVPClient::processGetChannelsList(unsigned char* data, int length)
364 {
365   unsigned char* sendBuffer = new unsigned char[50000]; // FIXME hope this is enough
366   int count = 4; // leave space for the packet length
367   char* point;
368   unsigned long type;
369
370   for (cChannel *channel = Channels.First(); channel; channel = Channels.Next(channel))
371   {
372 #if VDRVERSNUM < 10300
373     if (!channel->GroupSep() && !channel->Ca())
374 #else
375     if (!channel->GroupSep() && !channel->Ca(0))
376 #endif
377     {
378       log->log("Client", Log::DEBUG, "name: '%s'", channel->Name());
379
380       if (channel->Vpid()) type = 1;
381 #if VDRVERSNUM < 10300
382       else type = 2;
383 #else
384       else if (channel->Apid(0)) type = 2;
385       else continue;
386 #endif
387
388       if (count > 49000) break;
389       *(unsigned long*)&sendBuffer[count] = htonl(channel->Number());
390       count += 4;
391
392       *(unsigned long*)&sendBuffer[count] = htonl(type);
393       count += 4;
394
395       point = (char*)channel->Name();
396       strcpy((char*)&sendBuffer[count], point);
397       count += strlen(point) + 1;
398     }
399   }
400
401   *(unsigned long*)&sendBuffer[0] = htonl(count - 4); // -4 :  take off the size field
402
403   log->log("Client", Log::DEBUG, "recorded size as %u", ntohl(*(unsigned long*)&sendBuffer[0]));
404
405   tcp.sendPacket(sendBuffer, count);
406   delete[] sendBuffer;
407   log->log("Client", Log::DEBUG, "Written channels list");
408 }
409
410 void MVPClient::processStartStreamingChannel(unsigned char* data, int length)
411 {
412   log->log("Client", Log::DEBUG, "length = %i", length);
413   unsigned long channelNumber = ntohl(*(unsigned long*)data);
414
415   cChannel* channel = channelFromNumber(channelNumber);
416   if (!channel)
417   {
418     sendULONG(0);
419     return;
420   }
421
422   lp = MVPReceiver::create(channel);
423
424   if (!lp)
425   {
426     sendULONG(0);
427     return;
428   }
429
430   if (!lp->init())
431   {
432     delete lp;
433     lp = NULL;
434     sendULONG(0);
435     return;
436   }
437
438   sendULONG(1);
439 }
440
441 void MVPClient::processStopStreaming(unsigned char* data, int length)
442 {
443   log->log("Client", Log::DEBUG, "STOP STREAMING RECEIVED");
444   if (lp)
445   {
446     delete lp;
447     lp = NULL;
448   }
449   else if (rp)
450   {
451     writeResumeData();
452
453     delete rp;
454     delete recordingManager;
455     rp = NULL;
456     recordingManager = NULL;
457   }
458
459   sendULONG(1);
460 }
461
462 void MVPClient::processGetBlock(unsigned char* data, int length)
463 {
464   if (!lp && !rp)
465   {
466     log->log("Client", Log::DEBUG, "Get block called when no streaming happening!");
467     return;
468   }
469
470   ULLONG position = ntohll(*(ULLONG*)data);
471   data += sizeof(ULLONG);
472   unsigned long amount = ntohl(*(unsigned long*)data);
473
474   log->log("Client", Log::DEBUG, "getblock pos = %llu length = %lu", position, amount);
475
476   unsigned char sendBuffer[amount + 4];
477   unsigned long amountReceived = 0; // compiler moan.
478   if (lp)
479   {
480     log->log("Client", Log::DEBUG, "getting from live");
481     amountReceived = lp->getBlock(&sendBuffer[4], amount);
482
483     if (!amountReceived)
484     {
485       // vdr has possibly disconnected the receiver
486       log->log("Client", Log::DEBUG, "VDR has disconnected the live receiver");
487       delete lp;
488       lp = NULL;
489     }
490   }
491   else if (rp)
492   {
493     log->log("Client", Log::DEBUG, "getting from recording");
494     amountReceived = rp->getBlock(&sendBuffer[4], position, amount);
495   }
496
497   *(unsigned long*)&sendBuffer[0] = htonl(amountReceived);
498   tcp.sendPacket(sendBuffer, amountReceived + 4);
499   log->log("Client", Log::DEBUG, "written ok %lu", amountReceived);
500 }
501
502 void MVPClient::processStartStreamingRecording(unsigned char* data, int length)
503 {
504   // data is a pointer to the fileName string
505
506   recordingManager = new cRecordings;
507   recordingManager->Load();
508
509   cRecording* recording = recordingManager->GetByName((char*)data);
510
511   log->log("Client", Log::DEBUG, "recording pointer %p", recording);
512
513   if (recording)
514   {
515     rp = new RecPlayer(recording);
516
517     unsigned char sendBuffer[12];
518     *(unsigned long*)&sendBuffer[0] = htonl(8);
519     *(ULLONG*)&sendBuffer[4] = htonll(rp->getTotalLength());
520
521     tcp.sendPacket(sendBuffer, 12);
522     log->log("Client", Log::DEBUG, "written totalLength");
523   }
524   else
525   {
526     delete recordingManager;
527     recordingManager = NULL;
528   }
529 }
530
531 void MVPClient::processReScanRecording(unsigned char* data, int length)
532 {
533   ULLONG retval = 0;
534
535   if (!rp)
536   {
537     log->log("Client", Log::DEBUG, "Rescan recording called when no recording being played!");
538   }
539   else
540   {
541     rp->scan();
542     retval = rp->getTotalLength();
543   }
544
545   unsigned char sendBuffer[12];
546   *(unsigned long*)&sendBuffer[0] = htonl(8);
547   *(ULLONG*)&sendBuffer[4] = htonll(retval);
548
549   tcp.sendPacket(sendBuffer, 12);
550   log->log("Client", Log::DEBUG, "Rescan recording, wrote new length to client");
551 }
552
553 void MVPClient::processGetChannelSchedule(unsigned char* data, int length)
554 {
555   ULONG channelNumber = ntohl(*(ULLONG*)data);
556   log->log("Client", Log::DEBUG, "get schedule called for channel %lu", channelNumber);
557
558   cChannel* channel = channelFromNumber(channelNumber);
559   if (!channel)
560   {
561     unsigned char sendBuffer[4];
562     *(unsigned long*)&sendBuffer[0] = htonl(0);
563     tcp.sendPacket(sendBuffer, 4);
564     log->log("Client", Log::DEBUG, "written null");
565     return;
566   }
567
568 #if VDRVERSNUM < 10300
569   cMutexLock MutexLock;
570   const cSchedules *Schedules = cSIProcessor::Schedules(MutexLock);
571 #else
572   cSchedulesLock MutexLock;
573   const cSchedules *Schedules = cSchedules::Schedules(MutexLock);
574 #endif
575   if (!Schedules)
576   {
577     unsigned char sendBuffer[8];
578     *(unsigned long*)&sendBuffer[0] = htonl(4);
579     *(unsigned long*)&sendBuffer[4] = htonl(0);
580     tcp.sendPacket(sendBuffer, 8);
581     log->log("Client", Log::DEBUG, "written 0");
582     return;
583   }
584
585   unsigned char sendBuffer[8];
586   *(unsigned long*)&sendBuffer[0] = htonl(4);
587   *(unsigned long*)&sendBuffer[4] = htonl(1);
588   tcp.sendPacket(sendBuffer, 8);
589   log->log("Client", Log::DEBUG, "written 1");
590
591
592 }
593
594 void MVPClient::testChannelSchedule(unsigned char* data, int length)
595 {
596   FILE* f = fopen("/tmp/s.txt", "w");
597
598 #if VDRVERSNUM < 10300
599   cMutexLock MutexLock;
600   const cSchedules *Schedules = cSIProcessor::Schedules(MutexLock);
601 #else
602   cSchedulesLock MutexLock;
603   const cSchedules *Schedules = cSchedules::Schedules(MutexLock);
604 #endif
605   if (!Schedules)
606   {
607     fprintf(f, "Schedules = NULL\n");
608     fclose(f);
609     return;
610   }
611
612   fprintf(f, "Schedules dump:\n");
613   Schedules->Dump(f);
614
615
616   const cSchedule *Schedule;
617   int scheduleNumber = 0;
618
619   tChannelID tchid;
620   cChannel *thisChannel;
621
622 #if VDRVERSNUM < 10300
623   const cEventInfo *event;
624   int eventNumber = 0;
625 #else
626   const cEvent *event;
627 #endif
628
629 //    Schedule = Schedules->GetSchedule(channel->GetChannelID());
630 //    Schedule = Schedules->GetSchedule();
631   Schedule = Schedules->First();
632   if (!Schedule)
633   {
634     fprintf(f, "First Schedule = NULL\n");
635     fclose(f);
636     return;
637   }
638
639   while (Schedule)
640   {
641     fprintf(f, "Schedule #%i\n", scheduleNumber);
642     fprintf(f, "-------------\n\n");
643
644 #if VDRVERSNUM < 10300
645     tchid = Schedule->GetChannelID();
646 #else
647     tchid = Schedule->ChannelID();
648 #endif
649 #if VDRVERSNUM < 10300
650     fprintf(f, "ChannelID.ToString() = %s\n", tchid.ToString());
651     fprintf(f, "NumEvents() = %i\n", Schedule->NumEvents());
652 #else
653 //  put the count at the end.
654 #endif
655     thisChannel = Channels.GetByChannelID(tchid, true);
656     if (thisChannel)
657     {
658       fprintf(f, "Channel Number: %p %i\n", thisChannel, thisChannel->Number());
659     }
660     else
661     {
662       fprintf(f, "thisChannel = NULL for tchid\n");
663     }
664
665 #if VDRVERSNUM < 10300
666     for (eventNumber = 0; eventNumber < Schedule->NumEvents(); eventNumber++)
667     {
668       event = Schedule->GetEventNumber(eventNumber);
669       fprintf(f, "Event %i tableid = %i timestring = %s endtimestring = %s\n", eventNumber, event->GetTableID(), event->GetTimeString(), event->GetEndTimeString());
670       fprintf(f, "Event %i date = %s isfollowing = %i ispresent = %i\n", eventNumber, event->GetDate(), event->IsFollowing(), event->IsPresent());
671       fprintf(f, "Event %i extendeddescription = %s\n", eventNumber, event->GetExtendedDescription());
672       fprintf(f, "Event %i subtitle = %s title = %s\n", eventNumber, event->GetSubtitle(), event->GetTitle());
673       fprintf(f, "Event %i eventid = %u duration = %li time = %lu channelnumber = %i\n", eventNumber, event->GetEventID(), event->GetDuration(), event->GetTime(), event->GetChannelNumber());
674       fprintf(f, "Event %u dump:\n", eventNumber);
675       event->Dump(f);
676       fprintf(f, "\n\n");
677     }
678 #else
679 //  This whole section needs rewriting to walk the list.
680     event = Schedule->Events()->First();
681     while (event) {
682       event = Schedule->Events()->Next(event);
683     }
684 #endif
685
686
687     fprintf(f, "\nDump from object:\n");
688     Schedule->Dump(f);
689     fprintf(f, "\nEND\n");
690
691
692
693
694 /*
695   const cEventInfo *GetPresentEvent(void) const;
696   const cEventInfo *GetFollowingEvent(void) const;
697   const cEventInfo *GetEvent(unsigned short uEventID, time_t tTime = 0) const;
698   const cEventInfo *GetEventAround(time_t tTime) const;
699   const cEventInfo *GetEventNumber(int n) const { return Events.Get(n); }
700
701
702   const unsigned char GetTableID(void) const;
703   const char *GetTimeString(void) const;
704   const char *GetEndTimeString(void) const;
705   const char *GetDate(void) const;
706   bool IsFollowing(void) const;
707   bool IsPresent(void) const;
708   const char *GetExtendedDescription(void) const;
709   const char *GetSubtitle(void) const;
710   const char *GetTitle(void) const;
711   unsigned short GetEventID(void) const;
712   long GetDuration(void) const;
713   time_t GetTime(void) const;
714   tChannelID GetChannelID(void) const;
715   int GetChannelNumber(void) const { return nChannelNumber; }
716   void SetChannelNumber(int ChannelNumber) const { ((cEventInfo *)this)->nChannelNumber = ChannelNumber; } // doesn't modify the EIT data, so it's ok to make it 'const'
717   void Dump(FILE *f, const char *Prefix = "") const;
718
719 */
720
721
722
723
724
725     fprintf(f, "End of current Schedule\n\n\n");
726
727     Schedule = (const cSchedule *)Schedules->Next(Schedule);
728     scheduleNumber++;
729   }
730
731   fclose(f);
732 }
733
734 void MVPClient::processConfigSave(unsigned char* buffer, int length)
735 {
736   char* section = (char*)buffer;
737   char* key = NULL;
738   char* value = NULL;
739
740   for (int k = 0; k < length; k++)
741   {
742     if (buffer[k] == '\0')
743     {
744       if (!key)
745       {
746         key = (char*)&buffer[k+1];
747       }
748       else
749       {
750         value = (char*)&buffer[k+1];
751         break;
752       }
753     }
754   }
755
756   // if the last string (value) doesnt have null terminator, give up
757   if (buffer[length - 1] != '\0') return;
758
759   log->log("Client", Log::DEBUG, "Config save: %s %s %s", section, key, value);
760   if (config.setValueString(section, key, value))
761   {
762     sendULONG(1);
763   }
764   else
765   {
766     sendULONG(0);
767   }
768 }
769
770 void MVPClient::processConfigLoad(unsigned char* buffer, int length)
771 {
772   char* section = (char*)buffer;
773   char* key = NULL;
774
775   for (int k = 0; k < length; k++)
776   {
777     if (buffer[k] == '\0')
778     {
779       key = (char*)&buffer[k+1];
780       break;
781     }
782   }
783
784   char* value = config.getValueString(section, key);
785
786   if (value)
787   {
788     unsigned char sendBuffer[4 + strlen(value) + 1];
789     *(unsigned long*)&sendBuffer[0] = htonl(strlen(value) + 1);
790     strcpy((char*)&sendBuffer[4], value);
791     tcp.sendPacket(sendBuffer, 4 + strlen(value) + 1);
792
793     log->log("Client", Log::DEBUG, "Written config load packet");
794     delete[] value;
795   }
796   else
797   {
798     unsigned char sendBuffer[8];
799     *(unsigned long*)&sendBuffer[0] = htonl(4);
800     *(unsigned long*)&sendBuffer[4] = htonl(0);
801     tcp.sendPacket(sendBuffer, 8);
802
803     log->log("Client", Log::DEBUG, "Written config load failed packet");
804   }
805 }
806
807 void MVPClient::cleanConfig()
808 {
809   log->log("Client", Log::DEBUG, "Clean config");
810
811   cRecordings Recordings;
812   Recordings.Load();
813
814   int numReturns;
815   int length;
816   char* resumes = config.getSectionKeyNames("ResumeData", numReturns, length);
817   char* position = resumes;
818   for(int k = 0; k < numReturns; k++)
819   {
820     log->log("Client", Log::DEBUG, "EXAMINING: %i %i %p %s", k, numReturns, position, position);
821
822     cRecording* recording = Recordings.GetByName(position);
823     if (!recording)
824     {
825       // doesn't exist anymore
826       log->log("Client", Log::DEBUG, "Found a recording that doesn't exist anymore");
827       config.deleteValue("ResumeData", position);
828     }
829     else
830     {
831       log->log("Client", Log::DEBUG, "This recording still exists");
832     }
833
834     position += strlen(position) + 1;
835   }
836
837   delete[] resumes;
838 }
839
840