cnt4007c/Logger.java at master · robinclark/cnt4007c · GitHub

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
120
121
122
123
124
125
import java.util.*;
import java.io.*;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Calendar;


public class Logger extends Module {

	private String peer_ID;
	private File loggerFile;
	private String fileName;
	private String Time;
	private Calendar cal;
	private FileWriter fw;
	private BufferedWriter bw;

	public Logger(String peerID)
	{
		this.peer_ID = peerID;
		this.fileName = "log_peer_" + peerID + ".log";
		DateFormat date = new SimpleDateFormat("EEE MMM dd hh:mm:ss yyyy");
		cal = Calendar.getInstance();
		Time = date.format(cal.getTime());
	}

	@Override
	public void initialConfiguration() {

			if(loggerFile == null)
			{
				loggerFile = new File(Constants.PDIR + fileName);
				try
				{
					if(!loggerFile.exists())
					{
						loggerFile.createNewFile();
					}

					fw = new FileWriter(loggerFile.getName(),true);
					bw = new BufferedWriter(fw);
				} catch (IOException e)
				{
					e.printStackTrace();
				}
			}

			}

	public String TCPConnectLog(String destPeerID)
	{
		return "[" + Time + "]: Peer [" + peer_ID + "]  makes a connection to Peer [" + destPeerID + "].\n";
	}

	public String changeOfPeers(List<String> neighborList)
	{
		String list = formatPeerList(neighborList);
		return "[" + Time + "]: Peer [" + peer_ID + "] has the prefeered neighbors [" + list + "].\n";
	}

	public String changeOfOptimistic(String optimisticID)
	{
		return "[" + Time + "]: Peer [ " + peer_ID + "] has the optimistically-unchoked neighbor [" + optimisticID + "].\n";
 	}

	public String unchoking(String destPeerID)
	{
		return "[" + Time + "]: Peer [ " + peer_ID + "] is unchocked by [ " + destPeerID + "].\n";
	}

	public String chocking(String destPeerID)
	{
		return "[" + Time + "]: Peer [ " + peer_ID + "] is chocked by [ " + destPeerID + "].\n";
	}

	public String haveMessage(String destPeerID, int pieceIndx)
	{
		return "[" + Time + "]: Peer [ " + peer_ID + "] received a 'have' message from [" + destPeerID +"] for the piece [" + pieceIndx + "].\n";
	}

	public String interestedMessage(String destPeerID)
	{
		return "[" + Time + "]: Peer [ " + peer_ID + "] recieved an 'interested' message from [ " + destPeerID + "].\n";

	}

	public String notInterestedMessage(String destPeerID)
	{
		return "[" + Time + "]: Peer [ " + peer_ID + "] recieved an ' not interested' message from [ " + destPeerID + "].\n";
	}

	public String completionMessage()
	{
		return "[" + Time + "]: Peer [ " + peer_ID + " ] has downloaded the complete file.\n";
 	}

	public String testMessage()
	{
		return "Testing Peer [ " + peer_ID + "].\n";
	}

	public void writeLogger(String msg) throws IOException
	{
		bw.write(msg);
	}
	private String formatPeerList(List<String> list)
	{
		Iterator<String> iter = list.iterator();
		StringBuilder peerList = new StringBuilder();
		int extracommaIndex;
		while(iter.hasNext())
		{
			peerList.append(iter.next() + ",");
		}

		extracommaIndex = peerList.lastIndexOf(",");
		return peerList.substring(0,extracommaIndex);
	}

	public void close() throws IOException
	{
		bw.close();
	}

}