295 lines
7.5 KiB
C++
295 lines
7.5 KiB
C++
#include "cdutils_core.h"
|
|
#include "cdutils_parser.h"
|
|
#include "piconfig.h"
|
|
#include "piiobytearray.h"
|
|
#include "piiostring.h"
|
|
#include "pifile.h"
|
|
|
|
using namespace CDUtils;
|
|
|
|
const char CDCore::app_config[] =
|
|
"include = cd_ip.conf\n\
|
|
port_rec = 2\n\
|
|
port_send = 1\n\
|
|
[connection]\n\
|
|
device.cd = peer://cd_app:cd_pult #s\n\
|
|
[]\n\
|
|
connectionmodel = AAAM2Xja7VXLTttAFD12QpsikKjUSixYlLbKEpIUtVIlVEfqhk2FWuiGRRolUYtoHgrmpYiv6IItf8AveMMH9E/YsG6Ph3sde5hGoQoblLGuPHfunTPjc49nADxDA110+LTYC7FrPCAPeAO+vZu+aX7c/8PGd45WCJC0OGcfT6FDnmfSTPtwhZFt3HjgDs/Qtu5jPbZHtI/x50XfIzMQbdwEolbg9INP4ku++myPaUtCHYRaT2j1ldIh3VP60/Qff8vSfXLu9BP6JX9K/0TVH6jqVe22P1X/fao/oddWu/paDs1vBf9Jv/EZ91clbyHqv7BL6sscDOd4v4WTqs6jzaHGJ8QJerxlpJSpdZ7IWFJvDW7I2JxZqIM62k6A57RZmMQGmlyrxdV+WGBnmR01mXPI267hBKwp4FeBeo9VPtssxyb7rzHg1B7T9nCMU45U8BZlWuVWtIcD/CRGOqtsbW09851tXsHN0UTlLIAdASjSXnLyLn+H7L2+xbGYvC63Ezqg543egkLmn8qnRF6USbM4Qp9godkhzI777Ne5bCIt/5UtGz2o/yGby0nKpjqmbOa1ynkjmyzIrzvIZUeBPjvlUmbh32EFJbGyJZhR8YcvlS+3TpjhqeWSyvUkpbI9plSWtcKLcsK05beOJVEnhaEFfHEH+RwpeMcpn1JKGqWMNOL+G6wZyahlpdVOtufKfbDS+guLke9O\n\
|
|
";
|
|
|
|
const char CDCore::pult_config[] =
|
|
"include = cd_ip.conf\n\
|
|
port_rec = 1\n\
|
|
port_send = 2\n\
|
|
[connection]\n\
|
|
device.cd = peer://cd_pult:cd_app #s\n\
|
|
[]\n\
|
|
connectionmodel = AAAM2Xja7VXLTttAFD12QpsikKjUSixYlLbKEpIUtVIlVEfqhk2FWuiGRRolUYtoHgrmpYiv6IItf8AveMMH9E/YsG6Ph3sde5hGoQoblLGuPHfunTPjc49nADxDA110+LTYC7FrPCAPeAO+vZu+aX7c/8PGd45WCJC0OGcfT6FDnmfSTPtwhZFt3HjgDs/Qtu5jPbZHtI/x50XfIzMQbdwEolbg9INP4ku++myPaUtCHYRaT2j1ldIh3VP60/Qff8vSfXLu9BP6JX9K/0TVH6jqVe22P1X/fao/oddWu/paDs1vBf9Jv/EZ91clbyHqv7BL6sscDOd4v4WTqs6jzaHGJ8QJerxlpJSpdZ7IWFJvDW7I2JxZqIM62k6A57RZmMQGmlyrxdV+WGBnmR01mXPI267hBKwp4FeBeo9VPtssxyb7rzHg1B7T9nCMU45U8BZlWuVWtIcD/CRGOqtsbW09851tXsHN0UTlLIAdASjSXnLyLn+H7L2+xbGYvC63Ezqg543egkLmn8qnRF6USbM4Qp9godkhzI777Ne5bCIt/5UtGz2o/yGby0nKpjqmbOa1ynkjmyzIrzvIZUeBPjvlUmbh32EFJbGyJZhR8YcvlS+3TpjhqeWSyvUkpbI9plSWtcKLcsK05beOJVEnhaEFfHEH+RwpeMcpn1JKGqWMNOL+G6wZyahlpdVOtufKfbDS+guLke9O\n\
|
|
";
|
|
|
|
|
|
int __Core_Initializer__::count_(0);
|
|
CDCore * __Core_Initializer__::__instance__(0);
|
|
|
|
|
|
__Core_Initializer__::__Core_Initializer__() {
|
|
count_++;
|
|
//piCout << "try create Core" << count_;
|
|
if (count_ > 1) return;
|
|
//piCout << "create Core";
|
|
__instance__ = new CDCore();
|
|
}
|
|
|
|
|
|
__Core_Initializer__::~__Core_Initializer__() {
|
|
count_--;
|
|
//piCout << "try delete Core" << count_;
|
|
if (count_ > 0) return;
|
|
//piCout << "delete Core";
|
|
if (__instance__ != 0) {
|
|
delete __instance__;
|
|
__instance__ = 0;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
CDCore::CDCore() {
|
|
setName("CDCore");
|
|
datatr.setPacketSize(960);
|
|
CONNECTU(&connection, dataReceivedEvent, this, dataReceived);
|
|
/*PIString s(app_config);
|
|
connection.configureFromString(&s);
|
|
connection.start();*/
|
|
k_.name = "__root__";
|
|
k_.alias = "root";
|
|
|
|
CONNECTU(&datatr, sendRequest, this, dtSendRequest)
|
|
CONNECTU(&datatr, receiveFinished, this, dtReceiveFinished)
|
|
CONNECTU(&sendt, started, this, sendThread)
|
|
CONNECTU(&x_timer, tickEvent, this, xTimerTick)
|
|
|
|
/*k_[1] = KType(1, "123", "120+3", "comment");
|
|
k_[2] = KType(2, "1", "2", "comm");
|
|
k_[4] = KType(4, "-0.6", "-6/10", "mment");
|
|
k_.section(10)[5] = KType(5, "8", "2*2*2", "88");
|
|
k_.section(10).section(50)[100] = KType(100, "8", "2*2*2", "88");
|
|
k_.section(11)[3] = KType(3, "1", "1", "88");
|
|
k_.section(11)[4] = KType(4, "0", "0", "88");
|
|
k_.section(11)[6] = KType(6, "0", "0", "88");*/
|
|
//piCout << s;
|
|
}
|
|
|
|
|
|
CDCore::~CDCore() {
|
|
datatr.stop();
|
|
x_timer.stop();
|
|
sendt.stop();
|
|
sendt.waitForFinish(10);
|
|
connection.stop();
|
|
}
|
|
|
|
|
|
void CDCore::k_write(PIIODevice * d) {
|
|
k_.write(d, PIString());
|
|
}
|
|
|
|
|
|
void CDCore::k_read(PIIODevice * d) {
|
|
PIConfig conf(d, PIIODevice::ReadOnly);
|
|
k_.read(&(conf.rootEntry()));
|
|
k_.makePath();
|
|
K_ChangedGlobal();
|
|
PIVector<PIIODevice * > ds = connection.allDevices();
|
|
// piForeach(PIIODevice * d, ds) {
|
|
// if (d)
|
|
// piCoutObj << d->constructFullPath() << d->isOpened();
|
|
// }
|
|
}
|
|
|
|
|
|
void CDCore::k_parse(PIIODevice * d) {
|
|
k_ = CDParser::parse(d, CDType::cdK);
|
|
k_.makePath();
|
|
K_ChangedGlobal();
|
|
k_.name = "__root__";
|
|
k_.alias = "root";
|
|
}
|
|
|
|
|
|
void CDCore::k_update(PIIODevice * d) {
|
|
CDSection uk = k_;
|
|
k_parse(d);
|
|
bool kn = true;
|
|
if (!uk.isEmpty())
|
|
if (!uk.isSameStructure(k_)) {
|
|
piCout << "ask for save names";
|
|
K_KeepNamesRequest(&kn);
|
|
}
|
|
uk.update(k_, kn);
|
|
//piCout << k_.count() << uk.count();
|
|
k_ = uk;
|
|
k_.makePath();
|
|
k_.calculate();
|
|
K_ChangedGlobal();
|
|
}
|
|
|
|
|
|
void CDCore::k_calculate() {
|
|
k_.calculate();
|
|
K_ChangedGlobal();
|
|
}
|
|
|
|
|
|
void CDCore::initApp() {
|
|
init(appConfig());
|
|
}
|
|
|
|
|
|
void CDCore::initPult() {
|
|
init(pultConfig());
|
|
}
|
|
|
|
|
|
void CDCore::init(const PIString & configuration) {
|
|
PIString c = configuration;
|
|
//piCoutObj << "init" << c;
|
|
connection.stop();
|
|
connection.removeAllDevices();
|
|
connection.configureFromString(&c);
|
|
connection.start();
|
|
}
|
|
|
|
|
|
void CDCore::startPing() {
|
|
x_timer.start(1);
|
|
}
|
|
|
|
|
|
void CDUtils::CDCore::dataReceived(const PIString & from, const PIByteArray & data) {
|
|
// piCoutObj << "dataReceived" << from << data.size();
|
|
PIIODevice * d = connection.deviceByName("cd");
|
|
if (d && d == connection.deviceByFullPath(from)) {
|
|
if (data.size() >= sizeof(4)) {
|
|
const uint sig = *((const uint*)(data.data()));
|
|
if (sig == PIBaseTransfer::packetSignature()) datatr.received(data);
|
|
else {
|
|
CDPacketType pt = (CDPacketType)sig;
|
|
switch(pt) {
|
|
case CD_Ping:
|
|
//piCoutObj << "ping";
|
|
break;
|
|
default: break;
|
|
}
|
|
}
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
|
|
CDCore * CDCore::instance() {
|
|
/*static CDCore * ret = new CDCore();
|
|
return ret;*/
|
|
return __Core_Initializer__::__instance__;
|
|
}
|
|
|
|
|
|
void CDCore::K_Send() {
|
|
piCoutObj << "K_Send";
|
|
PIByteArray ba;
|
|
PIIOByteArray iob(&ba, PIIODevice::ReadWrite);
|
|
k_write(&iob);
|
|
//piCoutObj << PIString(ba);
|
|
if (sendt.isRunning()) {
|
|
piCoutObj << "send in process...";
|
|
return;
|
|
}
|
|
wheader.session_id = 0;
|
|
wheader.type = CD_KSend;
|
|
send_data.clear();
|
|
send_data << wheader << ba;
|
|
sendt.startOnce();
|
|
// ios.close();
|
|
// piCout << s;
|
|
//PIByteArray ba = PIByteArray::fromString(s);
|
|
// PIFile pf("k.txt", PIIODevice::ReadWrite);
|
|
// pf.resize(0);
|
|
// pf.write(s.toUTF8());
|
|
//k_write(&pf);
|
|
//piCout << pf.readLine();
|
|
}
|
|
|
|
|
|
void CDCore::K_Request() {
|
|
piCoutObj << "K_Request";
|
|
if (sendt.isRunning()) {
|
|
piCoutObj << "send in process...";
|
|
return;
|
|
}
|
|
wheader.session_id = 0;
|
|
wheader.type = CD_KQuery;
|
|
send_data.clear();
|
|
send_data << wheader;
|
|
sendt.startOnce();
|
|
}
|
|
|
|
|
|
void CDCore::sendThread() {
|
|
bool ok = datatr.send(send_data);
|
|
CDPacketType pt = (CDPacketType)wheader.type;
|
|
switch (pt) {
|
|
case CD_KSend:
|
|
if (ok) K_Sended();
|
|
else K_SendFail();
|
|
break;
|
|
case CD_KQuery:
|
|
if (!ok) K_ReceiveFail();
|
|
break;
|
|
default: break;
|
|
}
|
|
}
|
|
|
|
|
|
void CDCore::xTimerTick() {
|
|
PacketHeader ph;
|
|
ph.type = CD_Ping;
|
|
PIByteArray ba;
|
|
ba << ph;
|
|
connection.writeByName("cd", ba);
|
|
}
|
|
|
|
|
|
void CDCore::dtSendRequest(PIByteArray &data) {
|
|
connection.writeByName("cd", data);
|
|
// piCoutObj << "send" << data.size() << ret;
|
|
}
|
|
|
|
|
|
void CDCore::dtReceiveFinished(bool ok) {
|
|
if (ok) {
|
|
PIByteArray ba = datatr.data();
|
|
PacketHeader p;
|
|
ba >> p;
|
|
CDPacketType pt = (CDPacketType)p.type;
|
|
switch (pt) {
|
|
case CD_KQuery:
|
|
K_Send();
|
|
break;
|
|
case CD_KSend: {
|
|
piCoutObj << "K received";
|
|
PIByteArray k;
|
|
ba >> k;
|
|
k << uchar(0);
|
|
PIString s = PIString::fromUTF8((const char *)k.data());
|
|
PIIOString ios(&s);
|
|
k_read(&ios);
|
|
K_Received();
|
|
} break;
|
|
default: break;
|
|
}
|
|
}
|
|
}
|
|
|