Home
last modified time | relevance | path

Searched refs:buf (Results 1 – 25 of 92) sorted by path

1234

/unit/auto/
H A Dclang18 char buf[4];
20 buf[0] = '0';
21 set(0, buf, \"%d\", 1);
23 if (buf[0] == '1')
41 char buf[4];
43 buf[0] = '0';
44 set(0, buf, \"%d\", 1);
46 if (buf[0] == '1')
H A Dunix17 char buf[4];
19 if (getrandom(buf, 4, 0) < 0) {
39 char buf[4];
41 if (syscall(SYS_getrandom, buf, 4, 0) < 0) {
60 char buf[4];
62 if (getentropy(buf, 4) == -1) {
82 char buf[4];
84 if (getentropy(buf, 4) == -1) {
/unit/go/
H A Dnxt_cgo_lib.c14 const void *buf, size_t buf_size, const void *oob, size_t oob_size);
16 void *buf, size_t buf_size, void *oob, size_t *oob_size);
52 const void *buf, size_t buf_size, const void *oob, size_t oob_size) in nxt_cgo_port_send() argument
55 (void *) buf, buf_size, (void *) oob, oob_size); in nxt_cgo_port_send()
61 void *buf, size_t buf_size, void *oob, size_t *oob_size) in nxt_cgo_port_recv() argument
64 buf, buf_size, oob, oob_size); in nxt_cgo_port_recv()
H A Dport.go143 func nxt_go_port_send(pid C.int, id C.int, buf unsafe.Pointer, buf_size C.int,
158 n, oobn, err := p.snd.WriteMsgUnix(GoBytes(buf, buf_size),
171 func nxt_go_port_recv(pid C.int, id C.int, buf unsafe.Pointer, buf_size C.int,
186 n, oobn, _, _, err := p.rcv.ReadMsgUnix(GoBytes(buf, buf_size),
H A Dunit.go25 func buf_ref(buf []byte) C.uintptr_t {
26 if len(buf) == 0 {
44 func (buf *cbuf) init_bytes(b []byte) {
45 buf.b = buf_ref(b)
46 buf.s = C.size_t(len(b))
55 func (buf *cbuf) GoBytes() []byte {
56 if buf == nil {
62 Data: unsafe.Pointer(uintptr(buf.b)),
63 Len: int(buf.s),
64 Cap: int(buf.s),
[all …]
/unit/src/java/nginx/unit/
H A DRequest.java1284 private void processWsFrame(ByteBuffer buf, byte opCode, boolean last) in processWsFrame() argument
1287 trace("processWsFrame: " + opCode + ", [" + buf.position() + ", " + buf.limit() + "]"); in processWsFrame()
1289 wsSession.processFrame(buf, opCode, last); in processWsFrame()
1319 ByteBuffer buf, int pos, int len, byte opCode, boolean last); in sendWsFrame() argument
H A DResponse.java112 StringBuilder buf = new StringBuilder(); in addSetRFC6265Cookie() local
113 buf.append(name).append('=').append(value == null ? "" : value); in addSetRFC6265Cookie()
117 buf.append(";Path=").append(path); in addSetRFC6265Cookie()
122 buf.append(";Domain=").append(domain); in addSetRFC6265Cookie()
129 buf.append(";Expires="); in addSetRFC6265Cookie()
131 buf.append(ZERO_DATE_STRING); in addSetRFC6265Cookie()
135 buf.append(";Max-Age="); in addSetRFC6265Cookie()
136 buf.append(maxAge); in addSetRFC6265Cookie()
141 buf.append(";Secure"); in addSetRFC6265Cookie()
143 buf.append(";HttpOnly"); in addSetRFC6265Cookie()
[all …]
/unit/src/java/nginx/unit/websocket/
H A DWsFrameBase.java36 import org.apache.tomcat.util.buf.Utf8Decoder;
H A DWsRemoteEndpointImplBase.java48 import org.apache.tomcat.util.buf.Utf8Encoder;
H A DWsSession.java826 rawFragments.put(buf); in processFrame()
828 buf = rawFragments; in processFrame()
847 final ByteBuffer b = buf; in processFrame()
863 if (buf.remaining() >= 2) { in processFrame()
878 onMessage(buf, last); in processFrame()
931 buf.flip(); in onMessage()
937 buf.clear(); in onMessage()
944 if (buf == rawFragments) { in updateRawFragments()
945 buf.compact(); in updateRawFragments()
950 rawFragments.put(buf); in updateRawFragments()
[all …]
H A DWsWebSocketContainer.java71 import org.apache.tomcat.util.buf.StringUtils;
/unit/src/java/
H A Dnxt_jni.h38 nxt_unit_buf_t *buf; member
H A Dnxt_jni_InputStream.c167 nxt_unit_buf_t *buf; in nxt_java_InputStream_skip() local
174 buf = req->content_buf; in nxt_java_InputStream_skip()
176 while (buf != NULL) { in nxt_java_InputStream_skip()
177 b_size = buf->end - buf->free; in nxt_java_InputStream_skip()
180 buf->free += b_size; in nxt_java_InputStream_skip()
184 if (buf->end == buf->free) { in nxt_java_InputStream_skip()
185 buf = nxt_unit_buf_next(buf); in nxt_java_InputStream_skip()
191 buf = nxt_unit_buf_next(buf); in nxt_java_InputStream_skip()
H A Dnxt_jni_OutputStream.c92 if (buf == NULL) { in nxt_java_OutputStream_writeByte()
96 *buf->free++ = b; in nxt_java_OutputStream_writeByte()
98 if ((uint32_t) (buf->free - buf->start) >= data->buf_size) { in nxt_java_OutputStream_writeByte()
155 buf = data->buf; in nxt_java_OutputStream_req_buf()
157 if (buf == NULL || buf->free >= buf->end) { in nxt_java_OutputStream_req_buf()
161 if (buf == NULL) { in nxt_java_OutputStream_req_buf()
167 data->buf = buf; in nxt_java_OutputStream_req_buf()
170 return buf; in nxt_java_OutputStream_req_buf()
196 copy = buf->end - buf->free; in nxt_java_OutputStream_write()
205 if ((uint32_t) (buf->free - buf->start) >= data->buf_size) { in nxt_java_OutputStream_write()
[all …]
H A Dnxt_jni_Request.c72 jlong req_info_ptr, jobject buf, jint pos, jint len, jbyte opCode, jboolean last);
754 jlong req_info_ptr, jobject buf, jint pos, jint len, jbyte opCode, jboolean last) in nxt_java_Request_sendWsFrameBuf() argument
759 uint8_t *b = (*env)->GetDirectBufferAddress(env, buf); in nxt_java_Request_sendWsFrameBuf()
H A Dnxt_jni_Response.c331 buf = req->response_buf; in nxt_java_get_response_info()
335 || extra_data > (uint32_t) (buf->end - buf->free)) in nxt_java_get_response_info()
929 if (data->buf != NULL && data->buf->free > data->buf->start) { in nxt_java_Response_reset()
930 data->buf->free = data->buf->start; in nxt_java_Response_reset()
939 buf->free = buf->start + req->response_max_fields in nxt_java_Response_reset()
954 if (data->buf != NULL && data->buf->free > data->buf->start) { in nxt_java_Response_resetBuffer()
955 data->buf->free = data->buf->start; in nxt_java_Response_resetBuffer()
974 if (data->buf != NULL && data->buf->free > data->buf->start) { in nxt_java_Response_setBufferSize()
986 if (data->buf != NULL in nxt_java_Response_setBufferSize()
987 && (uint32_t) (data->buf->end - data->buf->start) < data->buf_size) in nxt_java_Response_setBufferSize()
[all …]
/unit/src/nodejs/unit-http/
H A Dnxt_napi.h366 get_value_string_latin1(napi_value val, char *buf, size_t bufsize) in get_value_string_latin1()
371 status = napi_get_value_string_latin1(env_, val, buf, bufsize, &res); in get_value_string_latin1()
396 get_value_string_utf8(napi_value val, char *buf, size_t bufsize) in get_value_string_utf8()
401 status = napi_get_value_string_utf8(env_, val, buf, bufsize, &res); in get_value_string_utf8()
H A Dunit.cpp937 nxt_unit_buf_t *buf; in response_write() local
962 buf = req->response_buf; in response_write()
965 buf = nxt_unit_response_buf_alloc(req, buf_len); in response_write()
966 if (buf == NULL) { in response_write()
971 have_buf_len = napi.get_value_string_utf8(argv[0], buf->free, in response_write()
974 buf->free += have_buf_len; in response_write()
976 ret = nxt_unit_buf_send(buf); in response_write()
/unit/src/
H A Dnxt_aix_send_file.c28 sb.buf = b; in nxt_aix_event_conn_io_send_file()
41 if (nhd > 1 || sb.buf == NULL || !nxt_buf_is_file(sb.buf)) { in nxt_aix_event_conn_io_send_file()
45 fb = sb.buf; in nxt_aix_event_conn_io_send_file()
H A Dnxt_app_log.c12 static u_char *nxt_log_error_time(u_char *buf, nxt_realtime_t *now,
15 static u_char *nxt_log_debug_time(u_char *buf, nxt_realtime_t *now,
112 nxt_log_error_time(u_char *buf, nxt_realtime_t *now, struct tm *tm, size_t size, in nxt_log_error_time() argument
115 return nxt_sprintf(buf, buf + size, format, in nxt_log_error_time()
132 nxt_log_debug_time(u_char *buf, nxt_realtime_t *now, struct tm *tm, size_t size, in nxt_log_debug_time() argument
135 return nxt_sprintf(buf, buf + size, format, in nxt_log_debug_time()
H A Dnxt_buf_filter.c327 nxt_buf_t *buf; member
356 ctx->buf = f->input; in nxt_buf_filter_file_job_completion()
416 fb = ctx->buf; in nxt_buf_filter_buf_completion()
H A Dnxt_cache.c27 nxt_cache_query_t *q, u_char *buf, size_t size);
468 u_char buf[1024]; in nxt_cache_release() local
473 p = buf; in nxt_cache_release()
474 size = sizeof(buf); in nxt_cache_release()
513 u_char *buf, size_t size) in nxt_cache_release_locked() argument
542 ret = cache->delete_copy(cache, node, buf, size); in nxt_cache_release_locked()
H A Dnxt_cert.c523 end = nxt_sprintf(buf, buf + sizeof(buf), "RSA (%d bits)", in nxt_cert_details()
531 end = nxt_sprintf(buf, buf + sizeof(buf), "DH (%d bits)", in nxt_cert_details()
715 (char *) buf, sizeof(buf)); in nxt_cert_name_details()
726 str.start = buf; in nxt_cert_name_details()
839 buf = NULL; in nxt_cert_store_load()
882 buf = p; in nxt_cert_store_load()
890 file.name = buf; in nxt_cert_store_load()
908 if (buf != NULL) { in nxt_cert_store_load()
909 nxt_free(buf); in nxt_cert_store_load()
918 if (buf != NULL) { in nxt_cert_store_load()
[all …]
H A Dnxt_clone.c90 u_char buf[256]; in nxt_clone_credential_map_write() local
92 end = buf + sizeof(buf); in nxt_clone_credential_map_write()
94 p = nxt_sprintf(buf, end, "/proc/%d/%s", pid, mapfile); in nxt_clone_credential_map_write()
102 mapfd = open((char*)buf, O_RDWR); in nxt_clone_credential_map_write()
104 nxt_alert(task, "failed to open proc map (%s) %E", buf, nxt_errno); in nxt_clone_credential_map_write()
115 "allowed lines %E", buf, nxt_errno); in nxt_clone_credential_map_write()
118 nxt_alert(task, "failed to write proc map (%s) %E", buf, in nxt_clone_credential_map_write()
H A Dnxt_conf.c98 u_char buf[NXT_CONF_MAX_TOKEN_LEN]; member
515 end = nxt_decode_uri(parse->buf, start, length); in nxt_conf_path_next_token()
520 token->length = end - parse->buf; in nxt_conf_path_next_token()
521 token->start = parse->buf; in nxt_conf_path_next_token()

1234