Home
last modified time | relevance | path

Searched refs:mos (Results 1 – 25 of 26) sorted by relevance

12

/mOS-networking-stack/core/src/
H A Darp.c166 int idx = g_config.mos->arp_table->num; in RegisterARPEntry()
168 if (!g_config.mos->arp_table->ent[idx]) in RegisterARPEntry()
171 g_config.mos->arp_table->ent[idx]->ip = ip; in RegisterARPEntry()
173 g_config.mos->arp_table->ent[idx]->mask = -1; in RegisterARPEntry()
176 g_config.mos->arp_table->num = idx + 1; in RegisterARPEntry()
344 g_config.mos->arp_table->ent[i]->haddr[0], in PrintARPTable()
345 g_config.mos->arp_table->ent[i]->haddr[1], in PrintARPTable()
346 g_config.mos->arp_table->ent[i]->haddr[2], in PrintARPTable()
347 g_config.mos->arp_table->ent[i]->haddr[3], in PrintARPTable()
348 g_config.mos->arp_table->ent[i]->haddr[4], in PrintARPTable()
[all …]
H A Dcore.c604 if (g_config.mos->tcp_timeout > 0) in HandleApplicationCalls()
697 if (g_config.mos->tcp_timeout > 0) in HandleApplicationCalls()
942 thresh = g_config.mos->max_concurrency; in RunMainLoop()
949 thresh = g_config.mos->max_concurrency; in RunMainLoop()
1152 mtcp->rbm_snd = SBManagerCreate(g_config.mos->wmem_size, g_config.mos->no_ring_buffers, in InitializeMTCPManager()
1153 g_config.mos->max_concurrency); in InitializeMTCPManager()
1210 g_config.mos->mos_log, ctx->cpu); in InitializeMTCPManager()
1374 if (cpu >= g_config.mos->num_cores) { in mtcp_create_context()
1377 cpu, g_config.mos->num_cores); in mtcp_create_context()
1650 conf->num_cores = g_config.mos->num_cores; in mtcp_getconf()
[all …]
H A Dnetmap_module.c47 ent = g_config.mos->netdev_table->ent; in netmap_init_handle()
59 for (j = 0; j < g_config.mos->netdev_table->num; j++) { in netmap_init_handle()
70 if (unlikely(g_config.mos->num_cores == 1)) in netmap_init_handle()
220 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in netmap_select()
231 rc = poll(pfd, g_config.mos->netdev_table->num, 0); in netmap_select()
248 for (i = 0; i < g_config.mos->netdev_table->num; i++) in netmap_get_nif()
270 for (i = 0; i < g_config.mos->netdev_table->num; i++) in netmap_destroy_handle()
282 num_dev = g_config.mos->netdev_table->num; in netmap_load_module_upper_half()
285 cpu_mask = g_config.mos->netdev_table->ent[i]->cpu_mask; in netmap_load_module_upper_half()
337 ent = g_config.mos->netdev_table->ent; in netmap_load_module_lower_half()
[all …]
H A Ddpdk_module.c194 for (j = 0; j < g_config.mos->netdev_table->num; j++) { in dpdk_init_handle()
466 for (i = 0; i < g_config.mos->netdev_table->num; i++) in dpdk_destroy_handle()
585 int cpu = g_config.mos->num_cores, ret; in dpdk_load_module_upper_half()
610 if (g_config.mos->nb_mem_channels == 0) { in dpdk_load_module_upper_half()
615 sprintf(mem_channels, "%d", g_config.mos->nb_mem_channels); in dpdk_load_module_upper_half()
667 if (!g_config.mos->multiprocess in dpdk_load_module_lower_half()
668 || (g_config.mos->multiprocess && g_config.mos->multiprocess_is_master)) { in dpdk_load_module_lower_half()
688 if (portid == g_config.mos->netdev_table->ent[eth_idx]->ifindex) in dpdk_load_module_lower_half()
690 if (eth_idx == g_config.mos->netdev_table->num) in dpdk_load_module_lower_half()
693 if (g_config.mos->netdev_table->ent[eth_idx]->cpu_mask & (1L << i)) in dpdk_load_module_lower_half()
[all …]
H A Dip_out.c19 for (i = 0; i < g_config.mos->route_table->num; i++) { in GetOutputInterface()
20 if ((daddr & g_config.mos->route_table->ent[i]->mask) in GetOutputInterface()
21 == g_config.mos->route_table->ent[i]->masked_ip) { in GetOutputInterface()
22 if (g_config.mos->route_table->ent[i]->prefix > prefix) { in GetOutputInterface()
23 nif = g_config.mos->route_table->ent[i]->nif; in GetOutputInterface()
24 prefix = g_config.mos->route_table->ent[i]->prefix; in GetOutputInterface()
46 if (g_config.mos->nic_forward_table != NULL) { in ForwardIPPacket()
48 g_config.mos->nic_forward_table->nic_fwd_table[pctx->p.in_ifidx]; in ForwardIPPacket()
85 pctx->p.ethh->h_source[i] = g_config.mos->netdev_table->ent[pctx->out_ifidx]->haddr[i]; in ForwardIPPacket()
H A Dconfig.c204 g_config.mos->tcp_tw_interval = in FeedMosConfLine()
207 g_config.mos->tcp_timeout = in FeedMosConfLine()
247 g_config.mos->cpu_mask |= cpu_mask; in FeedNetdevConfLine()
620 config->mos = conf; in InitMosBlock()
803 config->mos->arp = blk; in InitArpBlock()
830 config->mos->route = blk; in InitRouteBlock()
860 config->mos->nic_forward = blk; in InitNICForwardBlock()
1130 value = g_config.mos->cpu_mask; in PatchCONFIG()
1142 g_config.mos->num_cores = count; in PatchCONFIG()
1150 g_config.mos->forward = g_config.mos->forward && app_conf->ip_forward; in PatchCONFIG()
[all …]
H A Dpcap_module.c96 for (i = 0; i < g_config.mos->netdev_table->num; i++) in pcap_get_nif()
117 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in pcap_destroy_handle()
129 struct netdev_entry **ent = g_config.mos->netdev_table->ent; in pcap_load_module_upper_half()
131 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in pcap_load_module_upper_half()
H A Deth_out.c92 ethh->h_source[i] = g_config.mos->netdev_table->ent[nif]->haddr[i]; in EthernetOutput()
109 if (g_config.mos->nic_forward_table != NULL) { in ForwardEthernetFrame()
111 g_config.mos->nic_forward_table->nic_fwd_table[pctx->p.in_ifidx]; in ForwardEthernetFrame()
H A Dapi.c140 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_getsockname()
185 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_getsockopt()
273 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_setsockopt()
474 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_setsock_nonblock()
503 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_ioctl()
567 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_monitor()
598 g_config.mos->max_concurrency); in mtcp_monitor()
691 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_bind()
753 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_listen()
831 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_accept()
[all …]
H A Dtcp.c75 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in DetectStreamType()
76 if (ip == g_config.mos->netdev_table->ent[i]->ip_addr) { in DetectStreamType()
395 g_config.mos->tcp_tw_interval == 0) || in HandleMonitorStream()
399 g_config.mos->tcp_tw_interval == 0) || in HandleMonitorStream()
H A Dicmp.c194 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in ProcessICMPPacket()
195 if (pctx->p.iph->daddr == g_config.mos->netdev_table->ent[i]->ip_addr) { in ProcessICMPPacket()
H A Deth_in.c22 pctx->forward = g_config.mos->forward; in FillInPacketEthContext()
H A Deventpoll.c254 if (epid < 0 || epid >= g_config.mos->max_concurrency) { in mtcp_epoll_ctl()
260 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_epoll_ctl()
355 if (epid < 0 || epid >= g_config.mos->max_concurrency) { in mtcp_epoll_wait()
H A Daddr_pool.c183 if (ap->num_entry < g_config.mos->max_concurrency) { in CreateAddressPoolPerCore()
186 ap->num_entry, g_config.mos->max_concurrency); in CreateAddressPoolPerCore()
H A Dsocket.c170 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in GetSocket()
H A Dmos_api.c111 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_bind_monitor_filter()
196 if (msock < 0 || msock >= g_config.mos->max_concurrency) { in mtcp_set_uctx()
227 if (msock < 0 || msock >= g_config.mos->max_concurrency) { in mtcp_get_uctx()
865 if (sockfd < 0 || sockfd >= g_config.mos->max_concurrency) { in mtcp_getpeername()
H A Dtcp_in.c49 for (i = 0; i < g_config.mos->netdev_table->num; i++) { in FilterSYNPacket()
50 if (ip == g_config.mos->netdev_table->ent[i]->ip_addr) { in FilterSYNPacket()
588 rcvvar->rcvbuf = tcprb_new(mtcp->bufseg_pool, g_config.mos->rmem_size, cur_stream->buffer_mgmt); in ProcessTCPPayload()
804 if (g_config.mos->tcp_timeout > 0) in Handle_TCP_ST_SYN_SENT()
881 if (g_config.mos->tcp_timeout > 0) in Handle_TCP_ST_SYN_RCVD()
H A Dtimer.c87 cur_stream->rcvvar->ts_tw_expire = cur_ts + g_config.mos->tcp_tw_interval; in AddtoTimewaitList()
509 g_config.mos->tcp_timeout) { in CheckConnectionTimeout()
H A Dtcp_stream.c444 g_config.mos->max_concurrency, mtcp->flow_cnt);
530 stream->sndvar->snd_wnd = g_config.mos->wmem_size;
820 if (g_config.mos->tcp_timeout > 0)
/mOS-networking-stack/
H A Dsetup.sh67 CONF_FILE=$2/mos.conf
68 CONF_MASTER_FILE=$2/mos-master.conf
69 CONF_SLAVE_FILE=$2/mos-slave.conf
765 find | grep mos.conf | xargs rm -f
767 find | grep mos-master.conf | xargs rm -f
768 find | grep mos-slave.conf | xargs rm -f
H A DREADME.md2 …an.coverity.com/projects/11918/badge.svg)](https://scan.coverity.com/projects/mos-networking-stack)
23 Please visit http://mos.kaist.edu/ for more instructions.
H A D.standalone-template.conf6 mos {
H A D.end-template.conf17 mos {
/mOS-networking-stack/samples/lighttpd-1.4.32/
H A DINSTALL83 Also, remember to locate the 'mos.conf' at the directory where the binary lies.
84 -- This should be $<path_to_lighttpd>/src/mos.conf
/mOS-networking-stack/core/src/include/
H A Dconfig.h165 struct mos_conf *mos; member

12