add the other two handlers that receive PIDs in their message

apache · Mar 29, 2023 · e065f93 · e065f93
1 parent d622942
commit e065f93
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...erver/src/main/java/org/apache/hadoop/hbase/regionserver/handler/AssignRegionHandler.java b/...erver/src/main/java/org/apache/hadoop/hbase/regionserver/handler/AssignRegionHandler.java
@@ -37,6 +37,7 @@
 import org.slf4j.LoggerFactory;
 
 import org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode;
+import org.slf4j.MDC;
 
 /**
  * Handles opening of a region on a region server.
@@ -90,6 +91,7 @@ private void cleanUpAndReportFailure(IOException error) throws IOException {
 
   @Override
   public void process() throws IOException {
+    MDC.put("pid", Long.toString(openProcId));
     HRegionServer rs = getServer();
     String encodedName = regionInfo.getEncodedName();
     byte[] encodedNameBytes = regionInfo.getEncodedNameAsBytes();

diff --git a/...ver/src/main/java/org/apache/hadoop/hbase/regionserver/handler/UnassignRegionHandler.java b/...ver/src/main/java/org/apache/hadoop/hbase/regionserver/handler/UnassignRegionHandler.java
@@ -35,6 +35,7 @@
 import org.slf4j.LoggerFactory;
 
 import org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode;
+import org.slf4j.MDC;
 
 /**
  * Handles closing of a region on a region server.
@@ -84,6 +85,7 @@ private HRegionServer getServer() {
 
   @Override
   public void process() throws IOException {
+    MDC.put("pid", Long.toString(closeProcId));
     HRegionServer rs = getServer();
     byte[] encodedNameBytes = Bytes.toBytes(encodedName);
     Boolean previous = rs.getRegionsInTransitionInRS().putIfAbsent(encodedNameBytes, Boolean.FALSE);