src/amuled.cpp

   1 //
   2 // This file is part of the aMule Project.
   3 //
   4 // Copyright (c) 2003-2008 aMule Team ( admin@amule.org / http://www.amule.org )
   5 //
   6 // Any parts of this program derived from the xMule, lMule or eMule project,
   7 // or contributed by third-party developers are copyrighted by their
   8 // respective authors.
   9 //
  10 // This program is free software; you can redistribute it and/or modify
  11 // it under the terms of the GNU General Public License as published by
  12 // the Free Software Foundation; either version 2 of the License, or
  13 // (at your option) any later version.
  14 //
  15 // This program is distributed in the hope that it will be useful,
  16 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  17 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  18 // GNU General Public License for more details.
  19 //
  20 // You should have received a copy of the GNU General Public License
  21 // along with this program; if not, write to the Free Software
  22 // Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301, USA
  23 //
  24
  25
  26 #include "amule.h"                      // Interface declarations.
  27
  28 #include <include/common/EventIDs.h>
  29
  30 #ifdef HAVE_CONFIG_H
  31         #include "config.h"             // Needed for HAVE_SYS_RESOURCE_H, HAVE_STRERROR_R and STRERROR_R_CHAR_P, etc
  32 #endif
  33
  34 // Include the necessary headers for select(2), properly guarded
  35 #if defined HAVE_SYS_SELECT_H && !defined __IRIX__
  36 #       include <sys/select.h>
  37 #else
  38 #       ifdef HAVE_SYS_TIME_H
  39 #               include <sys/time.h>
  40 #       endif
  41 #       ifdef HAVE_SYS_TYPES_H
  42 #               include <sys/types.h>
  43 #       endif
  44 #       ifdef HAVE_UNISTD_H
  45 #               include <unistd.h>
  46 #       endif
  47 #endif
  48
  49 // Prefer the POSIX interface to strerror_r()
  50 #ifndef _XOPEN_SOURCE
  51 #define _XOPEN_SOURCE   600
  52 #endif
  53 #include <string.h>                     // Do_not_auto_remove
  54
  55 #include <wx/utils.h>
  56
  57 #include "Preferences.h"                // Needed for CPreferences
  58 #include "PartFile.h"                   // Needed for CPartFile
  59 #include "Logger.h"
  60 #include <common/Format.h>
  61 #include "InternalEvents.h"             // Needed for wxEVT_*
  62 #include "ThreadTasks.h"
  63 #include "GuiEvents.h"                  // Needed for EVT_MULE_NOTIFY
  64 #include "Timer.h"                      // Needed for EVT_MULE_TIMER
  65
  66 #include "ClientUDPSocket.h"            // Do_not_auto_remove (forward declaration not enough)
  67 #include "ListenSocket.h"               // Do_not_auto_remove (forward declaration not enough)
  68
  69
  70 #include <errno.h>
  71 #ifdef HAVE_SYS_RESOURCE_H
  72 #include <sys/resource.h> // Do_not_auto_remove
  73 #endif
  74
  75 #ifndef __WXMSW__
  76         #ifdef  HAVE_SYS_WAIT_H
  77                 #include <sys/wait.h> // Do_not_auto_remove
  78         #endif
  79
  80         #include <wx/unix/execute.h>
  81 #endif
  82
  83 #ifndef HAVE_STRERROR_R
  84
  85 // Replacement strerror_r() function for systems that don't have any.
  86 // Note that this replacement function is NOT thread-safe!
  87 static int rpl_strerror_r(int errnum, char *buf, size_t buflen)
  88 {
  89         char *tmp = strerror(errnum);
  90         if (tmp == NULL) {
  91                 errno = EINVAL;
  92                 return -1;
  93         } else {
  94                 strncpy(buf, tmp, buflen - 1);
  95                 buf[buflen - 1] = '\0';
  96                 if (strlen(tmp) >= buflen) {
  97                         errno = ERANGE;
  98                         return -1;
  99                 }
 100         }
 101         return 0;
 102 }
 103
 104 #       define strerror_r(errnum, buf, buflen)  rpl_strerror_r(errnum, buf, buflen)
 105 #else
 106 #       ifdef STRERROR_R_CHAR_P
 107
 108 // Replacement strerror_r() function for systems that return a char*.
 109 static int rpl_strerror_r(int errnum, char *buf, size_t buflen)
 110 {
 111         char *tmp = strerror_r(errnum, buf, buflen);
 112         if (tmp == NULL) {
 113                 errno = EINVAL;
 114                 return -1;
 115         } else if (tmp != buf) {
 116                 strncpy(buf, tmp, buflen - 1);
 117                 buf[buflen - 1] = '\0';
 118                 if (strlen(tmp) >= buflen) {
 119                         errno = ERANGE;
 120                         return -1;
 121                 }
 122         }
 123         return 0;
 124 }
 125
 126 #               define strerror_r(errnum, buf, buflen)  rpl_strerror_r(errnum, buf, buflen)
 127 #       endif
 128 #endif
 129
 130 BEGIN_EVENT_TABLE(CamuleDaemonApp, wxAppConsole)
 131         //
 132         // Socket handlers
 133         //
 134
 135         // Listen Socket
 136         EVT_SOCKET(ID_LISTENSOCKET_EVENT, CamuleDaemonApp::ListenSocketHandler)
 137
 138         // UDP Socket (servers)
 139         EVT_SOCKET(ID_SERVERUDPSOCKET_EVENT, CamuleDaemonApp::UDPSocketHandler)
 140         // UDP Socket (clients)
 141         EVT_SOCKET(ID_CLIENTUDPSOCKET_EVENT, CamuleDaemonApp::UDPSocketHandler)
 142
 143         // Socket timer (TCP)
 144         EVT_MULE_TIMER(ID_SERVER_RETRY_TIMER_EVENT, CamuleDaemonApp::OnTCPTimer)
 145
 146         // Core timer
 147         EVT_MULE_TIMER(ID_CORE_TIMER_EVENT, CamuleDaemonApp::OnCoreTimer)
 148
 149         EVT_MULE_NOTIFY(CamuleDaemonApp::OnNotifyEvent)
 150
 151         // Async dns handling
 152         EVT_MULE_INTERNAL(wxEVT_CORE_UDP_DNS_DONE, -1, CamuleDaemonApp::OnUDPDnsDone)
 153
 154         EVT_MULE_INTERNAL(wxEVT_CORE_SOURCE_DNS_DONE, -1, CamuleDaemonApp::OnSourceDnsDone)
 155
 156         EVT_MULE_INTERNAL(wxEVT_CORE_SERVER_DNS_DONE, -1, CamuleDaemonApp::OnServerDnsDone)
 157
 158         // Hash ended notifier
 159         EVT_MULE_HASHING(CamuleDaemonApp::OnFinishedHashing)
 160         EVT_MULE_AICH_HASHING(CamuleDaemonApp::OnFinishedAICHHashing)
 161
 162         // File completion ended notifier
 163         EVT_MULE_FILE_COMPLETED(CamuleDaemonApp::OnFinishedCompletion)
 164
 165         // HTTPDownload finished
 166         EVT_MULE_INTERNAL(wxEVT_CORE_FINISHED_HTTP_DOWNLOAD, -1, CamuleDaemonApp::OnFinishedHTTPDownload)
 167
 168         // Disk space preallocation finished
 169         EVT_MULE_ALLOC_FINISHED(CamuleDaemonApp::OnFinishedAllocation)
 170 END_EVENT_TABLE()
 171
 172 IMPLEMENT_APP(CamuleDaemonApp)
 173
 174 #ifdef AMULED28
 175 /*
 176  * Socket handling in wxBase
 177  *
 178  */
 179 class CSocketSet {
 180                 int m_count;
 181                 int m_fds[FD_SETSIZE], m_fd_idx[FD_SETSIZE];
 182                 GSocket *m_gsocks[FD_SETSIZE];
 183
 184                 fd_set m_set;
 185         public:
 186                 CSocketSet();
 187                 void AddSocket(GSocket *);
 188                 void RemoveSocket(GSocket *);
 189                 void FillSet(int &max_fd);
 190
 191                 void Detected(void (GSocket::*func)());
 192
 193                 fd_set *Set() { return &m_set; }
 194 };
 195
 196 CSocketSet::CSocketSet()
 197 {
 198         m_count = 0;
 199         for(int i = 0; i < FD_SETSIZE; i++) {
 200                 m_fds[i] = 0;
 201                 m_fd_idx[i] = 0xffff;
 202                 m_gsocks[i] = 0;
 203         }
 204 }
 205
 206 void CSocketSet::AddSocket(GSocket *socket)
 207 {
 208         wxASSERT(socket);
 209
 210         int fd = socket->m_fd;
 211
 212         if ( fd == -1 ) {
 213                 return;
 214         }
 215
 216         wxASSERT( (fd > 2) && (fd < FD_SETSIZE) );
 217
 218         if ( m_gsocks[fd] ) {
 219                 return;
 220         }
 221         m_fds[m_count] = fd;
 222         m_fd_idx[fd] = m_count;
 223         m_gsocks[fd] = socket;
 224         m_count++;
 225 }
 226
 227 void CSocketSet::RemoveSocket(GSocket *socket)
 228 {
 229         wxASSERT(socket);
 230
 231         int fd = socket->m_fd;
 232
 233         if ( fd == -1 ) {
 234                 return;
 235         }
 236
 237         wxASSERT( (fd > 2) && (fd < FD_SETSIZE) );
 238
 239         int i = m_fd_idx[fd];
 240         if ( i == 0xffff ) {
 241                 return;
 242         }
 243         wxASSERT(m_fds[i] == fd);
 244         m_fds[i] = m_fds[m_count-1];
 245         m_gsocks[fd] = 0;
 246         m_fds[m_count-1] = 0;
 247         m_fd_idx[fd] = 0xffff;
 248         m_fd_idx[m_fds[i]] = i;
 249         m_count--;
 250 }
 251
 252 void CSocketSet::FillSet(int &max_fd)
 253 {
 254         FD_ZERO(&m_set);
 255
 256         for(int i = 0; i < m_count; i++) {
 257             FD_SET(m_fds[i], &m_set);
 258             if ( m_fds[i] > max_fd ) {
 259                 max_fd = m_fds[i];
 260             }
 261         }
 262 }
 263
 264 void CSocketSet::Detected(void (GSocket::*func)())
 265 {
 266         for (int i = 0; i < m_count; i++) {
 267                 int fd = m_fds[i];
 268                 if ( FD_ISSET(fd, &m_set) ) {
 269                         GSocket *socket = m_gsocks[fd];
 270                         (*socket.*func)();
 271                 }
 272         }
 273 }
 274
 275 CAmuledGSocketFuncTable::CAmuledGSocketFuncTable() : m_lock(wxMUTEX_RECURSIVE)
 276 {
 277         m_in_set = new CSocketSet;
 278         m_out_set = new CSocketSet;
 279
 280         m_lock.Unlock();
 281 }
 282
 283 void CAmuledGSocketFuncTable::AddSocket(GSocket *socket, GSocketEvent event)
 284 {
 285         wxMutexLocker lock(m_lock);
 286
 287         if ( event == GSOCK_INPUT ) {
 288                 m_in_set->AddSocket(socket);
 289         } else {
 290                 m_out_set->AddSocket(socket);
 291         }
 292 }
 293
 294 void CAmuledGSocketFuncTable::RemoveSocket(GSocket *socket, GSocketEvent event)
 295 {
 296         wxMutexLocker lock(m_lock);
 297
 298         if ( event == GSOCK_INPUT ) {
 299                 m_in_set->RemoveSocket(socket);
 300         } else {
 301                 m_out_set->RemoveSocket(socket);
 302         }
 303 }
 304
 305 void CAmuledGSocketFuncTable::RunSelect()
 306 {
 307         wxMutexLocker lock(m_lock);
 308
 309         int max_fd = -1;
 310         m_in_set->FillSet(max_fd);
 311         m_out_set->FillSet(max_fd);
 312
 313         struct timeval tv;
 314         tv.tv_sec = 0;
 315         tv.tv_usec = 10000; // 10ms
 316
 317         int result = select(max_fd + 1, m_in_set->Set(), m_out_set->Set(), 0, &tv);
 318         if ( result > 0 ) {
 319                 m_in_set->Detected(&GSocket::Detected_Read);
 320                 m_out_set->Detected(&GSocket::Detected_Write);
 321         }
 322 }
 323
 324 GSocketGUIFunctionsTable *CDaemonAppTraits::GetSocketGUIFunctionsTable()
 325 {
 326         return m_table;
 327 }
 328
 329 bool CAmuledGSocketFuncTable::OnInit()
 330 {
 331         return true;
 332 }
 333
 334 void CAmuledGSocketFuncTable::OnExit()
 335 {
 336 }
 337
 338 bool CAmuledGSocketFuncTable::CanUseEventLoop()
 339 {
 340         /*
 341          * FIXME: (lfroen) Not sure whether it's right.
 342          * I will review it later.
 343          */
 344         return false;
 345 }
 346
 347 bool CAmuledGSocketFuncTable::Init_Socket(GSocket *)
 348 {
 349         return true;
 350 }
 351
 352 void CAmuledGSocketFuncTable::Destroy_Socket(GSocket *)
 353 {
 354 }
 355
 356 void CAmuledGSocketFuncTable::Install_Callback(GSocket *sock, GSocketEvent e)
 357 {
 358         AddSocket(sock, e);
 359 }
 360
 361 void CAmuledGSocketFuncTable::Uninstall_Callback(GSocket *sock, GSocketEvent e)
 362 {
 363         RemoveSocket(sock, e);
 364 }
 365
 366 void CAmuledGSocketFuncTable::Enable_Events(GSocket *socket)
 367 {
 368         Install_Callback(socket, GSOCK_INPUT);
 369         Install_Callback(socket, GSOCK_OUTPUT);
 370 }
 371
 372 void CAmuledGSocketFuncTable::Disable_Events(GSocket *socket)
 373 {
 374         Uninstall_Callback(socket, GSOCK_INPUT);
 375         Uninstall_Callback(socket, GSOCK_OUTPUT);
 376 }
 377
 378 #endif  // AMULED28
 379
 380 #ifndef __WXMSW__
 381
 382 #ifdef AMULED28
 383
 384 CDaemonAppTraits::CDaemonAppTraits(CAmuledGSocketFuncTable *table)
 385 :
 386 wxConsoleAppTraits(),
 387 m_oldSignalChildAction(),
 388 m_newSignalChildAction(),
 389 m_table(table),
 390 m_lock(wxMUTEX_RECURSIVE),
 391 m_sched_delete()
 392 {
 393         m_lock.Unlock();
 394 }
 395
 396
 397 void CDaemonAppTraits::ScheduleForDestroy(wxObject *object)
 398 {
 399         wxMutexLocker lock(m_lock);
 400
 401         //delete object;
 402         m_sched_delete.push_back(object);
 403 }
 404
 405 void CDaemonAppTraits::RemoveFromPendingDelete(wxObject *object)
 406 {
 407         wxMutexLocker lock(m_lock);
 408
 409         for(std::list<wxObject *>::iterator i = m_sched_delete.begin();
 410                 i != m_sched_delete.end(); i++) {
 411                         if ( *i == object ) {
 412                                 m_sched_delete.erase(i);
 413                                 return;
 414                         }
 415                 }
 416 }
 417
 418 void CDaemonAppTraits::DeletePending()
 419 {
 420         wxMutexLocker lock(m_lock);
 421
 422         while ( !m_sched_delete.empty() ) {
 423                 std::list<wxObject *>::iterator i = m_sched_delete.begin();
 424                 wxObject *object = *i;
 425                 delete object;
 426         }
 427         //m_sched_delete.erase(m_sched_delete.begin(), m_sched_delete.end());
 428 }
 429
 430 wxAppTraits *CamuleDaemonApp::CreateTraits()
 431 {
 432         return new CDaemonAppTraits(m_table);
 433 }
 434
 435 #else   // AMULED28
 436
 437 CDaemonAppTraits::CDaemonAppTraits()
 438 :
 439 wxConsoleAppTraits(),
 440 m_oldSignalChildAction(),
 441 m_newSignalChildAction()
 442 {
 443 }
 444
 445 wxAppTraits *CamuleDaemonApp::CreateTraits()
 446 {
 447         return new CDaemonAppTraits();
 448 }
 449
 450 #endif  // !AMULED28
 451
 452 #endif  // __WXMSW__
 453
 454 #if defined(__WXMAC__) && !wxCHECK_VERSION(2, 9, 0)
 455 #include <wx/stdpaths.h> // Do_not_auto_remove (guess)
 456 static wxStandardPathsCF gs_stdPaths;
 457 wxStandardPathsBase& CDaemonAppTraits::GetStandardPaths()
 458 {
 459         return gs_stdPaths;
 460 }
 461 #endif
 462
 463
 464 #ifdef AMULED28
 465
 466 CamuleDaemonApp::CamuleDaemonApp()
 467 :
 468 m_Exit(false),
 469 m_table(new CAmuledGSocketFuncTable())
 470 {
 471         wxPendingEventsLocker = new wxCriticalSection;
 472 }
 473
 474 #endif  // !AMULED28
 475
 476
 477 #ifndef __WXMSW__
 478
 479
 480 static EndProcessDataMap endProcDataMap;
 481
 482
 483 int CDaemonAppTraits::WaitForChild(wxExecuteData &execData)
 484 {
 485         int status = 0;
 486         pid_t result = 0;
 487         // Build the log message
 488         wxString msg;
 489         msg << wxT("WaitForChild() has been called for child process with pid `") <<
 490                 execData.pid <<
 491                 wxT("'. ");
 492
 493         if (execData.flags & wxEXEC_SYNC) {
 494                 result = AmuleWaitPid(execData.pid, &status, 0, &msg);
 495                 if (result == -1 || (!WIFEXITED(status) && !WIFSIGNALED(status))) {
 496                         msg << wxT(" Waiting for subprocess termination failed.");
 497                         AddDebugLogLineN(logGeneral, msg);
 498                 }
 499         } else {
 500                 /** wxEXEC_ASYNC */
 501                 // Give the process a chance to start or forked child to exit
 502                 // 1 second is enough time to fail on "path not found"
 503                 wxSleep(1);
 504                 result = AmuleWaitPid(execData.pid, &status, WNOHANG, &msg);
 505                 if (result == 0) {
 506                         // Add a WxEndProcessData entry to the map, so that we can
 507                         // support process termination
 508                         wxEndProcessData *endProcData = new wxEndProcessData();
 509                         endProcData->pid = execData.pid;
 510                         endProcData->process = execData.process;
 511                         endProcData->tag = 0;
 512                         endProcDataMap[execData.pid] = endProcData;
 513
 514                         status = execData.pid;
 515                 } else {
 516                         // if result != 0, then either waitpid() failed (result == -1)
 517                         // and there is nothing we can do, or the child has changed
 518                         // status, which means it is probably dead.
 519                         status = 0;
 520                 }
 521         }
 522
 523         // Log our passage here
 524         AddDebugLogLineN(logGeneral, msg);
 525
 526         return status;
 527 }
 528
 529
 530 void OnSignalChildHandler(int /*signal*/, siginfo_t *siginfo, void * /*ucontext*/)
 531 {
 532         // Build the log message
 533         wxString msg;
 534         msg << wxT("OnSignalChildHandler() has been called for child process with pid `") <<
 535                 siginfo->si_pid <<
 536                 wxT("'. ");
 537         // Make sure we leave no zombies by calling waitpid()
 538         int status = 0;
 539         pid_t result = AmuleWaitPid(siginfo->si_pid, &status, WNOHANG, &msg);
 540         if (result != 1 && result != 0 && (WIFEXITED(status) || WIFSIGNALED(status))) {
 541                 // Fetch the wxEndProcessData structure corresponding to this pid
 542                 EndProcessDataMap::iterator it = endProcDataMap.find(siginfo->si_pid);
 543                 if (it != endProcDataMap.end()) {
 544                         wxEndProcessData *endProcData = it->second;
 545                         // Remove this entry from the process map
 546                         endProcDataMap.erase(siginfo->si_pid);
 547                         // Save the exit code for the wxProcess object to read later
 548                         endProcData->exitcode = result != -1 && WIFEXITED(status) ?
 549                                 WEXITSTATUS(status) : -1;
 550                         // Make things work as in wxGUI
 551                         wxHandleProcessTermination(endProcData);
 552
 553                         // wxHandleProcessTermination() will "delete endProcData;"
 554                         // So we do not delete it again, ok? Do not uncomment this line.
 555                         //delete endProcData;
 556                 } else {
 557                         msg << wxT(" Error: the child process pid is not on the pid map.");
 558                 }
 559         }
 560
 561         // Log our passage here
 562         AddDebugLogLineN(logGeneral, msg);
 563 }
 564
 565
 566 pid_t AmuleWaitPid(pid_t pid, int *status, int options, wxString *msg)
 567 {
 568         // strerror_r() buffer
 569         const int ERROR_BUFFER_LEN = 256;
 570         char errorBuffer[ERROR_BUFFER_LEN];
 571
 572         *status = 0;
 573         pid_t result = waitpid(pid, status, options);
 574         if (result == -1) {
 575                 strerror_r(errno, errorBuffer, ERROR_BUFFER_LEN);
 576                 *msg << wxT("Error: waitpid() call failed: ") <<
 577                         char2unicode(errorBuffer) <<
 578                         wxT(".");
 579         } else if (result == 0) {
 580                 if (options & WNOHANG)  {
 581                         *msg << wxT("The child is alive.");
 582                 } else {
 583                         *msg << wxT("Error: waitpid() call returned 0 but "
 584                                 "WNOHANG was not specified in options.");
 585                 }
 586         } else {
 587                 if (WIFEXITED(*status)) {
 588                         *msg << wxT("Child has terminated with status code `") <<
 589                                 WEXITSTATUS(*status) <<
 590                                 wxT("'.");
 591                 } else if (WIFSIGNALED(*status)) {
 592                         *msg << wxT("Child was killed by signal `") <<
 593                                 WTERMSIG(*status) <<
 594                                 wxT("'.");
 595                         if (WCOREDUMP(*status)) {
 596                                 *msg << wxT(" A core file has been dumped.");
 597                         }
 598                 } else if (WIFSTOPPED(*status)) {
 599                         *msg << wxT("Child has been stopped by signal `") <<
 600                                 WSTOPSIG(*status) <<
 601                                 wxT("'.");
 602 #ifdef WIFCONTINUED /* Only found in recent kernels. */
 603                 } else if (WIFCONTINUED(*status)) {
 604                         *msg << wxT("Child has received `SIGCONT' and has continued execution.");
 605 #endif
 606                 } else {
 607                         *msg << wxT("The program was not able to determine why the child has signaled.");
 608                 }
 609         }
 610
 611         return result;
 612 }
 613
 614
 615 #endif // __WXMSW__
 616
 617
 618 int CamuleDaemonApp::OnRun()
 619 {
 620         if (!thePrefs::AcceptExternalConnections()) {
 621                 AddLogLineCS(_("ERROR: aMule daemon cannot be used when external connections are disabled. To enable External Connections, use either a normal aMule, start amuled with the option --ec-config or set the key \"AcceptExternalConnections\" to 1 in the file ~/.aMule/amule.conf"));
 622                 return 0;
 623         } else if (thePrefs::ECPassword().IsEmpty()) {
 624                 AddLogLineCS(_("ERROR: A valid password is required to use external connections, and aMule daemon cannot be used without external connections. To run aMule deamon, you must set the \"ECPassword\" field in the file ~/.aMule/amule.conf with an appropriate value. Execute amuled with the flag --ec-config to set the password. More information can be found at http://wiki.amule.org"));
 625                 return 0;
 626         }
 627
 628 #ifndef __WXMSW__
 629         // strerror_r() buffer
 630         const int ERROR_BUFFER_LEN = 256;
 631         char errorBuffer[ERROR_BUFFER_LEN];
 632
 633         // Process the return code of dead children so that we do not create
 634         // zombies. wxBase does not implement wxProcess callbacks, so no one
 635         // actualy calls wxHandleProcessTermination() in console applications.
 636         // We do our best here.
 637         int ret = 0;
 638         ret = sigaction(SIGCHLD, NULL, &m_oldSignalChildAction);
 639         m_newSignalChildAction = m_oldSignalChildAction;
 640         m_newSignalChildAction.sa_sigaction = OnSignalChildHandler;
 641         m_newSignalChildAction.sa_flags |=  SA_SIGINFO;
 642         m_newSignalChildAction.sa_flags &= ~SA_RESETHAND;
 643         ret = sigaction(SIGCHLD, &m_newSignalChildAction, NULL);
 644         if (ret == -1) {
 645                 strerror_r(errno, errorBuffer, ERROR_BUFFER_LEN);
 646                 AddDebugLogLineC(logStandard, wxString(wxT("CamuleDaemonApp::OnRun(): Installation of SIGCHLD callback with sigaction() failed: ")) << char2unicode(errorBuffer) << wxT("."));
 647         } else {
 648                 AddDebugLogLineN(logGeneral, wxT("CamuleDaemonApp::OnRun(): Installation of SIGCHLD callback with sigaction() succeeded."));
 649         }
 650 #endif // __WXMSW__
 651
 652 #ifdef AMULED28
 653
 654         while ( !m_Exit ) {
 655                 m_table->RunSelect();
 656                 ProcessPendingEvents();
 657                 ((CDaemonAppTraits *)GetTraits())->DeletePending();
 658         }
 659
 660         // ShutDown is beeing called twice. Once here and again in OnExit().
 661         ShutDown();
 662
 663         return 0;
 664
 665 #else
 666
 667 #ifdef AMULED_DUMMY
 668         return 0;
 669 #else
 670         return wxApp::OnRun();
 671 #endif
 672
 673 #endif
 674 }
 675
 676 bool CamuleDaemonApp::OnInit()
 677 {
 678         if ( !CamuleApp::OnInit() ) {
 679                 return false;
 680         }
 681         AddLogLineNS(_("amuled: OnInit - starting timer"));
 682         core_timer = new CTimer(this,ID_CORE_TIMER_EVENT);
 683         core_timer->Start(CORE_TIMER_PERIOD);
 684         glob_prefs->GetCategory(0)->title = GetCatTitle(thePrefs::GetAllcatFilter());
 685         glob_prefs->GetCategory(0)->path = thePrefs::GetIncomingDir();
 686
 687         return true;
 688 }
 689
 690 int CamuleDaemonApp::InitGui(bool ,wxString &)
 691 {
 692 #ifndef __WXMSW__
 693         if ( !enable_daemon_fork ) {
 694                 return 0;
 695         }
 696         AddLogLineNS(_("amuled: forking to background - see you"));
 697         theLogger.SetEnabledStdoutLog(false);
 698         //
 699         // fork to background and detach from controlling tty
 700         // while redirecting stdout to /dev/null
 701         //
 702         for(int i_fd = 0;i_fd < 3; i_fd++) {
 703                 close(i_fd);
 704         }
 705         int fd = open("/dev/null",O_RDWR);
 706         if (dup(fd)){}  // prevent GCC warning
 707         if (dup(fd)){}
 708         pid_t pid = fork();
 709
 710         wxASSERT(pid != -1);
 711
 712         if ( pid ) {
 713                 exit(0);
 714         } else {
 715                 pid = setsid();
 716                 //
 717                 // Create a Pid file with the Pid of the Child, so any daemon-manager
 718                 // can easily manage the process
 719                 //
 720                 if (!m_PidFile.IsEmpty()) {
 721                         wxString temp = CFormat(wxT("%d\n")) % pid;
 722                         wxFFile ff(m_PidFile, wxT("w"));
 723                         if (!ff.Error()) {
 724                                 ff.Write(temp);
 725                                 ff.Close();
 726                         } else {
 727                                 AddLogLineNS(_("Cannot Create Pid File"));
 728                         }
 729                 }
 730         }
 731
 732 #endif
 733         return 0;
 734 }
 735
 736
 737 int CamuleDaemonApp::OnExit()
 738 {
 739 #ifdef AMULED28
 740         /*
 741          * Stop all socket threads before entering
 742          * shutdown sequence.
 743          */
 744         delete listensocket;
 745         listensocket = 0;
 746         if (clientudp) {
 747                 delete clientudp;
 748                 clientudp = NULL;
 749         }
 750 #endif
 751
 752         ShutDown();
 753
 754 #ifndef __WXMSW__
 755         const int ERROR_BUFFER_LEN = 256;
 756         char errorBuffer[ERROR_BUFFER_LEN];
 757         wxString msg;
 758         int ret = sigaction(SIGCHLD, &m_oldSignalChildAction, NULL);
 759         if (ret == -1) {
 760                 strerror_r(errno, errorBuffer, ERROR_BUFFER_LEN);
 761                 msg << wxT("CamuleDaemonApp::OnRun(): second sigaction() failed: ") <<
 762                         char2unicode(errorBuffer) <<
 763                         wxT(".");
 764                 AddDebugLogLineC(logStandard, msg);
 765         } else {
 766                 msg << wxT("CamuleDaemonApp::OnRun(): Uninstallation of SIGCHLD "
 767                         "callback with sigaction() succeeded.");
 768                 AddDebugLogLineN(logGeneral, msg);
 769         }
 770 #endif // __WXMSW__
 771
 772         // lfroen: delete socket threads
 773         if (ECServerHandler) {
 774                 ECServerHandler = 0;
 775         }
 776
 777         delete core_timer;
 778
 779         return CamuleApp::OnExit();
 780 }
 781
 782
 783 int CamuleDaemonApp::ShowAlert(wxString msg, wxString title, int flags)
 784 {
 785         if ( flags | wxICON_ERROR ) {
 786                 title = CFormat(_("ERROR: %s")) % title;
 787         }
 788         AddLogLineCS(title + wxT(" ") + msg);
 789
 790         return 0;       // That's neither yes nor no, ok, cancel
 791 }
 792
 793 // File_checked_for_headers