X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=netconf-server%2Fsrc%2Fmain%2Fjava%2Forg%2Fcommscope%2Ftr069adapter%2Fnetconf%2Fserver%2Fhelper%2FServerPortAllocationHelper.java;fp=netconf-server%2Fsrc%2Fmain%2Fjava%2Forg%2Fcommscope%2Ftr069adapter%2Fnetconf%2Fserver%2Fhelper%2FServerPortAllocationHelper.java;h=9e5479d934aee536a3b3bec3a259be321b539552;hb=17d7d2966615671ef113dd32c7ba5ebff47f5e6f;hp=f5ff597e90b1d0868d2696406469b63043912f48;hpb=5c0154874432f3b08c9ad3a2cec990c7a3ab7c4b;p=oam%2Ftr069-adapter.git

diff --git a/netconf-server/src/main/java/org/commscope/tr069adapter/netconf/server/helper/ServerPortAllocationHelper.java b/netconf-server/src/main/java/org/commscope/tr069adapter/netconf/server/helper/ServerPortAllocationHelper.java
index f5ff597..9e5479d 100644
--- a/netconf-server/src/main/java/org/commscope/tr069adapter/netconf/server/helper/ServerPortAllocationHelper.java
+++ b/netconf-server/src/main/java/org/commscope/tr069adapter/netconf/server/helper/ServerPortAllocationHelper.java
@@ -75,8 +75,8 @@ public class ServerPortAllocationHelper {
     }
     LOG.debug("Successfully populated available ports list.");
   }
-
-  public String reserveServerPort() throws ServerPortAllocationException {
+  
+  public synchronized String reserveServerPort() throws ServerPortAllocationException {
 
     if (availablePorts.isEmpty()) {
       LOG.debug(
@@ -89,6 +89,7 @@ public class ServerPortAllocationHelper {
     LOG.debug("Trying to reserve port : {}", port);
     if (isServerPortInUse(port)) {
       LOG.debug("Port {} is already in use.", port);
+      availablePorts.poll();
       return reserveServerPort(); // retry if current port is not available
     }