import org.apache.raft.util.CodeInjectionForTesting;
import java.util.LinkedList;
import java.util.Queue;
import java.util.UUID;
import java.util.concurrent.ConcurrentLinkedQueue;
<BUG>import java.util.concurrent.atomic.AtomicBoolean;
import static org.apache.raft.grpc.RaftGRpcService.GRPC_SEND_SERVER_REQUEST;</BUG>
public class GRpcLogAppender extends LogAppender {
private final RaftServerProtocolClient client;
private final Queue<AppendEntriesRequestProto> pendingRequests;

import org.apache.raft.util.CodeInjectionForTesting;
import java.util.LinkedList;
import java.util.Queue;
import java.util.UUID;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.atomic.AtomicBoolean;
import static io.grpc.Status.fromThrowable;
import static org.apache.raft.grpc.RaftGRpcService.GRPC_SEND_SERVER_REQUEST;
public class GRpcLogAppender extends LogAppender {
private final RaftServerProtocolClient client;
private final Queue<AppendEntriesRequestProto> pendingRequests;
