1 files changed, 118 insertions, 0 deletions
diff --git a/src/pmtime/timelord.h b/src/pmtime/timelord.h
new file mode 100644
index 0000000..31fedf9
--- /dev/null
+++ b/src/pmtime/timelord.h
@@ -0,0 +1,118 @@
+/*
+ * Copyright (c) 2007, Aconex.  All Rights Reserved.
+ * 
+ * This program is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU General Public License as published by the
+ * Free Software Foundation; either version 2 of the License, or (at your
+ * option) any later version.
+ * 
+ * This program is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
+ * or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
+ * for more details.
+ */
+#ifndef TIMELORD_H
+#define TIMELORD_H
+
+#include <QtCore/QVariant>
+#include <QtCore/QTimer>
+#include <QtCore/QList>
+#include <QtCore/QTextStream>
+#include <QtNetwork/QTcpSocket>
+#include <QtNetwork/QTcpServer>
+#include <QtGui/QApplication>
+
+#include "console.h"
+#include "pmtimelive.h"
+#include "pmtimearch.h"
+
+// The TimeClient class provides a socket that is connected with a client.
+// For every client that connects to the server, the server creates a new
+// instance of this class.
+//
+class TimeClient : public QObject
+{
+    Q_OBJECT
+
+public:
+    // State transitions for a pmtime client.  Basic SET/ACK protocol is:
+    // - client connects and sends initial (global) SET
+    // - server responds with ACK (beware live mode, with timers SETs here)
+    // - server now sends SETs with optional ACKs, until first ACK recv'd
+    // - after first ACK recv'd by server, all subsequent SETs must be ACK'd.
+    // The other messages can be sent/recv'd any time after the server has
+    // ACK'd the initial connection.
+    //
+    typedef enum {
+	Disconnected = 1,
+	ClientConnectSET,
+	ServerConnectACK,
+	ServerNeedACK,
+	ClientReady,
+    } State;
+
+public:
+    TimeClient(QTcpSocket *socket, QObject *parent);
+    ~TimeClient();
+    void reset();
+
+    void setContext(PmTimeArch *ac, PmTimeLive *hc) { my.ac = ac; my.hc = hc; }
+    bool writeClient(PmTime::Packet *k, char *tz = NULL, int tzlen = 0,
+				char *label = NULL, int llen = 0);
+
+signals:
+    void endConnect(TimeClient *);
+
+public slots:
+    void readClient();
+    void disconnectClient();
+
+private:
+    struct {
+	QTcpSocket *socket;
+	TimeClient::State state;
+	PmTime::Source source;
+	struct timeval acktime;	// time position @ last STEP
+	PmTimeLive *hc;
+	PmTimeArch *ac;
+    } my;
+};
+
+// The TimeLord class is a QTcpServer which randomly travels the space-
+// time continuim, servicing and connecting up clients with the server;
+// it also hooks up logging of the action to the wide-screen console in
+// the Tardis.
+//
+// For each client that connects it creates a new TimeClient (maintained
+// in a QList) - the new instance is responsible for communication with
+// that TCP client.
+//
+class TimeLord : public QTcpServer
+{
+    Q_OBJECT
+
+public:
+    TimeLord(QApplication *app);
+    void setContext(PmTimeLive *live, PmTimeArch *archive);
+
+signals:
+    void lastClientExit();
+
+public slots:
+    void quit();
+    void newConnection();
+    void endConnect(TimeClient *client);
+    void timePulse(PmTime::Packet *k);
+    void boundsPulse(PmTime::Packet *k);
+    void vcrModePulse(PmTime::Packet *k, int drag);
+    void tzPulse(PmTime::Packet *k, char *t, int tlen, char *l, int llen);
+
+private:
+    struct {
+	PmTimeLive *hc;
+	PmTimeArch *ac;
+	QList<TimeClient*> clientlist;
+    } my;
+};
+
+#endif // TIMELORD_H