[~] Refactor
This commit is contained in:
parent
f38336a795
commit
707dafbf5c
36
d1/f2.py
36
d1/f2.py
@ -1,4 +1,5 @@
|
|||||||
import os
|
import os
|
||||||
|
import tempfile
|
||||||
import time
|
import time
|
||||||
import io
|
import io
|
||||||
import traceback
|
import traceback
|
||||||
@ -34,8 +35,18 @@ def application(environ, start_response):
|
|||||||
method=environ['REQUEST_METHOD'],
|
method=environ['REQUEST_METHOD'],
|
||||||
protocol=environ['SERVER_PROTOCOL'],
|
protocol=environ['SERVER_PROTOCOL'],
|
||||||
)
|
)
|
||||||
|
output_dat = None
|
||||||
|
input_dat = None
|
||||||
|
def op1():
|
||||||
|
for o in [input_dat, output_dat]:
|
||||||
|
if not o is None and os.path.exists(o):
|
||||||
|
os.unlink(o)
|
||||||
try:
|
try:
|
||||||
with io.open('2.dat', 'wb') as f:
|
output_dat = tempfile.mktemp(suffix='.dat')
|
||||||
|
input_dat = tempfile.mktemp(suffix='.dat')
|
||||||
|
op1()
|
||||||
|
|
||||||
|
with io.open(input_dat, 'wb') as f:
|
||||||
f.write(t3)
|
f.write(t3)
|
||||||
|
|
||||||
t17 = [
|
t17 = [
|
||||||
@ -46,9 +57,9 @@ def application(environ, start_response):
|
|||||||
for k, v in t2.items()
|
for k, v in t2.items()
|
||||||
], []),
|
], []),
|
||||||
'-X', t7['method'],
|
'-X', t7['method'],
|
||||||
'--data-binary', '@2.dat',
|
'--data-binary', '@%s' % input_dat,
|
||||||
'--max-filesize', '%d' % (60 * 1024 * 1024),
|
'--max-filesize', '%d' % (60 * 1024 * 1024),
|
||||||
'-o', '1.dat',
|
'-o', output_dat,
|
||||||
'-v',
|
'-v',
|
||||||
'-q',
|
'-q',
|
||||||
]
|
]
|
||||||
@ -65,18 +76,23 @@ def application(environ, start_response):
|
|||||||
if o.startswith('< ')
|
if o.startswith('< ')
|
||||||
]
|
]
|
||||||
t9 = '\r\n'.join(response_headers)
|
t9 = '\r\n'.join(response_headers)
|
||||||
while True:
|
if not 'Content-Length: 0' in t9:
|
||||||
try:
|
for k in range(3):
|
||||||
with io.open('1.dat', 'rb') as f:
|
try:
|
||||||
t10 = f.read()
|
with io.open(output_dat, 'rb') as f:
|
||||||
break
|
t10 = f.read()
|
||||||
except:
|
break
|
||||||
time.sleep(0.05)
|
except:
|
||||||
|
time.sleep(0.05)
|
||||||
|
else:
|
||||||
|
t10 = b''
|
||||||
finally:
|
finally:
|
||||||
p.terminate()
|
p.terminate()
|
||||||
except:
|
except:
|
||||||
t9 = 'FUCK SHIT\r\n'
|
t9 = 'FUCK SHIT\r\n'
|
||||||
t10 = traceback.format_exc().encode('utf-8')
|
t10 = traceback.format_exc().encode('utf-8')
|
||||||
|
finally:
|
||||||
|
op1()
|
||||||
|
|
||||||
if not any([o.startswith('Content-Length') for o in t9]):
|
if not any([o.startswith('Content-Length') for o in t9]):
|
||||||
t9 = t9.replace('Transfer-Encoding: chunked\r\n', '')
|
t9 = t9.replace('Transfer-Encoding: chunked\r\n', '')
|
||||||
|
Loading…
Reference in New Issue
Block a user