26 struct sockaddr* ai_addr;
33 #include <arpa/inet.h>
34 #include <netinet/in.h>
36 #include <semaphore.h>
41 #include <sys/socket.h>
43 #include <sys/prctl.h>
55 #include "config_auto.h"
58 #ifndef GRAPHICS_DISABLED
78 proc.append(executable);
81 std::cout <<
"Starting " << proc << std::endl;
82 STARTUPINFO start_info;
83 PROCESS_INFORMATION proc_info;
84 GetStartupInfo(&start_info);
86 CREATE_NO_WINDOW | DETACHED_PROCESS,
NULL,
NULL,
87 &start_info, &proc_info))
96 prctl(PR_SET_PDEATHSIG, 2, 0, 0, 0);
98 char* mutable_args = strdup(args);
100 for (
int i = 0; mutable_args[i]; ++i) {
101 if (mutable_args[i] ==
' ') {
105 char** argv =
new char*[argc + 2];
106 argv[0] = strdup(executable);
107 argv[1] = mutable_args;
109 bool inquote =
false;
110 for (
int i = 0; mutable_args[i]; ++i) {
111 if (!inquote && mutable_args[i] ==
' ') {
112 mutable_args[i] =
'\0';
113 argv[argc++] = mutable_args + i + 1;
114 }
else if (mutable_args[i] ==
'"') {
116 mutable_args[i] =
' ';
120 execvp(executable, argv);
127 semaphore_ = CreateSemaphore(0, 0, 10, 0);
129 sem_init(&semaphore_, 0, 0);
135 ReleaseSemaphore(semaphore_, 1,
NULL);
137 sem_post(&semaphore_);
143 WaitForSingleObject(semaphore_, INFINITE);
145 sem_wait(&semaphore_);
151 mutex_ = CreateMutex(0,
FALSE, 0);
153 pthread_mutex_init(&mutex_,
NULL);
159 WaitForSingleObject(mutex_, INFINITE);
161 pthread_mutex_lock(&mutex_);
167 ReleaseMutex(mutex_);
169 pthread_mutex_unlock(&mutex_);
177 LPTHREAD_START_ROUTINE
f = (LPTHREAD_START_ROUTINE) func;
179 HANDLE newthread = CreateThread(
188 pthread_create(&helper,
NULL, func, arg);
195 msg_buffer_out_.append(msg);
202 while (msg_buffer_out_.size() > 0) {
203 int i = send(stream_, msg_buffer_out_.c_str(), msg_buffer_out_.length(), 0);
204 msg_buffer_out_.erase(0, i);
214 if (has_content) { result = strtok (
NULL,
"\n"); }
216 if (buffer_ptr_ !=
NULL) { result = strtok_r(
NULL,
"\n", &buffer_ptr_); }
220 if (result !=
NULL) {
return result;
235 FD_SET(stream_, &readfds);
237 int i = select(stream_+1, &readfds,
NULL,
NULL, &tv);
240 if (i == 0) {
return NULL; }
246 if (i <= 0) {
return NULL; }
247 msg_buffer_in_[i] =
'\0';
250 return strtok(msg_buffer_in_,
"\n");
253 return strtok_r(msg_buffer_in_,
"\n", &buffer_ptr_);
261 closesocket(stream_);
269 static const char* ScrollViewProg() {
271 const char* prog =
"java -Xms512m -Xmx1024m";
273 const char* prog =
"sh";
280 static std::string ScrollViewCommand(std::string scrollview_path) {
287 const char* cmd_template =
"-Djava.library.path=%s -cp %s/ScrollView.jar;"
288 "%s/piccolo-1.2.jar;%s/piccolox-1.2.jar"
289 " com.google.scrollview.ScrollView";
291 const char* cmd_template =
"-c \"trap 'kill %1' 0 1 2 ; java "
292 "-Xms1024m -Xmx2048m -Djava.library.path=%s -cp %s/ScrollView.jar:"
293 "%s/piccolo-1.2.jar:%s/piccolox-1.2.jar"
294 " com.google.scrollview.ScrollView"
295 " >/dev/null 2>&1 & wait\"";
297 int cmdlen = strlen(cmd_template) + 4*strlen(scrollview_path.c_str()) + 1;
298 char* cmd =
new char[cmdlen];
299 const char* sv_path = scrollview_path.c_str();
300 snprintf(cmd, cmdlen, cmd_template, sv_path, sv_path, sv_path, sv_path);
301 std::string command(cmd);
308 static void FreeAddrInfo(
struct addrinfo* addr_info) {
309 #if defined(__linux__)
310 freeaddrinfo(addr_info);
312 delete addr_info->ai_addr;
319 #if !defined(__linux__)
320 static int GetAddrInfoNonLinux(
const char* hostname,
int port,
321 struct addrinfo** addr_info) {
323 struct sockaddr_in* address;
324 *addr_info =
new struct addrinfo;
325 memset(*addr_info, 0,
sizeof(
struct addrinfo));
326 address =
new struct sockaddr_in;
327 memset(address, 0,
sizeof(
struct sockaddr_in));
329 (*addr_info)->ai_addr = (
struct sockaddr*) address;
330 (*addr_info)->ai_addrlen =
sizeof(
struct sockaddr);
331 (*addr_info)->ai_family = AF_INET;
332 (*addr_info)->ai_socktype = SOCK_STREAM;
334 struct hostent *name;
337 WSAStartup(MAKEWORD(1, 1), &wsaData);
338 name = gethostbyname(hostname);
340 name = gethostbyname(hostname);
344 FreeAddrInfo(*addr_info);
350 address->sin_family = name->h_addrtype;
351 memcpy((
char *) &address->sin_addr.s_addr,
352 name->h_addr_list[0], name->h_length);
353 address->sin_port = htons(port);
361 static int GetAddrInfo(
const char* hostname,
int port,
362 struct addrinfo** address) {
363 #if defined(__linux__)
365 snprintf(port_str, 40,
"%d", port);
366 return getaddrinfo(hostname, port_str,
NULL, address);
368 return GetAddrInfoNonLinux(hostname, port, address);
377 msg_buffer_in_[0] =
'\0';
382 struct addrinfo *addr_info =
NULL;
384 if (GetAddrInfo(hostname, port, &addr_info) != 0) {
385 std::cerr <<
"Error resolving name for ScrollView host "
386 << std::string(hostname) <<
":" << port << std::endl;
389 stream_ = socket(addr_info->ai_family, addr_info->ai_socktype,
390 addr_info->ai_protocol);
393 if (connect(stream_, addr_info->ai_addr, addr_info->ai_addrlen) < 0) {
394 const char* scrollview_path = getenv(
"SCROLLVIEW_PATH");
395 if (scrollview_path ==
NULL) {
396 #ifdef SCROLLVIEW_PATH
398 #define _XSTR(a) _STR(a)
399 scrollview_path = _XSTR(SCROLLVIEW_PATH);
403 scrollview_path =
".";
406 const char *prog = ScrollViewProg();
407 std::string command = ScrollViewCommand(scrollview_path);
412 while (connect(stream_, (
struct sockaddr *) addr_info->ai_addr,
413 addr_info->ai_addrlen) < 0) {
414 std::cout <<
"ScrollView: Waiting for server...\n";
422 FreeAddrInfo(addr_info);
426 delete[] msg_buffer_in_;
430 #endif // GRAPHICS_DISABLED