aboutsummaryrefslogtreecommitdiff
path: root/nxcomp/ServerStore.cpp
diff options
context:
space:
mode:
authorReinhard Tartler <siretart@tauware.de>2011-11-13 09:27:51 +0100
committerReinhard Tartler <siretart@tauware.de>2011-11-13 09:27:51 +0100
commit3e924126b56c4d421e8263d25f6b14aa4ceed047 (patch)
tree921403de7b834fb1ac89f97d84ce105e0b487051 /nxcomp/ServerStore.cpp
parenta840692edc9c6d19cd7c057f68e39c7d95eb767d (diff)
downloadnx-libs-3e924126b56c4d421e8263d25f6b14aa4ceed047.tar.gz
nx-libs-3e924126b56c4d421e8263d25f6b14aa4ceed047.tar.bz2
nx-libs-3e924126b56c4d421e8263d25f6b14aa4ceed047.zip
Imported nxcomp-3.1.0-4.tar.gznxcomp/3.1.0-4
Summary: Imported nxcomp-3.1.0-4.tar.gz Keywords: Imported nxcomp-3.1.0-4.tar.gz into Git repository
Diffstat (limited to 'nxcomp/ServerStore.cpp')
-rwxr-xr-xnxcomp/ServerStore.cpp171
1 files changed, 171 insertions, 0 deletions
diff --git a/nxcomp/ServerStore.cpp b/nxcomp/ServerStore.cpp
new file mode 100755
index 000000000..5544cd5f2
--- /dev/null
+++ b/nxcomp/ServerStore.cpp
@@ -0,0 +1,171 @@
+/**************************************************************************/
+/* */
+/* Copyright (c) 2001, 2007 NoMachine, http://www.nomachine.com/. */
+/* */
+/* NXCOMP, NX protocol compression and NX extensions to this software */
+/* are copyright of NoMachine. Redistribution and use of the present */
+/* software is allowed according to terms specified in the file LICENSE */
+/* which comes in the source distribution. */
+/* */
+/* Check http://www.nomachine.com/licensing.html for applicability. */
+/* */
+/* NX and NoMachine are trademarks of NoMachine S.r.l. */
+/* */
+/* All rights reserved. */
+/* */
+/**************************************************************************/
+
+#include "ServerStore.h"
+
+//
+// Cached reply classes.
+//
+
+#include "GetImageReply.h"
+#include "ListFontsReply.h"
+#include "QueryFontReply.h"
+#include "GetPropertyReply.h"
+#include "GenericReply.h"
+
+//
+// Set the verbosity level.
+//
+
+#define WARNING
+#define PANIC
+#undef TEST
+
+ServerStore::ServerStore(StaticCompressor *compressor)
+{
+ if (logofs == NULL)
+ {
+ logofs = &cout;
+ }
+
+ for (int i = 0; i < CHANNEL_STORE_OPCODE_LIMIT; i++)
+ {
+ replies_[i] = NULL;
+ events_[i] = NULL;
+ }
+
+ replies_[X_ListFonts] = new ListFontsReplyStore(compressor);
+ replies_[X_QueryFont] = new QueryFontReplyStore(compressor);
+ replies_[X_GetImage] = new GetImageReplyStore(compressor);
+ replies_[X_GetProperty] = new GetPropertyReplyStore(compressor);
+
+ replies_[X_NXInternalGenericReply] = new GenericReplyStore(compressor);
+}
+
+ServerStore::~ServerStore()
+{
+ if (logofs == NULL)
+ {
+ logofs = &cout;
+ }
+
+ for (int i = 0; i < CHANNEL_STORE_OPCODE_LIMIT; i++)
+ {
+ delete replies_[i];
+ delete events_[i];
+ }
+}
+
+int ServerStore::saveReplyStores(ostream *cachefs, md5_state_t *md5StateStream,
+ md5_state_t *md5StateClient, T_checksum_action checksumAction,
+ T_data_action dataAction) const
+{
+ for (int i = 0; i < CHANNEL_STORE_OPCODE_LIMIT; i++)
+ {
+ if (replies_[i] != NULL &&
+ replies_[i] -> saveStore(cachefs, md5StateStream, md5StateClient,
+ checksumAction, dataAction,
+ storeBigEndian()) < 0)
+ {
+ #ifdef PANIC
+ *logofs << "ServerStore: PANIC! Error saving reply store "
+ << "for OPCODE#" << (unsigned int) i << ".\n"
+ << logofs_flush;
+ #endif
+
+ cerr << "Error" << ": Error saving reply store "
+ << "for opcode '" << (unsigned int) i << "'.\n";
+
+ return -1;
+ }
+ }
+
+ return 1;
+}
+
+int ServerStore::saveEventStores(ostream *cachefs, md5_state_t *md5StateStream,
+ md5_state_t *md5StateClient, T_checksum_action checksumAction,
+ T_data_action dataAction) const
+{
+ for (int i = 0; i < CHANNEL_STORE_OPCODE_LIMIT; i++)
+ {
+ if (events_[i] != NULL &&
+ events_[i] -> saveStore(cachefs, md5StateStream, md5StateClient,
+ checksumAction, dataAction,
+ storeBigEndian()) < 0)
+ {
+ #ifdef PANIC
+ *logofs << "ServerStore: PANIC! Error saving event store "
+ << "for OPCODE#" << (unsigned int) i << ".\n"
+ << logofs_flush;
+ #endif
+
+ cerr << "Error" << ": Error saving event store "
+ << "for opcode '" << (unsigned int) i << "'.\n";
+
+ return -1;
+ }
+ }
+
+ return 1;
+}
+
+int ServerStore::loadReplyStores(istream *cachefs, md5_state_t *md5StateStream,
+ T_checksum_action checksumAction, T_data_action dataAction) const
+{
+ for (int i = 0; i < CHANNEL_STORE_OPCODE_LIMIT; i++)
+ {
+ if (replies_[i] != NULL &&
+ replies_[i] -> loadStore(cachefs, md5StateStream,
+ checksumAction, dataAction,
+ storeBigEndian()) < 0)
+ {
+ #ifdef PANIC
+ *logofs << "ServerStore: PANIC! Error loading reply store "
+ << "for OPCODE#" << (unsigned int) i << ".\n"
+ << logofs_flush;
+ #endif
+
+ return -1;
+ }
+ }
+
+ return 1;
+}
+
+int ServerStore::loadEventStores(istream *cachefs, md5_state_t *md5StateStream,
+ T_checksum_action checksumAction, T_data_action dataAction) const
+{
+ for (int i = 0; i < CHANNEL_STORE_OPCODE_LIMIT; i++)
+ {
+ if (events_[i] != NULL &&
+ events_[i] -> loadStore(cachefs, md5StateStream,
+ checksumAction, dataAction,
+ storeBigEndian()) < 0)
+ {
+ #ifdef PANIC
+ *logofs << "ServerStore: PANIC! Error loading event store "
+ << "for OPCODE#" << (unsigned int) i << ".\n"
+ << logofs_flush;
+ #endif
+
+ return -1;
+ }
+ }
+
+ return 1;
+}