mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

coulbeck
16.46.2007 ddf1e609df050161196a3f7d1191ef2d524d2838
Tidy up synchronized blocks in ServerHandler.
1 files modified
12 ■■■■ changed files
opends/src/server/org/opends/server/synchronization/changelog/ServerHandler.java 12 ●●●● patch | view | raw | blame | history
opends/src/server/org/opends/server/synchronization/changelog/ServerHandler.java
@@ -72,9 +72,9 @@
{
  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;
@@ -120,7 +120,7 @@
   */
  HeartbeatThread heartbeatThread = null;
  private static Map<ChangeNumber, ChangelogAckMessageList>
  private static final Map<ChangeNumber, ChangelogAckMessageList>
   changelogsWaitingAcks = new HashMap<ChangeNumber, ChangelogAckMessageList>();
  /**
@@ -453,11 +453,6 @@
  {
    synchronized (msgQueue)
    {
      if (msgQueue == null)
        return true;
      synchronized (msgQueue)
      {
        int queueSize = msgQueue.size();
        if ((maxReceiveQueue > 0) && (queueSize >= restartReceiveQueue))
          return false;
@@ -484,7 +479,6 @@
      }
      return true;
    }
  }
  /**
   * Check if the server associated to this ServerHandler is a changelog server.