|
@@ -48,8 +48,6 @@ stateMachine::~stateMachine()
|
|
|
*/
|
|
|
void stateMachine::init(QString tmp){
|
|
|
if(tmp =="recvClient"){
|
|
|
-
|
|
|
- printf("------------recvThread started-------------------\n");
|
|
|
recvThread = new QThread();
|
|
|
recvClient = new rabbitClient("recvClient");
|
|
|
connect(recvClient,SIGNAL(sendmsg_recvclientToRecvstate(std::string)),this,SLOT(getmsg_recvclientToRecvstate(std::string)));
|
|
@@ -66,8 +64,6 @@ void stateMachine::init(QString tmp){
|
|
|
});
|
|
|
recvThread->start();
|
|
|
}else{
|
|
|
-
|
|
|
- printf("------------sendThread started-------------------\n");
|
|
|
sendThread = new QThread();
|
|
|
sendClient = new rabbitClient("sendClient");
|
|
|
connect(this,SIGNAL(sendImg_sendstateToSendclient(std::string)),sendClient,SLOT(sendMsg(std::string)));
|
|
@@ -92,7 +88,6 @@ void stateMachine::init(QString tmp){
|
|
|
void stateMachine::getmsg_recvclientToRecvstate(std::string Recvmsg)
|
|
|
{
|
|
|
mutex.lock();
|
|
|
- printf("---------------state Machine slot recv(QString)-----------------------\n");
|
|
|
recvMsgQueue.push_back(QString::fromStdString(Recvmsg));
|
|
|
emit sendmsg_recvstateTohandlePool(Recvmsg);//信号
|
|
|
recvMsgQueue.clear();
|
|
@@ -133,7 +128,6 @@ void stateMachine::restart_send_client_slot()
|
|
|
void stateMachine::getImg_handlePoolToSendstate(std::string img)
|
|
|
{
|
|
|
mutex.lock();
|
|
|
- printf("------------------statemachine getimgfile----------------------\n");
|
|
|
emit sendImg_sendstateToSendclient(img);//信号
|
|
|
qDebug()<<"--------------------"<<QString::fromStdString(img);
|
|
|
mutex.unlock();
|