diff options
| author | Anton <anton@picapica> | 2017-12-01 22:16:24 +0400 |
|---|---|---|
| committer | Anton <anton@picapica> | 2017-12-01 22:16:24 +0400 |
| commit | 0f726c30f5f11990d325bc5e55015c42c80cd9d2 (patch) | |
| tree | f8c9b83cc440dd3a2f43285dc35199435f6e2701 /pica-client/nodethread.cpp | |
| parent | ac041927bc0c82e33acaa9e15fd46ecca0b77172 (diff) | |
| download | pica-pica-0f726c30f5f11990d325bc5e55015c42c80cd9d2.tar.gz pica-pica-0f726c30f5f11990d325bc5e55015c42c80cd9d2.zip | |
fixed code style on all source files (*.c *.cpp *.h) using astyle --style=allman --lineend=linux --indent=tab --pad-oper
Diffstat (limited to 'pica-client/nodethread.cpp')
| -rw-r--r-- | pica-client/nodethread.cpp | 196 |
1 files changed, 98 insertions, 98 deletions
diff --git a/pica-client/nodethread.cpp b/pica-client/nodethread.cpp index ee6504f..bf93e83 100644 --- a/pica-client/nodethread.cpp +++ b/pica-client/nodethread.cpp @@ -7,112 +7,112 @@ QMutex NodeThread::finished_mutex; NodeThread::NodeThread(Nodes::NodeRecord &addr, bool *completed, PICA_acc *acc, PICA_c2n **pica_conn, QMutex *wm) : - QThread(0) + QThread(0) { - node_addr = addr; - finished_flag = completed; - user_account = acc; - connection = pica_conn; - write_mutex = wm; - exit = 0; - start(); + node_addr = addr; + finished_flag = completed; + user_account = acc; + connection = pica_conn; + write_mutex = wm; + exit = 0; + start(); } void NodeThread::run() { - int ret; - exit = 0; - - /*ret = PICA_new_c2n(node_addr.address.toUtf8().constData(), - node_addr.port, - user_account.CA_file.toUtf8().constData(), - user_account.cert_file.toUtf8().constData(), - user_account.pkey_file.toUtf8().constData(), - DHParam::GetDHParamFilename().toUtf8().constData(), - AskPassword::ask_password_cb, - &ci);*/ - ret = PICA_new_c2n(user_account, node_addr.address.toUtf8().constData(), node_addr.port, &ci); - - switch(ret) - { - case PICA_OK: - - emit NodeStatusChanged(node_addr.address, node_addr.port, true); - - finished_mutex.lock(); - if (*finished_flag) - { - PICA_close_c2n(ci); - exit = 1; - } - else - { - *finished_flag = true; - *connection = ci; - emit ConnectedToNode(node_addr.address, node_addr.port, this); - } - finished_mutex.unlock(); - - - - break; - - case PICA_ERRSOCK: - case PICA_ERRDNSRESOLVE: - - emit NodeStatusChanged(node_addr.address, node_addr.port, false); - - exit = 1; - break; - - case PICA_ERRSSL: - exit = 1; - break; - - case PICA_ERRPROTONEW: - - emit ErrorMsg(QString("Node %1:%2 has newer protocol version. Please check if update for pica-client is available") - .arg(node_addr.address) - .arg(node_addr.port) - ); - exit = 1; - break; - - case PICA_ERRPROTOOLD: - - emit ErrorMsg(QString("Node %1:%2 has older protocol. Disconnected.") - .arg(node_addr.address) - .arg(node_addr.port) - ); - - exit = 1; - break; - - default: - exit = 1; - } - - if (exit) - return; - - do - { - write_mutex->lock(); - if (PICA_read(ci,10000) != PICA_OK || PICA_write(ci) != PICA_OK) - exit=1; - write_mutex->unlock(); - msleep(300); - } - while (!exit); - - write_mutex->lock(); - PICA_close_c2n(ci); - *connection = NULL; - write_mutex->unlock(); + int ret; + exit = 0; + + /*ret = PICA_new_c2n(node_addr.address.toUtf8().constData(), + node_addr.port, + user_account.CA_file.toUtf8().constData(), + user_account.cert_file.toUtf8().constData(), + user_account.pkey_file.toUtf8().constData(), + DHParam::GetDHParamFilename().toUtf8().constData(), + AskPassword::ask_password_cb, + &ci);*/ + ret = PICA_new_c2n(user_account, node_addr.address.toUtf8().constData(), node_addr.port, &ci); + + switch(ret) + { + case PICA_OK: + + emit NodeStatusChanged(node_addr.address, node_addr.port, true); + + finished_mutex.lock(); + if (*finished_flag) + { + PICA_close_c2n(ci); + exit = 1; + } + else + { + *finished_flag = true; + *connection = ci; + emit ConnectedToNode(node_addr.address, node_addr.port, this); + } + finished_mutex.unlock(); + + + + break; + + case PICA_ERRSOCK: + case PICA_ERRDNSRESOLVE: + + emit NodeStatusChanged(node_addr.address, node_addr.port, false); + + exit = 1; + break; + + case PICA_ERRSSL: + exit = 1; + break; + + case PICA_ERRPROTONEW: + + emit ErrorMsg(QString("Node %1:%2 has newer protocol version. Please check if update for pica-client is available") + .arg(node_addr.address) + .arg(node_addr.port) + ); + exit = 1; + break; + + case PICA_ERRPROTOOLD: + + emit ErrorMsg(QString("Node %1:%2 has older protocol. Disconnected.") + .arg(node_addr.address) + .arg(node_addr.port) + ); + + exit = 1; + break; + + default: + exit = 1; + } + + if (exit) + return; + + do + { + write_mutex->lock(); + if (PICA_read(ci, 10000) != PICA_OK || PICA_write(ci) != PICA_OK) + exit = 1; + write_mutex->unlock(); + msleep(300); + } + while (!exit); + + write_mutex->lock(); + PICA_close_c2n(ci); + *connection = NULL; + write_mutex->unlock(); } void NodeThread::CloseThread() { - exit = 1; + exit = 1; } |
