summaryrefslogtreecommitdiffstats
path: root/pica-client/nodethread.cpp
diff options
context:
space:
mode:
authorAnton <anton@picapica>2017-12-01 22:16:24 +0400
committerAnton <anton@picapica>2017-12-01 22:16:24 +0400
commit0f726c30f5f11990d325bc5e55015c42c80cd9d2 (patch)
treef8c9b83cc440dd3a2f43285dc35199435f6e2701 /pica-client/nodethread.cpp
parentac041927bc0c82e33acaa9e15fd46ecca0b77172 (diff)
downloadpica-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.cpp196
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;
}