src/main/java/derms/net/rmulticast/ReceivedSet.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

package derms.net.rmulticast;

import java.io.Serializable;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;

class ReceivedSet<T extends Serializable & Hashable> {
    private final Set<Message<T>> received;

    ReceivedSet() {
        this.received = new ConcurrentHashMap<Message<T>, Void>().keySet();
    }

    void add(Message<T> e) {
        received.add(e);
    }

    // TODO: faster search.
    boolean contains(MessageID mid) {
        for (Message<T> msg : received)
            if (msg.id().equals(mid))
                return true;
        return false;
    }
}