001/* 002 * Licensed to the Apache Software Foundation (ASF) under one 003 * or more contributor license agreements. See the NOTICE file 004 * distributed with this work for additional information 005 * regarding copyright ownership. The ASF licenses this file 006 * to you under the Apache License, Version 2.0 (the 007 * "License"); you may not use this file except in compliance 008 * with the License. You may obtain a copy of the License at 009 * 010 * http://www.apache.org/licenses/LICENSE-2.0 011 * 012 * Unless required by applicable law or agreed to in writing, software 013 * distributed under the License is distributed on an "AS IS" BASIS, 014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 015 * See the License for the specific language governing permissions and 016 * limitations under the License. 017 */ 018package org.apache.hadoop.hbase.master.procedure; 019 020import java.io.IOException; 021import java.util.Optional; 022import org.apache.hadoop.hbase.ServerName; 023import org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.ServerOperation; 024import org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer; 025import org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteOperation; 026import org.apache.hadoop.hbase.regionserver.LogRollCallable; 027import org.apache.yetus.audience.InterfaceAudience; 028 029import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; 030import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.LogRollRemoteProcedureStateData; 031 032/** 033 * The remote procedure to perform WAL rolling on the specific RegionServer without retrying. 034 */ 035@InterfaceAudience.Private 036public class LogRollRemoteProcedure extends ServerRemoteProcedure 037 implements ServerProcedureInterface { 038 039 public LogRollRemoteProcedure() { 040 } 041 042 public LogRollRemoteProcedure(ServerName targetServer) { 043 this.targetServer = targetServer; 044 } 045 046 @Override 047 protected void rollback(MasterProcedureEnv env) { 048 throw new UnsupportedOperationException(); 049 } 050 051 @Override 052 protected boolean abort(MasterProcedureEnv env) { 053 return false; 054 } 055 056 @Override 057 protected void serializeStateData(ProcedureStateSerializer serializer) throws IOException { 058 serializer.serialize(LogRollRemoteProcedureStateData.newBuilder() 059 .setTargetServer(ProtobufUtil.toServerName(targetServer)).build()); 060 } 061 062 @Override 063 protected void deserializeStateData(ProcedureStateSerializer serializer) throws IOException { 064 LogRollRemoteProcedureStateData data = 065 serializer.deserialize(LogRollRemoteProcedureStateData.class); 066 this.targetServer = ProtobufUtil.toServerName(data.getTargetServer()); 067 } 068 069 @Override 070 public Optional<RemoteOperation> remoteCallBuild(MasterProcedureEnv env, ServerName serverName) { 071 return Optional.of(new ServerOperation(this, getProcId(), LogRollCallable.class, 072 LogRollRemoteProcedureStateData.getDefaultInstance().toByteArray(), 073 env.getMasterServices().getMasterActiveTime())); 074 } 075 076 @Override 077 public ServerName getServerName() { 078 return targetServer; 079 } 080 081 @Override 082 public boolean hasMetaTableRegion() { 083 return false; 084 } 085 086 @Override 087 public ServerOperationType getServerOperationType() { 088 return ServerOperationType.LOG_ROLL; 089 } 090 091 @Override 092 protected boolean complete(MasterProcedureEnv env, Throwable error) { 093 // do not retry. just returns. 094 if (error != null) { 095 LOG.warn("Failed to roll wal for {}", targetServer, error); 096 return false; 097 } else { 098 return true; 099 } 100 } 101 102 @Override 103 public synchronized void remoteOperationCompleted(MasterProcedureEnv env, 104 byte[] remoteResultData) { 105 setResult(remoteResultData); 106 super.remoteOperationCompleted(env, remoteResultData); 107 } 108 109 @Override 110 protected void toStringClassDetails(StringBuilder sb) { 111 sb.append(getClass().getSimpleName()).append(" targetServer=").append(targetServer); 112 } 113}