org.apache.hadoop.mapred.TaskUmbilicalProtocol#org.apache.hadoop.ipc.ProtocolSignature源码实例Demo

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  if (!protocol.equals(RPC.getProtocolName(HAServiceProtocolPB.class))) {
    throw new IOException("Serverside implements " +
        RPC.getProtocolName(HAServiceProtocolPB.class) +
        ". The following requested protocol is unknown: " + protocol);
  }

  return ProtocolSignature.getProtocolSignature(clientMethodsHash,
      RPC.getProtocolVersion(HAServiceProtocolPB.class),
      HAServiceProtocolPB.class);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  if (!protocol.equals(RPC.getProtocolName(ZKFCProtocolPB.class))) {
    throw new IOException("Serverside implements " +
        RPC.getProtocolName(ZKFCProtocolPB.class) +
        ". The following requested protocol is unknown: " + protocol);
  }

  return ProtocolSignature.getProtocolSignature(clientMethodsHash,
      RPC.getProtocolVersion(ZKFCProtocolPB.class),
      HAServiceProtocolPB.class);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
        long clientVersion, int clientMethodsHash) throws IOException {
  if (!protocol.equals(RPC.getProtocolName(TraceAdminProtocolPB.class))) {
    throw new IOException("Serverside implements " +
        RPC.getProtocolName(TraceAdminProtocolPB.class) +
        ". The following requested protocol is unknown: " + protocol);
  }
  return ProtocolSignature.getProtocolSignature(clientMethodsHash,
      RPC.getProtocolVersion(TraceAdminProtocolPB.class),
      TraceAdminProtocolPB.class);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  if (!protocol.equals(RPC.getProtocolName(HAServiceProtocolPB.class))) {
    throw new IOException("Serverside implements " +
        RPC.getProtocolName(HAServiceProtocolPB.class) +
        ". The following requested protocol is unknown: " + protocol);
  }

  return ProtocolSignature.getProtocolSignature(clientMethodsHash,
      RPC.getProtocolVersion(HAServiceProtocolPB.class),
      HAServiceProtocolPB.class);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  if (!protocol.equals(RPC.getProtocolName(ZKFCProtocolPB.class))) {
    throw new IOException("Serverside implements " +
        RPC.getProtocolName(ZKFCProtocolPB.class) +
        ". The following requested protocol is unknown: " + protocol);
  }

  return ProtocolSignature.getProtocolSignature(clientMethodsHash,
      RPC.getProtocolVersion(ZKFCProtocolPB.class),
      HAServiceProtocolPB.class);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
        long clientVersion, int clientMethodsHash) throws IOException {
  if (!protocol.equals(RPC.getProtocolName(TraceAdminProtocolPB.class))) {
    throw new IOException("Serverside implements " +
        RPC.getProtocolName(TraceAdminProtocolPB.class) +
        ". The following requested protocol is unknown: " + protocol);
  }
  return ProtocolSignature.getProtocolSignature(clientMethodsHash,
      RPC.getProtocolVersion(TraceAdminProtocolPB.class),
      TraceAdminProtocolPB.class);
}
 

/**
 * This function tests the method signature fingerprint passed back from
 * name-node with MetaInfo is correct.
 */
@SuppressWarnings("unchecked")
public void testNameNodeFingerprintSent() throws IOException {
  InetSocketAddress addr = cluster.getNameNode().getNameNodeDNAddress();
  DFSClient client = new DFSClient(addr, cluster.getNameNode().getConf());

  client.namenode.create("/testNameNodeFingerprintSent.txt", FsPermission
      .getDefault(), client.getClientName(), true, (short)1, 65535L);

  
  Class<? extends VersionedProtocol> inter;
  try {
    inter = (Class<? extends VersionedProtocol>)Class.forName(ClientProtocol.class.getName());
  } catch (Exception e) {
    throw new IOException(e);
  }
  long serverVersion = ClientProtocol.versionID;
  int serverFpFromNn = ProtocolSignature.getFingerprint(ProtocolSignature.getProtocolSignature(
      0, serverVersion, inter).getMethods());
  
  LocatedBlockWithMetaInfo loc = client.namenode.addBlockAndFetchMetaInfo("/testNameNodeFingerprintSent.txt",
      client.getClientName(), null, 0L);
  
  int serverFp = loc.getMethodFingerPrint();
  TestCase.assertEquals(serverFpFromNn, serverFp);    

  FileSystem fs = cluster.getFileSystem();
  Path f = new Path("/testNameNodeFingerprintSent1.txt");
  DataOutputStream a_out = fs.create(f);
  a_out.writeBytes("something");
  a_out.close();
  
  LocatedBlocksWithMetaInfo locs = client.namenode.openAndFetchMetaInfo("/testNameNodeFingerprintSent.txt",
      0L, 0L);
  TestCase.assertEquals(locs.getMethodFingerPrint(), serverFp);    
}
 

@Override
public ProtocolSignature getProtocolSignature(
  String protocol,
  long clientVersion,
  int clientMethodsHash) throws IOException {
  return ProtocolSignature.getProtocolSignature(
    this, protocol, clientVersion, clientMethodsHash);
}
 

@Override
public ProtocolSignature getProtocolSignature(final String protocol,
    final long clientVersion, final int clientMethodsHash) throws IOException {
  return (new ImmutableFSCaller<ProtocolSignature>() {

    @Override
    ProtocolSignature call() throws IOException {
      return namenode.getProtocolSignature(
          protocol, clientVersion, clientMethodsHash);
    }

  }).callFS();
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException
{
  return ProtocolSignature.getProtocolSignature(this, protocol, clientVersion, clientMethodsHash);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol, long clientVersion, int clientMethodsHash) throws IOException
{
  throw new UnsupportedOperationException("not implemented in local mode");
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol, long clientVersion, int clientMethodsHash) throws IOException {
    return this.proxy.getProtocolSignature(protocol, clientVersion, clientMethodsHash);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol, long clientVersion, int clientMethodsHash) throws IOException {
    return null;
}
 

@Override
public ProtocolSignature getProtocolSignature(
    String protocol, long clientVersion, int clientMethodsHash) throws IOException {
  return ProtocolSignature.getProtocolSignature(this, protocol,
      clientVersion, clientMethodsHash);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
                                              long clientVersion, int clientMethodsHash) throws IOException {
  return ProtocolSignature.getProtocolSignature(this, protocol,
      clientVersion, clientMethodsHash);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  return ProtocolSignature.getProtocolSignature(this, 
      protocol, clientVersion, clientMethodsHash);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  return ProtocolSignature.getProtocolSignature(this, protocol, clientVersion,
      clientMethodsHash);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  return ProtocolSignature.getProtocolSignature(
      this, protocol, clientVersion, clientMethodsHash);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  return null;
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  return ProtocolSignature.getProtocolSignature(
      this, protocol, clientVersion, clientMethodsHash);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  return ProtocolSignature.getProtocolSignature(
      this, protocol, clientVersion, clientMethodsHash);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  return new ProtocolSignature(TestProtocol.versionID, null);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol, long clientVersion, int clientMethodsHash) throws IOException {
    return new ProtocolSignature(IServer.versionID, null);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  return ProtocolSignature.getProtocolSignature(this, 
      protocol, clientVersion, clientMethodsHash);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  return ProtocolSignature.getProtocolSignature(this, protocol, clientVersion,
      clientMethodsHash);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  return ProtocolSignature.getProtocolSignature(
      this, protocol, clientVersion, clientMethodsHash);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  return null;
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  return ProtocolSignature.getProtocolSignature(
      this, protocol, clientVersion, clientMethodsHash);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  return ProtocolSignature.getProtocolSignature(
      this, protocol, clientVersion, clientMethodsHash);
}
 

@Override
public ProtocolSignature getProtocolSignature(String protocol,
    long clientVersion, int clientMethodsHash) throws IOException {
  return new ProtocolSignature(TestProtocol.versionID, null);
}