]> git.vomp.tv Git - vompclient-marten.git/blob - vconnect.cc
Add audio types to protocol, add aac decoding, extract language codes from TS and...
[vompclient-marten.git] / vconnect.cc
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., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
19 */
20
21 #include "vconnect.h"
22
23 #include "video.h"
24 #include "colour.h"
25 #include "command.h"
26 #include "i18n.h"
27 #include "boxstack.h"
28 #include "message.h"
29 #include "log.h"
30 #include "wol.h"
31 #include "vserverselect.h"
32
33 VConnect::VConnect(char* tServer)
34 {
35   boxstack = BoxStack::getInstance();
36   vdr = VDR::getInstance();
37   logger = Log::getInstance();
38
39   setSize(400, 200);
40   createBuffer();
41   if (Video::getInstance()->getFormat() == Video::PAL)
42   {
43     setPosition(170, 200);
44   }
45   else
46   {
47     setPosition(160, 150);
48   }
49
50   exitable = 0;
51   irun = 0;
52   server = tServer;
53 }
54
55 VConnect::~VConnect()
56 {
57   irun = 0;
58   vdr->cancelFindingServer();
59   threadStop();
60 }
61
62 void VConnect::draw()
63 {
64   VInfo::draw();
65   logger->log("VConnect", Log::DEBUG, "Draw done");
66 }
67
68 int VConnect::handleCommand(int command)
69 {
70   return 1;
71 }
72
73 void VConnect::run()
74 {
75   threadStart();
76 }
77
78 void VConnect::threadMethod()
79 {
80   ULONG delay = 0;
81   int success;
82   irun = 1;
83
84   do
85   {
86     if (server) // Server is specified, fake a servers array
87     {
88       VDRServer vdrserver;
89       vdrserver.ip = new char[strlen(server)+1];
90       strcpy(vdrserver.ip, server);
91       vdrserver.name = new char[1];
92       vdrserver.name[0] = '\0';
93       servers.push_back(vdrserver);
94     }
95     else
96     {
97       setOneLiner(tr("Locating server"));
98       draw();
99       boxstack->update(this);
100
101       vdr->findServers(servers);
102       if (!irun)
103       {
104         for(UINT k = 0; k < servers.size(); k++)
105         {
106           delete[] servers[k].ip;
107           delete[] servers[k].name;
108         }
109         servers.clear();
110         return;
111       }
112     }
113
114     if (servers.size() == 1)
115     {
116       selectedServer = 0;
117     }
118     else
119     {
120       selectedServer = -1;
121       VServerSelect* vs = new VServerSelect(servers, this);
122       vs->draw();
123       boxstack->add(vs);
124       boxstack->update(vs);
125
126       threadLock();
127       threadWaitForSignal();
128       threadUnlock();
129     }
130
131     if (!irun)
132     {
133       for(UINT k = 0; k < servers.size(); k++)
134       {
135         delete[] servers[k].ip;
136         delete[] servers[k].name;
137       }
138       servers.clear();
139       return;
140     }
141
142     logger->log("VConnect", Log::NOTICE, "Connecting to server at %s", servers[selectedServer].ip);
143     Wol::getInstance()->setWakeUpIP(servers[selectedServer].ip);
144     vdr->setServerIP(servers[selectedServer].ip);
145
146
147     // Clear the serverIPs vector
148     for(UINT k = 0; k < servers.size(); k++)
149     {
150       delete[] servers[k].ip;
151       delete[] servers[k].name;
152     }
153     servers.clear();
154
155
156     setOneLiner(tr("Connecting to VDR"));
157     draw();
158     boxstack->update(this);
159
160     success = vdr->connect();
161     if (success)
162     {
163       logger->log("VConnect", Log::DEBUG, "Connected ok, doing login");
164       unsigned int version_server,version_client;
165       success = vdr->doLogin(&version_server,&version_client);
166
167       if (!success)
168       {
169         vdr->disconnect();
170         if (version_server!=version_client) {
171                 char buffer[1024];
172                 sprintf(buffer,"Protocoll mismatch s: %x c: %x",version_server,version_client);
173                 setOneLiner(buffer);
174         } else {
175                 setOneLiner(tr("Login failed"));
176         }
177         delay = 3000;
178       }
179     }
180     else
181     {
182       setOneLiner(tr("Connection failed"));
183       delay = 3000;
184     }
185
186     draw();
187     boxstack->update(this);
188     MILLISLEEP(delay);
189
190   } while(!success);
191
192
193   Message* m = new Message(); // Must be done after this thread ends
194   m->from = this;
195   m->to = Command::getInstance();
196   m->message = Message::VDR_CONNECTED;
197   Command::getInstance()->postMessage(m);
198 }
199
200 void VConnect::processMessage(Message* m)
201 {
202   if (m->message == Message::SERVER_SELECTED)
203   {
204     selectedServer = m->parameter;
205     threadSignal();
206   }
207 }