diff --git a/examples/senddata.c b/examples/senddata.c index 853cdc5a..81cf0a13 100644 --- a/examples/senddata.c +++ b/examples/senddata.c @@ -5,60 +5,60 @@ #define LIMIT 0x100000000UL -int main(void) { - ssh_session session; - ssh_channel channel; - char buffer[1024 * 1024] = {0}; - int rc; - uint64_t total=0; - uint64_t lastshown=4096; - session = connect_ssh("localhost", NULL, 0); - if (session == NULL) { - return 1; - } - - channel = ssh_channel_new(session); - if (channel == NULL) { - ssh_disconnect(session); - return 1; - } - - rc = ssh_channel_open_session(channel); - if (rc < 0) { - ssh_channel_close(channel); - ssh_disconnect(session); - return 1; - } - - rc = ssh_channel_request_exec(channel, "cat > /dev/null"); - if (rc < 0) { - ssh_channel_close(channel); - ssh_disconnect(session); - return 1; - } - - - while ((rc = ssh_channel_write(channel, buffer, sizeof(buffer))) > 0) { - total += rc; - if(total/2 >= lastshown){ - printf("written %llx\n", (long long unsigned int) total); - lastshown=total; +int main(void) +{ + ssh_session session; + ssh_channel channel; + char buffer[1024 * 1024] = {0}; + int rc; + uint64_t total = 0; + uint64_t lastshown = 4096; + session = connect_ssh("localhost", NULL, 0); + if (session == NULL) { + return 1; } - if(total > LIMIT) - break; - } - if (rc < 0) { - printf("error : %s\n",ssh_get_error(session)); + channel = ssh_channel_new(session); + if (channel == NULL) { + ssh_disconnect(session); + return 1; + } + + rc = ssh_channel_open_session(channel); + if (rc < 0) { + ssh_channel_close(channel); + ssh_disconnect(session); + return 1; + } + + rc = ssh_channel_request_exec(channel, "cat > /dev/null"); + if (rc < 0) { + ssh_channel_close(channel); + ssh_disconnect(session); + return 1; + } + + while ((rc = ssh_channel_write(channel, buffer, sizeof(buffer))) > 0) { + total += rc; + if (total / 2 >= lastshown) { + printf("written %llx\n", (long long unsigned int)total); + lastshown = total; + } + if (total > LIMIT) + break; + } + + if (rc < 0) { + printf("error : %s\n", ssh_get_error(session)); + ssh_channel_close(channel); + ssh_disconnect(session); + return 1; + } + + ssh_channel_send_eof(channel); ssh_channel_close(channel); + ssh_disconnect(session); - return 1; - } - ssh_channel_send_eof(channel); - ssh_channel_close(channel); - - ssh_disconnect(session); - - return 0; + return 0; }