added full ExtractCallback errors managementd to YACReader

2025-07-21 06:24:39 -04:00 · 2013-12-16 16:35:12 +01:00
commit 45b4bebce8
737 changed files with 67327 additions and 0 deletions
--- a/YACReaderLibrary/yacreader_local_server.cpp
+++ b/YACReaderLibrary/yacreader_local_server.cpp
@ -0,0 +1,188 @@
+#include "yacreader_local_server.h"
+
+#include <QLocalServer>
+#include <QLocalSocket>
+#include <QPointer>
+
+#include "yacreader_global.h"
+#include "db_helper.h"
+
+#include "comic_db.h"
+
+#include "QsLog.h"
+
+using namespace YACReader;
+
+QMutex YACReaderClientConnectionWorker::dbMutex;
+//int YACReaderClientConnectionWorker::count = 0;
+YACReaderLocalServer::YACReaderLocalServer(QObject *parent) :
+	QObject(parent)
+{
+	localServer = new QLocalServer(this);
+    QLocalServer::removeServer(YACREADERLIBRARY_GUID);
+	if (!localServer->listen(YACREADERLIBRARY_GUID)) {
+        QLOG_ERROR() << "Unable to create local server";
+	}
+
+	connect(localServer, SIGNAL(newConnection()), this, SLOT(sendResponse()));
+}
+
+bool YACReaderLocalServer::isListening()
+{
+	return localServer->isListening();
+}
+
+/*void YACReaderLocalServer::run()
+{
+	while(1)
+		exec();
+}*/
+
+void YACReaderLocalServer::sendResponse()
+{
+	QLocalSocket *clientConnection = localServer->nextPendingConnection();
+	//connect(clientConnection, SIGNAL(disconnected()),clientConnection, SLOT(deleteLater()));
+	clientConnection->setParent(0);
+
+	YACReaderClientConnectionWorker * worker = new YACReaderClientConnectionWorker(clientConnection);
+	if(worker != 0)
+	{
+		clientConnection->moveToThread(worker);
+		connect(worker,SIGNAL(comicUpdated(quint64, ComicDB)),this,SIGNAL(comicUpdated(quint64, ComicDB)));
+		connect(worker,SIGNAL(finished()),worker,SLOT(deleteLater()));
+		worker->start();
+	}
+	//clientConnection->waitForBytesWritten();*/
+	//clientConnection->disconnectFromServer();
+}
+
+bool YACReaderLocalServer::isRunning()
+{
+	QLocalSocket socket;
+	socket.connectToServer(YACREADERLIBRARY_GUID);
+	if (socket.waitForConnected(500)) 
+		return true; // Server is running (another instance of YACReaderLibrary has been launched)
+	return false;
+}
+
+
+YACReaderClientConnectionWorker::YACReaderClientConnectionWorker( QLocalSocket *cc)
+	:QThread(),clientConnection(cc)
+{
+
+}
+
+YACReaderClientConnectionWorker::~YACReaderClientConnectionWorker()
+{
+
+}
+/*#include <QFile>
+#include <QTextStream>
+#include <QDateTime>*/
+void YACReaderClientConnectionWorker::run()
+{
+	/*{
+	QFile f(QString("c:/temp/thread%1.txt").arg(count));
+	f.open(QIODevice::Append);
+	QTextStream out(&f);
+	out << QString("Thread%1 starts").arg(count) << endl;
+	f.close();
+	}
+	uint t1 = QDateTime::currentMSecsSinceEpoch();*/
+
+	quint64 libraryId;
+	ComicDB comic;
+	int tries = 0;
+	//QByteArray data;
+	while(clientConnection->bytesAvailable() < sizeof(quint16) && tries < 200)
+	{
+		clientConnection->waitForReadyRead(10);
+		tries++;
+	}
+	if(tries == 200)
+		return;
+	QDataStream sizeStream(clientConnection->read(sizeof(quint16)));
+	sizeStream.setVersion(QDataStream::Qt_4_8);
+	quint16 totalSize = 0;
+	sizeStream >> totalSize;
+
+	tries = 0;
+	while(clientConnection->bytesAvailable() < totalSize && tries < 200)
+	{
+		clientConnection->waitForReadyRead(10);
+		tries++;
+	}
+	if(tries == 200)
+		return;
+	QDataStream dataStream(clientConnection->read(totalSize));
+	quint8 msgType;
+	dataStream >> msgType;
+	dataStream >> libraryId;
+	dataStream >> comic;
+
+	switch (msgType)
+	{
+	case YACReader::RequestComicInfo:
+		{
+			QList<ComicDB> siblings;
+			getComicInfo(libraryId,comic,siblings);
+
+			QByteArray block;
+			QDataStream out(&block, QIODevice::WriteOnly);
+			out.setVersion(QDataStream::Qt_4_8);
+			out << (quint16)0;
+			out << comic;
+			out << siblings;
+			out.device()->seek(0);
+			out << (quint16)(block.size() - sizeof(quint16));
+
+			int  written = 0;
+			tries = 0;
+			while(written != block.size() && tries < 200)
+			{
+				int ret = clientConnection->write(block);
+				if(ret != -1)
+				{
+					written += ret;
+					clientConnection->flush();
+				}
+				else
+					tries++;
+			}
+			break;
+		}
+	case YACReader::SendComicInfo:
+		{
+			updateComic(libraryId,comic);
+			//clientConnection->disconnectFromServer();
+			break;
+		}
+
+	}
+
+	clientConnection->waitForDisconnected();
+	clientConnection->deleteLater();
+	/*count++;
+	uint t2 = QDateTime::currentMSecsSinceEpoch();
+	{
+	QFile f(QString("c:/temp/thread%1.txt").arg(count));
+	f.open(QIODevice::Append);
+	QTextStream out(&f);
+	out << QString("Thread%1 ends : time - %2").arg(count).arg(t2-t1) << endl;
+	f.close();
+	}*/
+}
+
+void YACReaderClientConnectionWorker::getComicInfo(quint64 libraryId, ComicDB & comic, QList<ComicDB> & siblings)
+{
+	QMutexLocker locker(&dbMutex);
+	comic = DBHelper::getComicInfo(DBHelper::getLibrariesNames().at(libraryId), comic.id);
+	siblings = DBHelper::getSiblings(DBHelper::getLibrariesNames().at(libraryId), comic.parentId);
+}
+
+void YACReaderClientConnectionWorker::updateComic(quint64 libraryId, ComicDB & comic)
+{
+	QMutexLocker locker(&dbMutex);
+	DBHelper::update(DBHelper::getLibrariesNames().at(libraryId), comic.info);
+	emit comicUpdated(libraryId, comic);
+}