malte_langkabel
c704b4f65c
* handled communication from VS to Coati and vice versa. * one bug still remains: Coati regards a tab as a single character while VS regards it as multiple characters. This causes offsets in communicated positions.
75 lines
1.5 KiB
C++
75 lines
1.5 KiB
C++
#include "QtTcpWrapper.h"
|
|
|
|
#include "utility/logging/logging.h"
|
|
|
|
QtTcpWrapper::QtTcpWrapper(QObject* parent, const std::string& ip, const quint16 port)
|
|
: QObject(parent)
|
|
, m_port(port)
|
|
, m_ip(ip)
|
|
{
|
|
QHostAddress address(m_ip.c_str());
|
|
|
|
m_tcpServer = new QTcpServer(this);
|
|
|
|
connect(m_tcpServer, SIGNAL(newConnection()), this, SLOT(acceptConnection()));
|
|
|
|
if (!m_tcpServer->listen(QHostAddress::LocalHost, m_port))
|
|
{
|
|
LOG_ERROR_STREAM(<< "TCP server failed to start with error: \"" + m_tcpServer->errorString().toStdString() + "\". Unable to listen for IDE plugin messages.");
|
|
}
|
|
}
|
|
|
|
QtTcpWrapper::~QtTcpWrapper()
|
|
{
|
|
if (m_tcpServer != NULL)
|
|
{
|
|
if (m_tcpServer->isListening())
|
|
{
|
|
m_tcpServer->close();
|
|
}
|
|
|
|
delete m_tcpServer;
|
|
}
|
|
}
|
|
|
|
void QtTcpWrapper::sendMessage(const std::string& message) const
|
|
{
|
|
QByteArray data;
|
|
data.append(message.c_str());
|
|
|
|
QTcpSocket socket;
|
|
socket.connectToHost(QHostAddress::LocalHost, 6666);
|
|
|
|
if (socket.waitForConnected())
|
|
{
|
|
socket.write(data);
|
|
socket.flush();
|
|
socket.waitForBytesWritten();
|
|
socket.close();
|
|
}
|
|
}
|
|
|
|
void QtTcpWrapper::setReadCallback(const std::function<void(const std::string&)>& callback)
|
|
{
|
|
m_readCallback = callback;
|
|
}
|
|
|
|
void QtTcpWrapper::acceptConnection()
|
|
{
|
|
m_tcpClient = m_tcpServer->nextPendingConnection();
|
|
|
|
connect(m_tcpClient, SIGNAL(readyRead()), this, SLOT(startRead()));
|
|
}
|
|
|
|
void QtTcpWrapper::startRead()
|
|
{
|
|
char buffer[1024] = { 0 };
|
|
m_tcpClient->read(buffer, m_tcpClient->bytesAvailable());
|
|
m_tcpClient->close();
|
|
|
|
if (m_readCallback != NULL)
|
|
{
|
|
m_readCallback(buffer);
|
|
}
|
|
}
|