Skip to content

Z
ZEO
Commit 159809f0 authored by Tim Peters's avatar Tim Peters
Browse files
Options

Merge rev 37387 from 3.4 branch. 

stats.py:  cut the # of file reads by 1/3, and the # of
struct.unpack() calls by 1/2.

Various bugfixes elsewhere.
parent ee41341d
Hide whitespace changes
Inline Side-by-side
Showing with 31 additions and 46 deletions
src/ZEO/cache.py
View file @ 159809f0
......@@ -368,7 +368,7 @@ class ClientCache(object):
assert o.end_tid is None # i.e., o was current
if o is None:
# TODO: Since we asserted o is not None above, this block
# should be removing; waiting on time to prove it can't happen.
# should be removed; waiting on time to prove it can't happen.
return
o.end_tid = tid
self.fc.update(o) # record the new end_tid on disk
......
src/ZEO/simul.py
View file @ 159809f0
#! /usr/bin/env python
##############################################################################
#
# Copyright (c) 2001, 2002 Zope Corporation and Contributors.
# Copyright (c) 2001-2005 Zope Corporation and Contributors.
# All Rights Reserved.
#
# This software is subject to the provisions of the Zope Public License,
# Version 2.0 (ZPL). A copy of the ZPL should accompany this distribution.
# Version 2.1 (ZPL). A copy of the ZPL should accompany this distribution.
# THIS SOFTWARE IS PROVIDED "AS IS" AND ANY AND ALL EXPRESS OR IMPLIED
# WARRANTIES ARE DISCLAIMED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
# WARRANTIES OF TITLE, MERCHANTABILITY, AGAINST INFRINGEMENT, AND FITNESS
......@@ -55,32 +55,34 @@ def main():
for o, a in opts:
if o == '-b':
simclass = BuddyCacheSimulation
if o == '-f':
elif o == '-f':
simclass = SimpleCacheSimulation
if o == '-l':
elif o == '-l':
simclass = LRUCacheSimulation
if o == '-y':
elif o == '-y':
simclass = AltZEOCacheSimulation
if o == '-z':
elif o == '-z':
simclass = ZEOCacheSimulation
if o == '-s':
elif o == '-s':
cachelimit = int(float(a)*MB)
if o == '-2':
elif o == '-2':
simclass = TwoQSimluation
if o == '-c':
elif o == '-c':
simclass = CircularCacheSimulation
if o == '-o':
elif o == '-o':
omicron = float(a)
if o == '-t':
elif o == '-t':
theta = float(a)
if o == '-O':
elif o == '-O':
simclass = OracleSimulation
if o == '-a':
elif o == '-a':
simclass = ARCCacheSimulation
if o == '-T':
elif o == '-T':
simclass = ThorSimulation
if o == '-U':
elif o == '-U':
simclass = UnboundedSimulation
else:
assert False, (o, a)
if len(args) != 1:
usage("exactly one file argument required")
......@@ -97,12 +99,12 @@ def main():
try:
import gzip
except ImportError:
print >>sys.stderr, "can't read gzipped files (no module gzip)"
print >> sys.stderr, "can't read gzipped files (no module gzip)"
return 1
try:
f = gzip.open(filename, "rb")
except IOError, msg:
print >>sys.stderr, "can't open %s: %s" % (filename, msg)
print >> sys.stderr, "can't open %s: %s" % (filename, msg)
return 1
elif filename == "-":
# Read from stdin
......@@ -112,7 +114,7 @@ def main():
try:
f = open(filename, "rb")
except IOError, msg:
print >>sys.stderr, "can't open %s: %s" % (filename, msg)
print >> sys.stderr, "can't open %s: %s" % (filename, msg)
return 1
# Create simulation object
......@@ -127,7 +129,6 @@ def main():
sim.printheader()
# Read trace file, simulating cache behavior
offset = 0
records = 0
f_read = f.read
struct_unpack = struct.unpack
......@@ -136,16 +137,13 @@ def main():
r = f_read(8)
if len(r) < 8:
break
offset += 8
ts, code = struct_unpack(">ii", r)
if ts == 0:
# Must be a misaligned record caused by a crash
##print "Skipping 8 bytes at offset", offset-8
continue
r = f_read(16)
if len(r) < 16:
break
offset += 16
records += 1
oid, serial = struct_unpack(">8s8s", r)
# Decode the code
......@@ -288,12 +286,10 @@ class Simulation:
print (self.format + " OVERALL") % args
class ZEOCacheSimulation(Simulation):
"""Simulate the current (ZEO 1.0 and 2.0) ZEO cache behavior.
"""Simulate the ZEO 1.0 and 2.0cache behavior.
This assumes the cache is not persistent (we don't know how to
simulate cache validation.)
"""
extraname = "flips"
......@@ -348,7 +344,6 @@ class ZEOCacheSimulation(Simulation):
del self.fileoids[1 - self.current][oid]
class AltZEOCacheSimulation(ZEOCacheSimulation):
"""A variation of the ZEO cache that copies to the current file.
When a hit is found in the non-current cache file, it is copied to
......@@ -436,16 +431,13 @@ class LRUCacheSimulation(Simulation):
self.size -= node.size
assert self.size >= 0
class Node:
class Node(object):
"""Node in a doubly-linked list, storing oid and size as payload.
A node can be linked or unlinked; in the latter case, next and
prev are None. Initially a node is unlinked.
"""
# Make it a new-style class in Python 2.2 and up; no effect in 2.1
__metaclass__ = type
__slots__ = ['prev', 'next', 'oid', 'size']
def __init__(self, oid, size):
......@@ -495,7 +487,6 @@ class Node2Q(Node):
Node.linkbefore(self, next)
class TwoQSimluation(Simulation):
# The original 2Q algorithm is page based and the authors offer
# tuning guidlines based on a page-based cache. Our cache is
# object based, so, for example, it's hard to compute the number
......@@ -922,7 +913,6 @@ class ARCCacheSimulation(Simulation):
pass
class OracleSimulation(LRUCacheSimulation):
# Not sure how to implement this yet. This is a cache where I
# cheat to see how good we could actually do. The cache
# replacement problem for multi-size caches is NP-hard, so we're
......@@ -987,7 +977,6 @@ class OracleSimulation(LRUCacheSimulation):
all, len(self.count))
class CircularCacheSimulation(Simulation):
# The cache is managed as a single file with a pointer that
# goes around the file, circularly, forever. New objects
# are written at the current pointer, evicting whatever was
......@@ -1481,7 +1470,6 @@ def hitrate(loads, hits):
return "%5.1f%%" % (100.0 * hits / max(1, loads))
def duration(secs):
mm, ss = divmod(secs, 60)
hh, mm = divmod(mm, 60)
if hh:
......@@ -1509,7 +1497,7 @@ def maybe(f, p=0.5):
#############################################################################
# Thor-like eviction scheme.
#
# The cache keeps such a list of all objects, and uses a travelling pointer
# The cache keeps a list of all objects, and uses a travelling pointer
# to decay the worth of objects over time.
class ThorNode(Node):
......
src/ZEO/stats.py
View file @ 159809f0
......@@ -149,23 +149,20 @@ def main():
he = None # timestamp at end of current interval
thisinterval = None # generally te//interval
f_read = f.read
struct_unpack = struct.unpack
unpack = struct.unpack
# Read file, gathering statistics, and printing each record if verbose.
try:
while 1:
r = f_read(8) # timestamp:4 code:4
if len(r) < 8:
r = f_read(26)
if len(r) < 26:
break
ts, code = struct_unpack(">ii", r)
ts, code, oidlen, start_tid, end_tid = unpack(">iiH8s8s", r)
if ts == 0:
# Must be a misaligned record caused by a crash.
if not quiet:
print "Skipping 8 bytes at offset", f.tell() - 8
print "Skipping 8 bytes at offset", f.tell() - 26
f.seek(f.tell() - 18)
continue
r = f_read(18) # oidlen:2 starttid:8 endtid:8
if len(r) < 18:
break
oidlen, start_tid, end_tid = struct_unpack(">H8s8s", r)
oid = f_read(oidlen)
if len(oid) < oidlen:
break
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7