forked from MattWoelk/DirectedDiffusion
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathRnFDataSend.java
55 lines (48 loc) · 1.35 KB
/
RnFDataSend.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
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Timer;
import java.util.TimerTask;
//import EDReceive.Sender;
public class RnFDataSend
{
//Timer m_timer=null;
Node sourceNode= null;
Long interval = null;
PacketTransmitter pktTrans = new PacketTransmitter();
public RnFDataSend(long anInterval, Node aSourceNode)
{
this.sourceNode = aSourceNode;
this.interval = anInterval;
// if(EDReceive(aSourceNode, a_interest)
// {
// m_timer = new Timer();
// m_timer.schedule( new EDReceiveTimer(a_node),a_interval);
// }
// else
// {
// if(m_timer!=null)
// m_timer.cancel();
// }
}
public void sendRnFData(Packet pkt)
{
Iterator<Node> iterator = sourceNode.getNeighbours().iterator();
ArrayList<Node> myRnFDataNeighborList = new ArrayList<Node>();
while (iterator.hasNext()) {
Node aNeighborNode = iterator.next();
// if (aNeighborNode.getIsRnFDataNode()) { //Assuming that this was set in blue path
myRnFDataNeighborList.add(aNeighborNode);
pktTrans.setNeighbors(myRnFDataNeighborList);//Assuming that we need to use the same PacketTramsmitter to trasmit data
pktTrans.addPacket(pkt);
break;
// }
}
}
public void RnFSendFlag()
{
}
public void run()
{
}
}