mirrors/ntex
1
0
Fork 0
mirror of https://github.com/ntex-rs/ntex.git synced 2025-04-03 21:07:39 +03:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Nikolay Kim 2025-03-27 10:34:25 +01:00
parent 0d58e280c2
commit a42137f52c
2 changed files with 4 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
ntex-server/src/net/accept.rs
View file

@ -193,6 +193,7 @@ impl Accept {
let mut events = Events::with_capacity(NonZeroUsize::new(512).unwrap());
loop {
println!("------- ACCEPT LOOP");
if let Err(e) = self.poller.wait(&mut events, None) {
if e.kind() == io::ErrorKind::Interrupted {
continue;
@ -202,6 +203,7 @@ impl Accept {
}
for event in events.iter() {
println!("------- ACCEPTED {:?}", event);
let readd = self.accept(event.key);
if readd {
self.add_source(event.key);
@ -378,6 +380,7 @@ impl Accept {
}
fn accept(&mut self, token: usize) -> bool {
println!("------- ACCEPTING 1 {:?}", token);
loop {
if let Some(info) = self.sockets.get_mut(token) {
let item = info.sock.accept();

2
ntex-server/src/wrk.rs
View file

@ -260,7 +260,7 @@ where
T: Send + 'static,
F: ServiceFactory<T> + 'static,
{
//println!("------- start worker {:?}", wrk.id);
println!("------- start worker {:?}", wrk.id);
loop {
//println!("------- run worker {:?}", wrk.id);