Update copyright to LGPL on all files
[dyninst.git] / dyninstAPI / src / eventgate.C
1 /*
2  * Copyright (c) 1996-2009 Barton P. Miller
3  * 
4  * We provide the Paradyn Parallel Performance Tools (below
5  * described as "Paradyn") on an AS IS basis, and do not warrant its
6  * validity or performance.  We reserve the right to update, modify,
7  * or discontinue this software at any time.  We shall have no
8  * obligation to supply such updates or modifications or any other
9  * form of support to you.
10  * 
11  * By your use of Paradyn, you understand and agree that we (or any
12  * other person or entity with proprietary rights in Paradyn) are
13  * under no obligation to provide either maintenance services,
14  * update services, notices of latent defects, or correction of
15  * defects for Paradyn.
16  * 
17  * This library is free software; you can redistribute it and/or
18  * modify it under the terms of the GNU Lesser General Public
19  * License as published by the Free Software Foundation; either
20  * version 2.1 of the License, or (at your option) any later version.
21  * 
22  * This library is distributed in the hope that it will be useful,
23  * but WITHOUT ANY WARRANTY; without even the implied warranty of
24  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
25  * Lesser General Public License for more details.
26  * 
27  * You should have received a copy of the GNU Lesser General Public
28  * License along with this library; if not, write to the Free Software
29  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
30  */
31
32 // $Id: signalhandler.C,v 
33
34 #include "eventgate.h"
35 #include "debug.h"
36 #include "util.h"
37
38 EventGate::EventGate(eventLock *l, eventType t, process *p, dyn_lwp *lwp,
39                      eventStatusCode_t status) :
40      lock(l), waiting(false)
41 {
42   //cond = new eventCond(lock);
43   EventRecord target_event;
44   target_event.type = t;
45   target_event.proc = p;
46   target_event.lwp = lwp;
47   target_event.status = status;
48   evts.push_back(target_event);
49
50   if (t != evtProcessExit) {
51     EventRecord process_exit_event;
52     process_exit_event.type = evtProcessExit;
53     process_exit_event.proc = p;
54     evts.push_back(process_exit_event);
55   }
56 }
57
58 bool EventGate::addEvent(eventType type, process *p)
59 {
60   EventRecord target_event;
61   target_event.type = type;
62   target_event.proc = p;
63   if (type == evtProcessExit) {
64     for (unsigned int i = 0; i < evts.size(); ++i) {
65       if (evts[i].isTemplateOf(target_event)) {
66         //fprintf(stderr, "%s[%d]:  dropping duplicate request to wait for proces exit\n",
67          //       FILE__, __LINE__);
68         return true;
69       }
70     }
71   }
72   evts.push_back(target_event);
73   return true;
74 }
75
76 EventGate::~EventGate()
77 {
78   //delete cond;
79 }
80
81 EventRecord &EventGate::wait(bool executeCallbacks /* = true */)
82 {
83   trigger.type = evtUndefined;
84   assert(lock->depth());
85  
86   still_waiting:
87   waiting = true;
88   if (executeCallbacks) 
89     getMailbox()->executeCallbacks(FILE__, __LINE__);
90
91   if (trigger.type != evtUndefined) {
92     return trigger;
93   }
94   extern int dyn_debug_signal;
95   if (dyn_debug_signal) {
96     signal_printf("%s[%d][%s]: waiting for event matching:\n", FILE__, __LINE__,
97             getThreadStr(getExecThreadID()));
98     for (unsigned int i = 0; i < evts.size(); ++i) {
99       char buf[1024];
100       signal_printf("\t%s\n", evts[i].sprint_event(buf));
101     }
102   }
103
104   lock->_WaitForSignal(FILE__, __LINE__);
105   waiting = false;
106   
107
108   bool triggered = false;
109   for (unsigned int i = 0; i < evts.size(); ++i) {
110     if (evts[i].isTemplateOf(trigger)) {
111       triggered = true;
112       break;
113     }
114   }
115   if (!triggered) goto still_waiting;
116
117   return trigger;
118 }
119
120 bool EventGate::signalIfMatch(EventRecord &ev)
121 {
122   lock->_Lock(FILE__, __LINE__);
123   if (!waiting) {
124     lock->_Unlock(FILE__, __LINE__);
125     return false;
126   }
127   bool ret = false;
128   for (unsigned int i = 0; i < evts.size(); ++i) {
129     if (evts[i].isTemplateOf(ev)) {
130       ret = true;
131       trigger = ev;
132       lock->_Broadcast(FILE__, __LINE__);
133       break;
134     }
135   }
136   lock->_Unlock(FILE__, __LINE__);
137   return ret;
138 }
139