Home
last modified time | relevance | path

Searched refs:dst (Results 1 – 25 of 26) sorted by last modified time

12

/unit/src/
H A Dnxt_unit.h186 void *dst, size_t size);
313 ssize_t nxt_unit_request_read(nxt_unit_request_info_t *req, void *dst,
328 ssize_t nxt_unit_websocket_read(nxt_unit_websocket_frame_t *ws, void *dst,
H A Dnxt_unit.c176 nxt_inline void nxt_unit_rbuf_cpy(nxt_unit_read_buf_t *dst,
3076 dst, size); in nxt_unit_request_read()
3079 res = read(req->content_fd, dst, size); in nxt_unit_request_read()
3095 dst = nxt_pointer_to(dst, res); in nxt_unit_request_read()
3219 p = dst; in nxt_unit_buf_read()
3424 dst, size); in nxt_unit_websocket_read()
3430 b = dst; in nxt_unit_websocket_read()
6146 memcpy(dst->buf, src->buf, src->size); in nxt_unit_rbuf_cpy()
6147 dst->size = src->size; in nxt_unit_rbuf_cpy()
6148 dst->oob.size = src->oob.size; in nxt_unit_rbuf_cpy()
[all …]
H A Dnxt_main_process.c1367 offsetof(nxt_fs_mount_t, dst),
H A Dnxt_application.c65 static u_char *nxt_cstr_dup(nxt_mp_t *mp, u_char *dst, u_char *src);
277 size += nxt_strlen(mnt[j].src) + nxt_strlen(mnt[j].dst) in nxt_discovery_modules()
307 mnt[j].src, mnt[j].dst, mnt[j].name, mnt[j].type, in nxt_discovery_modules()
445 to->dst = nxt_cstr_dup(mp, to->dst, from->dst); in nxt_discovery_module()
446 if (nxt_slow_path(to->dst == NULL)) { in nxt_discovery_module()
990 nxt_cstr_dup(nxt_mp_t *mp, u_char *dst, u_char *src) in nxt_cstr_dup() argument
997 if (dst == NULL) { in nxt_cstr_dup()
998 dst = nxt_mp_alloc(mp, len + 1); in nxt_cstr_dup()
999 if (nxt_slow_path(dst == NULL)) { in nxt_cstr_dup()
1004 p = nxt_cpymem(dst, src, len); in nxt_cstr_dup()
[all …]
H A Dnxt_http_request.c910 for (p = start, dst = dst_start; p < end; p++, dst++) { in nxt_http_arguments_parse()
911 *dst = *p; in nxt_http_arguments_parse()
916 name_length = dst - dst_start; in nxt_http_arguments_parse()
918 dst_start = dst + 1; in nxt_http_arguments_parse()
924 if (name_length != 0 || dst != dst_start) { in nxt_http_arguments_parse()
926 dst); in nxt_http_arguments_parse()
935 dst_start = dst + 1; in nxt_http_arguments_parse()
940 *dst = ' '; in nxt_http_arguments_parse()
957 *dst = (d0 << 4) + d1; in nxt_http_arguments_parse()
963 hash = nxt_http_field_hash_char(hash, *dst); in nxt_http_arguments_parse()
[all …]
H A Dnxt_conf.c1002 dst->u = src->u; in nxt_conf_copy_value()
1005 dst->type = src->type; in nxt_conf_copy_value()
1105 dst->type = src->type; in nxt_conf_copy_array()
1235 dst->type = src->type; in nxt_conf_copy_object()
2578 *dst++ = ch; in nxt_conf_json_escape()
2581 *dst++ = '\\'; in nxt_conf_json_escape()
2585 *dst++ = 'n'; in nxt_conf_json_escape()
2589 *dst++ = 'r'; in nxt_conf_json_escape()
2593 *dst++ = 't'; in nxt_conf_json_escape()
2605 *dst++ = 'u'; *dst++ = '0'; *dst++ = '0'; in nxt_conf_json_escape()
[all …]
H A Dnxt_file.h38 #define nxt_file_name_copy(dst, src, len) \ argument
39 nxt_cpymem(dst, src, len)
42 #define nxt_file_name_add(dst, src, len) \ argument
43 nxt_cpymem(dst, src, len)
H A Dnxt_fs.c14 char *start, *end, *dst; in nxt_fs_mkdir_all() local
22 dst = path; in nxt_fs_mkdir_all()
27 *dst++ = *start++; in nxt_fs_mkdir_all()
35 dst = nxt_cpymem(dst, start, end - start); in nxt_fs_mkdir_all()
36 *dst = '\0'; in nxt_fs_mkdir_all()
H A Dnxt_isolation.c635 len = nxt_strlen(lang_mnt[i].dst); in nxt_isolation_set_lang_mounts()
638 if (nxt_slow_path(mnt[i].dst == NULL)) { in nxt_isolation_set_lang_mounts()
643 p = nxt_cpymem(p, lang_mnt[i].dst, len); in nxt_isolation_set_lang_mounts()
664 if (nxt_slow_path(mnt->dst == NULL)) { in nxt_isolation_set_lang_mounts()
668 p = nxt_cpymem(mnt->dst, rootfs, rootfs_len); in nxt_isolation_set_lang_mounts()
683 if (nxt_slow_path(mnt->dst == NULL)) { in nxt_isolation_set_lang_mounts()
687 p = nxt_cpymem(mnt->dst, rootfs, rootfs_len); in nxt_isolation_set_lang_mounts()
747 nxt_fs_unmount(mnt[n].dst); in nxt_isolation_unmount_all()
759 const u_char *dst; in nxt_isolation_prepare_rootfs() local
770 dst = mnt[i].dst; in nxt_isolation_prepare_rootfs()
[all …]
H A Dnxt_string.h44 #define nxt_memcpy(dst, src, length) \ argument
45 (void) memcpy(dst, src, length)
48 NXT_EXPORT void nxt_memcpy_lowcase(u_char *dst, const u_char *src,
50 NXT_EXPORT void nxt_memcpy_upcase(u_char *dst, const u_char *src,
59 nxt_cpymem(void *dst, const void *src, size_t length) in nxt_cpymem() argument
61 return ((u_char *) memcpy(dst, src, length)) + length; in nxt_cpymem()
66 (void) memmove(dst, src, length)
77 NXT_EXPORT u_char *nxt_cpystr(u_char *dst, const u_char *src);
120 NXT_EXPORT nxt_str_t *nxt_str_dup(nxt_mp_t *mp, nxt_str_t *dst,
155 NXT_EXPORT u_char *nxt_decode_uri(u_char *dst, u_char *src, size_t length);
[all …]
H A Dnxt_string.c59 return dst; in nxt_str_dup()
73 char *p, *dst; in nxt_str_cstrz() local
82 return dst; in nxt_str_cstrz()
122 dst++; in nxt_cpystr()
126 return dst; in nxt_cpystr()
144 dst++; in nxt_cpystrn()
148 *dst = '\0'; in nxt_cpystrn()
150 return dst; in nxt_cpystrn()
550 return dst; in nxt_decode_uri()
591 return dst; in nxt_decode_uri_plus()
[all …]
H A Dnxt_sockaddr.c169 nxt_sockaddr_t *dst; in nxt_sockaddr_copy() local
173 dst = nxt_mp_alloc(mp, length); in nxt_sockaddr_copy()
175 if (nxt_fast_path(dst != NULL)) { in nxt_sockaddr_copy()
176 nxt_memcpy(dst, src, length); in nxt_sockaddr_copy()
179 return dst; in nxt_sockaddr_copy()
826 u_char c, *addr, *zero_start, *ipv4, *dst, *src, *end; in nxt_inet6_addr() local
939 dst = src + groups_left; in nxt_inet6_addr()
942 *dst-- = *src--; in nxt_inet6_addr()
H A Dnxt_fs_mount.h34 u_char *dst; member
H A Dnxt_fs_mount.c65 rc = mount((const char *) mnt->src, (const char *) mnt->dst, fsname, flags, in nxt_fs_mount()
70 mnt->src, mnt->dst, fsname, flags, mnt->data, nxt_errno); in nxt_fs_mount()
140 iov[3].iov_base = (void *) mnt->dst; in nxt_fs_mount()
141 iov[3].iov_len = nxt_strlen(mnt->dst) + 1; in nxt_fs_mount()
H A Dnxt_array.h35 NXT_EXPORT nxt_array_t *nxt_array_copy(nxt_mp_t *mp, nxt_array_t *dst,
H A Dnxt_file_name.c29 nxt_file_name_t *dst, *fn; in nxt_file_name_create() local
120 dst = fn; in nxt_file_name_create()
131 *dst++ = (nxt_file_name_t) ch; in nxt_file_name_create()
146 dst = nxt_file_name_add(dst, v->start, v->length); in nxt_file_name_create()
156 *dst++ = (nxt_file_name_t) (*p++); in nxt_file_name_create()
169 dst = nxt_file_name_add(dst, p, length); in nxt_file_name_create()
182 *dst++ = *fn++; in nxt_file_name_create()
190 *dst++ = '\0'; in nxt_file_name_create()
H A Dnxt_array.c122 if (dst == NULL) { in nxt_array_copy()
123 dst = nxt_array_create(mp, src->nelts, size); in nxt_array_copy()
124 if (nxt_slow_path(dst == NULL)) { in nxt_array_copy()
129 nxt_assert(size == dst->size); in nxt_array_copy()
131 if (dst->nalloc >= src->nelts) { in nxt_array_copy()
132 nxt_memcpy(dst->elts, src->elts, src->nelts * size); in nxt_array_copy()
135 nxt_memcpy(dst->elts, src->elts, dst->nelts * size); in nxt_array_copy()
137 for (i = dst->nelts; i < src->nelts; i++) { in nxt_array_copy()
138 data = nxt_array_add(dst); in nxt_array_copy()
147 dst->nelts = src->nelts; in nxt_array_copy()
[all …]
/unit/src/java/
H A Dnxt_jni_Response.c670 char *dst; in nxt_java_response_set_header() local
694 dst = nxt_unit_sptr_get(&f->value); in nxt_java_response_set_header()
695 memcpy(dst, value, value_len); in nxt_java_response_set_header()
696 dst[value_len] = '\0'; in nxt_java_response_set_header()
/unit/src/perl/
H A Dnxt_perl_psgi.c84 static ssize_t nxt_perl_psgi_io_read(nxt_unit_read_info_t *read_info, void *dst,
1003 nxt_perl_psgi_io_read(nxt_unit_read_info_t *read_info, void *dst, size_t size) in nxt_perl_psgi_io_read() argument
1012 res = PerlIO_read(ctx->fp, dst, size); in nxt_perl_psgi_io_read()
/unit/src/ruby/
H A Dnxt_ruby.c1040 nxt_ruby_rack_file_read(nxt_unit_read_info_t *read_info, void *dst, size_t size) in nxt_ruby_rack_file_read() argument
1049 res = pread(file->fd, dst, size, file->pos); in nxt_ruby_rack_file_read()
/unit/go/
H A Dnxt_cgo_lib.c77 nxt_cgo_request_read(nxt_unit_request_info_t *req, uintptr_t dst, in nxt_cgo_request_read() argument
80 return nxt_unit_request_read(req, (void *) dst, dst_len); in nxt_cgo_request_read()
/unit/src/java/nginx/unit/websocket/
H A DWsPongMessage.java29 byte[] dst = new byte[applicationData.limit()]; in WsPongMessage()
30 applicationData.get(dst); in WsPongMessage()
31 this.applicationData = ByteBuffer.wrap(dst); in WsPongMessage()
H A DAsyncChannelWrapper.java33 Future<Integer> read(ByteBuffer dst); in read() argument
35 <B,A extends B> void read(ByteBuffer dst, A attachment, in read() argument
H A DAsyncChannelWrapperNonSecure.java45 public Future<Integer> read(ByteBuffer dst) { in read() argument
46 return socketChannel.read(dst); in read()
50 public <B,A extends B> void read(ByteBuffer dst, A attachment, in read() argument
52 socketChannel.read(dst, attachment, handler); in read()
H A DAsyncChannelWrapperSecure.java78 public Future<Integer> read(ByteBuffer dst) { in read() argument
86 ReadTask readTask = new ReadTask(dst, future); in read()
94 public <B,A extends B> void read(ByteBuffer dst, A attachment, in read() argument
105 ReadTask readTask = new ReadTask(dst, future); in read()

12