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