package edu.uci.iotproject;
-import edu.uci.iotproject.analysis.PcapPacketPair;
import edu.uci.iotproject.analysis.TcpConversationUtils;
import edu.uci.iotproject.analysis.TriggerTrafficExtractor;
import edu.uci.iotproject.io.TriggerTimesFileReader;
import org.pcap4j.core.*;
-import org.pcap4j.packet.IpV4Packet;
import org.pcap4j.packet.namednumber.DataLinkType;
import java.io.EOFException;
public static void main(String[] args) throws PcapNativeException, NotOpenException, EOFException, TimeoutException, UnknownHostException {
// -------------------------------------------------------------------------------------------------------------
- // Example/debug code for searching for a pattern at the MAC layer.
-// String fileName = "./pcap/mac-tplink.local.pcapng";
-// PcapHandle handle;
-// try {
-// handle = Pcaps.openOffline(fileName, PcapHandle.TimestampPrecision.NANO);
-// } catch (PcapNativeException pne) {
-// handle = Pcaps.openOffline(fileName);
-// }
-// Arrays.asList(1590, 1590, 1590, 1001, 337, 197, 636, 1311, 177) // Full pattern (all non-zero payload packets).
-// MacLayerFlowPattern pattern = new MacLayerFlowPattern("TP_LINK_LOCAL_OFF_MAC", "50:c7:bf:33:1f:09", Arrays.asList(637, 1312));
-// MacLayerFlowPatternFinder finder = new MacLayerFlowPatternFinder(handle, pattern);
-// finder.findFlowPattern();
- // -------------------------------------------------------------------------------------------------------------
-//
-// //final String fileName = args.length > 0 ? args[0] : "/home/rtrimana/pcap_processing/smart_home_traffic/Code/Projects/SmartPlugDetector/pcap/wlan1.local.dns.pcap";
-// final String fileName = args.length > 0 ? args[0] : "/scratch/June-2018/TPLink/wlan1/tplink.wlan1.local.pcap";
-// //final String fileName = args.length > 0 ? args[0] : "/scratch/June-2018/DLink/wlan1/dlink.wlan1.local.pcap";
-// final String trainingFileName = "./pcap/TP_LINK_LOCAL_ON_SUBSET.pcap";
-//// final String trainingFileName = "./pcap/TP_LINK_LOCAL_ON.pcap";
-////
-//// // ====== Debug code ======
-// PcapHandle handle;
-// PcapHandle trainingPcap;
-// try {
-// handle = Pcaps.openOffline(fileName, PcapHandle.TimestampPrecision.NANO);
-// trainingPcap = Pcaps.openOffline(trainingFileName, PcapHandle.TimestampPrecision.NANO);
-// } catch (PcapNativeException pne) {
-// handle = Pcaps.openOffline(fileName);
-// trainingPcap = Pcaps.openOffline(trainingFileName);
-// }
-////
-//// // TODO: The followings are the way to extract multiple hostnames and their associated packet lengths lists
-//// //List<String> list = new ArrayList<>();
-//// //list.add("events.tplinkra.com");
-//// //FlowPattern fp = new FlowPattern("TP_LINK_LOCAL_ON", list, trainingPcap);
-//// //List<String> list2 = new ArrayList<>();
-//// //list2.add("devs.tplinkcloud.com");
-//// //list2.add("events.tplinkra.com");
-//// //FlowPattern fp3 = new FlowPattern("TP_LINK_REMOTE_ON", list2, trainingPcap);
-////
-// FlowPattern fp = new FlowPattern("TP_LINK_LOCAL_ON", "events.tplinkra.com", trainingPcap);
-// //FlowPattern fp = new FlowPattern("DLINK_LOCAL_ON", "rfe-us-west-1.dch.dlink.com", trainingPcap);
-// FlowPatternFinder fpf = new FlowPatternFinder(handle, fp);
-// fpf.start();
-////
-//// // ========================
-
- /*
- PcapReader pcapReader = new PcapReader(args[0]);
- PcapProcessingPipeline pipeline = new PcapProcessingPipeline(pcapReader);
- TcpReassembler tcpReassembler = new TcpReassembler();
- pipeline.addPcapPacketConsumer(tcpReassembler);
- pipeline.executePipeline();
- System.out.println("Pipeline terminated");
-
- List<List<PcapPacketPair>> pairs = new ArrayList<>();
- for (Conversation c : tcpReassembler.getTcpConversations()) {
- pairs.add(TcpConversationUtils.extractPacketPairs(c));
- }
- */
-
- /*
- // -------- 07-17-2018 --------
- // Only consider packets to/from the TP-Link plug.
- PcapReader pcapReader = new PcapReader(args[0], "ip host 192.168.1.159");
- TcpReassembler tcpReassembler = new TcpReassembler();
- PcapPacket packet;
- while((packet = pcapReader.readNextPacket()) != null) {
- tcpReassembler.consumePacket(packet);
- }
- // Now we have a set of reassembled TCP conversations.
- List<Conversation> conversations = tcpReassembler.getTcpConversations();
- for(Conversation c : conversations) {
- List<PcapPacketPair> pairs = TcpConversationUtils.extractPacketPairs(c);
- for (PcapPacketPair pair : pairs) {
- // TODO ...
- // 1. discard packets that are not within X seconds after trigger time
- // 2. conversations may be (are) with different servers - so need to plot in different plots, one per hostname?
- }
- }
-
- // ----------------------------
- */
+ // ------------ # Code for extracting traffic generated by a device within x seconds of a trigger # ------------
+ // Paths to input and output files (consider supplying these as arguments instead) and IP of the device for
+ // which traffic is to be extracted:
+ // D-Link July 26 experiment
+ final String inputPcapFile = "/Users/varmarken/temp/UCI IoT Project/experiments/2018-07/dlink/dlink.wlan1.local.pcap";
+ final String outputPcapFile = "/Users/varmarken/temp/UCI IoT Project/experiments/2018-07/dlink/dlink-processed.pcap";
+ final String triggerTimesFile = "/Users/varmarken/temp/UCI IoT Project/experiments/2018-07/dlink/dlink-july-26-2018.timestamps";
+ final String deviceIp = "192.168.1.246";
+ // TP-Link July 25 experiment
+// final String inputPcapFile = "/Users/varmarken/temp/UCI IoT Project/experiments/2018-07/tplink/tplink.wlan1.local.pcap";
+// final String outputPcapFile = "/Users/varmarken/temp/UCI IoT Project/experiments/2018-07/tplink/tplink-processed.pcap";
+// final String triggerTimesFile = "/Users/varmarken/temp/UCI IoT Project/experiments/2018-07/tplink/tplink-july-25-2018.timestamps";
+// final String deviceIp = "192.168.1.159";
- // -------- 07-19-2018 --------
TriggerTimesFileReader ttfr = new TriggerTimesFileReader();
-// List<Instant> triggerTimes = ttfr.readTriggerTimes("/Users/varmarken/Downloads/tplink-feb-13-2018.timestamps", false);
- List<Instant> triggerTimes = ttfr.readTriggerTimes("/Users/varmarken/temp/UCI IoT Project/June2018 experiments/tplink/tplink-june-14-2018-timestamps.txt", false);
-// String pcapFile = "/Users/varmarken/Development/Repositories/UCI/NetworkingGroup/smart_home_traffic/Code/Projects/SmartPlugDetector/pcap/wlan1.local.dns.pcap";
- String pcapFile = "/Users/varmarken/temp/UCI IoT Project/June2018 experiments/tplink/tplink.wlan1.local.pcap";
- String tpLinkPlugIp = "192.168.1.159";
- TriggerTrafficExtractor tte = new TriggerTrafficExtractor(pcapFile, triggerTimes, tpLinkPlugIp);
-// final PcapDumper outputter = Pcaps.openDead(DataLinkType.EN10MB, 65536).dumpOpen("/Users/varmarken/temp/traces/output/tplink-filtered.pcap");
- final PcapDumper outputter = Pcaps.openDead(DataLinkType.EN10MB, 65536).dumpOpen("/Users/varmarken/temp/UCI IoT Project/June2018 experiments/tplink/tplink-filtered.pcap");
+ List<Instant> triggerTimes = ttfr.readTriggerTimes(triggerTimesFile, false);
+ TriggerTrafficExtractor tte = new TriggerTrafficExtractor(inputPcapFile, triggerTimes, deviceIp);
+ final PcapDumper outputter = Pcaps.openDead(DataLinkType.EN10MB, 65536).dumpOpen(outputPcapFile);
DnsMap dnsMap = new DnsMap();
TcpReassembler tcpReassembler = new TcpReassembler();
tte.performExtraction(pkt -> {
outputter.flush();
outputter.close();
- /*
- int packets = 0;
- for (Conversation c : tcpReassembler.getTcpConversations()) {
- packets += c.getPackets().size();
- packets += c.getSynPackets().size();
- // only count the FIN packets, not the ACKs; every FinAckPair holds a FIN packet
- packets += c.getFinAckPairs().size();
- }
- // Produces 271 packets for the Feb 13 experiment
- // Applying filter: "(tcp and not tcp.len == 0 and not tcp.analysis.retransmission and not tcp.analysis.fast_retransmission) or (tcp.flags.syn == 1) or (tcp.flags.fin == 1)"
- // to the file gives 295 packets, but there are 24 TCP-Out-Of-Order SYN/SYNACKs which are filtered as retransmissions in Conversation, so the numbers seem to match.
- System.out.println("number of packets: " + packets);
- */
-
- List<List<PcapPacketPair>> pairs = new ArrayList<>();
- for (Conversation c : tcpReassembler.getTcpConversations()) {
- pairs.add(TcpConversationUtils.extractPacketPairs(c));
- }
- /*
- // Sort pairs according to timestamp of first packet of conversation for (debugging) convenience.
- Collections.sort(pairs, (l1, l2) -> {
- if (l1.get(0).getFirst().getTimestamp().isBefore(l2.get(0).getFirst().getTimestamp())) return -1;
- else if (l2.get(0).getFirst().getTimestamp().isBefore(l1.get(0).getFirst().getTimestamp())) return 1;
- else return 0;
- });
- */
- System.out.println("list of pairs produced");
- List<PcapPacketPair> eventstplinkraPairs = new ArrayList<>();
- List<List<PcapPacketPair>> otherPairs = new ArrayList<>();
- String hostname = "events.tplinkra.com";
- int emptyLists = 0;
- for (List<PcapPacketPair> lppp : pairs) {
- if (lppp.size() < 1) {
- emptyLists++;
- continue;
- }
- IpV4Packet ipPacket = lppp.get(0).getFirst().get(IpV4Packet.class);
- // If packets are associated with the hostname
- if (dnsMap.isRelatedToCloudServer(ipPacket.getHeader().getSrcAddr().getHostAddress(), hostname) ||
- dnsMap.isRelatedToCloudServer(ipPacket.getHeader().getDstAddr().getHostAddress(), hostname)) {
- eventstplinkraPairs.addAll(lppp);
- } else {
- // Pairs associated with different server
- otherPairs.add(lppp);
- }
- }
- System.out.println("number of empty list of packet pairs: " + emptyLists);
- HashMap<String, Integer> pairCount = new HashMap<>();
- for (PcapPacketPair ppp : eventstplinkraPairs) {
- if (pairCount.containsKey(ppp.toString())) {
- pairCount.put(ppp.toString(), pairCount.get(ppp.toString()) + 1);
- } else {
- pairCount.put(ppp.toString(), 1);
- }
- }
- System.out.println("pairCount map built");
-
- // Build map containing frequencies of packet lengths exchanged with events.tplinkra.com as well as a map with
- // the frequencies of specific sequences of packet lengths for the same hostname
- HashMap<Integer, Integer> eventstplinkraPacketLengthFreqMap = new HashMap<>();
- HashMap<String, Integer> eventstplinkraPacketSequenceFreqMap = new HashMap<>();
- for (Conversation c : tcpReassembler.getTcpConversations()) {
- if (c.getPackets().size() == 0) {
- continue;
- }
- PcapPacket firstPacket = c.getPackets().get(0);
- IpV4Packet firstPacketIp = firstPacket.get(IpV4Packet.class);
- if (!dnsMap.isRelatedToCloudServer(firstPacketIp.getHeader().getSrcAddr().getHostAddress(), hostname) &&
- !dnsMap.isRelatedToCloudServer(firstPacketIp.getHeader().getDstAddr().getHostAddress(), hostname)) {
- continue;
- }
- // Update the packet length freq map
- for (PcapPacket pp : c.getPackets()) {
- eventstplinkraPacketLengthFreqMap.merge(pp.length(), 1, (i1, i2) -> i1 + i2);
- }
- // Update the packet sequence freq map
- StringBuilder sb = new StringBuilder();
- for (PcapPacket pp : c.getPackets()) {
- sb.append(pp.length() + " ");
- }
- eventstplinkraPacketSequenceFreqMap.merge(sb.toString(), 1, (i1, i2) -> i1+i2);
- }
- System.out.println("packet length frequency map created");
-
- Map<String, List<Conversation>> hostnameConversationMap =
- TcpConversationUtils.groupConversationsByHostname(tcpReassembler.getTcpConversations(), dnsMap);
- System.out.println("hostnameConversationMap created");
- // ----------------------------
+ // Extract all conversations present in the filtered trace.
+ List<Conversation> allConversations = tcpReassembler.getTcpConversations();
+ // Group conversations by hostname.
+ Map<String, List<Conversation>> convsByHostname = TcpConversationUtils.groupConversationsByHostname(allConversations, dnsMap);
+ System.out.println("Grouped conversations by hostname.");
+ // For each hostname, count the frequencies of packet lengths exchanged with that hostname.
+ final Map<String, Map<Integer, Integer>> pktLenFreqsByHostname = new HashMap<>();
+ convsByHostname.forEach((host, convs) -> pktLenFreqsByHostname.put(host, TcpConversationUtils.countPacketLengthFrequencies(convs)));
+ System.out.println("Counted frequencies of packet lengths exchanged with each hostname.");
+ // For each hostname, count the frequencies of packet sequences (i.e., count how many conversations exchange a
+ // sequence of packets of some specific lengths).
+ final Map<String, Map<String, Integer>> pktSeqFreqsByHostname = new HashMap<>();
+ convsByHostname.forEach((host, convs) -> pktSeqFreqsByHostname.put(host, TcpConversationUtils.countPacketSequenceFrequencies(convs)));
+ System.out.println("Counted frequencies of packet sequences exchanged with each hostname.");
+ // For each hostname, count frequencies of packet pairs exchanged with that hostname across all conversations
+ final Map<String, Map<String, Integer>> pktPairFreqsByHostname =
+ TcpConversationUtils.countPacketPairFrequenciesByHostname(allConversations, dnsMap);
+ System.out.println("Counted frequencies of packet pairs per hostname");
+ // -------------------------------------------------------------------------------------------------------------
+ // -------------------------------------------------------------------------------------------------------------
}
}
import java.util.*;
/**
- * TODO add class documentation.
+ * Utility functions for analyzing and structuring (sets of) {@link Conversation}s.
*
- * @author Janus Varmarken
+ * @author Janus Varmarken {@literal <jvarmark@uci.edu>}
+ * @author Rahmadi Trimananda {@literal <rtrimana@uci.edu>}
*/
public class TcpConversationUtils {
+
+ /**
+ * <p>
+ * Given a {@link Conversation}, extract its set of "packet pairs", i.e., pairs of request-reply packets.
+ * </p>
+ *
+ * <b>Note:</b> in the current implementation, if one endpoint sends multiple packets back-to-back with no
+ * interleaved reply packets from the other endpoint, such packets are converted to one-item pairs (i.e., instances
+ * of {@lin PcapPacketPair} where {@link PcapPacketPair#getSecond()} is {@code null}).
+ *
+ * @param conv The {@code Conversation} for which packet pairs are to be extracted.
+ * @return The packet pairs extracted from {@code conv}.
+ */
public static List<PcapPacketPair> extractPacketPairs(Conversation conv) {
List<PcapPacket> packets = conv.getPackets();
List<PcapPacketPair> pairs = new ArrayList<>();
// TODO: what if there is long time between response and reply packet? Should we add a threshold and exclude those cases?
}
-
- public static Map<String, List<Conversation>> groupConversationsByHostname(List<Conversation> tcpConversations, DnsMap ipHostnameMappings) {
+ /**
+ * Given a collection of TCP conversations and associated DNS mappings, groups the conversations by hostname.
+ * @param tcpConversations The collection of TCP conversations.
+ * @param ipHostnameMappings The associated DNS mappings.
+ * @return A map where each key is a hostname and its associated value is a list of conversations where one of the
+ * two communicating hosts is that hostname (i.e. its IP maps to the hostname).
+ */
+ public static Map<String, List<Conversation>> groupConversationsByHostname(Collection<Conversation> tcpConversations, DnsMap ipHostnameMappings) {
HashMap<String, List<Conversation>> result = new HashMap<>();
for (Conversation c : tcpConversations) {
if (c.getPackets().size() == 0) {
return result;
}
+ public static Map<String, Integer> countPacketSequenceFrequencies(Collection<Conversation> conversations) {
+ Map<String, Integer> result = new HashMap<>();
+ for (Conversation conv : conversations) {
+ if (conv.getPackets().size() == 0) {
+ // Skip conversations with no payload packets.
+ continue;
+ }
+ StringBuilder sb = new StringBuilder();
+ for (PcapPacket pp : conv.getPackets()) {
+ sb.append(pp.length() + " ");
+ }
+ result.merge(sb.toString(), 1, (i1, i2) -> i1+i2);
+ }
+ return result;
+ }
+
+ /**
+ * Given a {@link Conversation}, counts the frequencies of each unique packet length seen as part of the
+ * {@code Conversation}.
+ * @param c The {@code Conversation} for which unique packet length frequencies are to be determined.
+ * @return A mapping from packet length to its frequency.
+ */
+ public static Map<Integer, Integer> countPacketLengthFrequencies(Conversation c) {
+ Map<Integer, Integer> result = new HashMap<>();
+ for (PcapPacket packet : c.getPackets()) {
+ result.merge(packet.length(), 1, (i1, i2) -> i1 + i2);
+ }
+ return result;
+ }
+
+ /**
+ * Like {@link #countPacketLengthFrequencies(Conversation)}, but counts packet length frequencies for a collection
+ * of {@code Conversation}s, i.e., the frequency of a packet length becomes the total number of packets with that
+ * length across <em>all</em> {@code Conversation}s in {@code conversations}.
+ * @param conversations The collection of {@code Conversation}s for which packet length frequencies are to be
+ * counted.
+ * @return A mapping from packet length to its frequency.
+ */
+ public static Map<Integer, Integer> countPacketLengthFrequencies(Collection<Conversation> conversations) {
+ Map<Integer, Integer> result = new HashMap<>();
+ for (Conversation c : conversations) {
+ Map<Integer, Integer> intermediateResult = countPacketLengthFrequencies(c);
+ for (Map.Entry<Integer, Integer> entry : intermediateResult.entrySet()) {
+ result.merge(entry.getKey(), entry.getValue(), (i1, i2) -> i1 + i2);
+ }
+ }
+ return result;
+ }
+
+ public static Map<String, Integer> countPacketPairFrequencies(Collection<PcapPacketPair> pairs) {
+ Map<String, Integer> result = new HashMap<>();
+ for (PcapPacketPair ppp : pairs) {
+ result.merge(ppp.toString(), 1, (i1, i2) -> i1 + i2);
+ }
+ return result;
+ }
+ public static Map<String, Map<String, Integer>> countPacketPairFrequenciesByHostname(Collection<Conversation> tcpConversations, DnsMap ipHostnameMappings) {
+ Map<String, List<Conversation>> convsByHostname = groupConversationsByHostname(tcpConversations, ipHostnameMappings);
+ HashMap<String, Map<String, Integer>> result = new HashMap<>();
+ for (Map.Entry<String, List<Conversation>> entry : convsByHostname.entrySet()) {
+ // Merge all packet pairs exchanged during the course of all conversations with hostname into one list
+ List<PcapPacketPair> allPairsExchangedWithHostname = new ArrayList<>();
+ entry.getValue().forEach(conversation -> allPairsExchangedWithHostname.addAll(extractPacketPairs(conversation)));
+ // Then count the frequencies of packet pairs exchanged with the hostname, irrespective of individual
+ // conversations
+ result.put(entry.getKey(), countPacketPairFrequencies(allPairsExchangedWithHostname));
+ }
+ return result;
+ }
}
projects / pingpong.git / commitdiff