Edit D:\app\Administrator\product\11.2.0\dbhome_1\ons\lib\oracle\ons\onsapi\ONS.class
?? 1{ ? ?! ?" #$ H% ?&' ?( ?)* + ,-. /0 + 12 3 45 0 6 7 8 9 : ;-<= 9> 9?@ <A <BCD EFG ?HI ?J ?KL H HM HNOP ?Q R ?S ?T ?U V W X Y Z [ \ ]^ [_ [ ` a b c d e f g hij klm ?no pq pbr stu ?vw txy vz {-| tB vB }~ ? ??? ?? ?? ??? ?? 0? v?-????? ?? ?? ???? ? 0? 0? 0. ?? ?? <? v? t? v? v? 0??? ?? ? ?? ? ? ??? v?? ? ?? ??? ?? ??? ??????? ??? ?? ??? ?? ?? ?? ??? ??? ??? ???? ? ???? ??? ?? ??? H?????? ??? ???? ?? ?? ? ?? ?_ ?? ? ?? 0???? ?? ???? t? t?-? v? v? v? ?? 9?? ?? 9???? ? ? lock Ljava/lang/Object; myoems Loracle/ons/onsapi/ONS; subscribers Ljava/util/HashMap; Signature FLjava/util/HashMap<Ljava/lang/Integer;Loracle/ons/onsapi/Subscriber;>; pendingSubscriptions TLjava/util/HashMap<Ljava/lang/Integer;Loracle/ons/onsapi/SubscriptionNotification;>; notifications RLjava/util/HashMap<Ljava/lang/String;Loracle/ons/onsapi/NotificationInformation;>; subscriberId I publisherId numPublishers currentSenderIndex lastServerIndex startTime J lastCleanupTime processId Ljava/lang/String; hostname configFile isSharedInstall Z hostNameSuffix receiver "Loracle/ons/onsapi/ReceiverThread; sender Loracle/ons/onsapi/SenderThread; monitor !Loracle/ons/onsapi/MonitorThread; receivers Ljava/util/List; 4Ljava/util/List<Loracle/ons/onsapi/ReceiverThread;>; senders 2Ljava/util/List<Loracle/ons/onsapi/SenderThread;>; serverList 3Ljava/util/List<Loracle/ons/onsapi/ServerElement;>; maxconnections connections walletfile password [C clusterid clustername instanceid instancename oraclehome debug localConn outstream Ljava/io/PrintStream; errstream shutdowntimeout notificationtimeout ONS_SSL_CONTEXT_PROTOCOL ConstantValue? ONS_SSL_KEY_MANAGEMENT? ONS_NODES ONS_WALLET_FILE ONS_PASSWORD ONS_ORACLE_HOME_KEY? ONS_HP_SEPARATOR ONS_FILE_STRING ONS_CONFIG_SEPARATOR C ONS_PERM_STRING ONS_ORACLE_HOME ONS_CONFIG_FILE setLogStream -(Ljava/io/PrintStream;Ljava/io/PrintStream;)V Code LineNumberTable LocalVariableTable out err <init> ()V e Loracle/ons/ONSException; Ljava/lang/Exception; this hostport timeout ex sm Ljava/lang/SecurityManager; Exceptions (ILjava/lang/String;)V pos mode value onsSetup (Ljava/lang/String;)V se !Loracle/ons/onsapi/ServerElement; hplist size i filestring wfile Ljava/io/File; config passwd getValue 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; end key start index found onsInit number getHostName ()Ljava/lang/String; h localadd Ljava/net/InetAddress; netStartup [(Ljava/lang/String;Loracle/ons/onsapi/ServerElement;Loracle/ons/onsapi/NotificationQueue;)Z port nq %Loracle/ons/onsapi/NotificationQueue; colon ret getONS ()Loracle/ons/onsapi/ONS; addSubscriber "(Loracle/ons/onsapi/Subscriber;J)V it Ljava/util/Iterator; s Loracle/ons/onsapi/Subscriber; ,Loracle/ons/onsapi/SubscriptionNotification; LocalVariableTypeTable 6Ljava/util/Iterator<Loracle/ons/onsapi/SenderThread;>; #findPendingSubscriptionNotification /(I)Loracle/ons/onsapi/SubscriptionNotification; id removeSubscriber (I)V shutdown lookupSubscriber !(I)Loracle/ons/onsapi/Subscriber; addPublisher (Loracle/ons/onsapi/Publisher;)V p Loracle/ons/onsapi/Publisher; removePublisher senderIterator receiverIterator 8Ljava/util/Iterator<Loracle/ons/onsapi/ReceiverThread;>; publish #(Loracle/ons/onsapi/Notification;)V subs Loracle/ons/onsapi/Notification; 4Ljava/util/Iterator<Loracle/ons/onsapi/Subscriber;>; deliver cur bytesEqual ([B[BI)Z a [B b len same handleSubscriptionReply (IZLjava/lang/String;)V sid success message "Loracle/ons/SubscriptionException; resendSubscriptions #(Loracle/ons/onsapi/SenderThread;)V "Ljava/util/NoSuchElementException; st createNewSubscriber D(Ljava/lang/String;Ljava/lang/String;)Loracle/ons/onsapi/Subscriber; c E(Ljava/lang/String;Ljava/lang/String;J)Loracle/ons/onsapi/Subscriber; createNewPublisher 1(Ljava/lang/String;)Loracle/ons/onsapi/Publisher; readLocalPort (Ljava/lang/String;)I readRemotePort readRequestPort readPortFromConfigFile '(Ljava/lang/String;Ljava/lang/String;)I loc !Ljava/lang/NumberFormatException; line eq Ljava/io/IOException; portname fis Ljava/io/FileInputStream; ib Loracle/ons/onsapi/InputBuffer; done portstr fname foundopenport foundport readStandaloneLocalPort propVal getConfigFileName configFileObj dotPos tmpConfigFileOrig tmpConfigFile tmpHName readFormFactor &(Ljava/lang/String;)Ljava/lang/String; formfactor buffer isDupNotification #(Loracle/ons/onsapi/Notification;)Z ninfo +Loracle/ons/onsapi/NotificationInformation; nkey currentTime cleanupNotificationTable @(Ljava/lang/String;Loracle/ons/onsapi/NotificationInformation;)V elem (J)V entry Entry InnerClasses Ljava/util/Map$Entry; set Ljava/util/Set; TLjava/util/Map$Entry<Ljava/lang/String;Loracle/ons/onsapi/NotificationInformation;>; jLjava/util/Iterator<Ljava/util/Map$Entry<Ljava/lang/String;Loracle/ons/onsapi/NotificationInformation;>;>; eLjava/util/Set<Ljava/util/Map$Entry<Ljava/lang/String;Loracle/ons/onsapi/NotificationInformation;>;>; replace %(Loracle/ons/onsapi/ReceiverThread;)V r getNextServer #()Loracle/ons/onsapi/ServerElement; buildServerList $(Ljava/lang/String;)Ljava/util/List; hp [Ljava/lang/String; serverlist G(Ljava/lang/String;)Ljava/util/List<Loracle/ons/onsapi/ServerElement;>; determineOracleHome oracleHome <clinit> SourceFile ONS.java7898WX+-./ "oracle/ons/onsapi/CreatePermission ONSUserWh }4 java/lang/StringBuilder localhost:?? } oracle/ons/ONSException??zX?? Error starting ONS oracle.ons.shutdowntimeout ? : java/lang/Exception? 9Can't determine ORACLE_HOME from configuration file given JHostport list can not be empty, at least one host:port should be specified??)%l6 java/util/ArrayList$%'% java/util/HashMap"#, oracle/ons/onsapi/ServerElement} oracle/ons/onsapi/MonitorThreadWwX Config string can not be null nodes=st walletfile= walletpassword=} file: ! java/io/File"#$# walletfile: does not exist!%&gh'()*'+ ,- java/lang/LongW?|}50123 oracle.ons.debug !ONS.constructor ==> DEBUG enabled./h oracle.ons.maxconnections0? Number of max connections:123 'Caught exception getting local hostname45 UNKNOWNHOST ONS::netStartup ==> hostport='6 oracle/ons/onsapi/ReceiverThreadW7 oracle/ons/onsapi/SenderThreadW8 !9:?? Caught exception in netStartup() oracle/ons/onsapi/ONS;? *oracle/ons/onsapi/SubscriptionNotification?<}W= java/lang/IntegerW?>?@ABCDE#FGH??_? oracle/ons/SubscriptionException &Subscription failed for unknown reasonIJI?X oracle/ons/onsapi/Subscriber??@?K#LMNOP????QRS????TU java/util/NoSuchElementException@V %oracle/ons/onsapi/SubscribePermissionWWWX #oracle/ons/onsapi/PublishPermission oracle/ons/onsapi/PublisherWY local?? remote request opmn conf opmn.xml java/io/FileInputStream Unable to open config file oracle/ons/onsapi/InputBufferWZ[} <port'?\}]^_` java/lang/NumberFormatExceptionaX java/io/IOExceptionb} End of data encountered.c: #No port entry found in config file *I/O error encountered reading config file ?h Unable to open config file localport= )Format error when reading localport value usesharedinstall= trued .GetHostName system call failed. Cannot proceed ons.confige# VERROR: Hostname could not be resolved and config file (ons.config) could not be found. . 3ERROR: config file (ons.config) could not be found. .formfactor Unable to open formfactor file fg java/lang/StringWh "No entry found in formfactor file .I/O error encountered reading formfactor file ?}i};?? )oracle/ons/onsapi/NotificationInformationjX??klmno java/util/Map$EntrysGp-JXq?rsJ:tXuXvw?? *Error starting receiver and sender threadsx# ,yz oracle.ons.oracleconfighome oracle.ons.oraclehome oracle.ons.oraclehome not set java/lang/ObjectU8V8 SSL SunX509 oraclehome= java/lang/System getSecurityManager ()Ljava/lang/SecurityManager; java/lang/SecurityManager checkPermission (Ljava/security/Permission;)V append -(Ljava/lang/String;)Ljava/lang/StringBuilder; (I)Ljava/lang/StringBuilder; toString getProperty valueOf '(Ljava/lang/String;)Ljava/lang/Integer; intValue ()I separator lastIndexOf substring (II)Ljava/lang/String; length java/util/List java/util/Collections synchronizedList "(Ljava/util/List;)Ljava/util/List; get (I)Ljava/lang/Object; getHostport setConnected (Z)V *(Loracle/ons/onsapi/ONS;Ljava/util/List;)V toLowerCase startsWith (Ljava/lang/String;)Z (I)Ljava/lang/String; isFile ()Z isDirectory toCharArray ()[C indexOf (Ljava/lang/String;I)I charAt (I)C (II)I currentTimeMillis ()J java/io/PrintStream println parseInt java/net/InetAddress getLocalHost ()Ljava/net/InetAddress; printStackTrace (Ljava/io/PrintStream;)V (I)I N(Ljava/lang/String;ILoracle/ons/onsapi/ServerElement;Loracle/ons/onsapi/ONS;)V a(Loracle/ons/onsapi/ONS;Loracle/ons/onsapi/ReceiverThread;Loracle/ons/onsapi/NotificationQueue;)V add (Ljava/lang/Object;)Z setID subscription (ILjava/lang/String;Z)V put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; send /(Loracle/ons/onsapi/SubscriptionNotification;)V listIterator ()Ljava/util/ListIterator; java/util/Iterator hasNext next ()Ljava/lang/Object; waitForReply &(Ljava/lang/Object;)Ljava/lang/Object; remove isReady values ()Ljava/util/Collection; java/util/Collection iterator ()Ljava/util/Iterator; oracle/ons/onsapi/Notification recipients [I wakeup &(ZLoracle/ons/SubscriptionException;)V 0(Loracle/ons/onsapi/SubscriptionNotification;I)V >(Loracle/ons/onsapi/ONS;Ljava/lang/String;Ljava/lang/String;)V ?(Loracle/ons/onsapi/ONS;Ljava/lang/String;Ljava/lang/String;J)V ,(Loracle/ons/onsapi/ONS;Ljava/lang/String;)V (Ljava/io/InputStream;)V getNextLine trim java/lang/Character isDigit (C)Z decode close getMessage equals equalsIgnoreCase exists read ([B)I ([BII)V instanceName addCount getCount entrySet ()Ljava/util/Set; java/util/Set java/util/Map getTimestamp getServer getSenderThread "()Loracle/ons/onsapi/SenderThread; stopThread join getSenderQueue '()Loracle/ons/onsapi/NotificationQueue; isConnected split '(Ljava/lang/String;)[Ljava/lang/String; ! ? 2 ! "# $% &