| 302 | } |
| 303 | |
| 304 | int |
| 305 | UDPNetProcessorInternal::start(int n_upd_threads, size_t stacksize) |
| 306 | { |
| 307 | if (n_upd_threads < 1) { |
| 308 | return -1; |
| 309 | } |
| 310 | |
| 311 | pollCont_offset = eventProcessor.allocate(sizeof(PollCont)); |
| 312 | udpNetHandler_offset = eventProcessor.allocate(sizeof(UDPNetHandler)); |
| 313 | |
| 314 | eventProcessor.schedule_spawn(&initialize_thread_for_udp_net, ET_UDP); |
| 315 | eventProcessor.spawn_event_threads(ET_UDP, n_upd_threads, stacksize); |
| 316 | |
| 317 | return 0; |
| 318 | } |
| 319 | |
| 320 | namespace |
| 321 | { |