PeerStreamer

	def addr2hostname(self,addr,without_port=False):

			hostname = session.addr2hostname(addr.strip(),without_port)

		#print "hostname for addr "+addr+": "+str(hostname)

	def addr2hostname(self,addr,without_port=False):

			if without_port and peer.address.split(':')[0] == addr:

				hostname = peer.hostname

			self.address = ''.join(received['receiver'][0])

				self.address = ''.join(sent['sender'][0])

	return filename.split('.')[0][-10:]

#	if is_source_from_filename(filename):

#		return filename[25:35]

#	else:

#		return filename[31:41]

nicks = {}

#		'0000000000c5_0058': 's0',\

#		'0000000000c5_0068': 's1',\

#		'0000000000c5_0066': 's2',\

#		'0000000000c5_0055': 's3',\

#		'0000000000c5_0067': 's4',\

#		'0000000000c5_0065': 's5',\

#		'0000000000c5_0057': 's6',\

#		'0000000000c5_0056': 's7',\

#		'0000000000c5_00ab': 's8',\

#		'0000000000c5_00aa': 's9',\

#		'0000000000c5_0082': 's10',\

#		'0000000000c5_008c': 's11',\

#		'0000000000c5_0080': 's12',\

#		'0000000000c5_00c6': 's13',\

#		'0000000000c5_0097': 's14',\

#		'0000000000c5_0096': 's15',\

#}

	if name:

		if name not in nicks.keys():

			return ("s"+name[-2:]+name[10:12]).lower()

		else:

			return nicks[name]

		return str(name)

#		func(*params) ## sequential execution, for DEBUG

#			print edge

			host1 = exp.addr2hostname(key2hostnames(edge)[0])

			host2 = exp.addr2hostname(key2hostnames(edge)[1])

#			print str(host1) + ' ' + str(host2)

					purify_hostname(host1)+","+ \

					purify_hostname(host2)+","+ \

					dst = purify_hostname(exp.addr2hostname(avgs.ix[i].name,without_port=True))

					dst = purify_hostname(exp.addr2hostname(avgs.ix[i].name,without_port=True))

#!/usr/bin/python

import getopt,os,sys

sys.path.insert(0,'lib')

from utilities import *

from peerstreamer_logs import *

import shutil as sh

import py_logs_analyzer as analyse

SESSION_TOLERANCE=15

SESSION_INDEPENDENT_KEYWORDS=['rtt','timespread']

def name_splitter(folder):

	session_groups = {}

	for logfile in os.listdir(folder):

		if is_source_from_filename(logfile):

			source_info = logfile.split('.')[0].split('_')

			if len(source_info) > 4:

				session_groups[time_from_filename(logfile)] = source_info[3]

			else:

				session_groups[time_from_filename(logfile)] = 'standard'

	return session_groups

def get_group(session_groups,time):

	group = None

	for keytime in session_groups.keys():

#		print "comparing  " + str(time) + " with " + str(int(keytime))

		if (int(time) < (int(keytime) + SESSION_TOLERANCE)) and \

				(int(time) > (int(keytime) - SESSION_TOLERANCE)):

			group = session_groups[keytime]

	return group

def session_independent(logfile):

	for elm in SESSION_INDEPENDENT_KEYWORDS:

		if elm in logfile:

			return True

	return False

def multiple_dst_copy(folder,logfile,dsts):

	for dst in dsts:

		sh.copy2(folder+'/'+logfile,dst)

def splitter(folder):

	session_groups = name_splitter(folder)

	for name in set(session_groups.values()):

		if not os.path.exists(folder+'/'+name):

			os.makedirs(folder+'/'+name)

	for logfile in os.listdir(folder):

		if os.path.isfile(folder+"/"+logfile):

			if session_independent(logfile):

				multiple_dst_copy(folder,logfile,[folder +'/'+ v for v in set(session_groups.values())])

			else:

				logtime = time_from_filename(logfile) 

				group = get_group(session_groups,logtime)

				if group == None:

					print "[ERROR] group not found for "+logfile

				else:

					newfolder = folder+'/'+group+'/'

					sh.move(folder+'/'+logfile,newfolder+logfile)

def main(argv):

	try:

		opts,args = getopt.getopt(argv,"hf:",["help","folder"])

	except getopt.GetoptError:

		sys.exit(2)

	for opt,arg in opts:

		if opt in ("-h","--help"):

			sys.exit()

		elif opt in ("-f","--folder"):

			folder = arg

	try:

		folder

	except NameError:

		print "please provide a folder path"

		sys.exit()

	print "folder is " + folder

	splitter(folder)

	analyse.main(['-f',folder])

if __name__ == "__main__":

	main(sys.argv[1:])	

			plotHeatMap(chunkmat,maxv=maxv,min_color='w',xlab="Chunks sender",ylab="Chunks receiver",tit="Chunk exchanged among slivers in session "+str(session_id_shortner(session)))

#			levels=7