Edit D:\app\Administrator\product\11.2.0\dbhome_1\ons\lib\oracle\eons\rpc\impl\RpcInvocationImpl.class
?? 1 ' ? 9 ? 9 ? 9 ? ? ? 9 ? ? ? ? ? 9 ? 9 ? 9 ? ? ? ? ? 9 ? 9 ? 9 ? 9 ? ? ? ? ? ' ? ' ? ? ? ? ? ? ? n ? ? ? ? ? ? 9 ? ? 9 ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ' ? ? ? ? ? 9 ? ? ? ? ? ? ? 9 ? ? ? ? ? ? ? ? ? responseList Ljava/util/List; Signature /Ljava/util/List<Loracle/eons/rpc/RpcResponse;>; pendingServers Ljava/util/Set; -Ljava/util/Set<Loracle/eons/LogicalAddress;>; waitAll Z argType ? ArgType InnerClasses &Loracle/eons/rpc/impl/RpcUtil$ArgType; rpcName Ljava/lang/String; responseListener %Loracle/eons/rpc/RpcResponseListener; responseLoader Ljava/lang/ClassLoader; invokeId <init> ?(Ljava/lang/String;Ljava/lang/String;Ljava/util/List;Loracle/eons/rpc/impl/RpcUtil$ArgType;Loracle/eons/rpc/RpcResponseListener;)V Code LineNumberTable LocalVariableTable this (Loracle/eons/rpc/impl/RpcInvocationImpl; serverList LocalVariableTypeTable .Ljava/util/List<Loracle/eons/LogicalAddress;>; ?(Ljava/lang/String;Ljava/lang/String;Ljava/util/List<Loracle/eons/LogicalAddress;>;Loracle/eons/rpc/impl/RpcUtil$ArgType;Loracle/eons/rpc/RpcResponseListener;)V getResponseAll !(J)[Loracle/eons/rpc/RpcResponse; timeout J !(Z)[Loracle/eons/rpc/RpcResponse; blocking getResponse (J)Loracle/eons/rpc/RpcResponse; (Z)Loracle/eons/rpc/RpcResponse; isDone ()Z "(ZJ)[Loracle/eons/rpc/RpcResponse; t1 e Ljava/lang/InterruptedException; t0 time2wait wait4ever respList [Loracle/eons/rpc/RpcResponse; wait4response !(ZJ)Loracle/eons/rpc/RpcResponse; resp Loracle/eons/rpc/RpcResponse; addResponse $(Loracle/eons/LogicalAddress;[BZZI)V server Loracle/eons/LogicalAddress; response [B isResult isError errCode I r publishResponse (Loracle/eons/rpc/RpcResponse;)V currThread Ljava/lang/Thread; savedCL failWithRpcServerDown ()V laddr arr$ [Loracle/eons/LogicalAddress; len$ i$ laddrs cancel getArgType (()Loracle/eons/rpc/impl/RpcUtil$ArgType; hasAllResponses waitingFor (Loracle/eons/LogicalAddress;)Z getId ()Ljava/lang/String; getRpcName getPendingServers ()Ljava/util/Collection; 6()Ljava/util/Collection<Loracle/eons/LogicalAddress;>; SourceFile RpcInvocationImpl.java P ? O J I J B C java/util/ArrayList ; < java/util/HashSet P ? ? ? ? ? @ D H K L ? ? ? ? ? M N [ f a p ? e ? ? ? ? ? ? ? ? ? ? java/lang/InterruptedException ? ? oracle/eons/rpc/RpcResponse ? ? ? ? ? ? $oracle/eons/rpc/impl/RpcResponseImpl P ? ~ ? ? ? ? ? ? ? ? ? ? ONS-39 java/lang/Object ? ? ? ? ? y e ? ? ? ? ? ? ? ? d e ? oracle/eons/LogicalAddress s t ? &oracle/eons/rpc/impl/RpcInvocationImpl oracle/eons/rpc/RpcInvocation $oracle/eons/rpc/impl/RpcUtil$ArgType (Ljava/util/Collection;)V java/util/Collections synchronizedSet (Ljava/util/Set;)Ljava/util/Set; java/lang/Thread currentThread ()Ljava/lang/Thread; getContextClassLoader ()Ljava/lang/ClassLoader; java/util/List size ()I java/lang/System currentTimeMillis ()J wait (J)V interrupt toArray (([Ljava/lang/Object;)[Ljava/lang/Object; clear remove (I)Ljava/lang/Object; 6(Ljava/lang/String;Loracle/eons/LogicalAddress;[BZZI)V getResponseAddr ()Loracle/eons/LogicalAddress; oracle/eons/impl/OnsLogger logger Ljava/util/logging/Logger; java/util/logging/Level WARNING Ljava/util/logging/Level; java/util/logging/Logger log A(Ljava/util/logging/Level;Ljava/lang/String;[Ljava/lang/Object;)V java/util/Set (Ljava/lang/Object;)Z add notifyAll setContextClassLoader (Ljava/lang/ClassLoader;)V #oracle/eons/rpc/RpcResponseListener onResponse onCompletion contains oracle/eons/rpc/impl/RpcUtil 0 9 ' : ; <