Java 类org.apache.hadoop.hbase.io.WritableWithSize 实例源码

项目：LCIndex-HBase-0.94.16 文件：MonitoredRPCHandlerImpl.java

/**
 * Produces a string representation of the method currently being serviced
 * by this Handler.
 * @return A human-readable string representation of the method call.
 */
public long getRPCPacketLength() {
  if (getState() != State.RUNNING || packet == null) {
    // no RPC is currently running, or we don't have an RPC's packet info
    return -1L;
  }
  if (!(packet instanceof WritableWithSize)) {
    // the packet passed to us doesn't expose size information
    return -1L;
  }
  return ((WritableWithSize) packet).getWritableSize();
}

项目：IRIndex 文件：MonitoredRPCHandlerImpl.java

/**
 * Produces a string representation of the method currently being serviced
 * by this Handler.
 * @return A human-readable string representation of the method call.
 */
public long getRPCPacketLength() {
  if (getState() != State.RUNNING || packet == null) {
    // no RPC is currently running, or we don't have an RPC's packet info
    return -1L;
  }
  if (!(packet instanceof WritableWithSize)) {
    // the packet passed to us doesn't expose size information
    return -1L;
  }
  return ((WritableWithSize) packet).getWritableSize();
}

项目：RStore 文件：MonitoredRPCHandlerImpl.java

/**
 * Produces a string representation of the method currently being serviced
 * by this Handler.
 * @return A human-readable string representation of the method call.
 */
public long getRPCPacketLength() {
  if (getState() != State.RUNNING || packet == null) {
    // no RPC is currently running, or we don't have an RPC's packet info
    return -1L;
  }
  if (!(packet instanceof WritableWithSize)) {
    // the packet passed to us doesn't expose size information
    return -1L;
  }
  return ((WritableWithSize) packet).getWritableSize();
}

项目：HBase-Research 文件：MonitoredRPCHandlerImpl.java

/**
 * Produces a string representation of the method currently being serviced
 * by this Handler.
 * @return A human-readable string representation of the method call.
 */
public long getRPCPacketLength() {
  if (getState() != State.RUNNING || packet == null) {
    // no RPC is currently running, or we don't have an RPC's packet info
    return -1L;
  }
  if (!(packet instanceof WritableWithSize)) {
    // the packet passed to us doesn't expose size information
    return -1L;
  }
  return ((WritableWithSize) packet).getWritableSize();
}

项目：hbase-0.94.8-qod 文件：MonitoredRPCHandlerImpl.java

/**
 * Produces a string representation of the method currently being serviced
 * by this Handler.
 * @return A human-readable string representation of the method call.
 */
public long getRPCPacketLength() {
  if (getState() != State.RUNNING || packet == null) {
    // no RPC is currently running, or we don't have an RPC's packet info
    return -1L;
  }
  if (!(packet instanceof WritableWithSize)) {
    // the packet passed to us doesn't expose size information
    return -1L;
  }
  return ((WritableWithSize) packet).getWritableSize();
}

项目：hbase-0.94.8-qod 文件：MonitoredRPCHandlerImpl.java

/**
 * Produces a string representation of the method currently being serviced
 * by this Handler.
 * @return A human-readable string representation of the method call.
 */
public long getRPCPacketLength() {
  if (getState() != State.RUNNING || packet == null) {
    // no RPC is currently running, or we don't have an RPC's packet info
    return -1L;
  }
  if (!(packet instanceof WritableWithSize)) {
    // the packet passed to us doesn't expose size information
    return -1L;
  }
  return ((WritableWithSize) packet).getWritableSize();
}

项目：hindex 文件：MonitoredRPCHandlerImpl.java

/**
 * Produces a string representation of the method currently being serviced
 * by this Handler.
 * @return A human-readable string representation of the method call.
 */
public long getRPCPacketLength() {
  if (getState() != State.RUNNING || packet == null) {
    // no RPC is currently running, or we don't have an RPC's packet info
    return -1L;
  }
  if (!(packet instanceof WritableWithSize)) {
    // the packet passed to us doesn't expose size information
    return -1L;
  }
  return ((WritableWithSize) packet).getWritableSize();
}