generic-library/ssh2
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

improved non-blocking behavior for some of the initing stuff before the actual

Browse Source 
data transfer begins
This commit is contained in:
Daniel Stenberg 2009-03-13 22:14:47 +00:00
parent 2ba8db9168
commit d89782d99f
1 changed files with 24 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
example/simple/sftp_nonblock.c
View File

@ -1,5 +1,5 @@
/* /*
* $Id: sftp_nonblock.c,v 1.16 2009/03/13 12:35:13 bagder Exp $ * $Id: sftp_nonblock.c,v 1.17 2009/03/13 22:14:47 bagder Exp $
* *
* Sample showing how to do SFTP non-blocking transfers. * Sample showing how to do SFTP non-blocking transfers.
* *
@ -205,15 +205,23 @@ int main(int argc, char *argv[])
goto shutdown; goto shutdown;
} }
} }
#if 0
libssh2_trace(session, LIBSSH2_TRACE_CONN);
#endif
fprintf(stderr, "libssh2_sftp_init()!\n"); fprintf(stderr, "libssh2_sftp_init()!\n");
do { do {
sftp_session = libssh2_sftp_init(session); sftp_session = libssh2_sftp_init(session);
if ((!sftp_session) && (libssh2_session_last_errno(session) != if(!sftp_session) {
LIBSSH2_ERROR_EAGAIN)) { if(libssh2_session_last_errno(session) ==
fprintf(stderr, "Unable to init SFTP session\n"); LIBSSH2_ERROR_EAGAIN) {
goto shutdown; fprintf(stderr, "non-blocking init\n");
waitsocket(sock, session); /* now we wait */
}
else {
fprintf(stderr, "Unable to init SFTP session\n");
goto shutdown;
}
} }
} while (!sftp_session); } while (!sftp_session);
@ -223,10 +231,15 @@ int main(int argc, char *argv[])
sftp_handle = libssh2_sftp_open(sftp_session, sftppath, sftp_handle = libssh2_sftp_open(sftp_session, sftppath,
LIBSSH2_FXF_READ, 0); LIBSSH2_FXF_READ, 0);
if (!sftp_handle && if (!sftp_handle) {
(libssh2_session_last_errno(session) != LIBSSH2_ERROR_EAGAIN)) { if (libssh2_session_last_errno(session) != LIBSSH2_ERROR_EAGAIN) {
fprintf(stderr, "Unable to open file with SFTP\n"); fprintf(stderr, "Unable to open file with SFTP\n");
goto shutdown; goto shutdown;
}
else {
fprintf(stderr, "non-blocking open\n");
waitsocket(sock, session); /* now we wait */
}
} }
} while (!sftp_handle); } while (!sftp_handle);
@ -258,6 +271,7 @@ int main(int argc, char *argv[])
shutdown: shutdown:
printf("libssh2_session_disconnect\n");
while ((rc = libssh2_session_disconnect(session, while ((rc = libssh2_session_disconnect(session,
"Normal Shutdown, Thank you")) == "Normal Shutdown, Thank you")) ==
LIBSSH2_ERROR_EAGAIN); LIBSSH2_ERROR_EAGAIN);