You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2010/01/08 06:19:04 UTC
svn commit: r897095 - /incubator/cassandra/trunk/contrib/py_stress/stress.py
Author: jbellis
Date: Fri Jan 8 05:18:55 2010
New Revision: 897095
URL: http://svn.apache.org/viewvc?rev=897095&view=rev
Log:
stress.py: more locality on reads by default, and reformat so key_generator comments make sense. path by jbellis
Modified:
incubator/cassandra/trunk/contrib/py_stress/stress.py
Modified: incubator/cassandra/trunk/contrib/py_stress/stress.py
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/contrib/py_stress/stress.py?rev=897095&r1=897094&r2=897095&view=diff
==============================================================================
--- incubator/cassandra/trunk/contrib/py_stress/stress.py (original)
+++ incubator/cassandra/trunk/contrib/py_stress/stress.py Fri Jan 8 05:18:55 2010
@@ -63,7 +63,7 @@
help="Number of columns per key", default=5)
parser.add_option('-d', '--nodes', type="string", dest="nodes",
help="Host nodes (comma separated)", default="localhost")
-parser.add_option('-s', '--stdev', type="int", dest="stdev", default=0.3,
+parser.add_option('-s', '--stdev', type="int", dest="stdev", default=0.1,
help="standard deviation factor")
parser.add_option('-r', '--random', action="store_true", dest="random",
help="use random key generator (stdev will have no effect)")
@@ -104,17 +104,6 @@
stdev = total_keys * options.stdev
mean = total_keys / 2
-def get_client(host='127.0.0.1', port=9160, framed=False):
- socket = TSocket.TSocket(host, port)
- if framed:
- transport = TTransport.TFramedTransport(socket)
- else:
- transport = TTransport.TBufferedTransport(socket)
- protocol = TBinaryProtocol.TBinaryProtocolAccelerated(transport)
- client = Cassandra.Client(protocol)
- client.transport = transport
- return client
-
def key_generator_gauss():
while True:
guess = gauss(mean, stdev)
@@ -129,6 +118,19 @@
if options.random:
key_generator = key_generator_random
+
+def get_client(host='127.0.0.1', port=9160, framed=False):
+ socket = TSocket.TSocket(host, port)
+ if framed:
+ transport = TTransport.TFramedTransport(socket)
+ else:
+ transport = TTransport.TBufferedTransport(socket)
+ protocol = TBinaryProtocol.TBinaryProtocolAccelerated(transport)
+ client = Cassandra.Client(protocol)
+ client.transport = transport
+ return client
+
+
class Operation(Thread):
def __init__(self, i, counts):
Thread.__init__(self)