import org.apache.hadoop.ipc.ProtocolTranslator; //导入依赖的package包/类
/**
 * Test for {@link RetryInvocationHandler#isRpcInvocation(Object)}
 */
@Test
public void testRpcInvocation() throws Exception {
  // For a proxy method should return true
  final UnreliableInterface unreliable = (UnreliableInterface)
    RetryProxy.create(UnreliableInterface.class, unreliableImpl, RETRY_FOREVER);
  assertTrue(RetryInvocationHandler.isRpcInvocation(unreliable));

  final AtomicInteger count = new AtomicInteger();
  // Embed the proxy in ProtocolTranslator
  ProtocolTranslator xlator = new ProtocolTranslator() {
    @Override
    public Object getUnderlyingProxyObject() {
      count.getAndIncrement();
      return unreliable;
    }
  };
  
  // For a proxy wrapped in ProtocolTranslator method should return true
  assertTrue(RetryInvocationHandler.isRpcInvocation(xlator));
  // Ensure underlying proxy was looked at
  assertEquals(1, count.get());
  
  // For non-proxy the method must return false
  assertFalse(RetryInvocationHandler.isRpcInvocation(new Object()));
}
 

import org.apache.hadoop.ipc.ProtocolTranslator; //导入依赖的package包/类
@VisibleForTesting
static boolean isRpcInvocation(Object proxy) {
  if (proxy instanceof ProtocolTranslator) {
    proxy = ((ProtocolTranslator) proxy).getUnderlyingProxyObject();
  }
  if (!Proxy.isProxyClass(proxy.getClass())) {
    return false;
  }
  final InvocationHandler ih = Proxy.getInvocationHandler(proxy);
  return ih instanceof RpcInvocationHandler;
}
 

import org.apache.hadoop.ipc.ProtocolTranslator; //导入依赖的package包/类
/**
 * Test for {@link RetryInvocationHandler#isRpcInvocation(Object)}
 */
@Test
public void testRpcInvocation() throws Exception {
  // For a proxy method should return true
  final UnreliableInterface unreliable = (UnreliableInterface)
    RetryProxy.create(UnreliableInterface.class, unreliableImpl, RETRY_FOREVER);
  assertTrue(RetryInvocationHandler.isRpcInvocation(unreliable));
  
  // Embed the proxy in ProtocolTranslator
  ProtocolTranslator xlator = new ProtocolTranslator() {
    int count = 0;
    @Override
    public Object getUnderlyingProxyObject() {
      count++;
      return unreliable;
    }
    @Override
    public String toString() {
      return "" + count;
    }
  };
  
  // For a proxy wrapped in ProtocolTranslator method should return true
  assertTrue(RetryInvocationHandler.isRpcInvocation(xlator));
  // Ensure underlying proxy was looked at
  assertEquals(xlator.toString(), "1");
  
  // For non-proxy the method must return false
  assertFalse(RetryInvocationHandler.isRpcInvocation(new Object()));
}
 

import org.apache.hadoop.ipc.ProtocolTranslator; //导入依赖的package包/类
/**
 * Test for {@link RetryInvocationHandler#isRpcInvocation(Object)}
 */
public void testRpcInvocation() throws Exception {
  // For a proxy method should return true
  final UnreliableInterface unreliable = (UnreliableInterface)
    RetryProxy.create(UnreliableInterface.class, unreliableImpl, RETRY_FOREVER);
  assertTrue(RetryInvocationHandler.isRpcInvocation(unreliable));
  
  // Embed the proxy in ProtocolTranslator
  ProtocolTranslator xlator = new ProtocolTranslator() {
    int count = 0;
    @Override
    public Object getUnderlyingProxyObject() {
      count++;
      return unreliable;
    }
    @Override
    public String toString() {
      return "" + count;
    }
  };
  
  // For a proxy wrapped in ProtocolTranslator method should return true
  assertTrue(RetryInvocationHandler.isRpcInvocation(xlator));
  // Ensure underlying proxy was looked at
  assertEquals(xlator.toString(), "1");
  
  // For non-proxy the method must return false
  assertFalse(RetryInvocationHandler.isRpcInvocation(new Object()));
}