| | |
| | | { |
| | | private short serverId; |
| | | private ProtocolSession session; |
| | | private MsgQueue msgQueue = new MsgQueue(); |
| | | private final MsgQueue msgQueue = new MsgQueue(); |
| | | private MsgQueue lateQueue = new MsgQueue(); |
| | | private Map<ChangeNumber, AckMessageList> waitingAcks = |
| | | private final Map<ChangeNumber, AckMessageList> waitingAcks = |
| | | new HashMap<ChangeNumber, AckMessageList>(); |
| | | private ChangelogCache changelogCache = null; |
| | | private String serverURL; |
| | |
| | | */ |
| | | HeartbeatThread heartbeatThread = null; |
| | | |
| | | private static Map<ChangeNumber, ChangelogAckMessageList> |
| | | private static final Map<ChangeNumber, ChangelogAckMessageList> |
| | | changelogsWaitingAcks = new HashMap<ChangeNumber, ChangelogAckMessageList>(); |
| | | |
| | | /** |
| | |
| | | { |
| | | synchronized (msgQueue) |
| | | { |
| | | if (msgQueue == null) |
| | | return true; |
| | | |
| | | synchronized (msgQueue) |
| | | { |
| | | int queueSize = msgQueue.size(); |
| | | if ((maxReceiveQueue > 0) && (queueSize >= restartReceiveQueue)) |
| | | return false; |
| | |
| | | } |
| | | return true; |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * Check if the server associated to this ServerHandler is a changelog server. |