]> git.vomp.tv Git - vompserver.git/blob - mvpserver.c
Stop logging
[vompserver.git] / mvpserver.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 "mvpserver.h"
22
23 MVPServer::MVPServer()
24 {
25 }
26
27 MVPServer::~MVPServer()
28 {
29   if (threadIsActive()) stop();
30 }
31
32 int MVPServer::stop()
33 {
34   if (!threadIsActive()) return 0;
35
36   threadCancel();
37   log.log("MVPServer", Log::INFO, "Stopped MVPServer thread");
38
39   udpr.stop();
40   log.shutdown();
41
42   close(listeningSocket);
43
44   return 1;
45 }
46
47 int MVPServer::run()
48 {
49   if (threadIsActive()) return 1;
50
51   log.init(Log::DEBUG, "/tmp/vompserver.log", 0);
52   
53   if (!udpr.run())
54   {
55     log.log("MVPServer", Log::CRIT, "Could not start UDP replier");
56     log.shutdown();
57     return 0;
58   }
59
60   // start thread here
61   if (!threadStart())
62   {
63     log.log("MVPServer", Log::CRIT, "Could not start MVPServer thread");
64     udpr.stop();
65     log.shutdown();
66     return 0;
67   }
68
69   log.log("MVPServer", Log::DEBUG, "MVPServer run success");
70   return 1;
71 }
72
73 void MVPServer::threadMethod()
74 {
75   // I want to die as soon as I am cancelled because I'll be in accept()
76   pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
77   pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
78
79   struct sockaddr_in address;
80   address.sin_family = AF_INET;
81   address.sin_port = htons(3024);
82   address.sin_addr.s_addr = INADDR_ANY;
83   socklen_t length = sizeof(address);
84
85   listeningSocket = socket(AF_INET, SOCK_STREAM, 0);
86   if (listeningSocket < 0)
87   {
88     log.log("MVPServer", Log::CRIT, "Could not get TCP socket in vompserver");
89     return;
90   }
91
92   int value=1;
93   setsockopt(listeningSocket,SOL_SOCKET,SO_REUSEADDR,&value,sizeof(value));
94
95   if (bind(listeningSocket,(struct sockaddr *)&address,sizeof(address)) < 0)
96   {
97     log.log("MVPServer", Log::CRIT, "Could not bind to socket in vompserver");
98     close(listeningSocket);
99     return;
100   }
101
102   listen(listeningSocket, 5);
103
104   int clientSocket;
105
106   while(1)
107   {
108     clientSocket = accept(listeningSocket,(struct sockaddr *)&address, &length);
109     MVPClient* m = new MVPClient(clientSocket);
110     m->run();
111   }
112 }
113
114
115 ULLONG ntohll(ULLONG a)
116 {
117   return htonll(a);
118 }
119
120 ULLONG htonll(ULLONG a)
121 {
122   #if BYTE_ORDER == BIG_ENDIAN
123     return a;
124   #else
125     ULLONG b = 0;
126
127     b = ((a << 56) & 0xFF00000000000000ULL)
128       | ((a << 40) & 0x00FF000000000000ULL)
129       | ((a << 24) & 0x0000FF0000000000ULL)
130       | ((a <<  8) & 0x000000FF00000000ULL)
131       | ((a >>  8) & 0x00000000FF000000ULL)
132       | ((a >> 24) & 0x0000000000FF0000ULL)
133       | ((a >> 40) & 0x000000000000FF00ULL)
134       | ((a >> 56) & 0x00000000000000FFULL) ;
135
136     return b;
137   #endif
138 }