Commit ca416e79 authored by Reinhard Tartler's avatar Reinhard Tartler

Imported nxcomp-3.3.0-4.tar.gz

Summary: Imported nxcomp-3.3.0-4.tar.gz Keywords: Imported nxcomp-3.3.0-4.tar.gz into Git repository
parent 95ce6b74
ChangeLog: ChangeLog:
nxcomp-3.3.0-4
- Check if the variable storing the ping time exceeded the maximum
integer value.
- Recover incorrect sequence number when the proxy is not connected
to an agent.
nxcomp-3.3.0-3 nxcomp-3.3.0-3
- Removed a condition in ClientChannel that caused a loss in event - Removed a condition in ClientChannel that caused a loss in event
......
...@@ -4539,24 +4539,6 @@ int ClientChannel::handleWrite(const unsigned char *message, unsigned int length ...@@ -4539,24 +4539,6 @@ int ClientChannel::handleWrite(const unsigned char *message, unsigned int length
lastSequence_ = serverSequence_; lastSequence_ = serverSequence_;
} }
} }
/*
FIXME: This block was added, otherwise we have a loss
of the nxagent events.
*/
else
{
#ifdef DEBUG
*logofs << "handleWrite: Updating last event's sequence "
<< lastSequence_ << " to X server's sequence number "
<< serverSequence_ << " for FD#" << fd_
<< ".\n" << logofs_flush;
#endif
lastSequence_ = serverSequence_;
}
/*
FIXME: This causes the loss of the nxagent events.
// //
// Check if by producing events at client side we // Check if by producing events at client side we
...@@ -4565,7 +4547,12 @@ FIXME: This causes the loss of the nxagent events. ...@@ -4565,7 +4547,12 @@ FIXME: This causes the loss of the nxagent events.
// comply with the last one known by client. // comply with the last one known by client.
// //
if (serverSequence_ > lastSequence_) /*
FIXME: Recover the sequence number if the proxy
is not connected to an agent.
*/
if (serverSequence_ > lastSequence_ ||
control -> SessionMode != session_proxy)
{ {
#ifdef DEBUG #ifdef DEBUG
*logofs << "handleWrite: Updating last event's sequence " *logofs << "handleWrite: Updating last event's sequence "
...@@ -4589,7 +4576,6 @@ FIXME: This causes the loss of the nxagent events. ...@@ -4589,7 +4576,6 @@ FIXME: This causes the loss of the nxagent events.
<< logofs_flush; << logofs_flush;
} }
#endif #endif
*/
// //
// Check if remote side used fast encoding. // Check if remote side used fast encoding.
......
...@@ -3645,7 +3645,7 @@ int Proxy::handlePing() ...@@ -3645,7 +3645,7 @@ int Proxy::handlePing()
{ {
int diffPing = diffTimestamp(timeouts_.pingTs, nowTs); int diffPing = diffTimestamp(timeouts_.pingTs, nowTs);
if (diffPing >= (control -> PingTimeout - if (diffPing < 0 || diffPing >= (control -> PingTimeout -
control -> LatencyTimeout * 5)) control -> LatencyTimeout * 5))
{ {
#if defined(TEST) || defined(INFO) || defined(PING) #if defined(TEST) || defined(INFO) || defined(PING)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment