blob: 43dbabccca42fcae97cf9e82a7fc8a07622199ed (
plain)
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
|
package net.cshift.transit.network;
import net.cshift.transit.network.packet.IStaticPacket;
/**
* @author Kyle Gunger
* @apiNote A channel represents a connection between two nodes. It is able to send data in packets, and serves as a way to organize incoming traffic.
* @param <D> The type of data the packets will be transfering
*/
public class Channel<D> {
private INode to;
private int id;
private String group;
/** This constructor should be called by a node approving a connection. The approving node can give the connection an ID and group.
* Negative IDs indicate a terminated connection, so do not initialize the class with a negative ID.
*
* @param node The recieving node
* @param id The channel's id, as assigned by the recieving node.
* @param group
*/
public Channel(INode node, int id, String group)
{
to = node;
this.id = id;
this.group = group;
}
// ####################
// # Channel specific #
// ####################
/** The recieving INode
*
* @return
*/
public INode getReciever()
{
return to;
}
/** The ID of the connection, assigned by the recieving INode
*
* @return
*/
public int getID()
{
return id;
}
/** The group that the channel operates on
*
* @return
*/
public String getGroup() {
return group;
}
/** Returns true if the connection has been terminated
*
* @return
*/
public boolean isTerminated()
{
return id < 0;
}
// ################################
// # Info from the recieving node #
// ################################
/** Pressure
*
* @return A Number representing the pressure from the channel (in base group units).
*/
public Number pressure()
{
return to.getPressure(this);
}
/** Max transfer rate
*
* @return A Number representing the max transfer rate from the channel (in base group units).
*/
public Number rate()
{
return to.getRate(this);
}
// ################################
// # Interact with the other node #
// ################################
/** Terminates the connection and relays the termination to the recieving node
*/
public void terminate()
{
id = -1;
to.onTerminate(this);
}
/** Send a packet to the recieving node
*
* @param packet the packet to send
* @return {@code true} if the recieving node accepts the packet
*/
public boolean send(IStaticPacket<D> packet)
{
if(!this.isTerminated())
return to.accept(packet, this);
return false;
}
}
|
