end
local function http_read_cb(err, data, conn)
logger.errx(task, 'http_read_cb: got reply: %s, error: %s, conn: %s', data, err, conn)
- conn:add_write(http_read_post_cb, "POST /request2 HTTP/1.1\r\n\r\n")
+ conn:add_write(http_read_post_cb, "POST /request2 HTTP/1.1\r\nHost: 127.0.0.1:18080\r\n\r\n")
task:insert_result('HTTP_ASYNC_RESPONSE', 1.0, data or err)
end
rspamd_tcp:request({
task = task,
callback = http_read_cb,
host = '127.0.0.1',
- data = {'GET /request HTTP/1.1\r\nConnection: keep-alive\r\n\r\n'},
+ data = {'GET /request HTTP/1.1\r\nHost: 127.0.0.1:18080\r\nConnection: keep-alive\r\n\r\n'},
read = true,
port = 18080,
})
logger.errx(task, 'connect_sync %1, %2', is_ok, tostring(connection))
- is_ok, err = connection:write('GET /request HTTP/1.1\r\nConnection: keep-alive\r\n\r\n')
+ is_ok, err = connection:write('GET /request HTTP/1.1\r\nHost: 127.0.0.1:18080\r\nConnection: keep-alive\r\n\r\n')
logger.errx(task, 'write %1, %2', is_ok, err)
if not is_ok then
task:insert_result('HTTP_SYNC_RESPONSE', 1.0, got_content)
- is_ok, err = connection:write("POST /request HTTP/1.1\r\n\r\n")
+ is_ok, err = connection:write("POST /request HTTP/1.1\r\nHost: 127.0.0.1:18080\r\n\r\n")
logger.errx(task, 'write[2] %1, %2', is_ok, err)
got_content = ''
return
end
- is_ok, err = connection:write(string.format('%s %s HTTP/1.1\r\nConnection: close\r\n\r\n', method:upper(), url))
+ is_ok, err = connection:write(string.format('%s %s HTTP/1.1\r\nHost: 127.0.0.1:18080\r\nConnection: close\r\n\r\n', method:upper(), url))
logger.errx(task, 'write %1, %2', is_ok, err)
if not is_ok then
async def main():
parser = argparse.ArgumentParser()
- parser.add_argument("--bind", "-b", default="localhost", help="bind address")
+ parser.add_argument("--bind", "-b", default="127.0.0.1", help="bind address")
parser.add_argument("--port", "-p", type=int, default=18080, help="bind port")
parser.add_argument("--keyfile", "-k", help="server private key file")
parser.add_argument("--certfile", "-c", help="server certificate file")