X-Git-Url: https://review.fuel-infra.org/gitweb?a=blobdiff_plain;f=eventlet%2Ftests%2Fmanual%2Fgreenio_memtest.py;fp=eventlet%2Ftests%2Fmanual%2Fgreenio_memtest.py;h=0000000000000000000000000000000000000000;hb=358bd9258c2b6d2ee74de4dfd07a5123107abad4;hp=9117b1010d35cf1107c11f7202aee46ee2bbe5ca;hpb=376ff3bfe7071cc0793184a378c4e74508fb0d97;p=packages%2Ftrusty%2Fpython-eventlet.git diff --git a/eventlet/tests/manual/greenio_memtest.py b/eventlet/tests/manual/greenio_memtest.py deleted file mode 100644 index 9117b10..0000000 --- a/eventlet/tests/manual/greenio_memtest.py +++ /dev/null @@ -1,83 +0,0 @@ -import eventlet -from eventlet import greenio -import os - - -__test__ = False -_proc_status = '/proc/%d/status' % os.getpid() - -_scale = {'kB': 1024.0, 'mB': 1024.0 * 1024.0, - 'KB': 1024.0, 'MB': 1024.0 * 1024.0} - - -def _VmB(VmKey): - '''Private. - ''' - global _proc_status, _scale - # get pseudo file /proc//status - try: - t = open(_proc_status) - v = t.read() - t.close() - except: - return 0.0 # non-Linux? - # get VmKey line e.g. 'VmRSS: 9999 kB\n ...' - i = v.index(VmKey) - v = v[i:].split(None, 3) # whitespace - if len(v) < 3: - return 0.0 # invalid format? - # convert Vm value to bytes - return float(v[1]) * _scale[v[2]] - - -def memory(since=0.0): - '''Return memory usage in bytes. - ''' - return _VmB('VmSize:') - since - - -def resident(since=0.0): - '''Return resident memory usage in bytes. - ''' - return _VmB('VmRSS:') - since - - -def stacksize(since=0.0): - '''Return stack size in bytes. - ''' - return _VmB('VmStk:') - since - - -def test_pipe_writes_large_messages(): - r, w = os.pipe() - - r = greenio.GreenPipe(r) - w = greenio.GreenPipe(w, 'w') - - large_message = b"".join([1024 * chr(i) for i in range(65)]) - - def writer(): - w.write(large_message) - w.close() - - gt = eventlet.spawn(writer) - - for i in range(65): - buf = r.read(1024) - expected = 1024 * chr(i) - if buf != expected: - print( - "expected=%r..%r, found=%r..%r iter=%d" - % (expected[:4], expected[-4:], buf[:4], buf[-4:], i)) - gt.wait() - - -if __name__ == "__main__": - _iter = 1 - while True: - test_pipe_writes_large_messages() - - _iter += 1 - if _iter % 10 == 0: - print("_iter = %d, VmSize: %d, VmRSS = %d, VmStk = %d" % - (_iter, memory(), resident(), stacksize()))