aboutsummaryrefslogtreecommitdiff
path: root/nxcomp/Proxy.h
diff options
context:
space:
mode:
Diffstat (limited to 'nxcomp/Proxy.h')
-rw-r--r--nxcomp/Proxy.h1276
1 files changed, 0 insertions, 1276 deletions
diff --git a/nxcomp/Proxy.h b/nxcomp/Proxy.h
deleted file mode 100644
index ea60c827a..000000000
--- a/nxcomp/Proxy.h
+++ /dev/null
@@ -1,1276 +0,0 @@
-/**************************************************************************/
-/* */
-/* Copyright (c) 2001, 2011 NoMachine (http://www.nomachine.com) */
-/* Copyright (c) 2008-2014 Oleksandr Shneyder <o.shneyder@phoca-gmbh.de> */
-/* Copyright (c) 2014-2016 Ulrich Sibiller <uli42@gmx.de> */
-/* Copyright (c) 2014-2016 Mihai Moldovan <ionic@ionic.de> */
-/* Copyright (c) 2011-2016 Mike Gabriel <mike.gabriel@das-netzwerkteam.de>*/
-/* Copyright (c) 2015-2016 Qindel Group (http://www.qindel.com) */
-/* */
-/* NXCOMP, NX protocol compression and NX extensions to this software */
-/* are copyright of the aforementioned persons and companies. */
-/* */
-/* Redistribution and use of the present software is allowed according */
-/* to terms specified in the file LICENSE.nxcomp which comes in the */
-/* source distribution. */
-/* */
-/* All rights reserved. */
-/* */
-/* NOTE: This software has received contributions from various other */
-/* contributors, only the core maintainers and supporters are listed as */
-/* copyright holders. Please contact us, if you feel you should be listed */
-/* as copyright holder, as well. */
-/* */
-/**************************************************************************/
-
-#ifndef Proxy_H
-#define Proxy_H
-
-#include <sys/types.h>
-
-#ifdef _AIX
-#include <sys/select.h>
-#endif
-
-#include "Misc.h"
-#include "Timestamp.h"
-
-#include "List.h"
-#include "Channel.h"
-#include "Transport.h"
-#include "EncodeBuffer.h"
-#include "ProxyReadBuffer.h"
-#include "ChannelEndPoint.h"
-
-//
-// Forward declaration as we
-// need a pointer.
-//
-
-class Agent;
-
-//
-// Set the verbosity level.
-//
-
-#define PANIC
-#define WARNING
-#undef TEST
-#undef DEBUG
-
-//
-// Log the important tracepoints related
-// to writing packets to the peer proxy.
-//
-
-#undef FLUSH
-
-//
-// Codes used for control messages in
-// proxy-to-proxy protocol.
-//
-// The following codes are currently
-// unused.
-//
-// code_alert_reply,
-// code_reset_request,
-// code_reset_reply,
-// code_load_reply,
-// code_save_reply,
-// code_shutdown_reply,
-// code_configuration_request,
-// code_configuration_reply.
-//
-// These are for compatibility with
-// old versions.
-//
-// code_sync_request,
-// code_sync_reply,
-//
-// The code_new_aux_connection should not
-// be used anymore. Auxiliary X connections
-// are treated as normal X channels since
-// version 1.5.0.
-//
-
-typedef enum
-{
- code_new_x_connection,
- code_new_cups_connection,
- code_new_aux_connection,
- code_new_smb_connection,
- code_new_media_connection,
- code_switch_connection,
- code_drop_connection,
- code_finish_connection,
- code_begin_congestion,
- code_end_congestion,
- code_alert_request,
- code_alert_reply,
- code_reset_request,
- code_reset_reply,
- code_load_request,
- code_load_reply,
- code_save_request,
- code_save_reply,
- code_shutdown_request,
- code_shutdown_reply,
- code_control_token_request,
- code_control_token_reply,
- code_configuration_request,
- code_configuration_reply,
- code_statistics_request,
- code_statistics_reply,
- code_new_http_connection,
- code_sync_request,
- code_sync_reply,
- code_new_font_connection,
- code_new_slave_connection,
- code_finish_listeners,
- code_split_token_request,
- code_split_token_reply,
- code_data_token_request,
- code_data_token_reply,
- code_last_tag
-
-} T_proxy_code;
-
-typedef enum
-{
- operation_in_negotiation,
- operation_in_messages,
- operation_in_configuration,
- operation_in_statistics,
- operation_last_tag
-
-} T_proxy_operation;
-
-typedef enum
-{
- frame_ping,
- frame_data,
-
-} T_frame_type;
-
-typedef enum
-{
- token_control,
- token_split,
- token_data
-
-} T_token_type;
-
-typedef enum
-{
- load_if_any,
- load_if_first
-
-} T_load_type;
-
-class Proxy
-{
- public:
-
- //
- // Maximum number of supported channels.
- //
-
- static const int CONNECTIONS_LIMIT = 256;
-
- //
- // Numboer of token types.
- //
-
- static const int TOKEN_TYPES = 3;
-
- //
- // Lenght of buffer we use to add our
- // control messages plus the length of
- // the data frame.
- //
-
- static const int CONTROL_CODES_LENGTH = ENCODE_BUFFER_PREFIX_SIZE - 5;
-
- static const int CONTROL_CODES_THRESHOLD = CONTROL_CODES_LENGTH - 9;
-
- Proxy(int fd);
-
- virtual ~Proxy();
-
- //
- // Inform the proxy that the negotiation phase is
- // completed and that it can start handling binary
- // messages.
- //
-
- int setOperational();
-
- int getOperational()
- {
- return (operation_ != operation_in_negotiation);
- }
-
- int setReadDescriptors(fd_set *fdSet, int &fdMax, T_timestamp &tsMax);
-
- int setWriteDescriptors(fd_set *fdSet, int &fdMax, T_timestamp &tsMax);
-
- //
- // Perform the operation on the proxy
- // link or its own channels.
- //
-
- int handleRead(int &resultFds, fd_set &fdSet);
-
- int handleFlush(int &resultFds, fd_set &fdSet);
-
- int handleRead();
-
- int handleRead(int fd, const char *data = NULL, int size = 0);
-
- int handleEvents();
-
- int handleFlush();
-
- int handleFlush(int fd);
-
- int handlePing();
-
- int handleFinish();
-
- int handleShutdown();
-
- int handleStatistics(int type, ostream *statofs);
-
- int handleAlert(int alert);
-
- int handleRotate()
- {
- activeChannels_.rotate();
-
- return 1;
- }
-
- int handleChannelConfiguration();
-
- int handleSocketConfiguration();
-
- int handleLinkConfiguration();
-
- int handleCacheConfiguration();
-
- //
- // These must be called just after initialization to
- // tell to the proxy where the network connections
- // have to be forwarded.
- //
-
- virtual void handleDisplayConfiguration(const char *xServerDisplay, int xServerAddrFamily,
- sockaddr * xServerAddr, unsigned int xServerAddrLength) = 0;
-
- virtual void handlePortConfiguration(ChannelEndPoint &cupsServerPort,
- ChannelEndPoint &smbServerPort,
- ChannelEndPoint &mediaServerPort,
- ChannelEndPoint &httpServerPort,
- const char *fontServerPort) = 0;
-
- //
- // Create new tunneled channels.
- //
-
- virtual int handleNewConnection(T_channel_type type, int clientFd) = 0;
-
- virtual int handleNewConnectionFromProxy(T_channel_type type, int channelId) = 0;
-
- virtual int handleNewAgentConnection(Agent *agent) = 0;
-
- virtual int handleNewXConnection(int clientFd) = 0;
-
- virtual int handleNewXConnectionFromProxy(int channelId) = 0;
-
- int handleNewGenericConnection(int clientFd, T_channel_type type, const char *label);
-
- int handleNewGenericConnectionFromProxy(int channelId, T_channel_type type,
- ChannelEndPoint &endpoint, const char *label);
-
- int handleNewGenericConnectionFromProxyUnix(int channelId, T_channel_type type,
- const char *path, const char *label);
-
- int handleNewGenericConnectionFromProxyTCP(int channelId, T_channel_type type,
- const char *hostname, long port, const char *label);
-
- int handleNewSlaveConnection(int clientFd);
-
- int handleNewSlaveConnectionFromProxy(int channelId);
-
- void checkSlaves();
-
- //
- // Force closure of channels.
- //
-
- int handleCloseConnection(int clientFd);
-
- int handleCloseAllXConnections();
-
- int handleCloseAllListeners();
-
- //
- // Called when the loop has replaced
- // or closed a previous alert.
- //
-
- void handleResetAlert();
-
- //
- // Handle the persistent cache.
- //
-
- virtual int handleLoad(T_load_type type) = 0;
-
- virtual int handleSave() = 0;
-
- protected:
-
- //
- // Timeout related data:
- //
- // flush
- // split
- // motion
- //
- // Timeouts in milliseconds after which the
- // proxy will have to perform the operation.
- //
- // readTs, writeTs
- //
- // Timestamp of last packet received or sent
- // to remote proxy. Used to detect lost con-
- // nection.
- //
- // loopTs
- //
- // Timestamp of last loop completed by the
- // proxy
- //
- // pingTs
- //
- // Timestamp of last ping request sent to the
- // remote peer.
- //
- // alertTs
- //
- // Timestamp of last 'no data received' alert
- // dialog shown to the user.
- //
- // loadTs
- //
- // Were message stores populated from data on
- // disk.
- //
- // splitTs
- // motionTs
- //
- // Timestamps of the last operation of this
- // kind handled by the proxy.
- //
-
- typedef struct
- {
- int split;
- int motion;
-
- T_timestamp readTs;
- T_timestamp writeTs;
-
- T_timestamp loopTs;
- T_timestamp pingTs;
- T_timestamp alertTs;
- T_timestamp loadTs;
-
- T_timestamp splitTs;
- T_timestamp motionTs;
-
- } T_proxy_timeouts;
-
- //
- // Bytes accumulated so far while waiting
- // to send the next token, number of tokens
- // remaining for each token type and other
- // token related information.
- //
-
- typedef struct
- {
- int size;
- int limit;
-
- int bytes;
- int remaining;
-
- T_proxy_code request;
- T_proxy_code reply;
-
- T_token_type type;
-
- } T_proxy_token;
-
- int handlePostConnectionFromProxy(int channelId, int serverFd,
- T_channel_type type, const char *label);
-
- int handleDrain();
-
- int handleFrame(T_frame_type type);
-
- int handleFinish(int channelId);
-
- int handleDrop(int channelId);
-
- int handleFinishFromProxy(int channelId);
-
- int handleDropFromProxy(int channelId);
-
- int handleStatisticsFromProxy(int type);
-
- int handleStatisticsFromProxy(const unsigned char *message, unsigned int length);
-
- int handleNegotiation(const unsigned char *message, unsigned int length);
-
- int handleNegotiationFromProxy(const unsigned char *message, unsigned int length);
-
- int handleToken(T_frame_type type);
-
- int handleTokenFromProxy(T_proxy_token &token, int count);
-
- int handleTokenReplyFromProxy(T_proxy_token &token, int count);
-
- int handleSyncFromProxy(int channelId);
-
- int handleSwitch(int channelId);
-
- int handleControl(T_proxy_code code, int data = -1);
-
- int handleControlFromProxy(const unsigned char *message);
-
- //
- // Interleave reads of the X server
- // events while writing data to the
- // remote proxy.
- //
-
- virtual int handleAsyncEvents() = 0;
-
- //
- // Timer related functions.
- //
-
- protected:
-
- void setTimer(int value)
- {
- SetTimer(value);
- }
-
- void resetTimer()
- {
- ResetTimer();
-
- timer_ = 0;
- }
-
- public:
-
- void handleTimer()
- {
- timer_ = 1;
- }
-
- int getTimer()
- {
- return timer_;
- }
-
- //
- // Can the channel consume data and the
- // proxy produce more output?
- //
-
- int canRead(int fd) const
- {
- return (isTimeToRead() == 1 &&
- isTimeToRead(getChannel(fd)) == 1);
- }
-
- //
- // Can the proxy read more data from its
- // peer?
- //
-
- int canRead() const
- {
- return (transport_ -> readable() != 0);
- }
-
- int canFlush() const
- {
- return (encodeBuffer_.getLength() +
- controlLength_ + transport_ -> length() +
- transport_ -> flushable() > 0);
- }
-
- int needFlush(int channelId) const
- {
- return (outputChannel_ == channelId &&
- encodeBuffer_.getLength() > 0);
- }
-
- int needFlush() const
- {
- return (encodeBuffer_.getLength() > 0);
- }
-
- int shouldFlush() const
- {
- if ((int) ((encodeBuffer_.getLength() +
- controlLength_) / statistics ->
- getStreamRatio()) >= control -> TokenSize)
- {
- #if defined(TEST) || defined(INFO) || defined(FLUSH)
- *logofs << "Proxy: FLUSH! Requesting a flush with "
- << (encodeBuffer_.getLength() + controlLength_)
- << " bytes and stream ratio " << (double) statistics ->
- getStreamRatio() << ".\n" << logofs_flush;
- #endif
-
- return 1;
- }
-
- #if defined(TEST) || defined(INFO) || defined(FLUSH)
- *logofs << "Proxy: Not requesting a flush with "
- << (encodeBuffer_.getLength() + controlLength_)
- << " bytes and stream ratio " << (double) statistics ->
- getStreamRatio() << ".\n" << logofs_flush;
- #endif
-
- return 0;
- }
-
- int needDrain() const
- {
- return (congestion_ == 1 || transport_ -> length() >
- control -> TransportProxyBufferThreshold);
- }
-
- int getFd() const
- {
- return fd_;
- }
-
- int getFlushable(int fd) const
- {
- if (fd == fd_)
- {
- return (encodeBuffer_.getLength() + controlLength_ +
- transport_ -> flushable());
- }
-
- return 0;
- }
-
- int getSplitSize()
- {
- return (clientStore_ != NULL ? clientStore_ ->
- getSplitTotalSize() : 0);
- }
-
- int getSplitStorageSize()
- {
- return (clientStore_ != NULL ? clientStore_ ->
- getSplitTotalStorageSize() : 0);
- }
-
- //
- // Returns the number of active channels
- // that currently managed by this proxy.
- //
-
- int getChannels(T_channel_type type = channel_none);
-
- //
- // If descriptor corresponds to a valid
- // channel, returns the type of traffic
- // carried by it.
- //
-
- T_channel_type getType(int fd);
-
- //
- // Given a channel type, returns the
- // literal name.
- //
-
- const char *getTypeName(T_channel_type type);
-
- //
- // Get a convenient name for 'localhost'.
- //
-
- const char *getComputerName();
-
- //
- // Set if we have initiated the shutdown
- // procedure and if the shutdown request
- // has been received from the remote.
- //
-
- int getFinish() const
- {
- return finish_;
- }
-
- int getShutdown() const
- {
- return shutdown_;
- }
-
- //
- // Interfaces to the transport buffers.
- //
-
- int getLength(int fd) const
- {
- if (fd == fd_)
- {
- return transport_ -> length();
- }
-
- int channelId = getChannel(fd);
-
- if (channelId < 0 || channels_[channelId] == NULL)
- {
- return 0;
- }
-
- return transports_[channelId] -> length();
- }
-
- int getPending(int fd) const
- {
- if (fd == fd_)
- {
- return transport_ -> pending();
- }
-
- int channelId = getChannel(fd);
-
- if (channelId < 0 || channels_[channelId] == NULL)
- {
- return 0;
- }
-
- return transports_[channelId] -> pending();
- }
-
- //
- // Check if the proxy or the given channel
- // has data in the buffer because of a
- // blocking write.
- //
-
- int getBlocked(int fd) const
- {
- if (fd == fd_)
- {
- return transport_ -> blocked();
- }
-
- int channelId = getChannel(fd);
-
- if (channelId < 0 || channels_[channelId] == NULL)
- {
- return 0;
- }
-
- return transports_[channelId] -> blocked();
- }
-
- //
- // Check if the proxy or the given channel has
- // data to read.
- //
-
- int getReadable(int fd) const
- {
- if (fd == fd_)
- {
- return transport_ -> readable();
- }
-
- int channelId = getChannel(fd);
-
- if (channelId < 0 || channels_[channelId] == NULL)
- {
- return 0;
- }
-
- return transports_[channelId] -> readable();
- }
-
- //
- // Return a vale between 0 and 9 in the case
- // of the proxy descriptor.
- //
-
- int getCongestion(int fd) const
- {
- if (fd == fd_)
- {
- return (agent_ != nothing && congestions_[agent_] == 1 ? 9 :
- (int) statistics -> getCongestionInFrame());
- }
-
- int channelId = getChannel(fd);
-
- if (channelId < 0 || channels_[channelId] == NULL)
- {
- return 0;
- }
-
- return channels_[channelId] -> getCongestion();
- }
-
- //
- // Let the statistics class get info
- // from the message stores.
- //
-
- const ClientStore * const getClientStore() const
- {
- return clientStore_;
- }
-
- const ServerStore * const getServerStore() const
- {
- return serverStore_;
- }
-
- //
- // These can be called asynchronously by
- // channels during their read or write
- // loop.
- //
-
- int handleAsyncRead(int fd)
- {
- return handleRead(fd);
- }
-
- int handleAsyncCongestion(int fd)
- {
- int channelId = getChannel(fd);
-
- return handleControl(code_begin_congestion, channelId);
- }
-
- int handleAsyncDecongestion(int fd)
- {
- int channelId = getChannel(fd);
-
- return handleControl(code_end_congestion, channelId);
- }
-
- int handleAsyncSplit(int fd, Split *split)
- {
- return channels_[getChannel(fd)] ->
- handleSplitEvent(encodeBuffer_, split);
- }
-
- int handleAsyncPriority()
- {
- if (control -> FlushPriority == 1)
- {
- return handleFlush();
- }
-
- return 0;
- }
-
- int canAsyncFlush() const
- {
- return shouldFlush();
- }
-
- int handleAsyncFlush()
- {
- return handleFlush();
- }
-
- int handleAsyncSwitch(int fd)
- {
- return handleSwitch(getChannel(fd));
- }
-
- int handleAsyncKeeperCallback()
- {
- KeeperCallback();
-
- return 1;
- }
-
- //
- // Internal interfaces used to verify the
- // availability of channels and the proxy
- // link.
- //
-
- protected:
-
- int isTimeToRead() const
- {
- if (congestion_ == 0 && transport_ ->
- blocked() == 0)
- {
- return 1;
- }
- else
- {
- #if defined(TEST) || defined(INFO)
- *logofs << "Proxy: Can't read from channels "
- << "with congestion " << congestion_
- << " and blocked " << transport_ ->
- blocked() << ".\n" << logofs_flush;
- #endif
-
- return 0;
- }
- }
-
- int isTimeToRead(int channelId) const
- {
- if (channelId >= 0 && channelId < CONNECTIONS_LIMIT &&
- channels_[channelId] != NULL &&
- congestions_[channelId] == 0)
- {
- if (channels_[channelId] -> getType() == channel_x11 ||
- tokens_[token_data].remaining > 0 ||
- channels_[channelId] ->
- getFinish() == 1)
- {
- return 1;
- }
-
- #if defined(TEST) || defined(INFO)
- *logofs << "Proxy: Can't read from generic "
- << "descriptor FD#" << getFd(channelId)
- << " channel ID#" << channelId << " with "
- << tokens_[token_data].remaining
- << " data tokens remaining.\n"
- << logofs_flush;
- #endif
-
- return 0;
- }
-
- #if defined(TEST) || defined(INFO)
-
- if (channelId < 0 || channelId >= CONNECTIONS_LIMIT ||
- channels_[channelId] == NULL)
- {
- *logofs << "Proxy: WARNING! No valid channel for ID#"
- << channelId << ".\n" << logofs_flush;
- }
- else if (channels_[channelId] -> getFinish())
- {
- *logofs << "Proxy: Can't read from finishing "
- << "descriptor FD#" << getFd(channelId)
- << " channel ID#" << channelId << ".\n"
- << logofs_flush;
- }
- else if (congestions_[channelId] == 1)
- {
- *logofs << "Proxy: Can't read from congested "
- << "descriptor FD#" << getFd(channelId)
- << " channel ID#" << channelId << ".\n"
- << logofs_flush;
- }
-
- #endif
-
- return 0;
- }
-
- //
- // Handle the flush and split timeouts.
- // All these functions should round up
- // to the value of the latency timeout
- // to save a further loop.
- //
-
- protected:
-
- int isTimeToSplit() const
- {
- if (isTimestamp(timeouts_.splitTs) &&
- getTimeToNextSplit() <= control ->
- LatencyTimeout)
- {
- if (tokens_[token_split].remaining > 0)
- {
- return 1;
- }
-
- #if defined(TEST) || defined(INFO)
- *logofs << "Proxy: WARNING! Can't encode splits "
- << "with " << tokens_[token_split].remaining
- << " split tokens remaining.\n"
- << logofs_flush;
- #endif
- }
-
- return 0;
- }
-
- int isTimeToMotion() const
- {
- return (isTimestamp(timeouts_.motionTs) &&
- getTimeToNextMotion() <= control ->
- LatencyTimeout);
- }
-
- int getTimeToNextSplit() const
- {
- #if defined(TEST) || defined(INFO) || defined(FLUSH)
-
- if (isTimestamp(timeouts_.splitTs) == 0)
- {
- #ifdef PANIC
- *logofs << "Proxy: PANIC! No split timeout was set "
- << "for proxy FD#" << fd_ << ".\n"
- << logofs_flush;
- #endif
-
- cerr << "Error" << ": No split timeout was set "
- << "for proxy FD#" << fd_ << ".\n";
-
- HandleCleanup();
- }
-
- #endif
-
- int diffTs = timeouts_.split -
- diffTimestamp(timeouts_.splitTs,
- getTimestamp());
-
- return (diffTs > 0 ? diffTs : 0);
- }
-
- int getTimeToNextMotion() const
- {
- #if defined(TEST) || defined(INFO) || defined(FLUSH)
-
- if (isTimestamp(timeouts_.motionTs) == 0)
- {
- #ifdef PANIC
- *logofs << "Proxy: PANIC! No motion timeout was set "
- << "for proxy FD#" << fd_ << ".\n"
- << logofs_flush;
- #endif
-
- cerr << "Error" << ": No motion timeout was set "
- << "for proxy FD#" << fd_ << ".\n";
-
- HandleCleanup();
- }
-
- #endif
-
- int diffTs = timeouts_.motion -
- diffTimestamp(timeouts_.motionTs,
- getTimestamp());
-
- return (diffTs > 0 ? diffTs : 0);
- }
-
- protected:
-
- //
- // Implement persistence of cache on disk.
- //
-
- virtual int handleLoadFromProxy() = 0;
- virtual int handleSaveFromProxy() = 0;
-
- int handleLoadStores();
- int handleSaveStores();
-
- char *handleSaveAllStores(const char *savePath, bool & isTooSmall) const;
-
- virtual int handleSaveAllStores(ostream *cachefs, md5_state_t *md5StateStream,
- md5_state_t *md5StateClient) const = 0;
-
- int handleSaveVersion(unsigned char *buffer, int &major, int &minor, int &patch) const;
-
- void handleFailOnSave(const char *fullName, const char *failContext) const;
-
- const char *handleLoadAllStores(const char *loadPath, const char *loadName) const;
-
- virtual int handleLoadAllStores(istream *cachefs, md5_state_t *md5StateStream) const = 0;
-
- int handleLoadVersion(const unsigned char *buffer, int &major, int &minor, int &patch) const;
-
- void handleFailOnLoad(const char *fullName, const char *failContext) const;
-
- //
- // Prepare for a new persistent cache.
- //
-
- int handleResetPersistentCache();
-
- //
- // Reset the stores in the case of a
- // failure loading the cache.
- //
-
- int handleResetStores();
-
- //
- // Reset the transport buffer and the
- // other counters.
- //
-
- void handleResetFlush();
-
- //
- // Utility functions used to map file
- // descriptors to channel ids.
- //
-
- protected:
-
- int allocateChannelMap(int fd);
- int checkChannelMap(int channelId);
- int assignChannelMap(int channelId, int fd);
-
- void cleanupChannelMap(int channelId);
-
- virtual int checkLocalChannelMap(int channelId) = 0;
-
- int addControlCodes(T_proxy_code code, int data);
- int addTokenCodes(T_proxy_token &token);
-
- int getFd(int channelId) const
- {
- if (channelId >= 0 && channelId < CONNECTIONS_LIMIT)
- {
- return fdMap_[channelId];
- }
-
- return -1;
- }
-
- int getChannel(int fd) const
- {
- if (fd >= 0 && fd < CONNECTIONS_LIMIT)
- {
- return channelMap_[fd];
- }
-
- return -1;
- }
-
- protected:
-
- void setSplitTimeout(int channelId);
- void setMotionTimeout(int channelId);
-
- void increaseChannels(int channelId);
- void decreaseChannels(int channelId);
-
- int allocateTransport(int channelFd, int channelId);
- int deallocateTransport(int channelId);
-
- //
- // The proxy has its own transport.
- //
-
- ProxyTransport *transport_;
-
- //
- // The static compressor is shared among
- // channels and all the message stores.
- //
-
- StaticCompressor *compressor_;
-
- //
- // Map NX specific opcodes.
- //
-
- OpcodeStore *opcodeStore_;
-
- //
- // Stores are shared between channels.
- //
-
- ClientStore *clientStore_;
- ServerStore *serverStore_;
-
- //
- // Client and server caches are shared
- // between channels.
- //
-
- ClientCache *clientCache_;
- ServerCache *serverCache_;
-
- //
- // The proxy's file descriptor.
- //
-
- int fd_;
-
- //
- // Channels currently selected for I/O
- // operations.
- //
-
- int inputChannel_;
- int outputChannel_;
-
- //
- // List of active channels.
- //
-
- List activeChannels_;
-
- //
- // Used to read data sent from peer proxy.
- //
-
- ProxyReadBuffer readBuffer_;
-
- //
- // Used to send data to peer proxy.
- //
-
- EncodeBuffer encodeBuffer_;
-
- //
- // Control messages' array.
- //
-
- int controlLength_;
-
- unsigned char controlCodes_[CONTROL_CODES_LENGTH];
-
- //
- // Table of channel classes taking
- // care of open X connections.
- //
-
- Channel *channels_[CONNECTIONS_LIMIT];
-
- //
- // Table of open sockets.
- //
-
- Transport *transports_[CONNECTIONS_LIMIT];
-
- //
- // Timeout related data.
- //
-
- T_proxy_timeouts timeouts_;
-
- //
- // Proxy can be decoding messages,
- // handling a link reconfiguration,
- // or decoding statistics.
- //
-
- int operation_;
-
- //
- // True if we are currently draining
- // the proxy link.
- //
-
- int draining_;
-
- //
- // Force flush because of prioritized
- // control messages to send.
- //
-
- int priority_;
-
- //
- // Set if we have initiated the close
- // down procedure.
- //
-
- int finish_;
-
- //
- // Remote peer requested the shutdown.
- //
-
- int shutdown_;
-
- //
- // We are in the middle of a network
- // congestion in the path to remote
- // proxy.
- //
-
- int congestion_;
-
- //
- // Channels at the remote end that
- // are not consuming their data.
- //
-
- int congestions_[CONNECTIONS_LIMIT];
-
- //
- // Is the timer expired?
- //
-
- int timer_;
-
- //
- // Did the proxy request an alert?
- //
-
- int alert_;
-
- //
- // The channel id of the agent.
- //
-
- int agent_;
-
- //
- // Token related data.
- //
-
- T_proxy_token tokens_[TOKEN_TYPES];
-
- //
- // Pointer to stream descriptor where
- // proxy is producing statistics.
- //
-
- ostream *currentStatistics_;
-
- private:
-
- //
- // Map channel ids to file descriptors.
- //
-
- int channelMap_[CONNECTIONS_LIMIT];
- int fdMap_[CONNECTIONS_LIMIT];
- int slavePidMap_[CONNECTIONS_LIMIT];
-};
-
-#endif /* Proxy_H */