| | |
| | | } |
| | | } // For late servers |
| | | } |
| | | |
| | | return bestServer; |
| | | } |
| | | |
| | |
| | | try |
| | | { |
| | | rcvWindow--; |
| | | if (rcvWindow < halfRcvWindow) |
| | | if ((rcvWindow < halfRcvWindow) && (session != null)) |
| | | { |
| | | session.publish(new WindowMessage(halfRcvWindow)); |
| | | rcvWindow += halfRcvWindow; |
| | |
| | | this.maxReceiveQueue = maxReceiveQueue; |
| | | this.maxSendDelay = maxSendDelay; |
| | | this.maxSendQueue = maxSendQueue; |
| | | // TODO : Changing those parameters requires to either restart a new |
| | | // session with the replicationServer or renegociate the parameters that |
| | | // were sent in the ServerStart message |
| | | |
| | | // For info, a new session with the replicationServer |
| | | // will be recreated in the replication domain |
| | | // to take into account the new configuration. |
| | | } |
| | | |
| | | /** |