ProPeler
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
cpanel-ccs
/
contrib
/
tools
/
Filename :
protocolanalysis.py
back
Copy
#!/usr/bin/env python ## # Copyright (c) 2009-2017 Apple Inc. All rights reserved. # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. ## from __future__ import print_function from gzip import GzipFile import collections import datetime import getopt import os import socket import sys import tables import traceback import glob from calendarserver.logAnalysis import getAdjustedMethodName, METHOD_PUT_ICS, \ METHOD_PUT_ORGANIZER, METHOD_PUT_ATTENDEE, METHOD_PROPFIND_CALENDAR, \ METHOD_POST_FREEBUSY, METHOD_POST_ORGANIZER, METHOD_POST_ISCHEDULE_FREEBUSY, \ METHOD_POST_ISCHEDULE, METHOD_GET_DROPBOX, METHOD_PROPFIND_CALENDAR_HOME, \ METHOD_PROPFIND_CACHED_CALENDAR_HOME, METHOD_PROPFIND_ADDRESSBOOK_HOME, \ METHOD_PROPFIND_CACHED_ADDRESSBOOK_HOME, METHOD_PROPFIND_PRINCIPALS, \ METHOD_PROPFIND_CACHED_PRINCIPALS def safePercent(x, y, multiplier=100): return ((multiplier * x) / y) if y else 0 responseCountBuckets = ( (10, "(a):0-10"), (100, "(b):11-100"), (250, "(c):101-250"), (500, "(d):251-500"), (1000, "(e):501-1000"), (2500, "(f):1001-2500"), (5000, "(g):2501-5000"), (None, "(h):5001+"), ) requestSizeBuckets = ( (1000, "(a):0-1KB"), (2500, "(b):1-2.5KB"), (5000, "(c):2.5-5KB"), (10000, "(d):5-10KB"), (100000, "(e):10-100KB"), (1000000, "(f):100KB-1MB"), (10000000, "(g):1-10MB"), (100000000, "(h):10-100MB"), (None, "(i):100+MB"), ) responseSizeBuckets = ( (1000, "(a):0-1KB"), (5000, "(b):1-2.5KB"), (5000, "(c):2.5-5KB"), (10000, "(d):5-10KB"), (100000, "(e):10-100KB"), (1000000, "(f):100KB-1MB"), (10000000, "(g):1-10MB"), (None, "(h):10+MB"), ) requestTimeBuckets = ( (10, "(a):0-10ms"), (50, "(b):10-50ms"), (100, "(c):50-100ms"), (250, "(d):100-250ms"), (500, "(e):250-500ms"), (1000, "(f):500ms-1s"), (5000, "(g):1-5s"), (10000, "(h):5-10s"), (30000, "(i):10-30s"), (60000, "(j):30-60s"), (120000, "(k):60-120s"), (None, "(l):120s+"), ) userInteractionCountBuckets = ( (0, "(a):0"), (1, "(b):1"), (2, "(c):2"), (3, "(d):3"), (4, "(e):4"), (5, "(f):5"), (10, "(g):6-10"), (15, "(h):11-15"), (20, "(i):16-20"), (30, "(j):21-30"), (50, "(k):31-50"), (None, "(l):51+"), ) httpMethods = set(( "ACL", "BIND", "CONNECT", "COPY", "DELETE", "GET", "HEAD", "MKCALENDAR", "MKCOL", "MOVE", "OPTIONS", "POST", "PROPFIND", "PROPPATCH", "PUT", "REPORT", "SEARCH", )) # 401s METHOD_401 = "Z 401s" class CalendarServerLogAnalyzer(object): """ @ivar resolutionMinutes: The number of minutes long a statistics bucket will be. For example, if this is C{5}, then all data points less than 5 will be placed into the first bucket; data points greater than or equal to 5 and less than 10 will be placed into the second bucket, and so on. @ivar timeBucketCount: The number of statistics buckets of length C{resolutionMinutes} needed to hold one day of data. @ivar hourlyTotals: A C{list} of length C{timeBucketCount} holding ... """ class LogLine(object): def __init__(self, ipaddr, userid, logDateTime, logTime, method, uri, status, reqbytes, referer, client, extended): self.ipaddr = ipaddr self.userid = userid self.logDateTime = logDateTime self.logTime = logTime self.method = method self.uri = uri self.status = status self.bytes = reqbytes self.referer = referer self.client = client self.extended = extended def __init__( self, startHour=None, endHour=None, utcoffset=0, resolutionMinutes=60, filterByUser=None, filterByClient=None, ignoreNonHTTPMethods=True, separate401s=True, ): self.startHour = startHour self.endHour = endHour self.utcoffset = utcoffset self.adjustHour = None self.filterByUser = filterByUser self.filterByClient = filterByClient self.ignoreNonHTTPMethods = ignoreNonHTTPMethods self.separate401s = separate401s self.startTime = datetime.datetime.now().replace(microsecond=0) self.host = socket.getfqdn() self.startLog = "" self.endLog = "" self.resolutionMinutes = resolutionMinutes self.timeBucketCount = (24 * 60) / resolutionMinutes self.loggedUTCOffset = None self.hourlyTotals = [[0, 0, 0, collections.defaultdict(int), 0.0, ] for _ignore in xrange(self.timeBucketCount)] self.clientTotals = collections.defaultdict(lambda: [0, set(), set()]) self.clientIDMap = {} self.clientByMethodCount = collections.defaultdict(lambda: collections.defaultdict(int)) self.clientIDByMethodCount = {} self.clientByMethodTotalTime = collections.defaultdict(lambda: collections.defaultdict(float)) self.clientByMethodAveragedTime = collections.defaultdict(lambda: collections.defaultdict(float)) self.statusByMethodCount = collections.defaultdict(lambda: collections.defaultdict(int)) self.hourlyByMethodCount = collections.defaultdict(lambda: [0, ] * self.timeBucketCount) self.hourlyByOKMethodCount = collections.defaultdict(lambda: [0, ] * self.timeBucketCount) self.hourlyByMethodTime = collections.defaultdict(lambda: [0.0, ] * self.timeBucketCount) self.hourlyByOKMethodTime = collections.defaultdict(lambda: [0.0, ] * self.timeBucketCount) self.averagedHourlyByMethodTime = collections.defaultdict(lambda: [0.0, ] * self.timeBucketCount) self.averagedHourlyByOKMethodTime = collections.defaultdict(lambda: [0.0, ] * self.timeBucketCount) self.hourlyPropfindByResponseCount = collections.defaultdict(lambda: [0, ] * self.timeBucketCount) self.hourlyByStatus = collections.defaultdict(lambda: [0, ] * self.timeBucketCount) self.hourlyByRecipientCount = collections.defaultdict(lambda: [[0, 0] for _ignore in xrange(self.timeBucketCount)]) self.averagedHourlyByRecipientCount = collections.defaultdict(lambda: [0, ] * self.timeBucketCount) self.responseTimeVsQueueDepth = collections.defaultdict(lambda: [0, 0.0, ]) self.averagedResponseTimeVsQueueDepth = collections.defaultdict(int) self.instanceCount = collections.defaultdict(int) self.requestSizeByBucket = collections.defaultdict(lambda: [0, ] * self.timeBucketCount) self.responseSizeByBucket = collections.defaultdict(lambda: [0, ] * self.timeBucketCount) self.responseCountByMethod = collections.defaultdict(lambda: [0, 0]) self.requestTimeByBucket = collections.defaultdict(lambda: [0, ] * self.timeBucketCount) self.requestURI = collections.defaultdict(int) self.userWeights = collections.defaultdict(int) self.userCounts = collections.defaultdict(int) self.userResponseTimes = collections.defaultdict(float) self.newEvents = 0 self.newInvites = 0 self.updateEvents = 0 self.updateInvites = 0 self.attendeeInvites = 0 self.otherUserCalendarRequests = {} self.currentLine = None self.linesRead = collections.defaultdict(int) def analyzeLogFile(self, logFilePath): fpath = os.path.expanduser(logFilePath) if fpath.endswith(".gz"): f = GzipFile(fpath) else: f = open(fpath) effectiveStart = self.startHour if self.startHour is not None else 0 effectiveEnd = self.endHour if self.endHour is not None else 23 self.maxIndex = (effectiveEnd - effectiveStart + 1) * 60 / self.resolutionMinutes try: lineCtr = 0 for line in f: lineCtr += 1 if lineCtr <= self.linesRead[logFilePath]: continue self.linesRead[logFilePath] += 1 if line.startswith("Log"): continue try: self.parseLine(line) except: print("Could not parse line:\n%s" % (line,)) continue # Filter method if self.ignoreNonHTTPMethods and not self.currentLine.method.startswith("REPORT(") and not self.currentLine.method.startswith("POST(") and self.currentLine.method not in httpMethods: self.currentLine.method = "???" # Do hour ranges logHour = int(self.currentLine.logTime[0:2]) logMinute = int(self.currentLine.logTime[3:5]) if self.adjustHour is None: self.adjustHour = self.startHour if self.startHour is not None else logHour hourFromStart = logHour - self.adjustHour if hourFromStart < 0: hourFromStart += 24 if self.startHour is not None and logHour < self.startHour: continue elif self.endHour is not None and logHour > self.endHour: continue timeBucketIndex = (hourFromStart * 60 + logMinute) / self.resolutionMinutes if not self.startLog: self.startLog = self.currentLine.logDateTime self.endLog = self.currentLine.logDateTime # Filter on user id if self.filterByUser and self.currentLine.userid != self.filterByUser: continue # Filter on client adjustedClient = self.getClientAdjustedName() if self.filterByClient and adjustedClient.find(self.filterByClient) == -1: continue # Get some useful values is503 = self.currentLine.method == "???" isOK = self.currentLine.status / 100 == 2 adjustedMethod = self.getAdjustedMethodName() instance = self.currentLine.extended.get("i", "") responseTime = float(self.currentLine.extended.get("t", 0.0)) queueDepth = int(self.currentLine.extended.get("or", 0)) contentLength = int(self.currentLine.extended.get("cl", -1)) rcount = int(self.currentLine.extended.get("responses", -1)) if rcount == -1: rcount = int(self.currentLine.extended.get("rcount", -1)) # Main summary self.hourlyTotals[timeBucketIndex][0] += 1 self.hourlyTotals[timeBucketIndex][1] += 1 if is503 else 0 self.hourlyTotals[timeBucketIndex][2] += queueDepth self.hourlyTotals[timeBucketIndex][3][instance] = max(self.hourlyTotals[timeBucketIndex][3][instance], queueDepth) self.hourlyTotals[timeBucketIndex][4] += responseTime # Client analysis if not is503: self.clientTotals[" TOTAL"][0] += 1 self.clientTotals[" TOTAL"][1].add(self.currentLine.userid) self.clientTotals[" TOTAL"][2].add(self.currentLine.ipaddr) self.clientTotals[adjustedClient][0] += 1 self.clientTotals[adjustedClient][1].add(self.currentLine.userid) self.clientTotals[adjustedClient][2].add(self.currentLine.ipaddr) self.clientByMethodCount[" TOTAL"][" TOTAL"] += 1 self.clientByMethodCount[" TOTAL"][adjustedMethod] += 1 self.clientByMethodCount[adjustedClient][" TOTAL"] += 1 self.clientByMethodCount[adjustedClient][adjustedMethod] += 1 self.clientByMethodTotalTime[" TOTAL"][" TOTAL"] += responseTime self.clientByMethodTotalTime[" TOTAL"][adjustedMethod] += responseTime self.clientByMethodTotalTime[adjustedClient][" TOTAL"] += responseTime self.clientByMethodTotalTime[adjustedClient][adjustedMethod] += responseTime self.statusByMethodCount[" TOTAL"][" TOTAL"] += 1 self.statusByMethodCount[" TOTAL"][adjustedMethod] += 1 self.statusByMethodCount["2xx" if isOK else "%d" % (self.currentLine.status,)][" TOTAL"] += 1 self.statusByMethodCount["2xx" if isOK else "%d" % (self.currentLine.status,)][adjustedMethod] += 1 # Method counts, timing and status self.hourlyByMethodCount[" TOTAL"][timeBucketIndex] += 1 self.hourlyByMethodCount[adjustedMethod][timeBucketIndex] += 1 self.hourlyByOKMethodCount[" TOTAL"][timeBucketIndex] += 1 self.hourlyByOKMethodCount[adjustedMethod if isOK else METHOD_401][timeBucketIndex] += 1 self.hourlyByMethodTime[" TOTAL"][timeBucketIndex] += responseTime self.hourlyByMethodTime[adjustedMethod][timeBucketIndex] += responseTime self.hourlyByOKMethodTime[" TOTAL"][timeBucketIndex] += responseTime self.hourlyByOKMethodTime[adjustedMethod if isOK else METHOD_401][timeBucketIndex] += responseTime self.hourlyByStatus[" TOTAL"][timeBucketIndex] += 1 self.hourlyByStatus[self.currentLine.status][timeBucketIndex] += 1 if self.currentLine.status == 201: if adjustedMethod == METHOD_PUT_ICS: self.newEvents += 1 elif adjustedMethod == METHOD_PUT_ORGANIZER: self.newInvites += 1 elif isOK: if adjustedMethod == METHOD_PUT_ICS: self.updateEvents += 1 elif adjustedMethod == METHOD_PUT_ORGANIZER: self.updateInvites += 1 elif adjustedMethod == METHOD_PUT_ATTENDEE: self.attendeeInvites += 1 # Cache analysis if adjustedMethod == METHOD_PROPFIND_CALENDAR and self.currentLine.status == 207: responses = int(self.currentLine.extended.get("responses", 0)) self.hourlyPropfindByResponseCount[" TOTAL"][timeBucketIndex] += 1 self.hourlyPropfindByResponseCount[self.getCountBucket(responses, responseCountBuckets)][timeBucketIndex] += 1 # Scheduling analysis if adjustedMethod == METHOD_POST_FREEBUSY: recipients = int(self.currentLine.extended.get("recipients", 0)) self.hourlyByRecipientCount["Freebusy One Offs" if recipients == 1 else "Freebusy Average"][timeBucketIndex][0] += 1 self.hourlyByRecipientCount["Freebusy One Offs" if recipients == 1 else "Freebusy Average"][timeBucketIndex][1] += recipients self.hourlyByRecipientCount["Freebusy Max."][timeBucketIndex][0] = max(self.hourlyByRecipientCount["Freebusy Max."][timeBucketIndex][0], recipients) elif adjustedMethod == METHOD_POST_ORGANIZER: recipients = int(self.currentLine.extended.get("itip.request", 0)) + int(self.currentLine.extended.get("itip.cancel", 0)) self.hourlyByRecipientCount["iTIP Average"][timeBucketIndex][0] += 1 self.hourlyByRecipientCount["iTIP Average"][timeBucketIndex][1] += recipients self.hourlyByRecipientCount["iTIP Max."][timeBucketIndex][0] = max(self.hourlyByRecipientCount["iTIP Max."][timeBucketIndex][0], recipients) elif adjustedMethod == METHOD_PUT_ORGANIZER: recipients = int(self.currentLine.extended["itip.requests"]) self.hourlyByRecipientCount["iTIP Average"][timeBucketIndex][0] += 1 self.hourlyByRecipientCount["iTIP Average"][timeBucketIndex][1] += recipients self.hourlyByRecipientCount["iTIP Max."][timeBucketIndex][0] = max(self.hourlyByRecipientCount["iTIP Max."][timeBucketIndex][0], recipients) elif adjustedMethod == METHOD_POST_ISCHEDULE_FREEBUSY: recipients = int(self.currentLine.extended.get("recipients", 0)) self.hourlyByRecipientCount["iFreebusy One Offs" if recipients == 1 else "iFreebusy Average"][timeBucketIndex][0] += 1 self.hourlyByRecipientCount["iFreebusy One Offs" if recipients == 1 else "iFreebusy Average"][timeBucketIndex][1] += recipients self.hourlyByRecipientCount["iFreebusy Max."][timeBucketIndex][0] = max(self.hourlyByRecipientCount["iFreebusy Max."][timeBucketIndex][0], recipients) elif adjustedMethod == METHOD_POST_ISCHEDULE: recipients = int(self.currentLine.extended.get("recipients", 0)) + int(self.currentLine.extended.get("itip.request", 0)) + int(self.currentLine.extended.get("itip.cancel", 0)) self.hourlyByRecipientCount["iSchedule Average"][timeBucketIndex][0] += 1 self.hourlyByRecipientCount["iSchedule Average"][timeBucketIndex][1] += recipients self.hourlyByRecipientCount["iSchedule Max."][timeBucketIndex][0] = max(self.hourlyByRecipientCount["iSchedule Max."][timeBucketIndex][0], recipients) # Queue depth analysis self.responseTimeVsQueueDepth[queueDepth][0] += 1 self.responseTimeVsQueueDepth[queueDepth][1] += responseTime # Instance counts self.instanceCount[instance] += 1 # Request/response size analysis if contentLength != -1: self.requestSizeByBucket[" TOTAL"][timeBucketIndex] += 1 self.requestSizeByBucket[self.getCountBucket(contentLength, requestSizeBuckets)][timeBucketIndex] += 1 if adjustedMethod != METHOD_GET_DROPBOX: self.responseSizeByBucket[" TOTAL"][timeBucketIndex] += 1 self.responseSizeByBucket[self.getCountBucket(self.currentLine.bytes, responseSizeBuckets)][timeBucketIndex] += 1 if rcount != -1: self.responseCountByMethod[" TOTAL"][0] += rcount self.responseCountByMethod[" TOTAL"][1] += 1 self.responseCountByMethod[adjustedMethod][0] += rcount self.responseCountByMethod[adjustedMethod][1] += 1 # Request time analysis self.requestTimeByBucket[" TOTAL"][timeBucketIndex] += 1 self.requestTimeByBucket[self.getCountBucket(responseTime, requestTimeBuckets)][timeBucketIndex] += 1 # Request URI analysis self.requestURI[self.currentLine.uri] += 1 self.userAnalysis(adjustedMethod) # Look at interactions between different users self.userInteractionAnalysis(adjustedMethod) except Exception: print("Failed to process line:\n%s" % (line,)) raise finally: f.close() # Average various items self.averagedHourlyByMethodTime.clear() for method, hours in self.hourlyByMethodTime.iteritems(): counts = self.hourlyByMethodCount[method] for hour in xrange(self.timeBucketCount): if counts[hour]: newValue = hours[hour] / counts[hour] else: newValue = hours[hour] self.averagedHourlyByMethodTime[method][hour] = newValue self.averagedHourlyByOKMethodTime.clear() for method, hours in self.hourlyByOKMethodTime.iteritems(): counts = self.hourlyByOKMethodCount[method] for hour in xrange(self.timeBucketCount): if counts[hour]: newValue = hours[hour] / counts[hour] else: newValue = hours[hour] self.averagedHourlyByOKMethodTime[method][hour] = newValue self.averagedResponseTimeVsQueueDepth.clear() for k, v in self.responseTimeVsQueueDepth.iteritems(): self.averagedResponseTimeVsQueueDepth[k] = (v[0], v[1] / v[0],) self.averagedHourlyByRecipientCount.clear() for method, value in self.hourlyByRecipientCount.iteritems(): for hour in xrange(self.timeBucketCount): if method in ("Freebusy Average", "iTIP Average", "iFreebusy Average", "iSchedule Average",): newValue = ((1.0 * value[hour][1]) / value[hour][0]) if value[hour][0] != 0 else 0 else: newValue = value[hour][0] self.averagedHourlyByRecipientCount[method][hour] = newValue averaged = collections.defaultdict(int) for key, value in self.responseCountByMethod.iteritems(): averaged[key] = (value[0] / value[1]) if value[1] else 0 self.averageResponseCountByMethod = averaged for client, data in self.clientByMethodTotalTime.iteritems(): for method, totaltime in data.iteritems(): count = self.clientByMethodCount[client][method] self.clientByMethodAveragedTime[client][method] = totaltime / count if count else 0 self.clientIDMap = {} for ctr, client in enumerate(sorted(self.clientByMethodCount.keys(), key=lambda x: x.lower())): if ctr == 0: self.clientIDMap[client] = "Total" else: self.clientIDMap[client] = "ID-%02d" % (ctr,) self.clientIDByMethodCount = {} for client, data in self.clientByMethodCount.iteritems(): self.clientIDByMethodCount[self.clientIDMap[client]] = data def parseLine(self, line): startPos = line.find("- ") endPos = line.find(" [") ipaddr = line[0:startPos - 2] userid = line[startPos + 2:endPos] startPos = endPos + 1 logDateTime = line[startPos + 1:startPos + 21] logTime = line[startPos + 13:startPos + 21] if self.loggedUTCOffset is None: self.loggedUTCOffset = int(line[startPos + 22:startPos + 25]) startPos = line.find(']', startPos + 21) + 3 endPos = line.find(' ', startPos) if line[startPos] == '?': method = "???" uri = "" startPos += 5 else: method = line[startPos:endPos] startPos = endPos + 1 endPos = line.find(" HTTP/", startPos) uri = line[startPos:endPos] startPos = endPos + 11 status = int(line[startPos:startPos + 3]) startPos += 4 endPos = line.find(' ', startPos) reqbytes = int(line[startPos:endPos]) startPos = endPos + 2 endPos = line.find('"', startPos) # Handle "attacks" where double-quotes may appear in the string if line[endPos + 1] != ' ': endPos = line.find('"', endPos + 1) referrer = line[startPos:endPos] startPos = endPos + 3 endPos = line.find('"', startPos) client = line[startPos:endPos] startPos = endPos + 2 if line[startPos] == '[': extended = {} startPos += 1 endPos = line.find(' ', startPos) extended["t"] = line[startPos:endPos] startPos = endPos + 6 endPos = line.find(' ', startPos) extended["i"] = line[startPos:endPos] startPos = endPos + 1 endPos = line.find(']', startPos) extended["or"] = line[startPos:endPos] else: items = line[startPos:].split() extended = dict([item.split('=') for item in items if item.find("=") != -1]) self.currentLine = CalendarServerLogAnalyzer.LogLine(ipaddr, userid, logDateTime, logTime, method, uri, status, reqbytes, referrer, client, extended) def getClientAdjustedName(self): versionClients = ( "iCal/", "iPhone/", "iOS/", "CalendarAgent", "Calendar/", "CoreDAV/", "Safari/", "dataaccessd", "curl/", "DAVKit", ) for client in versionClients: index = self.currentLine.client.find(client) if index != -1: endex = self.currentLine.client.find(' ', index) if endex == -1: endex = len(self.currentLine.client) name = self.currentLine.client[index:endex] return name index = self.currentLine.client.find("calendarclient") if index != -1: code = self.currentLine.client[14] if code == 'A': return "iCal/3 sim" elif code == 'B': return "iPhone/3 sim" else: return "Simulator" quickclients = ( ("CardDAVPlugin/", "CardDAVPlugin"), ("Address%20Book/", "AddressBook"), ("AddressBook/", "AddressBook"), ("Mail/", "Mail"), ("iChat/", "iChat"), ("InterMapper/", "InterMapper"), ) for quick, result in quickclients: index = self.currentLine.client.find(quick) if index != -1: return result return self.currentLine.client[:20] def getAdjustedMethodName(self): return getAdjustedMethodName(self.currentLine.extended, self.currentLine.method, self.currentLine.uri) def getCountBucket(self, count, buckets): for limit, key in buckets: if limit is None: break if count <= limit: return key return key # Determine method weight 1 - 10 # weighting = { # "ACL": lambda x: 3, # "DELETE" : lambda x: 5, # "GET" : lambda x: 3 * (1 + x.bytes / (1024 * 1024)), # METHOD_GET_DROPBOX : lambda x: 3 * (1 + x.bytes / (1024 * 1024)), # "HEAD" : lambda x: 1, # "MKCALENDAR" : lambda x: 2, # "MKCOL" : lambda x: 2, # "MOVE" : lambda x: 3, # "OPTIONS" : lambda x: 1, # METHOD_POST_FREEBUSY : lambda x: 5 * int(x.extended.get("recipients", 1)), # METHOD_PUT_ORGANIZER : lambda x: 5 * int(x.extended.get("recipients", 1)), # METHOD_PUT_ATTENDEE : lambda x: 5 * int(x.extended.get("recipients", 1)), # "PROPFIND" : lambda x: 3 * int(x.extended.get("responses", 1)), # METHOD_PROPFIND_CALENDAR : lambda x: 5 * (int(math.log10(float(x.extended.get("responses", 1)))) + 1), # METHOD_PROPFIND_CALENDAR_HOME : lambda x: 5 * (int(math.log10(float(x.extended.get("responses", 1)))) + 1), # "PROPFIND inbox" : lambda x: 5 * (int(math.log10(float(x.extended.get("responses", 1)))) + 1), # METHOD_PROPFIND_PRINCIPALS : lambda x: 5 * (int(math.log10(float(x.extended.get("responses", 1)))) + 1), # METHOD_PROPFIND_CACHED_CALENDAR_HOME : lambda x: 2, # METHOD_PROPFIND_CACHED_PRINCIPALS : lambda x: 2, # "PROPPATCH" : lambda x: 4, # METHOD_PROPPATCH_CALENDAR : lambda x:8, # METHOD_PUT_ICS : lambda x: 4, # METHOD_PUT_ORGANIZER : lambda x: 8, # METHOD_PUT_ATTENDEE : lambda x: 6, # METHOD_PUT_DROPBOX : lambda x: 10, # "REPORT" : lambda x: 5, # METHOD_REPORT_CALENDAR_MULTIGET : lambda x: 5 * int(x.extended.get("rcount", 1)), # METHOD_REPORT_CALENDAR_QUERY : lambda x: 4 * int(x.extended.get("responses", 1)), # METHOD_REPORT_EXPAND_P : lambda x: 5, # "REPORT principal-match" : lambda x: 5, # } weighting = {} def userAnalysis(self, adjustedMethod): if self.currentLine.userid == "-": return # try: # self.userWeights[self.currentLine.userid] += self.weighting[adjustedMethod](self.currentLine) # except KeyError: # self.userWeights[self.currentLine.userid] += 5 self.userWeights[self.currentLine.userid] += 1 responseTime = float(self.currentLine.extended.get("t", 0.0)) self.userCounts["%s:%s" % (self.currentLine.userid, self.getClientAdjustedName(),)] += 1 self.userResponseTimes["%s:%s" % (self.currentLine.userid, self.getClientAdjustedName(),)] += responseTime def summarizeUserInteraction(self, adjustedMethod): summary = {} otherData = self.otherUserCalendarRequests.get(adjustedMethod, {}) for _ignore_user, others in otherData.iteritems(): bucket = self.getCountBucket(len(others), userInteractionCountBuckets) summary[bucket] = summary.get(bucket, 0) + 1 return summary def userInteractionAnalysis(self, adjustedMethod): """ If the current line is a record of one user accessing another user's data, update C{self.otherUserCalendarRequests} to account for it. """ forMethod = self.otherUserCalendarRequests.setdefault(adjustedMethod, {}) others = forMethod.setdefault(self.currentLine.userid, set()) segments = self.currentLine.uri.split('/') if segments[:3] == ['', 'calendars', '__uids__']: if segments[3:] != [self.currentLine.userid, '']: others.add(segments[3]) def printAll(self, doTabs, summary): self.printInfo(doTabs) print("Load Analysis") self.printHourlyTotals(doTabs, summary) if not summary: print("Client Analysis") self.printClientTotals(doTabs) print("Protocol Analysis Count") self.printHourlyByXXXDetails( self.hourlyByOKMethodCount if self.separate401s else self.hourlyByMethodCount, doTabs, ) print("Protocol Analysis Average Response Time (ms)") self.printHourlyByXXXDetails( self.averagedHourlyByOKMethodTime if self.separate401s else self.averagedHourlyByMethodTime, doTabs, showAverages=True, ) print("Protocol Analysis Total Response Time (ms)") self.printHourlyByXXXDetails( self.hourlyByOKMethodTime if self.separate401s else self.hourlyByMethodTime, doTabs, showFloatPercent=True, ) print("Status Code Analysis") self.printHourlyByXXXDetails(self.hourlyByStatus, doTabs) print("Protocol Analysis by Status") self.printXXXMethodDetails(self.statusByMethodCount, doTabs, False) print("Cache Analysis") self.printHourlyCacheDetails(doTabs) if len(self.hourlyPropfindByResponseCount): print("PROPFIND Calendar response count distribution") self.printHourlyByXXXDetails(self.hourlyPropfindByResponseCount, doTabs) if len(self.averagedHourlyByRecipientCount): print("Average Recipient Counts") self.printHourlyByXXXDetails(self.averagedHourlyByRecipientCount, doTabs, showTotals=False) print("Queue Depth vs Response Time") self.printQueueDepthResponseTime(doTabs) print("Instance Count Distribution") self.printInstanceCount(doTabs) print("Protocol Analysis by Client") self.printXXXMethodDetails(self.clientIDByMethodCount, doTabs) if len(self.requestSizeByBucket): print("Request size distribution") self.printHourlyByXXXDetails(self.requestSizeByBucket, doTabs) if len(self.responseSizeByBucket): print("Response size distribution (excluding GET Dropbox)") self.printHourlyByXXXDetails(self.responseSizeByBucket, doTabs) if len(self.averageResponseCountByMethod): print("Average response count by method") self.printResponseCounts(doTabs) if len(self.requestTimeByBucket): print("Response time distribution") self.printHourlyByXXXDetails(self.requestTimeByBucket, doTabs) print("URI Counts") self.printURICounts(doTabs) # print("User Interaction Counts") # self.printUserInteractionCounts(doTabs) print("User Weights (top 100)") self.printUserWeights(doTabs) # print("User Response times") # self.printUserResponseTimes(doTabs) print("Sim values") self.printSimStats(doTabs) def printInfo(self, doTabs): table = tables.Table() table.addRow(("Run on:", self.startTime.isoformat(' '),)) table.addRow(("Host:", self.host,)) table.addRow(("First Log Entry:", self.startLog,)) table.addRow(("Last Log Entry:", self.endLog,)) if self.filterByUser: table.addRow(("Filtered to user:", self.filterByUser,)) if self.filterByClient: table.addRow(("Filtered to client:", self.filterByClient,)) table.addRow(("Lines Analyzed:", sum(self.linesRead.values()),)) table.printTabDelimitedData() if doTabs else table.printTable() print("") def getHourFromIndex(self, index): if index >= self.maxIndex: return None totalminutes = index * self.resolutionMinutes offsethour, minute = divmod(totalminutes, 60) localhour = divmod(offsethour + self.adjustHour + self.utcoffset, 24)[1] utchour = divmod(localhour - self.loggedUTCOffset - self.utcoffset, 24)[1] # Clip to select hour range return "%02d:%02d (%02d:%02d)" % (localhour, minute, utchour, minute,) def printHourlyTotals(self, doTabs, summary): table = tables.Table() table.addHeader( ("Local (UTC)", "Total", "Av. Requests", "Av. Response", "Av. Queue",) ) table.addHeader( ("", "Requests", "Per Second", "Time(ms)", "Depth") ) table.setDefaultColumnFormats( ( tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), tables.Table.ColumnFormat("%d", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%.1f", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%.1f", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%.2f", tables.Table.ColumnFormat.RIGHT_JUSTIFY), ) ) totalRequests = 0 totalDepth = 0 totalTime = 0.0 self.timeCounts = 0 for ctr in xrange(self.timeBucketCount): hour = self.getHourFromIndex(ctr) if hour is None: continue value = self.hourlyTotals[ctr] countRequests, _ignore503, countDepth, _igniore_maxDepth, countTime = value table.addRow( ( hour, countRequests, (1.0 * countRequests) / self.resolutionMinutes / 60, safePercent(countTime, countRequests, 1.0), safePercent(float(countDepth), countRequests, 1), ) ) totalRequests += countRequests totalDepth += countDepth totalTime += countTime self.timeCounts += 1 table.addFooter( ( "Total:", totalRequests, safePercent(totalRequests, self.timeCounts * self.resolutionMinutes * 60, 1.0), safePercent(totalTime, totalRequests, 1.0), safePercent(float(totalDepth), totalRequests, 1), ), columnFormats=( tables.Table.ColumnFormat("%s"), tables.Table.ColumnFormat("%d", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%.1f", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%.1f", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%.2f", tables.Table.ColumnFormat.RIGHT_JUSTIFY), ) ) table.printTabDelimitedData() if doTabs else table.printTable() print("") def printClientTotals(self, doTabs): table = tables.Table() table.setDefaultColumnFormats(( tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.LEFT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.LEFT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), )) table.addHeader(("ID", "Client", "Total", "Unique", "Unique")) table.addHeader(("", "", "", "Users", "IP addrs")) for title, clientData in sorted(self.clientTotals.iteritems(), key=lambda x: x[0].lower()): if title == " TOTAL": continue table.addRow(( "%s" % (self.clientIDMap[title],), title, "%d (%2d%%)" % (clientData[0], safePercent(clientData[0], self.clientTotals[" TOTAL"][0]),), "%d (%2d%%)" % (len(clientData[1]), safePercent(len(clientData[1]), len(self.clientTotals[" TOTAL"][1])),), "%d (%2d%%)" % (len(clientData[2]), safePercent(len(clientData[2]), len(self.clientTotals[" TOTAL"][2])),), )) table.addFooter(( "All", "", "%d " % (self.clientTotals[" TOTAL"][0],), "%d " % (len(self.clientTotals[" TOTAL"][1]),), "%d " % (len(self.clientTotals[" TOTAL"][2]),), )) table.printTabDelimitedData() if doTabs else table.printTable() print("") def printHourlyByXXXDetails(self, hourlyByXXX, doTabs, showTotals=True, showAverages=False, showFloatPercent=False): totals = [(0, 0,)] * len(hourlyByXXX) table = tables.Table() headers = [["Local (UTC)", ], ["", ], ["", ], ["", ], ] use_headers = [True, False, False, False] formats = [tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), ] for k in sorted(hourlyByXXX.keys(), key=lambda x: str(x).lower()): if type(k) is str: if k[0] == ' ': k = k[1:] ks = k.split(" ") headers[0].append(ks[0]) if len(ks) > 1: headers[1].append(ks[1]) use_headers[1] = use_headers[1] or headers[1][-1] else: headers[1].append("") if len(ks) > 2: headers[2].append(ks[2]) use_headers[2] = use_headers[2] or headers[2][-1] else: headers[2].append("") if len(ks) > 3: headers[3].append(ks[3]) use_headers[3] = use_headers[3] or headers[3][-1] else: headers[3].append("") else: headers[0].append(k) headers[1].append("") headers[2].append("") headers[3].append("") formats.append(tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY)) table.addHeader(headers[0]) if use_headers[1]: table.addHeader(headers[1]) if use_headers[2]: table.addHeader(headers[2]) if use_headers[3]: table.addHeader(headers[3]) table.setDefaultColumnFormats(formats) for ctr in xrange(self.timeBucketCount): row = ["-"] * (len(hourlyByXXX) + 1) row[0] = self.getHourFromIndex(ctr) if row[0] is None: continue for colctr, items in enumerate(sorted(hourlyByXXX.items(), key=lambda x: str(x[0]).lower())): _ignore, value = items data = value[ctr] if " TOTAL" in hourlyByXXX: total = hourlyByXXX[" TOTAL"][ctr] else: total = None if type(data) is int: if total is not None: row[colctr + 1] = "%d (%2d%%)" % (data, safePercent(data, total),) else: row[colctr + 1] = "%d" % (data,) if data: totals[colctr] = (totals[colctr][0] + data, totals[colctr][1] + 1,) elif type(data) is float: if total is not None and showFloatPercent: row[colctr + 1] = "%.1f (%2d%%)" % (data, safePercent(data, total),) else: row[colctr + 1] = "%.1f" % (data,) if data: totals[colctr] = (totals[colctr][0] + data, totals[colctr][1] + 1,) table.addRow(row) if showTotals or showAverages: row = ["-"] * (len(hourlyByXXX) + 1) row[0] = "Average:" if showAverages else "Total:" for colctr, totaldata in enumerate(totals): data, count = totaldata if type(data) is int: row[colctr + 1] = "%d (%2d%%)" % (data, safePercent(data, totals[0][0]),) elif type(data) is float: data = ((data / count) if count else 0.0) if showAverages else data if showFloatPercent: row[colctr + 1] = "%.1f (%2d%%)" % (data, safePercent(data, totals[0][0]),) else: row[colctr + 1] = "%.1f" % (data,) table.addFooter(row) table.printTabDelimitedData() if doTabs else table.printTable() print("") def printHourlyCacheDetails(self, doTabs): totals = [0, ] * 7 table = tables.Table() header1 = ["Local (UTC)", "PROPFIND Calendar Home", "", "PROPFIND Address Book Home", "", "PROPFIND Principals", ""] header2 = ["", "Uncached", "Cached", "Uncached", "Cached", "Uncached", "Cached"] formats = [ tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), ] table.addHeader(header1, columnFormats=[ tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY, span=2), None, tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY, span=2), None, tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY, span=2), None, ]) table.addHeaderDivider(skipColumns=(0,)) table.addHeader(header2, columnFormats=[ tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), ]) table.setDefaultColumnFormats(formats) for ctr in xrange(self.timeBucketCount): hour = self.getHourFromIndex(ctr) if hour is None: continue row = [] row.append(hour) calHomeUncached = self.hourlyByOKMethodCount[METHOD_PROPFIND_CALENDAR_HOME][ctr] calHomeCached = self.hourlyByOKMethodCount[METHOD_PROPFIND_CACHED_CALENDAR_HOME][ctr] calHomeTotal = calHomeUncached + calHomeCached adbkHomeUncached = self.hourlyByOKMethodCount[METHOD_PROPFIND_ADDRESSBOOK_HOME][ctr] adbkHomeCached = self.hourlyByOKMethodCount[METHOD_PROPFIND_CACHED_ADDRESSBOOK_HOME][ctr] adbkHomeTotal = adbkHomeUncached + adbkHomeCached principalUncached = self.hourlyByOKMethodCount[METHOD_PROPFIND_PRINCIPALS][ctr] principalCached = self.hourlyByOKMethodCount[METHOD_PROPFIND_CACHED_PRINCIPALS][ctr] principalTotal = principalUncached + principalCached row.append("%d (%2d%%)" % (calHomeUncached, safePercent(calHomeUncached, calHomeTotal),)) row.append("%d (%2d%%)" % (calHomeCached, safePercent(calHomeCached, calHomeTotal),)) row.append("%d (%2d%%)" % (adbkHomeUncached, safePercent(adbkHomeUncached, adbkHomeTotal),)) row.append("%d (%2d%%)" % (adbkHomeCached, safePercent(adbkHomeCached, adbkHomeTotal),)) row.append("%d (%2d%%)" % (principalUncached, safePercent(principalUncached, principalTotal),)) row.append("%d (%2d%%)" % (principalCached, safePercent(principalCached, principalTotal),)) totals[1] += calHomeUncached totals[2] += calHomeCached totals[3] += adbkHomeUncached totals[4] += adbkHomeCached totals[5] += principalUncached totals[6] += principalCached table.addRow(row) row = [] row.append("Total:") row.append("%d (%2d%%)" % (totals[1], safePercent(totals[1], totals[1] + totals[2]),)) row.append("%d (%2d%%)" % (totals[2], safePercent(totals[2], totals[1] + totals[2]),)) row.append("%d (%2d%%)" % (totals[3], safePercent(totals[3], totals[3] + totals[4]),)) row.append("%d (%2d%%)" % (totals[4], safePercent(totals[4], totals[3] + totals[4]),)) row.append("%d (%2d%%)" % (totals[5], safePercent(totals[5], totals[5] + totals[6]),)) row.append("%d (%2d%%)" % (totals[6], safePercent(totals[6], totals[5] + totals[6]),)) table.addFooter(row) table.printTabDelimitedData() if doTabs else table.printTable() print("") def printQueueDepthResponseTime(self, doTabs): table = tables.Table() table.setDefaultColumnFormats(( tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), )) table.addHeader(("Queue Depth", "Av. Response Time (ms)", "Number")) for k, v in sorted(self.averagedResponseTimeVsQueueDepth.iteritems(), key=lambda x: x[0]): table.addRow(( "%d" % (k,), "%.1f" % (v[1],), "%d" % (v[0],), )) table.printTabDelimitedData() if doTabs else table.printTable() print("") def printXXXMethodDetails(self, data, doTabs, verticalTotals=True): table = tables.Table() header = ["Method", ] formats = [tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.LEFT_JUSTIFY), ] for k in sorted(data.keys(), key=lambda x: x.lower()): header.append(k) formats.append(tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY)) table.addHeader(header) table.setDefaultColumnFormats(formats) # Get full set of methods methods = set() for v in data.itervalues(): methods.update(v.keys()) for method in sorted(methods): if method == " TOTAL": continue row = [] row.append(method) for k, v in sorted(data.iteritems(), key=lambda x: x[0].lower()): total = v[" TOTAL"] if verticalTotals else data[" TOTAL"][method] row.append("%d (%2d%%)" % (v[method], safePercent(v[method], total),)) table.addRow(row) row = [] row.append("Total:") for k, v in sorted(data.iteritems(), key=lambda x: x[0].lower()): row.append("%d" % (v[" TOTAL"],)) table.addFooter(row) table.printTabDelimitedData() if doTabs else table.printTable() print("") def printInstanceCount(self, doTabs): total = sum(self.instanceCount.values()) table = tables.Table() table.addHeader(("Instance ID", "Count", "%% Total",)) table.setDefaultColumnFormats(( tables.Table.ColumnFormat("%d", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%d", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%.1f%%%%", tables.Table.ColumnFormat.RIGHT_JUSTIFY), )) # Top 100 only def safeIntKey(v): try: return int(v[0]) except ValueError: return -1 for key, value in sorted(self.instanceCount.iteritems(), key=safeIntKey): table.addRow(( key, value, safePercent(value, total, 1000.0), )) table.printTabDelimitedData() if doTabs else table.printTable() print("") def printURICounts(self, doTabs): total = sum(self.requestURI.values()) table = tables.Table() table.addHeader(("Request URI", "Count", "%% Total",)) table.setDefaultColumnFormats(( tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.LEFT_JUSTIFY), tables.Table.ColumnFormat("%d", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%.1f%%%%", tables.Table.ColumnFormat.RIGHT_JUSTIFY), )) # Top 100 only for key, value in sorted(self.requestURI.iteritems(), key=lambda x: x[1], reverse=True)[:100]: table.addRow(( key, value, safePercent(value, total, 1000.0), )) table.printTabDelimitedData() if doTabs else table.printTable() print("") def printUserWeights(self, doTabs): total = sum(self.userWeights.values()) table = tables.Table() table.addHeader(("User ID", "Weight", "%% Total",)) table.setDefaultColumnFormats(( tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), tables.Table.ColumnFormat("%d", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%.1f%%%%", tables.Table.ColumnFormat.RIGHT_JUSTIFY), )) # Top 100 only for key, value in sorted(self.userWeights.iteritems(), key=lambda x: x[1], reverse=True)[:100]: table.addRow(( key, value, safePercent(value, total, 1000.0), )) table.printTabDelimitedData() if doTabs else table.printTable() print("") def printResponseCounts(self, doTabs): table = tables.Table() table.addHeader(("Method", "Av. Response Count",)) table.setDefaultColumnFormats(( tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.LEFT_JUSTIFY), tables.Table.ColumnFormat("%d", tables.Table.ColumnFormat.RIGHT_JUSTIFY), )) for method, value in sorted(self.averageResponseCountByMethod.iteritems(), key=lambda x: x[0]): if method == " TOTAL": continue table.addRow(( method, value, )) table.addFooter(("Total:", self.averageResponseCountByMethod[" TOTAL"],)) table.printTabDelimitedData() if doTabs else table.printTable() print("") def printUserResponseTimes(self, doTabs): totalCount = 0 averages = {} for user in self.userResponseTimes.keys(): count = self.userCounts[user] total = self.userResponseTimes[user] averages[user] = total / count totalCount += total table = tables.Table() table.addHeader(("User ID/Client", "Av. Response (ms)", "%% Total",)) table.setDefaultColumnFormats(( tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), tables.Table.ColumnFormat("%d", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%.1f%%%%", tables.Table.ColumnFormat.RIGHT_JUSTIFY), )) for key, value in sorted(averages.iteritems(), key=lambda x: x[1], reverse=True): table.addRow(( key, value, safePercent(value, total, 1000.0), )) table.printTabDelimitedData() if doTabs else table.printTable() print("") def printUserInteractionCounts(self, doTabs): table = tables.Table() table.setDefaultColumnFormats(( tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%0.2f", tables.Table.ColumnFormat.RIGHT_JUSTIFY), )) table.addHeader(("# users accessed", "# of users", "% of users")) summary = self.summarizeUserInteraction(METHOD_PROPFIND_CALENDAR_HOME) total = sum(summary.values()) for k, v in sorted(summary.iteritems()): # Chop off the "(a):" part. table.addRow((k[4:], v, safePercent(float(v), total))) table.printTabDelimitedData() if doTabs else table.printTable() print("") def printSimStats(self, doTabs): users = len(self.userCounts.keys()) hours = self.timeCounts / self.resolutionMinutes / 60 table = tables.Table() table.setDefaultColumnFormats(( tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), )) table.addHeader(("Item", "Value", "Items, per User, per Day", "Interval (sec), per item, per user")) table.addRow(("Unique Users", users, "", "")) def _addRow(title, item): table.addRow((title, item, "%.1f" % (safePercent(24 * item, hours * users, 1.0),), "%.1f" % (safePercent(hours * 60 * 60 * users, item, 1.0),),)) _addRow("New Events", self.newEvents) _addRow("New Invites", self.newInvites) _addRow("Updated Events", self.updateEvents) _addRow("Updated Invites", self.updateInvites) _addRow("Attendee Invites", self.attendeeInvites) table.addRow(( "Recipients", "%.1f" % (safePercent(sum(self.averagedHourlyByRecipientCount["iTIP Average"]), self.timeCounts, 1.0),), "", "", )) table.printTabDelimitedData() if doTabs else table.printTable() print("") class TablePrinter(object): @classmethod def printDictDictTable(cls, data, doTabs): table = tables.Table() header = ["", ] formats = [tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.LEFT_JUSTIFY), ] for k in sorted(data.keys(), key=lambda x: x.lower()): header.append(k) formats.append(tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY)) table.addHeader(header) table.setDefaultColumnFormats(formats) # Get full set of row names rowNames = set() for v in data.itervalues(): rowNames.update(v.keys()) for rowName in sorted(rowNames): if rowName == " TOTAL": continue row = [] row.append(rowName) for k, v in sorted(data.iteritems(), key=lambda x: x[0].lower()): value = v[rowName] if type(value) is str: row.append(value) else: if type(value) is float: fmt = "%.1f" else: fmt = "%d" if " TOTAL" in v: total = v[" TOTAL"] row.append((fmt + " (%2d%%)") % (value, safePercent(value, total),)) else: row.append(fmt % (value,)) table.addRow(row) if " TOTAL" in rowNames: row = [] row.append("Total:") for k, v in sorted(data.iteritems(), key=lambda x: x[0].lower()): value = v[" TOTAL"] if type(value) is str: fmt = "%s" elif type(value) is float: fmt = "%.1f" else: fmt = "%d" row.append(fmt % (value,)) table.addFooter(row) table.printTabDelimitedData() if doTabs else table.printTable() print("") class Differ(TablePrinter): def __init__(self, analyzers): self.analyzers = analyzers def printAll(self, doTabs, summary): self.printInfo(doTabs) print("Load Analysis Differences") # self.printLoadAnalysisDetails(doTabs) self.printHourlyTotals(doTabs) if not summary: print("Client Differences") self.printClientTotals(doTabs) print("Protocol Count Differences") self.printMethodCountDetails(doTabs) print("Average Response Time Differences") self.printMethodTimingDetails("clientByMethodAveragedTime", doTabs) print("Total Response Time Differences") self.printMethodTimingDetails("clientByMethodTotalTime", doTabs) print("Average Response Count Differences") self.printResponseCountDetails(doTabs) def printInfo(self, doTabs): table = tables.Table() table.addRow(("Run on:", self.analyzers[0].startTime.isoformat(' '),)) table.addRow(("Host:", self.analyzers[0].host,)) for ctr, analyzer in enumerate(self.analyzers): table.addRow(("Log Start #%d:" % (ctr + 1,), analyzer.startLog,)) if self.analyzers[0].filterByUser: table.addRow(("Filtered to user:", self.analyzers[0].filterByUser,)) table.printTabDelimitedData() if doTabs else table.printTable() print("") def printLoadAnalysisDetails(self, doTabs): # First gather all the data byCategory = collections.defaultdict(lambda: collections.defaultdict(str)) firstData = [] lastData = [] for ctr, analyzer in enumerate(self.analyzers): title = "#%d %s" % (ctr + 1, analyzer.startLog[0:11],) totalRequests = 0 totalTime = 0.0 for ctr2 in xrange(analyzer.timeBucketCount): hour = analyzer.getHourFromIndex(ctr2) if hour is None: continue value = analyzer.hourlyTotals[ctr2] countRequests, _ignore503, _ignore_countDepth, _ignore_maxDepth, countTime = value totalRequests += countRequests totalTime += countTime byCategory[title]["#1 Total Requests"] = "%d" % (totalRequests,) byCategory[title]["#2 Av. Response Time (ms)"] = "%.1f" % (safePercent(totalTime, totalRequests, 1.0),) if ctr == 0: firstData = (totalRequests, safePercent(totalTime, totalRequests, 1.0),) lastData = (totalRequests, safePercent(totalTime, totalRequests, 1.0),) title = "Difference" byCategory[title]["#1 Total Requests"] = "%+d (%+.1f%%)" % (lastData[0] - firstData[0], safePercent(lastData[0] - firstData[0], firstData[0], 100.0),) byCategory[title]["#2 Av. Response Time (ms)"] = "%+.1f (%+.1f%%)" % (lastData[1] - firstData[1], safePercent(lastData[1] - firstData[1], firstData[1], 100.0),) self.printDictDictTable(byCategory, doTabs) def printHourlyTotals(self, doTabs): table = tables.Table() hdr1 = [""] hdr2 = ["Local (UTC)"] hdr3 = [""] fmt1 = [tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY)] fmt23 = [tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY)] for ctr, analyzer in enumerate(self.analyzers): title = "#%d %s" % (ctr + 1, analyzer.startLog[0:11],) hdr1.extend([title, "", ""]) hdr2.extend(["Total", "Av. Requests", "Av. Response"]) hdr3.extend(["Requests", "Per Second", "Time(ms)"]) fmt1.extend([ tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY, span=3), None, None, ]) fmt23.extend([ tables.Table.ColumnFormat(), tables.Table.ColumnFormat(), tables.Table.ColumnFormat(), ]) title = "Difference" hdr1.extend([title, "", ""]) hdr2.extend(["Total", "Av. Requests", "Av. Response"]) hdr3.extend(["Requests", "Per Second", "Time(ms)"]) fmt1.extend([ tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY, span=3), None, None, ]) fmt23.extend([ tables.Table.ColumnFormat(), tables.Table.ColumnFormat(), tables.Table.ColumnFormat(), ]) table.addHeader(hdr1, columnFormats=fmt1) table.addHeaderDivider() table.addHeader(hdr2, columnFormats=fmt23) table.addHeader(hdr3, columnFormats=fmt23) fmt = [tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY)] for ctr in range(len(self.analyzers) + 1): fmt.extend([ tables.Table.ColumnFormat("%d", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%.1f", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%.1f", tables.Table.ColumnFormat.RIGHT_JUSTIFY), ]) table.setDefaultColumnFormats(fmt) totalRequests = [0] * len(self.analyzers) totalTime = [0.0] * len(self.analyzers) for ctr in xrange(self.analyzers[0].timeBucketCount): hour = self.analyzers[0].getHourFromIndex(ctr) if hour is None: continue diffRequests = None diffRequestRate = None diffTime = None row = [hour] for ctr2, analyzer in enumerate(self.analyzers): value = analyzer.hourlyTotals[ctr] countRequests, _ignore503, _ignore_countDepth, _ignore_maxDepth, countTime = value requestRate = (1.0 * countRequests) / analyzer.resolutionMinutes / 60 averageTime = safePercent(countTime, countRequests, 1.0) row.extend([ countRequests, requestRate, averageTime, ]) totalRequests[ctr2] += countRequests totalTime[ctr2] += countTime diffRequests = countRequests if diffRequests is None else countRequests - diffRequests diffRequestRate = requestRate if diffRequestRate is None else requestRate - diffRequestRate diffTime = averageTime if diffTime is None else averageTime - diffTime row.extend([ diffRequests, diffRequestRate, diffTime, ]) table.addRow(row) ftr = ["Total:"] diffRequests = None diffRequestRate = None diffTime = None for ctr, analyzer in enumerate(self.analyzers): requestRate = (1.0 * totalRequests[ctr]) / analyzer.resolutionMinutes / 60 averageTime = safePercent(totalTime[ctr], totalRequests[ctr], 1.0) ftr.extend([ totalRequests[ctr], requestRate, averageTime, ]) diffRequests = totalRequests[ctr] if diffRequests is None else totalRequests[ctr] - diffRequests diffRequestRate = requestRate if diffRequestRate is None else requestRate - diffRequestRate diffTime = averageTime if diffTime is None else averageTime - diffTime ftr.extend([ diffRequests, diffRequestRate, diffTime, ]) fmt = [tables.Table.ColumnFormat("%s")] for ctr in range(len(self.analyzers) + 1): fmt.extend([ tables.Table.ColumnFormat("%d", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%.1f", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%.1f", tables.Table.ColumnFormat.RIGHT_JUSTIFY), ]) table.addFooter(ftr, columnFormats=fmt) table.printTabDelimitedData() if doTabs else table.printTable() print("") def printClientTotals(self, doTabs): table = tables.Table() header1 = ["Client", ] header2 = ["", ] header1formats = [tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), ] header2formats = [tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), ] formats = [tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.LEFT_JUSTIFY), ] for ctr, analyzer in enumerate(self.analyzers): title = "#%d %s" % (ctr + 1, analyzer.startLog[0:11],) header1.extend((title, "")) header2.extend(("Total", "Unique",)) header1formats.extend(( tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY, span=2), None, )) header2formats.extend(( tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), )) formats.extend(( tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), )) header1.extend(("Difference", "")) header2.extend(("Total", "Unique",)) header1formats.extend(( tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY, span=2), None, )) header2formats.extend(( tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.CENTER_JUSTIFY), )) formats.extend(( tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), tables.Table.ColumnFormat("%s", tables.Table.ColumnFormat.RIGHT_JUSTIFY), )) table.addHeader(header1, columnFormats=header1formats) table.addHeaderDivider(skipColumns=(0,)) table.addHeader(header2, columnFormats=header2formats) table.setDefaultColumnFormats(formats) allClients = set() for analyzer in self.analyzers: allClients.update(analyzer.clientTotals.keys()) for title in sorted(allClients, key=lambda x: x.lower()): if title == " TOTAL": continue row = [title, ] for analyzer in self.analyzers: row.append("%d (%2d%%)" % (analyzer.clientTotals[title][0], safePercent(analyzer.clientTotals[title][0], analyzer.clientTotals[" TOTAL"][0]),)) row.append("%d (%2d%%)" % (len(analyzer.clientTotals[title][1]), safePercent(len(analyzer.clientTotals[title][1]), len(analyzer.clientTotals[" TOTAL"][1])),)) firstTotal = (self.analyzers[0].clientTotals[title][0], safePercent(self.analyzers[0].clientTotals[title][0], self.analyzers[0].clientTotals[" TOTAL"][0], 100.0),) firstUnique = (len(self.analyzers[0].clientTotals[title][1]), safePercent(len(self.analyzers[0].clientTotals[title][1]), len(self.analyzers[0].clientTotals[" TOTAL"][1]), 100.0,)) lastTotal = (self.analyzers[-1].clientTotals[title][0], safePercent(self.analyzers[-1].clientTotals[title][0], self.analyzers[-1].clientTotals[" TOTAL"][0], 100.0),) lastUnique = (len(self.analyzers[-1].clientTotals[title][1]), safePercent(len(self.analyzers[-1].clientTotals[title][1]), len(self.analyzers[-1].clientTotals[" TOTAL"][1]), 100.0,)) row.append("%+d (%+.1f%%)" % (lastTotal[0] - firstTotal[0], lastTotal[1] - firstTotal[1])) row.append("%+d (%+.1f%%)" % (lastUnique[0] - firstUnique[0], lastUnique[1] - firstUnique[1])) table.addRow(row) footer = ["All", ] for analyzer in self.analyzers: footer.append("%d " % (analyzer.clientTotals[" TOTAL"][0],)) footer.append("%d " % (len(analyzer.clientTotals[" TOTAL"][1]),)) firstTotal = self.analyzers[0].clientTotals[" TOTAL"][0] firstUnique = len(self.analyzers[0].clientTotals[" TOTAL"][1]) lastTotal = self.analyzers[-1].clientTotals[" TOTAL"][0] lastUnique = len(self.analyzers[-1].clientTotals[" TOTAL"][1]) footer.append("%+d (%+.1f%%)" % (lastTotal - firstTotal, safePercent(lastTotal - firstTotal, firstTotal, 100.0),)) footer.append("%+d (%+.1f%%)" % (lastUnique - firstUnique, safePercent(lastUnique - firstUnique, firstUnique, 100.0),)) table.addFooter(footer) table.printTabDelimitedData() if doTabs else table.printTable() print("") def printMethodCountDetails(self, doTabs): # First gather all the data allMethods = set() byMethod = collections.defaultdict(lambda: collections.defaultdict(int)) for ctr, analyzer in enumerate(self.analyzers): title = "#%d %s" % (ctr + 1, analyzer.startLog[0:11],) for method, value in analyzer.clientByMethodCount[" TOTAL"].iteritems(): byMethod[title][method] = value allMethods.add(method) title = "Difference" for method in allMethods: firstTotal = self.analyzers[0].clientByMethodCount[" TOTAL"].get(" TOTAL", 0) lastTotal = self.analyzers[-1].clientByMethodCount[" TOTAL"].get(" TOTAL", 0) if method == " TOTAL": byMethod[title][method] = "%+d (%+.1f%%)" % (lastTotal - firstTotal, safePercent(lastTotal - firstTotal, firstTotal, 100.0),) else: firstValue = self.analyzers[0].clientByMethodCount[" TOTAL"].get(method, 0) firstPercent = ((100.0 * firstValue) / firstTotal) if firstTotal != 0 else 0.0 lastValue = self.analyzers[-1].clientByMethodCount[" TOTAL"].get(method, 0) lastPercent = ((100.0 * lastValue) / lastTotal) if lastTotal != 0 else 0.0 byMethod[title][method] = "%+d (%+.1f%%)" % (lastValue - firstValue, lastPercent - firstPercent,) self.printDictDictTable(byMethod, doTabs) def printMethodTimingDetails(self, timingType, doTabs): # First gather all the data allMethods = set() byMethod = collections.defaultdict(lambda: collections.defaultdict(int)) for ctr, analyzer in enumerate(self.analyzers): title = "#%d %s" % (ctr + 1, analyzer.startLog[0:11],) for method, value in getattr(analyzer, timingType)[" TOTAL"].iteritems(): byMethod[title][method] = value allMethods.add(method) title1 = "1. Difference" title2 = "2. % Difference" title3 = "3. % Total Diff." for method in allMethods: firstTotal = getattr(self.analyzers[0], timingType)[" TOTAL"].get(" TOTAL", 0) lastTotal = getattr(self.analyzers[-1], timingType)[" TOTAL"].get(" TOTAL", 0) if method == " TOTAL": byMethod[title1][method] = "%+.1f" % (lastTotal - firstTotal,) byMethod[title2][method] = "%+.1f%%" % (safePercent(lastTotal - firstTotal, firstTotal, 100.0),) byMethod[title3][method] = "" else: firstValue = getattr(self.analyzers[0], timingType)[" TOTAL"].get(method, 0) lastValue = getattr(self.analyzers[-1], timingType)[" TOTAL"].get(method, 0) byMethod[title1][method] = "%+.1f" % ( lastValue - firstValue, ) byMethod[title2][method] = "%+.1f%%" % ( safePercent(lastValue - firstValue, firstValue, 100.0), ) byMethod[title3][method] = "%+.1f%%" % ( safePercent(lastValue - firstValue, lastTotal - firstTotal, 100.0), ) self.printDictDictTable(byMethod, doTabs) def printResponseCountDetails(self, doTabs): # First gather all the data allMethods = set() byMethod = collections.defaultdict(lambda: collections.defaultdict(int)) for ctr, analyzer in enumerate(self.analyzers): title = "#%d %s" % (ctr + 1, analyzer.startLog[0:11],) for method, value in analyzer.averageResponseCountByMethod.iteritems(): byMethod[title][method] = value allMethods.add(method) title = "Difference" for method in allMethods: firstTotal = self.analyzers[0].averageResponseCountByMethod.get(" TOTAL", 0) lastTotal = self.analyzers[-1].averageResponseCountByMethod.get(" TOTAL", 0) if method == " TOTAL": byMethod[title][method] = "%+d (%+.1f%%)" % (lastTotal - firstTotal, safePercent(lastTotal - firstTotal, firstTotal, 100.0),) else: firstValue = self.analyzers[0].averageResponseCountByMethod.get(method, 0) lastValue = self.analyzers[-1].averageResponseCountByMethod.get(method, 0) byMethod[title][method] = "%+d (%+.1f%%)" % (lastValue - firstValue, safePercent(lastValue - firstValue, firstValue, 100.0),) self.printDictDictTable(byMethod, doTabs) def usage(error_msg=None): if error_msg: print(error_msg) print("""Usage: protocolanalysis [options] [FILE] Options: -h Print this help and exit --hours Range of hours (local time) to analyze [0:23] --utcoffset Local time offset for UTC log entries --resolution Time resolution in minutes [60] --user User to analyze --client Client to analyze --tabs Generate tab-delimited output rather than table --summary Print the Load Analysis summary only --repeat Parse the file and then allow more data to be parsed --diff Compare two or more files Arguments: FILE File names for the access logs to analyze Description: This utility will analyze the output of access logs and generate tabulated statistics. It can also display statistics about the differences between two logs. """) if error_msg: raise ValueError(error_msg) else: sys.exit(0) if __name__ == "__main__": try: diffMode = False doTabDelimited = False repeat = False summary = False resolution = 60 startHour = None endHour = None utcoffset = 0 filterByUser = None filterByClient = None options, args = getopt.getopt(sys.argv[1:], "h", ["diff", "hours=", "utcoffset=", "resolution=", "repeat", "summary", "tabs", "user=", "client=", ]) for option, value in options: if option == "-h": usage() elif option == "--diff": diffMode = True elif option == "--repeat": repeat = True elif option == "--summary": summary = True elif option == "--tabs": doTabDelimited = True elif option == "--hours": splits = value.split(":") if len(splits) not in (1, 2): usage("Wrong format for --hours: %s %s" % (value, splits)) elif len(splits) == 1: startHour = int(splits[0]) endHour = startHour + 24 else: startHour = int(splits[0]) endHour = int(splits[1]) if endHour < startHour: endHour += 24 elif option == "--utcoffset": utcoffset = int(value) elif option == "--resolution": resolution = int(value) elif option == "--user": filterByUser = value elif option == "--client": filterByClient = value else: usage("Unrecognized option: %s" % (option,)) if repeat and diffMode: usage("Cannot have --repeat and --diff together") # Process arguments if len(args) == 0: args = ("/var/log/caldavd/access.log",) pwd = os.getcwd() logs = [] for arg in args: arg = os.path.expanduser(arg) if not arg.startswith("/"): arg = os.path.join(pwd, arg) if arg.endswith("/"): arg = arg[:-1] if "*" in arg: logs.extend(glob.iglob(arg)) else: if not os.path.exists(arg): print("Path does not exist: '%s'. Ignoring." % (arg,)) continue logs.append(arg) analyzers = [] for log in logs: if diffMode or not analyzers: analyzers.append(CalendarServerLogAnalyzer(startHour, endHour, utcoffset, resolution, filterByUser, filterByClient)) print("Analyzing: %s" % (log,)) analyzers[-1].analyzeLogFile(log) if diffMode and len(analyzers) > 1: Differ(analyzers).printAll(doTabDelimited, summary) else: analyzers[0].printAll(doTabDelimited, summary) if repeat: while True: again = raw_input("Repeat analysis [y/n]:") if again.lower()[0] == "n": break print("\n\n\n") for arg in args: print("Analyzing: %s" % (arg,)) analyzers[0].analyzeLogFile(arg) analyzers[0].printAll(doTabDelimited, summary) except Exception, e: print(traceback.print_exc()) sys.exit(str(e))