add refresh metadata log

Author: JackShi148

src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java

@@ -485,6 +485,7 @@ private <T> T execute(String tableName, TableExecuteCallback<T> callback, ObServ
                     }
                     tableParam = getTableParamWithRoute(tableName, rowKey, route);
                 }
+                logger.warn("[latency monitor] tableParm obTable ip:port is {}:{}", tableParam.getObTable().getIp(), tableParam.getObTable().getPort());
                 T t = callback.execute(tableParam);
                 resetExecuteContinuousFailureCount(tableName);
                 return t;
@@ -700,6 +701,7 @@ private <T> T execute(String tableName, OperationExecuteCallback<T> callback,
                         throw new ObTableException("RowKey or scan range is null");
                     }
                 }
+                logger.warn("[latency monitor] tableParm obTable ip:port is {}:{}", tableParam.getObTable().getIp(), tableParam.getObTable().getPort());
                 T t = callback.execute(tableParam);
                 resetExecuteContinuousFailureCount(tableName);
                 return t;

src/main/java/com/alipay/oceanbase/rpc/location/model/TableLocations.java

@@ -138,7 +138,9 @@ public TableEntry refreshMeta(String tableName, ServerRoster serverRoster,
                 tryTimes++;
                 try {
                     logger.warn("[latency monitor] try to acquire refresh table meta lock, tableName: {}", tableName);
-                    acquired = lock.tryLock(tableEntryRefreshLockTimeout, TimeUnit.MILLISECONDS);
+                    if (!acquired) {
+                        acquired = lock.tryLock(tableEntryRefreshLockTimeout, TimeUnit.MILLISECONDS);
+                    }
                     if (!acquired) {
                         String errMsg = "try to lock tableEntry refreshing timeout, tableName:" + tableName
                                 + " , timeout:" + tableEntryRefreshLockTimeout + ".";
@@ -323,7 +325,9 @@ public TableEntry refreshPartitionLocation(TableEntry tableEntry, String tableNa
                 }
                 tryTimes++;
                 try {
-                    acquired = lock.tryLock(tableEntryRefreshLockTimeout, TimeUnit.MILLISECONDS);
+                    if (!acquired) {
+                        acquired = lock.tryLock(tableEntryRefreshLockTimeout, TimeUnit.MILLISECONDS);
+                    }
                     if (!acquired) {
                         String errMsg = "try to lock tablet location refreshing timeout " + " ,tableName:"
                                 + tableName + " , timeout:" + tableEntryRefreshLockTimeout + ".";
@@ -460,7 +464,9 @@ public TableEntry refreshTabletLocationBatch(TableEntry tableEntry, String table
                 }
                 tryTimes++;
                 try {
-                    acquired = lock.tryLock(tableEntryRefreshLockTimeout, TimeUnit.MILLISECONDS);
+                    if (!acquired) {
+                        acquired = lock.tryLock(tableEntryRefreshLockTimeout, TimeUnit.MILLISECONDS);
+                    }
                     if (!acquired) {
                         logger.warn("[latency monitor] fail to acquire refresh tablet locations in batch lock, tableName: {}", tableName);
                         String errMsg = "try to lock locations refreshing in batch timeout " + " ,tableName:"

src/main/java/com/alipay/oceanbase/rpc/location/model/TableRoute.java

@@ -391,13 +391,15 @@ public void refreshRosterByRsList(List<ObServerAddr> newRsList) throws Exception
                 allDummyKey, newRsList);
             throw new ObTableUnexpectedException("all rs servers are not available");
         }
+        logger.warn("[latency monitor] after loadTableEntryRandomly");
 
         // 1. get tenant server address to renew ObTable roster
         List<ReplicaLocation> replicaLocations = tableEntry.getTableLocation()
             .getReplicaLocations();
         // update new ob table and get new server address
         List<ObServerAddr> servers = tableRoster.refreshTablesAndGetNewServers(replicaLocations);
         serverRoster.reset(servers);
+        logger.warn("[latency monitor] after refreshTablesAndGetNewServers");
 
         // 2. Get Server LDC info for weak read consistency.
         success = false;
@@ -426,6 +428,7 @@ public void refreshRosterByRsList(List<ObServerAddr> newRsList) throws Exception
                 allDummyKey.getTenantName(), JSON.toJSON(serverRoster));
             throw new ObTableUnexpectedException("all tenant servers are not available");
         }
+        logger.warn("[latency monitor] after getServerLdc");
 
         // 3. reset Server LDC location.
         String regionFromOcp = configServerInfo.getIdc2Region(tableClient.getCurrentIDC());
@@ -710,6 +713,7 @@ private ObTableParam getTableInternal(String tableName, TableEntry tableEntry, l
                                           ObServerRoute route) throws Exception {
         ReplicaLocation replica = null;
         long tabletId = getTabletIdByPartId(tableEntry, partId);
+        logger.warn("[latency monitor] tablet id: {}", tabletId);
         ObPartitionLocationInfo obPartitionLocationInfo = null;
         obPartitionLocationInfo = getOrRefreshPartitionInfo(tableEntry, tableName, tabletId);
         if (obPartitionLocationInfo.getPartitionLocation() == null) {

src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientLSBatchOpsImpl.java

@@ -634,7 +634,7 @@ public void partitionExecute(ObTableSingleOpResult[] results,
                         }
                     }
                 }
-                logger.warn("[latency monitor] ls_id: {}, tryTimes: {}", lsId, tryTimes);
+                logger.warn("[latency monitor] ls_id: {}, tryTimes: {}, ip:port is: {}:{}", lsId, tryTimes, subObTable.getIp(), subObTable.getPort());
                 ObPayload result = subObTable.execute(tableLsOpRequest);
                 if (result != null && result.getPcode() == Pcodes.OB_TABLE_API_MOVE) {
                     ObTableApiMove moveResponse = (ObTableApiMove) result;