home *** CD-ROM | disk | FTP | other *** search
/ PC World Komputer 1999 mARCH / PCWK3A99.iso / Linux / DDD331 / DDD-3_1_.000 / DDD-3_1_ / ddd-3.1.1 / ddd / AgentM.C < prev    next >
C/C++ Source or Header  |  1998-03-25  |  3KB  |  138 lines
  1. // $Id: AgentM.C,v 1.10 1998/03/25 12:42:10 zeller Exp $
  2. // Agent Manager
  3.  
  4. // Copyright (C) 1995 Technische Universitaet Braunschweig, Germany.
  5. // Written by Andreas Zeller <zeller@ips.cs.tu-bs.de>.
  6. // 
  7. // This file is part of DDD.
  8. // 
  9. // DDD is free software; you can redistribute it and/or
  10. // modify it under the terms of the GNU General Public
  11. // License as published by the Free Software Foundation; either
  12. // version 2 of the License, or (at your option) any later version.
  13. // 
  14. // DDD is distributed in the hope that it will be useful,
  15. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  16. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
  17. // See the GNU General Public License for more details.
  18. // 
  19. // You should have received a copy of the GNU General Public
  20. // License along with DDD -- see the file COPYING.
  21. // If not, write to the Free Software Foundation, Inc.,
  22. // 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
  23. // 
  24. // DDD is the data display debugger.
  25. // For details, see the DDD World-Wide-Web page, 
  26. // `http://www.cs.tu-bs.de/softech/ddd/',
  27. // or send a mail to the DDD developers <ddd@ips.cs.tu-bs.de>.
  28.  
  29. char AgentM_rcsid[] = 
  30.     "$Id: AgentM.C,v 1.10 1998/03/25 12:42:10 zeller Exp $";
  31.  
  32. #ifdef __GNUG__
  33. #pragma implementation
  34. #endif
  35.  
  36.  
  37. #include "AgentM.h"
  38. #include "Agent.h"
  39. #include "SignalB.h"
  40. #include "config.h"
  41.  
  42. extern "C" {
  43. #include <unistd.h>
  44. #include <sys/types.h>
  45. #include <sys/wait.h>
  46. }
  47.  
  48. DEFINE_TYPE_INFO_0(AgentManager)
  49.  
  50. #if 0
  51. #include "SignalC.h"
  52.  
  53. // Make sure to call all destructors, even when a signal comes
  54. static SignalCleanup hasta_la_vista_you_filthy_agents;
  55. #endif
  56.  
  57.  
  58. // Add an agent
  59. void AgentManager::operator += (Agent *key)
  60. {
  61.     for (Agent *c = first; c != 0; c = c->next)
  62.     if (c == key)
  63.         return;
  64.  
  65.     SignalBlocker sb(SIGCHLD);
  66.  
  67.     key->next = first;
  68.     first     = key;
  69. }
  70.  
  71. // Remove an agent
  72. void AgentManager::operator -= (Agent *key)
  73. {
  74.     Agent *prev = 0;
  75.     for (Agent *c = first; c != 0; c = c->next)
  76.     {
  77.     if (c == key)
  78.     {
  79.         SignalBlocker sb(SIGCHLD);
  80.  
  81.         if (prev == 0)
  82.         first = c->next;
  83.         else
  84.         prev->next = c->next;
  85.     }
  86.     else
  87.     {
  88.         prev = c;
  89.     }
  90.     }
  91. }
  92.  
  93.  
  94. // Search an agent
  95. Agent *AgentManager::search(int pid)
  96. {
  97.     for (Agent *c = first; c != 0; c = c->next)
  98.     if (pid == c->pid())
  99.         return c;
  100.  
  101.     return 0;
  102. }
  103.  
  104. // Commit all pending changes
  105. void AgentManager::commit()
  106. {
  107.     for (Agent *c = first; c != 0; c = c->next)
  108.     c->commit();
  109. }
  110.  
  111. // Agent Manager Destructor: called at the end of the show
  112. AgentManager::~AgentManager()
  113. {
  114.     // Terminate using low-level functions
  115.     for (Agent *c = first; c != 0; c = c->next)
  116.     c->terminate(true);
  117. }
  118.  
  119. // Process status change
  120. bool AgentManager::childStatusChange()
  121. {
  122.     bool gotit = false;
  123.  
  124.     for (Agent *c = first; c != 0; c = c->next)
  125.     {
  126.     pid_t pid = c->pid();
  127.     int status;
  128.  
  129.     if (pid > 0 && waitpid(pid, &status, WNOHANG) == pid)
  130.     {
  131.         c->callHandlers(_Died, (void *)status);
  132.         gotit = true;
  133.     }
  134.     }
  135.  
  136.     return gotit;
  137. }
  138.