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
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
|
package events.implementations;
import core.VSInternalProcess;
import core.time.VSVectorTime;
/**
* Concrete implementation of a Vector timestamp-triggered event.
* This event fires when a specific Vector timestamp condition is met.
*
* Example usage:
* - Fire when vector clock equals [3,2,1]
* - Fire when vector clock is greater than or equal to [5,0,2]
* - Fire when any element in vector clock reaches a threshold
*
* @author Paul C. Buetow
*/
public class VSVectorTimestampEvent extends VSTimestampTriggeredEvent {
private String actionDescription;
private Runnable customAction;
/**
* Constructor for basic Vector timestamp event
*/
public VSVectorTimestampEvent(VSVectorTime targetVector, ComparisonOperator op) {
super(targetVector, op);
this.actionDescription = "Vector timestamp condition met";
}
/**
* Constructor with custom action description
*/
public VSVectorTimestampEvent(VSVectorTime targetVector, ComparisonOperator op, String description) {
super(targetVector, op);
this.actionDescription = description;
}
/**
* Constructor with custom action
*/
public VSVectorTimestampEvent(VSVectorTime targetVector, ComparisonOperator op, String description, Runnable action) {
super(targetVector, op);
this.actionDescription = description;
this.customAction = action;
}
/**
* Default constructor for serialization
*/
public VSVectorTimestampEvent() {
super();
this.actionDescription = "Vector timestamp event";
}
@Override
public void onInit() {
super.onInit();
}
@Override
protected void onTimestampReached() {
VSInternalProcess internalProcess = (VSInternalProcess) process;
// Log the event
String message = String.format("Vector timestamp event triggered: %s (current: %s, target: %s %s)",
actionDescription,
internalProcess.getVectorTime(),
targetVectorTime,
operator);
internalProcess.log(message);
// Execute custom action if provided
if (customAction != null) {
try {
customAction.run();
} catch (RuntimeException e) {
// Log the error but don't let it stop the event processing
internalProcess.log("Error executing custom action: " + e.getMessage());
exceptions.VSErrorHandler.warning("Vector timestamp event custom action failed", e);
}
}
// Default behavior: change process color to indicate trigger
changeProcessColor();
}
/**
* Change process color to indicate the timestamp event has been triggered
*/
protected void changeProcessColor() {
if (process instanceof VSInternalProcess) {
VSInternalProcess internalProcess = (VSInternalProcess) process;
// Change to highlight color temporarily
internalProcess.highlightOn();
}
}
/**
* Convenience method to create event that triggers when any vector element reaches threshold
*/
public static VSVectorTimestampEvent createThresholdEvent(int processCount, long threshold, String description) {
VSVectorTime targetVector = new VSVectorTime(0);
for (int i = 0; i < processCount; i++) {
targetVector.add(threshold);
}
return new VSVectorTimestampEvent(targetVector, ComparisonOperator.GREATER_EQUAL, description);
}
/**
* Convenience method to create event that triggers when specific process element reaches value
*/
public static VSVectorTimestampEvent createProcessThresholdEvent(int processCount, int processIndex, long threshold, String description) {
VSVectorTime targetVector = new VSVectorTime(0);
for (int i = 0; i < processCount; i++) {
targetVector.add(i == processIndex ? threshold : 0L);
}
return new VSVectorTimestampEvent(targetVector, ComparisonOperator.GREATER_EQUAL, description);
}
@Override
public String toString() {
return String.format(" [VectorTrigger: %s %s - %s]",
targetVectorTime, operator, actionDescription);
}
// Getters and setters
public String getActionDescription() {
return actionDescription;
}
public void setActionDescription(String description) {
this.actionDescription = description;
}
public void setCustomAction(Runnable action) {
this.customAction = action;
}
@Override
protected String createShortname(String savedShortname) {
return "VectorTrigger";
}
}
|
