summaryrefslogtreecommitdiff
path: root/sources/core/VSTask.java
diff options
context:
space:
mode:
Diffstat (limited to 'sources/core/VSTask.java')
-rw-r--r--sources/core/VSTask.java13
1 files changed, 2 insertions, 11 deletions
diff --git a/sources/core/VSTask.java b/sources/core/VSTask.java
index 43b0265..26b2485 100644
--- a/sources/core/VSTask.java
+++ b/sources/core/VSTask.java
@@ -84,13 +84,8 @@ public class VSTask implements Comparable {
final String protocolName = message.getProtocolName();
final String protocolClassname = message.getProtocolClassname();
- final long recvLamportTime = message.getLamportTime() + 1;
- final long lamportTime = process.getLamportTime() + 1;
-
- if (recvLamportTime > lamportTime)
- process.setLamportTime(recvLamportTime);
- else
- process.setLamportTime(lamportTime);
+ process.updateLamportTime(message.getLamportTime()+1);
+ process.updateVectorTime(message.getVectorTime());
Object protocolObj;
@@ -120,10 +115,6 @@ public class VSTask implements Comparable {
private void onProcessEventStart() {
final VSProcessEvent processEvent = (VSProcessEvent) event;
processEvent.onStart(process);
- /*
- if (process.isCrashed())
- process.setLamportTime(process.getLamportTime()-1);
- */
}
public long getTaskTime() {