if task:get_queue_id() == 'SSL Large TCP request' then
logger.errx(task, 'ssl_large_tcp_symbol: begin')
- for i = 1,2000 do
- data[i] = 'test\n'
+ for i = 1,10 do
+ local st = {}
+ for j=1,60000 do
+ st[j] = 't'
+ end
+ st[#st + 1] = '\n'
+ data[i] = table.concat(st)
end
rspamd_tcp:request({
class SSLTCPHandler(SocketServer.BaseRequestHandler):
def handle(self):
- data = self.request.recv(1024)
+ time.sleep(0.5)
+ data = self.request.recv(16384)
while data:
print "{} wrote:".format(self.client_address[0])
print data
+ time.sleep(0.1)
self.request.sendall(data)
- data = self.request.recv(1024)
+ time.sleep(0.1)
+ data = self.request.recv(16384)
class SSL_TCP_Server(SocketServer.TCPServer):
def __init__(self,