pub fn run_new[A, X](mut global_app A, port int) ! {

if port <= 0 || port > 65535 {

return error('invalid port number `${port}`, it should be between 1 and 65535')

}

server.run() or { panic(err) }

}

fn parallel_request_handler[A, X](req fasthttp.HttpRequest) ![]u8 {

// Get parameters from user_data - copy to avoid use-after-free

params := unsafe { *(&RequestParams(req.user_data)) }

mut global_app := unsafe { &A(params.global_app) }

client_fd := req.client_conn_fd

// Parse the raw request bytes into a standard `http.Request`.

req2 := http.parse_request_str(s.clone()) or {

return 'HTTP/1.1 500 Internal Server Error\r\nContent-Length: 0\r\nConnection: close\r\n\r\n'.bytes()

}

// Create and populate the `veb.Context`.

fn handle_request_and_route[A, X](mut app A, req http.Request, client_fd int, routes &map[string]Route, controllers []&ControllerPath) &Context {

// Create and populate the `veb.Context` from the request.

mut url := urllib.parse(req.url) or {

// This should be rare if http.parse_request succeeded.

mut bad_ctx := &Context{

req: req

}

bad_ctx.not_found()

return bad_ctx

form, files := parse_form_from_request(req) or {

mut bad_ctx := &Context{

req: req

}

bad_ctx.request_error('Failed to parse form data: ${err.msg()}')

return bad_ctx

mut ctx := &Context{

req: req

page_gen_start: time.ticks()

}

if connection_header := req.header.get(.connection) {

if connection_header.to_lower() == 'close' {

// Create a new user context and pass veb's context

mut user_context := X{}

user_context.Context = ctx

handle_route[A, X](mut app, mut user_context, url, host, routes)

return &user_context.Context

}