WolfSSL
/
wolfssh
mirror of https://github.com/wolfSSL/wolfssh.git
1
0
Fork 0
Code Issues Releases Wiki Activity

example echoserver behaves like a crude echoserver

pull/1/head
John Safranek 2015-01-14 15:04:47 -08:00
parent e21e6fd0eb
commit 2ce312400a
1 changed files with 11 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
examples/echoserver/echoserver.c
View File

@ -245,25 +245,22 @@ static THREAD_RETURN CYASSL_THREAD server_worker(void* vArgs)
{ {
WOLFSSH* ssh = (WOLFSSH*)vArgs; WOLFSSH* ssh = (WOLFSSH*)vArgs;
SOCKET_T clientFd = wolfSSH_get_fd(ssh); SOCKET_T clientFd = wolfSSH_get_fd(ssh);
const char* msgA = "Who's there?!\r\n";
const char* msgB = "Go away!\r\n";
char rxBuf[4096]; char buf[4096];
int rxBufSz; int bufSz;
if (wolfSSH_accept(ssh) == WS_SUCCESS) { if (wolfSSH_accept(ssh) == WS_SUCCESS) {
wolfSSH_stream_send(ssh, (uint8_t*)msgA, (uint32_t)strlen(msgA)); while (1) {
bufSz = wolfSSH_stream_read(ssh, (uint8_t*)buf, sizeof(buf));
rxBufSz = wolfSSH_stream_read(ssh, (uint8_t*)rxBuf, sizeof(rxBuf)); if (bufSz > 0) {
if (rxBufSz > 0) { wolfSSH_stream_send(ssh, (uint8_t*)buf, bufSz);
rxBuf[rxBufSz] = 0; }
printf("client sent %d bytes\n%s", rxBufSz, rxBuf); else {
printf("wolfSSH_stream_read returned %d\n", bufSz);
break;
}
} }
else
printf("wolfSSH_stream_read returned %d\n", rxBufSz);
wolfSSH_stream_send(ssh, (uint8_t*)msgB, (uint32_t)strlen(msgB));
} }
close(clientFd); close(clientFd);
wolfSSH_free(ssh); wolfSSH_free(ssh);