Home
last modified time | relevance | path

Searched refs:c (Results 1 – 25 of 86) sorted by relevance

1234

/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dchunk.c37 c = calloc(1, sizeof(*c)); in chunk_init()
84 for (c = cq->first; c; ) { in chunkqueue_free()
86 c = c->next; in chunkqueue_free()
90 for (c = cq->unused; c; ) { in chunkqueue_free()
92 c = c->next; in chunkqueue_free()
145 for (c = cq->first; c; c = c->next) { in chunkqueue_reset()
148 c->offset = c->mem->used - 1; in chunkqueue_reset()
151 c->offset = c->file.length; in chunkqueue_reset()
327 for (c = cq->first; c; c = c->next) { in chunkqueue_length()
347 for (c = cq->first; c; c = c->next) { in chunkqueue_written()
[all …]
H A DSConscript7 common_src = Split("buffer.c log.c \
8 keyvalue.c chunk.c \
9 http_chunk.c stream.c fdevent.c \
10 stat_cache.c plugin.c joblist.c etag.c array.c \
11 data_string.c data_count.c data_array.c \
12 data_integer.c md5.c data_fastcgi.c \
17 data_config.c bitset.c \
18 inet_ntop_cache.c crc32.c \
22 splaytree.c network_writev.c \
29 src = Split("server.c response.c connections.c network.c \
[all …]
H A DMakefile.am59 common_src=buffer.c log.c \
60 keyvalue.c chunk.c \
61 http_chunk.c stream.c fdevent.c \
62 stat_cache.c plugin.c joblist.c etag.c array.c \
63 data_string.c data_count.c data_array.c \
64 data_integer.c md5.c data_fastcgi.c \
69 data_config.c bitset.c \
77 splaytree.c status_counter.c network_mtcp_writev.c
79 src = server.c response.c connections.c network.c \
80 configfile.c configparser.c request.c proc_open.c
[all …]
H A Dnetwork_writev.c34 chunk *c; in network_write_chunkqueue_writev() local
36 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) { in network_write_chunkqueue_writev()
133 c = c->next; in network_write_chunkqueue_writev()
169 abs_offset = c->file.start + c->offset; in network_write_chunkqueue_writev()
211 munmap(c->file.mmap.start, c->file.mmap.length); in network_write_chunkqueue_writev()
223 we_want_to_send = c->file.length - c->offset; in network_write_chunkqueue_writev()
224 to_mmap = (c->file.start + c->file.length) - c->file.mmap.offset; in network_write_chunkqueue_writev()
247 strerror(errno), c->file.name, c->file.fd); in network_write_chunkqueue_writev()
254 buffer_copy_string_len(c->mem, c->file.mmap.start, c->file.mmap.length); in network_write_chunkqueue_writev()
313 if (c->offset == c->file.length) { in network_write_chunkqueue_writev()
[all …]
H A Dnetwork_mtcp_writev.c36 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) {
133 c = c->next;
169 abs_offset = c->file.start + c->offset;
224 to_mmap = (c->file.start + c->file.length) - c->file.mmap.offset;
254 buffer_copy_string_len(c->mem, c->file.mmap.start, c->file.mmap.length);
313 if (c->offset == c->file.length) {
349 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) { in network_write_chunkqueue_mtcp_writev()
363 offset = c->mem->ptr + c->offset; in network_write_chunkqueue_mtcp_writev()
419 offset = c->file.start + c->offset; in network_write_chunkqueue_mtcp_writev()
420 toSend = c->file.length - c->offset; in network_write_chunkqueue_mtcp_writev()
[all …]
H A Dmd5.c90 #define FF(a, b, c, d, x, s, ac) { \ argument
91 (a) += F ((b), (c), (d)) + (x) + (UINT4)(ac); \
95 #define GG(a, b, c, d, x, s, ac) { \ argument
96 (a) += G ((b), (c), (d)) + (x) + (UINT4)(ac); \
100 #define HH(a, b, c, d, x, s, ac) { \ argument
101 (a) += H ((b), (c), (d)) + (x) + (UINT4)(ac); \
105 #define II(a, b, c, d, x, s, ac) { \ argument
106 (a) += I ((b), (c), (d)) + (x) + (UINT4)(ac); \
203 FF (a, b, c, d, x[ 0], S11, 0xd76aa478); /* 1 */ in li_MD5Transform()
204 FF (d, a, b, c, x[ 1], S12, 0xe8c7b756); /* 2 */ in li_MD5Transform()
[all …]
H A Dnetwork_linux_sendfile.c31 chunk *c; in network_write_chunkqueue_linuxsendfile() local
33 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) { in network_write_chunkqueue_linuxsendfile()
36 switch(c->type) { in network_write_chunkqueue_linuxsendfile()
110 c = c->next; in network_write_chunkqueue_linuxsendfile()
133 offset = c->file.start + c->offset; in network_write_chunkqueue_linuxsendfile()
134 toSend = c->file.length - c->offset; in network_write_chunkqueue_linuxsendfile()
139 if (-1 == (c->file.fd = open(c->file.name->ptr, O_RDONLY))) { in network_write_chunkqueue_linuxsendfile()
212 c->offset += r; in network_write_chunkqueue_linuxsendfile()
216 if (c->offset == c->file.length) { in network_write_chunkqueue_linuxsendfile()
222 close(c->file.fd); in network_write_chunkqueue_linuxsendfile()
[all …]
H A Dnetwork_freebsd_sendfile.c35 chunk *c; in network_write_chunkqueue_freebsdsendfile() local
37 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) { in network_write_chunkqueue_freebsdsendfile()
40 switch(c->type) { in network_write_chunkqueue_freebsdsendfile()
115 c = c->next; in network_write_chunkqueue_freebsdsendfile()
139 strerror(errno), c->file.name); in network_write_chunkqueue_freebsdsendfile()
143 offset = c->file.start + c->offset; in network_write_chunkqueue_freebsdsendfile()
144 toSend = c->file.length - c->offset; in network_write_chunkqueue_freebsdsendfile()
147 if (-1 == c->file.fd) { in network_write_chunkqueue_freebsdsendfile()
148 if (-1 == (c->file.fd = open(c->file.name->ptr, O_RDONLY))) { in network_write_chunkqueue_freebsdsendfile()
194 c->offset += r; in network_write_chunkqueue_freebsdsendfile()
[all …]
H A Dnetwork_write.c28 chunk *c; in network_write_chunkqueue_write() local
30 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) { in network_write_chunkqueue_write()
33 switch(c->type) { in network_write_chunkqueue_write()
44 offset = c->mem->ptr + c->offset; in network_write_chunkqueue_write()
45 toSend = c->mem->used - 1 - c->offset; in network_write_chunkqueue_write()
74 c->offset += r; in network_write_chunkqueue_write()
78 if (c->offset == (off_t)c->mem->used - 1) { in network_write_chunkqueue_write()
100 offset = c->file.start + c->offset; in network_write_chunkqueue_write()
101 toSend = c->file.length - c->offset; in network_write_chunkqueue_write()
186 c->offset += r; in network_write_chunkqueue_write()
[all …]
H A Dnetwork_openssl.c32 chunk *c; in network_write_chunkqueue_openssl() local
61 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) { in network_write_chunkqueue_openssl()
64 switch(c->type) { in network_write_chunkqueue_openssl()
70 if (c->mem->used == 0 || c->mem->used == 1) { in network_write_chunkqueue_openssl()
75 offset = c->mem->ptr + c->offset; in network_write_chunkqueue_openssl()
76 toSend = c->mem->used - 1 - c->offset; in network_write_chunkqueue_openssl()
147 c->offset += r; in network_write_chunkqueue_openssl()
152 if (c->offset == (off_t)c->mem->used - 1) { in network_write_chunkqueue_openssl()
177 off_t offset = c->file.start + c->offset; in network_write_chunkqueue_openssl()
178 off_t toSend = c->file.length - c->offset; in network_write_chunkqueue_openssl()
[all …]
H A Dnetwork_solaris_sendfilev.c42 chunk *c; in network_write_chunkqueue_solarissendfilev() local
44 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) { in network_write_chunkqueue_solarissendfilev()
47 switch(c->type) { in network_write_chunkqueue_solarissendfilev()
68 for(tc = c, i = 0; i < num_chunks; tc = tc->next, i++) { in network_write_chunkqueue_solarissendfilev()
121 c = c->next; in network_write_chunkqueue_solarissendfilev()
148 strerror(errno), c->file.name); in network_write_chunkqueue_solarissendfilev()
152 offset = c->file.start + c->offset; in network_write_chunkqueue_solarissendfilev()
153 toSend = c->file.length - c->offset; in network_write_chunkqueue_solarissendfilev()
162 if (-1 == (ifd = open(c->file.name->ptr, O_RDONLY))) { in network_write_chunkqueue_solarissendfilev()
186 c->offset += written; in network_write_chunkqueue_solarissendfilev()
[all …]
H A DMakefile.in150 http_chunk.c stream.c fdevent.c stat_cache.c plugin.c \
151 joblist.c etag.c array.c data_string.c data_count.c \
152 data_array.c data_integer.c md5.c data_fastcgi.c \
156 fdevent_libmtcp.c data_config.c bitset.c inet_ntop_cache.c \
434 network.c configfile.c configparser.c request.c proc_open.c \
435 buffer.c log.c keyvalue.c chunk.c http_chunk.c stream.c \
436 fdevent.c stat_cache.c plugin.c joblist.c etag.c array.c \
437 data_string.c data_count.c data_array.c data_integer.c md5.c \
441 fdevent_libmtcp.c data_config.c bitset.c inet_ntop_cache.c \
754 stat_cache.c plugin.c joblist.c etag.c array.c \
[all …]
H A Dmod_mysql_vhost.c134 if (c) return c; in mod_mysql_vhost_connection_data()
135 c = calloc(1, sizeof(*c)); in mod_mysql_vhost_connection_data()
139 c->fcgi_arg = buffer_init(); in mod_mysql_vhost_connection_data()
140 c->fcgi_offset = 0; in mod_mysql_vhost_connection_data()
161 buffer_free(c->fcgi_arg); in CONNECTION_FUNC()
162 c->fcgi_offset = 0; in CONNECTION_FUNC()
164 free(c); in CONNECTION_FUNC()
341 plugin_connection_data *c; local
408 c->fcgi_arg->used = 0;
411 c->fcgi_offset = c->fcgi_arg->used = 0;
[all …]
H A Dchunk.h51 int chunkqueue_set_tempdirs(chunkqueue *c, array *tempdirs);
54 int chunkqueue_append_buffer(chunkqueue *c, buffer *mem);
55 int chunkqueue_append_buffer_weak(chunkqueue *c, buffer *mem);
56 int chunkqueue_prepend_buffer(chunkqueue *c, buffer *mem);
58 buffer * chunkqueue_get_append_buffer(chunkqueue *c);
59 buffer * chunkqueue_get_prepend_buffer(chunkqueue *c);
64 off_t chunkqueue_length(chunkqueue *c);
65 off_t chunkqueue_written(chunkqueue *c);
66 void chunkqueue_free(chunkqueue *c);
67 void chunkqueue_reset(chunkqueue *c);
[all …]
H A Dbuffer.c990 if (c == '/' || c == '\0') { in buffer_path_simplify()
1031 return (c >= '0' && c <= '9'); in light_isdigit()
1037 c |= 32; in light_isxdigit()
1038 return (c >= 'a' && c <= 'f'); in light_isxdigit()
1042 c |= 32; in light_isalpha()
1043 return (c >= 'a' && c <= 'z'); in light_isalpha()
1047 return light_isdigit(c) || light_isalpha(c); in light_isalnum()
1055 for (c = b->ptr; *c; c++) { in buffer_to_lower()
1056 if (*c >= 'A' && *c <= 'Z') { in buffer_to_lower()
1070 for (c = b->ptr; *c; c++) { in buffer_to_upper()
[all …]
H A Drequest.c47 for (; *c && *c != ']'; c++) { in request_check_hostname()
48 if (*c == ':') { in request_check_hostname()
52 } else if (!light_isxdigit(*c) && '.' != *c) { in request_check_hostname()
58 if (!*c) { in request_check_hostname()
64 for (c += 2; *c; c++) { in request_check_hostname()
77 for (; *c; c++) { in request_check_hostname()
105 if (c == '.') { in request_check_hostname()
141 if (c != '-' && !light_isalnum(c)) { in request_check_hostname()
153 if (c == '.') { in request_check_hostname()
166 if (c == '.') { in request_check_hostname()
[all …]
H A Dconnections.c178 fprintf(stderr, "%c", c > 32 && c < 128 ? c : '.');
195 fprintf(stderr, "%c", c > 32 && c < 128 ? c : '.');
935 for (c = cq->first; c;) {
965 c = c->next;
967 c = c->next;
987 for (c = cq->first; c; c = c->next) {
991 b.ptr = c->mem->ptr + c->offset;
1036 for (c = cq->first; c; c = c->next) {
1039 b.ptr = c->mem->ptr + c->offset;
1054 c->offset = c->mem->used - 1;
[all …]
H A Dmod_cml.c183 char *c; in cache_call_lua() local
188 for (c = b->ptr + b->used - 1; c > b->ptr && *c != '/'; c--); in cache_call_lua()
190 if (*c == '/') { in cache_call_lua()
191 b->used = c - b->ptr + 2; in cache_call_lua()
192 *(c+1) = '\0'; in cache_call_lua()
197 for (c = b->ptr + b->used - 1; c > b->ptr && *c != '/'; c--); in cache_call_lua()
199 if (*c == '/') { in cache_call_lua()
200 b->used = c - b->ptr + 2; in cache_call_lua()
201 *(c+1) = '\0'; in cache_call_lua()
H A Dmod_status.c451 connection *c = srv->conns->ptr[j]; in mod_status_handle_server_status_html() local
454 if (CON_STATE_READ == c->state && c->request.orig_uri->used > 0) { in mod_status_handle_server_status_html()
482 connection *c = srv->conns->ptr[j]; in mod_status_handle_server_status_html() local
490 if (c->request.content_length) { in mod_status_handle_server_status_html()
506 if (CON_STATE_READ == c->state && c->request.orig_uri->used > 0) { in mod_status_handle_server_status_html()
518 if (buffer_is_empty(c->server_name)) { in mod_status_handle_server_status_html()
527 if (!buffer_is_empty(c->uri.path)) { in mod_status_handle_server_status_html()
531 if (!buffer_is_empty(c->uri.query)) { in mod_status_handle_server_status_html()
536 if (!buffer_is_empty(c->request.orig_uri)) { in mod_status_handle_server_status_html()
607 connection *c = srv->conns->ptr[k]; in mod_status_handle_server_status_text() local
[all …]
/mOS-networking-stack/core/src/
H A DMakefile.in74 SRCS = core.c tcp_stream.c config.c api.c mos_api.c eventpoll.c socket.c pipe.c \
75 tcp_util.c eth_in.c ip_in.c tcp.c tcp_in.c eth_out.c ip_out.c tcp_out.c \
76 arp.c timer.c cpu.c util.c addr_pool.c fhash.c memory_mgt.c logger.c debug.c \
77 tcp_rb_frag_queue.c tcp_send_buffer.c tcp_sb_queue.c tcp_stream_queue.c \
78 bpf/sf_bpf_filter.c bpf/sfbpf-int.c bpf/sf_gencode.c bpf/sf_grammar.c \
79 bpf/sf_nametoaddr.c bpf/sf_optimize.c bpf/sf_scanner.c \
80 event_callback.c tcp_rb.c icmp.c scalable_event.c key_value_store.c
83 SRCS += dpdk_module.c
87 SRCS += pcap_module.c
91 SRCS += netmap_module.c
[all …]
/mOS-networking-stack/core/src/bpf/
H A Dsfbpf-int.c129 register int c; in xdtoi()
131 if (isdigit(c))
142 int c; local
146 c = getc(f);
147 } while (isspace(c) && c != '\n');
149 return c;
155 int c; local
158 c = getc(f);
159 while (c != '\n' && c != EOF);
161 return c;
[all …]
H A DMakefile7 all: sf_bpf_filter.c sfbpf-int.c sf_gencode.c sf_grammar.c \
8 sf_nametoaddr.c sf_optimize.c sf_scanner.c main.c
/mOS-networking-stack/samples/midstat/
H A Dmidstat.c60 struct connection *c; in find_connection() local
63 if (c->sock == sock) in find_connection()
64 return c; in find_connection()
74 struct connection *c; in cb_creation() local
77 if (!c) in cb_creation()
81 c->sock = sock; in cb_creation()
82 if (mtcp_getpeername(mctx, c->sock, (void *)c->addrs, &addrslen, in cb_creation()
97 struct connection *c; in cb_destroy() local
103 free(c); in cb_destroy()
110 struct connection *c; in cb_st_chg() local
[all …]
/mOS-networking-stack/core/test/scalable_event/
H A DMakefile9 CORE_SRC=$(addprefix $(SRC_DIR)/,scalable_event.c key_value_store.c fhash.c util.c)
13 $(PROG): test.c $(CORE_SRC)
/mOS-networking-stack/samples/epserver/
H A DMakefile.in41 $(TARGET): $(MTCP_TARGET) $(TARGET).c $(CMN_DIR)/*.c ../../util/http_parsing.c
45 $(TARGETMP): $(MTCP_TARGET) $(TARGETMP).c $(CMN_DIR)/*.c ../../util/http_parsing.c

1234