Home
last modified time | relevance | path

Searched refs:ret (Results 1 – 25 of 51) sorted by relevance

123

/mOS-networking-stack/dpdk-iface-kmod/
H A Ddpdk_iface_main.c229 if (ret == 0) in main()
243 if (ret == 0) in main()
269 for (ret = 0; ret < num_devices; ret++) { in main()
270 di[ret].pd.ports_eth_addr = &di[ret].ports_eth_addr.addr_bytes[0]; in main()
272 rte_eth_macaddr_get(ret, &di[ret].ports_eth_addr); in main()
274 rte_eth_dev_info_get(ret, &di[ret].dev_details); in main()
276 if ((di[ret].pd.numa_socket=rte_eth_dev_socket_id(ret)) == -1) { in main()
295 if (ret == -1) { in main()
301 for (ret = 0; ret < num_devices; ret++) { in main()
305 ret, in main()
[all …]
H A Ddpdk_iface.c122 int ret = 0; in igb_net_ioctl() local
134 if (ret) in igb_net_ioctl()
145 if (!ret) { in igb_net_ioctl()
171 if (ret) in igb_net_ioctl()
187 if (ret) { in igb_net_ioctl()
206 if (!ret) { in igb_net_ioctl()
228 ret = -1; in igb_net_ioctl()
237 return ret; in igb_net_ioctl()
243 return ret; in igb_net_ioctl()
255 int ret; in iface_pci_init_module() local
[all …]
/mOS-networking-stack/util/
H A Dring_buffer.c189 assert(to_move == ret); in MoveToREPData()
197 int to_move, ret; in MoveData() local
217 assert(to_move == ret); in MoveData()
219 return ret; in MoveData()
224 int to_send, wr, ret; in MtcpWriteFromBuffer() local
236 assert (wr == ret); in MtcpWriteFromBuffer()
243 int free_len, ret; in MtcpReadFromBuffer() local
250 if (ret < 0) { in MtcpReadFromBuffer()
252 return ret; in MtcpReadFromBuffer()
254 AddDataLen(r_buff, ret); in MtcpReadFromBuffer()
[all …]
H A Dhttp_parsing.c96 char *ret = data; in http_get_url() local
105 ret += sizeof(HTTP_GET); in http_get_url()
106 while (*ret && SPACE_OR_TAB(*ret)) in http_get_url()
107 ret++; in http_get_url()
109 temp = ret; in http_get_url()
115 return ret; in http_get_url()
H A Dcpu.c24 int ret; in CoreAffinitize() local
40 ret = sched_setaffinity(0, n, cmask); in CoreAffinitize()
45 return ret; in CoreAffinitize()
54 return ret; in CoreAffinitize()
/mOS-networking-stack/samples/epserver/
H A Depserver-mp.c122 int ret; in SendUntilAvailable() local
131 ret = 1; in SendUntilAvailable()
139 if (ret < 0) { in SendUntilAvailable()
147 sent += ret; in SendUntilAvailable()
310 int ret; in CreateListeningSocket() local
319 if (ret < 0) { in CreateListeningSocket()
330 if (ret < 0) { in CreateListeningSocket()
337 if (ret < 0) { in CreateListeningSocket()
356 int ret; in GlobInitServer() local
475 int i, ret; in RunServer() local
[all …]
H A Depserver.c123 int ret; in SendUntilAvailable() local
132 ret = 1; in SendUntilAvailable()
140 if (ret < 0) { in SendUntilAvailable()
148 sent += ret; in SendUntilAvailable()
311 int ret; in CreateListeningSocket() local
320 if (ret < 0) { in CreateListeningSocket()
331 if (ret < 0) { in CreateListeningSocket()
357 int ret; in GlobInitServer() local
476 int i, ret; in RunServer() local
615 int ret, i; in main() local
[all …]
/mOS-networking-stack/core/src/
H A Ddpdk_module.c223 int ret; in dpdk_send_pkts() local
228 ret = 0; in dpdk_send_pkts()
261 pkts += ret; in dpdk_send_pkts()
262 cnt -= ret; in dpdk_send_pkts()
283 return ret; in dpdk_send_pkts()
369 int ret; in dpdk_recv_pkts() local
391 return ret; in dpdk_recv_pkts()
605 for (ret = 0; ret < cpu; ret++) in dpdk_load_module_upper_half()
641 if (ret < 0) in dpdk_load_module_upper_half()
711 if (ret < 0) in dpdk_load_module_lower_half()
[all …]
H A Dcpu.c42 int ret; in mtcp_core_affinitize() local
54 ret = sched_setaffinity(Gettid(), sizeof(cpus), &cpus); in mtcp_core_affinitize()
58 return ret; in mtcp_core_affinitize()
74 ret = fscanf(fp, "%d", &phy_id); in mtcp_core_affinitize()
75 if (ret != 1) { in mtcp_core_affinitize()
91 return ret; in mtcp_core_affinitize()
H A Dapi.c1202 int ret; in CloseStreamSocket() local
1310 int ret; in mtcp_close() local
1351 ret = -1; in mtcp_close()
1357 return ret; in mtcp_close()
1365 int ret; in mtcp_abort() local
1509 int ret; in mtcp_recv() local
1578 ret = -1; in mtcp_recv()
1608 return ret; in mtcp_recv()
1732 int ret; in CopyFromUser() local
1776 int ret; in mtcp_write() local
[all …]
H A Dip_in.c34 int ret; in ProcessInIPv4Packet() local
43 ret = ERROR; in ProcessInIPv4Packet()
49 ret = FALSE; in ProcessInIPv4Packet()
75 ret = ERROR; in ProcessInIPv4Packet()
92 ret = FALSE; in ProcessInIPv4Packet()
100 return ret; in ProcessInIPv4Packet()
H A Dpipe.c44 int ret; in mtcp_pipe() local
76 ret = pthread_mutex_init(&pp->pipe_lock, NULL); in mtcp_pipe()
77 if (ret) { in mtcp_pipe()
86 ret = pthread_cond_init(&pp->pipe_cond, NULL); in mtcp_pipe()
87 if (ret) { in mtcp_pipe()
138 int ret; in PipeRead() local
177 ret = pthread_cond_wait(&pp->pipe_cond, &pp->pipe_lock); in PipeRead()
178 if (ret) { in PipeRead()
241 int ret; in PipeWrite() local
281 ret = pthread_cond_wait(&pp->pipe_cond, &pp->pipe_lock); in PipeWrite()
[all …]
H A Deth_in.c33 int ret = -1; in ProcessPacket() local
58 ret = ProcessInIPv4Packet(mtcp, &pctx); in ProcessPacket()
65 ret = ProcessARPPacket(mtcp, cur_ts, ifidx, pkt_data, len); in ProcessPacket()
81 if (ret < 0) { in ProcessPacket()
86 return ret; in ProcessPacket()
H A Daddr_pool.c221 int ret = -1; in FetchAddress() local
260 ret = 0; in FetchAddress()
265 return ret; in FetchAddress()
273 int ret = -1; in FetchAddressPerCore() local
288 ret = 0; in FetchAddressPerCore()
293 return ret; in FetchAddressPerCore()
300 int ret = -1; in FreeAddress() local
337 ret = 0; in FreeAddress()
342 return ret; in FreeAddress()
H A Dtcp_out.c518 int ret = 0; in SendControlPacket() local
578 int ret; in WriteTCPControlList() local
601 if (ret < 0) { in WriteTCPControlList()
628 int ret; in WriteTCPDataList() local
644 ret = 0; in WriteTCPDataList()
652 ret = -1; in WriteTCPDataList()
668 if (ret < 0) { in WriteTCPDataList()
719 int ret; in WriteTCPACKList() local
767 if (ret < 0) { in WriteTCPACKList()
842 int ret; in AddtoControlList() local
[all …]
H A Dicmp.c39 uint16_t ret = 0; in ICMPChecksum() local
55 ret = ~sum; in ICMPChecksum()
57 return ret; in ICMPChecksum()
154 int ret = 0; in ProcessICMPECHORequest() local
158 ret = ERROR; in ProcessICMPECHORequest()
164 return ret; in ProcessICMPECHORequest()
H A Deventpoll.c347 int i, cnt, ret; in mtcp_epoll_wait() local
427 ret = pthread_cond_timedwait(&ep->epoll_cond, in mtcp_epoll_wait()
429 if (ret && ret != ETIMEDOUT) { in mtcp_epoll_wait()
433 ret, strerror(errno)); in mtcp_epoll_wait()
438 ret = pthread_cond_wait(&ep->epoll_cond, &ep->epoll_lock); in mtcp_epoll_wait()
439 if (ret) { in mtcp_epoll_wait()
443 ret, strerror(errno)); in mtcp_epoll_wait()
/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dfdevent_freebsd_kqueue.c25 int ret, n = 0; in fdevent_freebsd_kqueue_event_del() local
48 ret = kevent(ev->kq_fd, in fdevent_freebsd_kqueue_event_del()
53 if (ret == -1) { in fdevent_freebsd_kqueue_event_del()
64 int ret, n = 0; in fdevent_freebsd_kqueue_event_set() local
95 ret = kevent(ev->kq_fd, in fdevent_freebsd_kqueue_event_set()
100 if (ret == -1) { in fdevent_freebsd_kqueue_event_set()
111 int ret; in fdevent_freebsd_kqueue_poll() local
117 ret = kevent(ev->kq_fd, in fdevent_freebsd_kqueue_poll()
122 if (ret == -1) { in fdevent_freebsd_kqueue_poll()
134 return ret; in fdevent_freebsd_kqueue_poll()
H A Dmod_cml_lua.c211 int ret = -1; in cache_parse_lua() local
296 ret = (int)lua_tonumber(L, -1); in cache_parse_lua()
306 if (ret == 0) { in cache_parse_lua()
315 ret = -1; in cache_parse_lua()
357 ret = 1; /* cache-miss */ in cache_parse_lua()
365 ret = -1; in cache_parse_lua()
382 ret = -1; in cache_parse_lua()
393 if (ret == 0) { in cache_parse_lua()
428 ret = 0; /* cache-hit */ in cache_parse_lua()
435 if (ret == 1 && !buffer_is_empty(p->trigger_handler)) { in cache_parse_lua()
[all …]
H A Dfdevent_solaris_port.c95 int ret; in fdevent_solaris_port_poll() local
105 if ((ret = port_getn(ev->port_fd, ev->port_events, 0, &wait_for_events, &timeout)) < 0) return ret; in fdevent_solaris_port_poll()
113 if ((ret = port_getn(ev->port_fd, ev->port_events, ev->maxfds, &available_events, &timeout)) < 0) { in fdevent_solaris_port_poll()
116 if (!(errno == ETIME && wait_for_events != available_events)) return ret; in fdevent_solaris_port_poll()
122 if ((ret = port_associate(ev->port_fd, PORT_SOURCE_FD, ev->port_events[i].portev_object, in fdevent_solaris_port_poll()
H A Dmod_auth.c546 handler_t ret = auth_ldap_init(srv, s); in SETDEFAULTS_FUNC() local
547 if (ret == HANDLER_ERROR) in SETDEFAULTS_FUNC()
548 return (ret); in SETDEFAULTS_FUNC()
561 int ret; in auth_ldap_init() local
580 ret = LDAP_VERSION3; in auth_ldap_init()
581 if (LDAP_OPT_SUCCESS != (ret = ldap_set_option(s->ldap, LDAP_OPT_PROTOCOL_VERSION, &ret))) { in auth_ldap_init()
582 log_error_write(srv, __FILE__, __LINE__, "ss", "ldap:", ldap_err2string(ret)); in auth_ldap_init()
594 "Loading CA certificate failed:", ldap_err2string(ret)); in auth_ldap_init()
600 if (LDAP_OPT_SUCCESS != (ret = ldap_start_tls_s(s->ldap, NULL, NULL))) { in auth_ldap_init()
611 log_error_write(srv, __FILE__, __LINE__, "ss", "ldap:", ldap_err2string(ret)); in auth_ldap_init()
[all …]
H A Dhttp_auth.c149 int ret = -1; in http_auth_get_password() local
219 ret = 0; in http_auth_get_password()
287 ret = 0; in http_auth_get_password()
299 ret = 0; in http_auth_get_password()
304 return ret; in http_auth_get_password()
707 int ret; in http_auth_basic_password_compare() local
760 if (p->anon_conf->ldap == NULL || ret != LDAP_SERVER_DOWN || in http_auth_basic_password_compare()
769 "ldap:", ldap_err2string(ret), "filter:", p->ldap_filter); in http_auth_basic_password_compare()
800 ret = LDAP_VERSION3; in http_auth_basic_password_compare()
801 if (LDAP_OPT_SUCCESS != (ret = ldap_set_option(ldap, LDAP_OPT_PROTOCOL_VERSION, &ret))) { in http_auth_basic_password_compare()
[all …]
H A Dconfigfile.c25 int ret = 0; in config_insert() local
308 return ret; in config_insert()
935 int ret; in config_parse() local
965 ret = -1; in config_parse()
990 int ret; in config_parse_file() local
1005 ret = 0; in config_parse_file()
1009 ret = -1; in config_parse_file()
1018 return ret; in config_parse_file()
1047 int ret; in config_parse_cmd() local
1068 ret = -1; in config_parse_cmd()
[all …]
H A Dmod_compress.c415 int ret = -1; in deflate_file_to_file() local
541 ret = deflate_file_to_buffer_bzip2(srv, con, p, start, sce->st.st_size); in deflate_file_to_file()
545 ret = -1; in deflate_file_to_file()
549 if (ret == 0) { in deflate_file_to_file()
553 ret = -1; in deflate_file_to_file()
556 ret = -1; in deflate_file_to_file()
569 if (ret != 0) { in deflate_file_to_file()
585 int ret = -1; in deflate_file_to_buffer() local
637 ret = deflate_file_to_buffer_bzip2(srv, con, p, start, sce->st.st_size); in deflate_file_to_buffer()
641 ret = -1; in deflate_file_to_buffer()
[all …]
/mOS-networking-stack/core/test/scalable_event/
H A Dtest.c65 bool ret = rand_r(&seed) < g_threshold; in ft_prob() local
68 return ret; in ft_prob()
74 int i, ret = 1; in power() local
79 ret *= base; in power()
81 return ret; in power()

123