mirrors
/
ssheven
mirror of https://github.com/cy384/ssheven.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ssh read speed improvements

This commit is contained in:
cy384 2020-09-14 17:26:14 -04:00
parent 1edeac2637
commit 25550db076
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
ssheven.c
View File

@ -120,8 +120,9 @@ void end_connection(void)
read_thread_state = DONE; read_thread_state = DONE;
} }
void check_network_events(void) int check_network_events(void)
{ {
int ok = 1;
OSStatus err = noErr; OSStatus err = noErr;
// check if we have any new network events // check if we have any new network events
@ -132,18 +133,20 @@ void check_network_events(void)
case T_DATA: case T_DATA:
case T_EXDATA: case T_EXDATA:
// got data // got data
ssh_read(); // we always try to read, so ignore this event
break; break;
case T_RESET: case T_RESET:
// connection reset? close it/give up // connection reset? close it/give up
end_connection(); end_connection();
ok = 0;
break; break;
case T_DISCONNECT: case T_DISCONNECT:
// got disconnected // got disconnected
OTRcvDisconnect(ssh_con.endpoint, nil); OTRcvDisconnect(ssh_con.endpoint, nil);
end_connection(); end_connection();
ok = 0;
break; break;
case T_ORDREL: case T_ORDREL:
@ -154,6 +157,7 @@ void check_network_events(void)
err = OTSndOrderlyDisconnect(ssh_con.endpoint); err = OTSndOrderlyDisconnect(ssh_con.endpoint);
} }
end_connection(); end_connection();
ok = 0;
break; break;
default: default:
@ -161,7 +165,7 @@ void check_network_events(void)
break; break;
} }
return; return ok;
} }
void display_about_box(void) void display_about_box(void)
@ -682,7 +686,7 @@ void* read_thread(void* arg)
// process incoming data until we've failed or are asked to EXIT // process incoming data until we've failed or are asked to EXIT
while (read_thread_command == READ && read_thread_state == OPEN) while (read_thread_command == READ && read_thread_state == OPEN)
{ {
check_network_events(); if (check_network_events()) ssh_read();
YieldToAnyThread(); YieldToAnyThread();
} }