oci/zeronet
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Sql memory benchmark update

Browse source
This commit is contained in:
HelloZeroNet 2016-04-18 00:48:14 +02:00
parent 3dd99626ff
commit 14db5c8469
1 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/Test/BenchmarkSsl.py
View file

@ -6,16 +6,17 @@ import time
import sys import sys
import socket import socket
import ssl import ssl
sys.path.append(os.path.abspath("src")) # Imports relative to src dir sys.path.append(os.path.abspath("..")) # Imports relative to src dir
import cStringIO as StringIO import cStringIO as StringIO
import gevent import gevent
from gevent.server import StreamServer from gevent.server import StreamServer
from gevent.pool import Pool from gevent.pool import Pool
from Config import config
config.parse()
from util import SslPatch from util import SslPatch
# Server # Server
socks = [] socks = []
data = os.urandom(1024 * 100) data = os.urandom(1024 * 100)
@ -40,7 +41,7 @@ def handle(sock_raw, addr):
elif line == "gotssl\n": elif line == "gotssl\n":
sock.sendall("yes\n") sock.sendall("yes\n")
sock = gevent.ssl.wrap_socket( sock = gevent.ssl.wrap_socket(
sock_raw, server_side=True, keyfile='data/key-rsa.pem', certfile='data/cert-rsa.pem', sock_raw, server_side=True, keyfile='../../data/key-rsa.pem', certfile='../../data/cert-rsa.pem',
ciphers=ciphers, ssl_version=ssl.PROTOCOL_TLSv1 ciphers=ciphers, ssl_version=ssl.PROTOCOL_TLSv1
) )
else: else:
@ -86,7 +87,7 @@ def getData():
sock.do_handshake() sock.do_handshake()
clipher = sock.cipher() clipher = sock.cipher()
for req in range(100): for req in range(20):
sock.sendall("req\n") sock.sendall("req\n")
buff = StringIO.StringIO() buff = StringIO.StringIO()
data = sock.recv(16 * 1024) data = sock.recv(16 * 1024)
@ -124,9 +125,9 @@ def info():
gevent.spawn(info) gevent.spawn(info)
for test in range(10): for test in range(1):
clients = [] clients = []
for i in range(10): # Thread for i in range(500): # Thread
clients.append(gevent.spawn(getData)) clients.append(gevent.spawn(getData))
gevent.joinall(clients) gevent.joinall(clients)