blob: 8f8509e5f436497bb744bbb96de4f19b7ea04f35 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
/*******************************************************************************
* Copyright (c) 2011 protos software gmbh (http://www.protos.de).
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*
* CONTRIBUTORS:
* Thomas Schuetz
*
*******************************************************************************/
package org.eclipse.etrice.runtime.java.messaging;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
/**
* The MessageServiceController controls life cycle of and access to all MessageServices in one SubSystem.
*
* @author Thomas Schuetz
* @author Thomas Jung
* @author Henrik Rentz-Reichert
*
*/
public class MessageServiceController {
private List<IMessageService> messageServiceList = null;
private boolean running = false;
public MessageServiceController(/*IRTObject parent*/){
// TODOTS: Who is parent of MessageServices and Controller?
// this.parent = parent;
messageServiceList = new ArrayList<IMessageService>();
}
public void addMsgSvc(IMessageService msgSvc){
// TODOTS: Who is parent of MessageServices ?
assert(msgSvc.getAddress().threadID == messageServiceList.size());
messageServiceList.add(msgSvc);
}
public int getNMsgSvc() {
return messageServiceList.size();
}
public IMessageService getMsgSvc(int threadID){
assert(threadID < messageServiceList.size());
return messageServiceList.get(threadID);
}
public void start() {
// start all message services
for (IMessageService msgSvc : messageServiceList){
Thread thread = new Thread(msgSvc, msgSvc.getName());
msgSvc.setThread(thread);
thread.start();
// TODOTS: start in order of priorities
}
running = true;
}
public void stop() {
if (!running)
return;
//dumpThreads("org.eclipse.etrice.runtime.java.messaging.MessageServiceController.stop()");
terminate();
waitTerminate();
running = false;
}
/**
* @param msg
*
*/
protected void dumpThreads(String msg) {
System.out.println("<<< begin dump threads <<<");
System.out.println("=== "+msg);
Map<Thread, StackTraceElement[]> traces = Thread.getAllStackTraces();
for (Thread thread : traces.keySet()) {
System.out.println("thread "+thread.getName());
StackTraceElement[] elements = traces.get(thread);
int n = 2;
if (elements.length<n)
n = elements.length;
for (int i = 0; i < n; i++) {
System.out.println(" "+elements[i].toString());
}
}
System.out.println(">>> end dump threads >>>");
}
private void terminate() {
// terminate all message services
for (IMessageService msgSvc : messageServiceList){
msgSvc.terminate();
// TODOTS: stop in order of priorities
}
}
/**
* waitTerminate waits blocking for all MessageServices to terminate
* ! not threadsafe !
*/
public void waitTerminate() {
for (IMessageService msgSvc : messageServiceList) {
try {
msgSvc.getThread().join(1000); // wait at most 1000ms
if (msgSvc.getThread().isAlive())
System.out.println("### Message Service "
+ msgSvc.getName() + " could not be stopped");
}
catch (InterruptedException e1) {
}
}
}
public void resetAll() {
stop();
messageServiceList.clear();
}
}
|
