sources/core/VSMessage.java


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

package core;

import core.time.*;
import events.*;
import prefs.VSPrefs;
import protocols.*;

public class VSMessage extends VSPrefs implements VSEvent {
    private String protocolClassname;
    private VSProcess sendingProcess;
    private long messageID;
    private static long messageCounter;
    private long lamportTime;
    private VSVectorTime vectorTime;

    public VSMessage(String protocolClassname) {
        this.protocolClassname = protocolClassname;
        this.messageID = ++messageCounter;
    }

    public String getProtocolName() {
        return RegisteredProtocols.getProtocolName(getProtocolClassname());
    }

    public String getProtocolClassname() {
        return protocolClassname;
    }

    public long getMessageID() {
        return messageID;
    }

    public void setSendingProcess(VSProcess sendingProcess) {
        this.sendingProcess = sendingProcess;
        lamportTime = sendingProcess.getLamportTime();
        vectorTime = sendingProcess.getVectorTime().getCopy();
    }

    public VSProcess getSendingProcess() {
        return sendingProcess;
    }

    public long getLamportTime() {
        return lamportTime;
    }

    public VSVectorTime getVectorTime() {
        return vectorTime;
    }

    public String toString() {
        return "ID: " + messageID;
    }

    public String toStringFull() {
        return toString() + "; " + super.toString();
    }

    public boolean equals(VSMessage message) {
        return messageID == message.getMessageID();
    }
}