qtforum.de

Code: Alles auswählen

			quint16 personCount;
			personCount = cam->getPersonCount();
			qDebug() << personCount;
			*out << personCount;
			write(block);
			flush();

Code: Alles auswählen

	out = new QDataStream(&block, QIODevice::WriteOnly);
	out->setVersion(QDataStream::Qt_4_0);

Code: Alles auswählen

    QDataStream in(&socket);
    in.setVersion(QDataStream::Qt_4_0);

	qDebug("Data available!");


    if (blockSize == 0) {
        if (socket.bytesAvailable() < (int)sizeof(quint16))
            return;

        in >> blockSize;
    }

    qDebug() << socket.bytesAvailable();
    qDebug() << blockSize;

Code: Alles auswählen

private:
	QTcpSocket*		socket;
	QBuffer*		buffer;

QChatClient::QChatClient(QWidget* parent, Qt::WFlags flags) 
: QMainWindow(parent, flags)
{
	
	buffer = new QBuffer(this);
	socket = new QTcpSocket(this);
	buffer->open(QIODevice::ReadWrite);
	
}

void QChatClient::toggleConnection()
{
	if (socket->state() == QAbstractSocket::UnconnectedState)
	{
		socket->connectToHost(server, port);
	}
	
	else
	{
		socket->disconnectFromHost();
	}
}

void QChatClient::receiveMessage()
{
	// missing some checks for returns values for the sake of simplicity
	qint64 bytes = buffer->write(socket->readAll());
	// go back as many bytes as we just wrote so that it can be read
	buffer->seek(buffer->pos() - bytes);
	// read only full lines, line by line
	while (buffer->canReadLine())
	{
		QString line = buffer->readLine();
		
	}
}

Code: Alles auswählen

private:
	QHash<QTcpSocket*, QBuffer*> buffers;
void QChatServer::addConnection()
{
	QTcpSocket* connection = nextPendingConnection();
	connections.append(connection);
	QBuffer* buffer = new QBuffer(this);
	buffer->open(QIODevice::ReadWrite);
	buffers.insert(connection, buffer);
	connect(connection, SIGNAL(disconnected()), SLOT(removeConnection()));
	connect(connection, SIGNAL(readyRead()),	SLOT(receiveMessage()));
}

void QChatServer::removeConnection()
{
	QTcpSocket* socket = static_cast<QTcpSocket*>(sender());
	QBuffer* buffer = buffers.take(socket);
	QByteArray t = nicks.at(connections.indexOf(socket));
	nicks.removeAll(t);
	buffer->close();
	buffer->deleteLater();
	connections.removeAll(socket);
	socket->deleteLater();
}

void QChatServer::receiveMessage()
{
	QTcpSocket* socket = static_cast<QTcpSocket*>(sender());
	QBuffer* buffer = buffers.value(socket);
	
	// missing some checks for returns values for the sake of simplicity
	qint64 bytes = buffer->write(socket->readAll());
	// go back as many bytes as we just wrote so that it can be read
	buffer->seek(buffer->pos() - bytes);
	// read only full lines, line by line
	while (buffer->canReadLine())
	{
		QByteArray line = buffer->readLine();
		
			qDebug(line);
			foreach (QTcpSocket* connection, connections)
			{
				connection->write(line);
			}
		
	}
}