Tidy up synchronized blocks in ServerHandler.

coulbeck

16.46.2007 ddf1e609df050161196a3f7d1191ef2d524d2838

Tidy up synchronized blocks in ServerHandler.

 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,37 +453,31 @@
  {
    synchronized (msgQueue)
    {
      if (msgQueue == null)
        return true;
      int queueSize = msgQueue.size();
      if ((maxReceiveQueue > 0) && (queueSize >= restartReceiveQueue))
        return false;
      if ((source != null) && (source.maxSendQueue > 0) &&
           (queueSize >= source.restartSendQueue))
        return false;

      synchronized (msgQueue)
      if (!msgQueue.isEmpty())
      {
        int queueSize = msgQueue.size();
        if ((maxReceiveQueue > 0) && (queueSize >= restartReceiveQueue))
          return false;
        if ((source != null) && (source.maxSendQueue > 0) &&
            (queueSize >= source.restartSendQueue))
          return false;
        UpdateMessage firstUpdate = msgQueue.first();
        UpdateMessage lastUpdate = msgQueue.last();

        if (!msgQueue.isEmpty())
        if ((firstUpdate != null) && (lastUpdate != null))
        {
          UpdateMessage firstUpdate = msgQueue.first();
          UpdateMessage lastUpdate = msgQueue.last();

          if ((firstUpdate != null) && (lastUpdate != null))
          {
            long timeDiff = lastUpdate.getChangeNumber().getTimeSec() -
            firstUpdate.getChangeNumber().getTimeSec();
            if ((maxReceiveDelay > 0) && (timeDiff >= restartReceiveDelay))
              return false;
            if ((source != null) && (source.maxSendDelay > 0)
                && (timeDiff >= source.restartSendDelay))
              return false;
          }
          long timeDiff = lastUpdate.getChangeNumber().getTimeSec() -
               firstUpdate.getChangeNumber().getTimeSec();
          if ((maxReceiveDelay > 0) && (timeDiff >= restartReceiveDelay))
            return false;
          if ((source != null) && (source.maxSendDelay > 0)
               && (timeDiff >= source.restartSendDelay))
            return false;
        }
      }
      return true;
    }
    return true;
  }

  /**