Home
last modified time | relevance | path

Searched refs:r (Results 1 – 25 of 106) sorted by path

12345

/unit/auto/
H A Dmake398 install -p -m u=rw,go=r $NXT_BUILD_DIR/$NXT_LIB_UNIT_STATIC \
402 install -p -m u=rw,go=r src/nxt_unit.h \
/unit/auto/os/
H A Dconf24 NXT_STATIC_LINK="\$(AR) -r -c"
47 NXT_STATIC_LINK="\$(AR) -r -c"
74 NXT_STATIC_LINK="\$(AR) -r -c"
109 NXT_STATIC_LINK="\$(AR) -r -c"
133 NXT_STATIC_LINK="\$(AR) -r -c"
155 NXT_STATIC_LINK="\$(AR) -r -c"
177 NXT_STATIC_LINK="\$(AR) -r -c"
199 NXT_STATIC_LINK="\$(AR) -r -c"
223 NXT_STATIC_LINK="\$(AR) -r -c"
241 NXT_STATIC_LINK="\$(AR) -r -c"
[all …]
H A Dtest12 NXT_SYSTEM_VERSION=`uname -r 2>/dev/null`
21 NXT_SYSTEM_VERSION=`uname -r 2>/dev/null`
29 NXT_SYSTEM_VERSION=`uname -r 2>/dev/null`
42 NXT_SYSTEM_VERSION=`uname -r 2>/dev/null`
50 NXT_SYSTEM_VERSION="`uname -v 2>/dev/null`.`uname -r 2>/dev/null`"
58 NXT_SYSTEM_VERSION=`uname -r 2>/dev/null`
70 NXT_SYSTEM_VERSION=`uname -r 2>/dev/null`
82 NXT_SYSTEM_VERSION=`uname -r 2>/dev/null`
91 NXT_SYSTEM_VERSION=`uname -r 2>/dev/null`
/unit/go/
H A Drequest.go37 func (r *request) Close() error {
53 r = &request{
70 r.req.Body = r
73 r.req.TLS = &tls.ConnectionState{ }
74 r.req.URL.Scheme = "https"
77 r.req.URL.Scheme = "http"
88 r.req.Header.Add(n, v)
91 return r, nil
114 r, err := new_request(c_req)
117 handler.ServeHTTP(&r.resp, &r.req)
[all …]
H A Dresponse.go25 return r.header
29 if !r.header_sent {
30 r.WriteHeader(http.StatusOK)
44 if r.ch == nil {
45 r.ch = make(chan int, 2)
48 wait_shm_ack(r.ch)
56 if r.header_sent {
60 r.header_sent = true
70 for k, vv := range r.header {
90 func (r *response) Flush() {
[all …]
/unit/pkg/deb/debian.module/
H A Dcontrol.in17 unit-r%%UNIT_VERSION%%%%MODULE_DEPENDS%%
H A Dunit.example-go-app9 func handler(w http.ResponseWriter, r *http.Request) {
12 fmt.Fprintf(w, "Method : %s\n", r.Method)
13 fmt.Fprintf(w, "URL : %s\n", r.URL.Path)
14 fmt.Fprintf(w, "Host : %s\n", r.Host)
/unit/pkg/deb/debian/
H A Dcontrol.in17 Provides: unit-r%%UNIT_VERSION%%
H A Dunit.example-go-app9 func handler(w http.ResponseWriter, r *http.Request) {
12 fmt.Fprintf(w, "Method : %s\n", r.Method)
13 fmt.Fprintf(w, "URL : %s\n", r.URL.Path)
14 fmt.Fprintf(w, "Host : %s\n", r.Host)
/unit/pkg/rpm/rpmbuild/SOURCES/
H A Dunit.example-go-app9 func handler(w http.ResponseWriter, r *http.Request) {
12 fmt.Fprintf(w, "Method : %s\n", r.Method)
13 fmt.Fprintf(w, "URL : %s\n", r.URL.Path)
14 fmt.Fprintf(w, "Host : %s\n", r.Host)
/unit/pkg/rpm/
H A Dunit.module.spec.in42 Requires: unit-r%%UNIT_VERSION%%
H A Dunit.spec.in50 Provides: unit-r%{version}
144 getent group unit >/dev/null || groupadd -r unit
146 useradd -r -g unit -s /sbin/nologin \
/unit/src/java/nginx/unit/
H A DContext.java1473 int r = i < varr2.length ? Integer.parseInt(varr2[i]) : 0; in compareVersion()
1475 int res = l - r; in compareVersion()
2946 String r = "/" + root.relativize(f.toPath());
2948 r += "/";
2951 trace("getResourcePaths: " + r);
2953 res.add(r);
/unit/src/java/nginx/unit/websocket/
H A DAsyncChannelGroupUtil.java117 public Thread newThread(final Runnable r) { in newThread() argument
122 return AccessController.doPrivileged(new NewThreadPrivilegedAction(r)); in newThread()
131 private final Runnable r; field in AsyncChannelGroupUtil.AsyncIOThreadFactory.NewThreadPrivilegedAction
133 public NewThreadPrivilegedAction(Runnable r) { in NewThreadPrivilegedAction() argument
134 this.r = r; in NewThreadPrivilegedAction()
139 Thread t = new Thread(r); in run()
H A DAsyncChannelWrapperSecure.java197 Status s = r.getStatus(); in run()
280 read += r.bytesProduced(); in run()
281 Status s = r.getStatus(); in run()
372 SSLEngineResult r = in run() local
374 checkResult(r, true); in run()
390 SSLEngineResult r = in run() local
392 checkResult(r, false); in run()
396 Runnable r = null; in run() local
398 r.run(); in run()
569 public Thread newThread(Runnable r) { in newThread() argument
[all …]
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerWholeText.java111 StringReader r = new StringReader(message); in decode() local
113 return ((TextStream<?>) decoder).decode(r); in decode()
/unit/src/java/nginx/unit/websocket/server/
H A DUpgradeUtil.java79 Request r = (Request) request.getAttribute(Request.BARE); in isWebSocketUpgradeRequest() local
83 (r != null) && in isWebSocketUpgradeRequest()
84 (r.isUpgrade())); in isWebSocketUpgradeRequest()
H A DWsHttpUpgradeHandler.java112 Request r = (Request) handshakeRequest.getAttribute(Request.BARE); in init() local
121 endpointConfig, r); in init()
H A DWsRemoteEndpointImplServer.java127 OnResultRunnable r = new OnResultRunnable(sh, t); in clearHandler() local
/unit/src/java/
H A Dnxt_jni_Request.c278 nxt_unit_request_t *r; in nxt_java_Request_getHeader() local
287 f = nxt_java_findHeader(r->fields, r->fields + r->fields_count, in nxt_java_Request_getHeader()
307 return nxt_java_newHeaderNamesEnumeration(env, r->fields, r->fields_count); in nxt_java_Request_getHeaderNames()
326 f = nxt_java_findHeader(r->fields, r->fields + r->fields_count, in nxt_java_Request_getHeaders()
332 f = r->fields + r->fields_count; in nxt_java_Request_getHeaders()
335 return nxt_java_newHeadersEnumeration(env, r->fields, r->fields_count, in nxt_java_Request_getHeaders()
359 f = nxt_java_findHeader(r->fields, r->fields + r->fields_count, in nxt_java_Request_getIntHeader()
448 f = r->fields + r->content_type_field; in nxt_java_Request_getContentType()
606 f = nxt_java_findHeader(r->fields, r->fields + r->fields_count, in nxt_java_Request_getServerName()
634 f = nxt_java_findHeader(r->fields, r->fields + r->fields_count, in nxt_java_Request_getServerPort()
[all …]
/unit/src/nodejs/unit-http/
H A Dunit.cpp587 nxt_unit_request_t *r; in create_headers() local
589 r = req->request; in create_headers()
599 for (i = 0; i < r->fields_count; i++) { in create_headers()
605 set_named_property(request, "httpVersion", r->version, r->version_length); in create_headers()
606 set_named_property(request, "method", r->method, r->method_length); in create_headers()
607 set_named_property(request, "url", r->target, r->target_length); in create_headers()
648 nxt_unit_request_t *r; in create_socket() local
650 r = req->request; in create_socket()
659 set_named_property(res, "remoteAddress", r->remote, r->remote_length); in create_socket()
661 r->local_addr_length); in create_socket()
[all …]
/unit/src/
H A Dnxt_controller.c693 nxt_controller_request_t *r; in nxt_controller_conn_init() local
705 r->conn = c; in nxt_controller_conn_init()
723 c->socket.data = r; in nxt_controller_conn_init()
755 nxt_controller_request_t *r; in nxt_controller_conn_read() local
758 r = data; in nxt_controller_conn_read()
804 if (preread >= r->length) { in nxt_controller_conn_read()
888 r = data; in nxt_controller_conn_body_read()
894 read, r->length); in nxt_controller_conn_body_read()
896 if (read >= r->length) { in nxt_controller_conn_body_read()
1018 r = ctx; in nxt_controller_request_content_length()
[all …]
H A Dnxt_h1proto.c988 r->state->ready_handler(task, r, NULL); in nxt_h1p_request_body_read()
1679 r->state->error_handler(task, r, h1p); in nxt_h1p_request_error()
2201 r->state->error_handler(task, r, peer); in nxt_h1p_peer_connect()
2229 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_connected()
2247 r->state->error_handler(task, r, peer); in nxt_h1p_peer_refused()
2397 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_header_sent()
2577 r->state->error_handler(task, r, peer); in nxt_h1p_peer_header_read_done()
2708 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_body_process()
2752 r->state->error_handler(task, r, peer); in nxt_h1p_peer_error()
2776 r->state->error_handler(task, r, peer); in nxt_h1p_peer_send_timeout()
[all …]
H A Dnxt_h1proto_websocket.c83 h1p = r->proto.h1; in nxt_h1p_websocket_first_frame_start()
176 r = h1p->request; in nxt_h1p_conn_ws_keepalive()
183 nxt_http_request_error_handler(task, r, r->proto.any); in nxt_h1p_conn_ws_keepalive()
437 r->state->ready_handler(task, r, NULL); in nxt_h1p_conn_ws_frame_process()
456 r->state->error_handler(task, r, h1p); in nxt_h1p_conn_ws_error()
605 nxt_http_request_error_handler(task, r, r->proto.any); in hxt_h1p_send_ws_error()
637 r = data; in nxt_h1p_conn_ws_error_sent()
641 r->state->error_handler(task, r, r->proto.any); in nxt_h1p_conn_ws_error_sent()
656 r = obj; in nxt_h1p_conn_ws_pong()
670 nxt_http_request_error_handler(task, r, r->proto.any); in nxt_h1p_conn_ws_pong()
[all …]
H A Dnxt_http.h242 nxt_http_request_t *r,
258 void (*body_read)(nxt_task_t *task, nxt_http_request_t *r);
259 void (*local_addr)(nxt_task_t *task, nxt_http_request_t *r);
329 nxt_buf_t *nxt_http_buf_last(nxt_http_request_t *r);
340 nxt_array_t *nxt_http_arguments_parse(nxt_http_request_t *r);
341 nxt_array_t *nxt_http_cookies_parse(nxt_http_request_t *r);
361 nxt_int_t nxt_http_route_addr_rule(nxt_http_request_t *r,
365 nxt_int_t nxt_http_route_test_rule(nxt_http_request_t *r,
390 nxt_http_request_t *r, nxt_http_action_t *action);
394 nxt_http_request_t *r, nxt_upstream_t *upstream);
[all …]

12345