X-Git-Url: http://plrg.eecs.uci.edu/git/?p=pingpong.git;a=blobdiff_plain;f=base_gexf_generator.py;h=ad677eccdd2882fd3c9b1258674f02d16bf1b45c;hp=535391286d2a4a9fdf50a1401ab668abb3c8a4fc;hb=18b3c06f38f8083d485f232c51e78e0fa5066d53;hpb=a8f869fdfb7a728f275a345ea8ef19f7914b225c diff --git a/base_gexf_generator.py b/base_gexf_generator.py index 5353912..ad677ec 100644 --- a/base_gexf_generator.py +++ b/base_gexf_generator.py @@ -106,7 +106,7 @@ def traverse_and_merge_nodes(G, dev_list_file): dev_list = create_device_list(DEVICE_MAC_LIST) # Traverse every node # Check that the node is not a smarthome device - for node in nodes: + for node in list(nodes): neighbors = G[node] #G.neighbors(node) #print "Neighbors: ", neighbors, "\n" # Skip if the node is a smarthome device @@ -174,7 +174,8 @@ def place_in_graph(G, eth_src, eth_dst, device_dns_mappings, dev_list, layers, ip_src = layers[JSON_KEY_IP][JSON_KEY_IP_SRC] ip_dst = layers[JSON_KEY_IP][JSON_KEY_IP_DST] # Categorize source and destination IP addresses: local vs. non-local - ip_re = re.compile(r'\b192.168.[0-9.]+') + #ip_re = re.compile(r'\b192.168.[0-9.]+') + ip_re = re.compile(r'\b192.168.1.[0-9.]+') src_is_local = ip_re.search(ip_src) dst_is_local = ip_re.search(ip_dst) # Store protocol into the set (source) @@ -253,7 +254,7 @@ def parse_json(file_path): # Create an exclusion list exc_list = create_device_list(EXCLUSION_MAC_LIST) # First parse the file once, constructing a map that contains information about individual devices' DNS resolutions. - device_dns_mappings = parser.parse_dns.parse_json_dns(file_path) # "./json/eth1.dump.json" + device_dns_mappings = parser.parse_dns.parse_json_dns(file_path) # Init empty graph G = nx.DiGraph() # Mapping from edge to a set of protocols @@ -261,6 +262,7 @@ def parse_json(file_path): # Mapping from edge to traffic volume edge_to_vol = dict() # Parse file again, this time constructing a graph of device<->server and device<->device communication. + i = 0 with open(file_path) as jf: # Read JSON; data becomes reference to root JSON object (or in our case json array) data = json.load(jf)