Edit D:\app\Administrator\product\11.2.0\dbhome_1\opmn\lib\oracle\ons\ONS.class
?? 1? ? ? ? ? ? !" # $%& ' ?()*+ #, - . ?/ 0 1 ?2 ?3 ?456 ?7 ?8 ?9: ];<=> K?@ KA KBC ?D ?EFG ?HI 0 JK ?L ?MN 5 ?O ?P ?Q ?R ?S ?TFUV >W >XY AZ A[\ ?]^ ?_`a ?bc? K#d ?efg hi ?jklmno Kpq Kr Kst ]# ]u ]vwx Kyz ?{ K| K} K~? ??? l ?? ?? ?? ?? ?? ? ??? u? u1 ?? ?? ?? ?? ?? ?? ?? ???? ?? ??? "??? K?? ??? ?? ??F? ?[ ?[ ??? ??? ? ??? ?? ?? ??? ?? l? ??F????? ?? ?? ???? ?# l? l? lG ??? ?? A? ?? ?? ?? ?? l????? ?? ?? ?? ?? ?? ??? ??? ?# ?? ??? ?#? ??? ????? ?#?? ?? ??? K? K? ?? ??? ??? ??? K??? ?? ????? ???? K? ???? ]?????? ?? K??? ? ? ? ? 5? ?? ? 5? ? ? 5? 5 ?? ? ?F ? ? ? ? > K ># lock Ljava/lang/Object; myoems Loracle/ons/ONS; subscribers Ljava/util/Hashtable; pendingSubscriptions notifications Ljava/util/HashMap; subscriberId I publisherId numPublishers currentSenderIndex lastServerIndex startTime J lastCleanupTime processId Ljava/lang/String; hostname configFile isSharedInstall Z hostNameSuffix receiver Loracle/ons/ReceiverThread; sender Loracle/ons/SenderThread; monitor Loracle/ons/MonitorThread; receivers Ljava/util/List; senders serverList maxconnections connections walletfile password [C clusterid clustername instanceid instancename oraclehome debug localConn outstream Ljava/io/PrintStream; errstream shutdowntimeout notificationtimeout remoteIOtimeout ONS_REMOTE_MIN_TIMEOUT ConstantValue ONS_REMOTE_MAX_TIMEOUT ONS_REMOTE_DFLT_TIMEOUT u0 ONS_REMOTE_SUBSCRIBER_ID c ONS_REMOTE_SUBSCRIPTION ONS_SSL_CONTEXT_PROTOCOL ONS_SSL_KEY_MANAGEMENT ONS_NODES ONS_WALLET_FILE ONS_PASSWORD ONS_HP_SEPARATOR ONS_FILE_STRING ONS_REMOTE_TIMEOUT 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 fname pos mode value (Ljava/util/List;)V hplist onsSetup (Ljava/lang/String;)V se Loracle/ons/ServerElement; size i =(Ljava/util/List;Ljava/security/KeyStore;Ljava/lang/String;)V ks Ljava/security/KeyStore; rtval filestring wfile Ljava/io/File; config passwd remotetimeout rtconf getValue 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; end key start index found checkDebug onsInit number getHostName ()Ljava/lang/String; h localadd Ljava/net/InetAddress; netStartup M(Ljava/lang/String;Loracle/ons/ServerElement;Loracle/ons/NotificationQueue;)Z port nq Loracle/ons/NotificationQueue; colon ret getONS ()Loracle/ons/ONS; getRunningONS addSubscriber (Loracle/ons/Subscriber;J)V it Ljava/util/Iterator; s Loracle/ons/Subscriber; %Loracle/ons/SubscriptionNotification; #findPendingSubscriptionNotification ((I)Loracle/ons/SubscriptionNotification; id removeSubscriber (I)V shutdown lookupSubscriber (I)Loracle/ons/Subscriber; addPublisher (Loracle/ons/Publisher;)V p Loracle/ons/Publisher; removePublisher publish (Loracle/ons/Notification;)V subs Ljava/util/Enumeration; current Loracle/ons/Notification; 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/SenderThread;)V "Ljava/util/NoSuchElementException; st createNewSubscriber =(Ljava/lang/String;Ljava/lang/String;)Loracle/ons/Subscriber; c >(Ljava/lang/String;Ljava/lang/String;J)Loracle/ons/Subscriber; createNewPublisher *(Ljava/lang/String;)Loracle/ons/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/InputBuffer; done portstr foundopenport foundport readStandaloneLocalPort propVal getConfigFileName configFileObj dotPos tmpConfigFileOrig tmpConfigFile tmpHName readFormFactor &(Ljava/lang/String;)Ljava/lang/String; formfactor buffer isDupNotification (Loracle/ons/Notification;)Z ninfo $Loracle/ons/NotificationInformation; nkey currentTime cleanupNotificationTable 9(Ljava/lang/String;Loracle/ons/NotificationInformation;)V elem (J)V entry Entry InnerClasses Ljava/util/Map$Entry; set Ljava/util/Set; replace (Loracle/ons/ReceiverThread;)V r getNextServer ()Loracle/ons/ServerElement; buildServerList $(Ljava/lang/String;)Ljava/util/List; hp [Ljava/lang/String; serverlist <clinit> SourceFile ONS.javaCDEDlm79':;!"# oracle/ons/CreatePermission ONSUserl?$%& oracle.ons.oracleconfighome'?@' oracle.ons.oraclehome oracle/ons/ONSException oracle.ons.oraclehome not set java/lang/StringBuilder 127.0.0.1:()??(*+????m?? Error starting ONS oracle.ons.shutdowntimeout,-./F java/lang/Exception0' opmn conf opmn.xml1? 9Can't determine ORACLE_HOME from configuration file given234/ JHostport list can not be empty, at least one host:port should be specified645?/B+ java/util/ArrayList6783454 java/util/HashMap%$!"1289: oracle/ons/ServerElement;?<= oracle/ons/MonitorThreadl>?m Config string can not be null?m nodes=?? oracle.ons.remotetimeout remotetimeout=A+ java/lang/String propertyH #ONS:: remote timeout configured by : ?@?A? ONS:: remote timeout set to 20 ONS:: remote timeout set to 3600 &ONS:: invalid remote timeout ignored: walletfile= walletpassword=B? file:CD2E java/io/FileFGHG walletfile: does not exist!IJ direct-connect?KLMNKO oracle.ons.debug !ONS.constructor ==> DEBUG enabled java/util/Hashtable PQ#$ java/lang/Longl&'-.??('<'='>'?' oracle.ons.maxconnections Number of max connections:RST 'Caught exception getting local hostnameUV UNKNOWNHOST ONS::netStartup ==> hostport=KW oracle/ons/ReceiverThreadlX oracle/ons/SenderThreadlY/0Z[?? Caught exception in netStartup() oracle/ons/ONS\? #oracle/ons/SubscriptionNotification?/]?l^ java/lang/Integerl?_`abcdefGghi?+t? oracle/ons/SubscriptionException &Subscription failed for unknown reason9jkj?m oracle/ons/Subscriber??a?lGmnopGqh????rst????uv java/util/NoSuchElementExceptionaw oracle/ons/SubscribePermissionlxly oracle/ons/PublishPermission oracle/ons/Publisherlz local?? remote request java/io/FileInputStream Unable to open config file oracle/ons/InputBufferl{|? <portK?}?~??- java/lang/NumberFormatException?m java/io/IOException?? End of data encountered.?[ #No port entry found in config file *I/O error encountered reading config file ??)' Unable to open config file localport= )Format error when reading localport value*+ usesharedinstall= true?D,' .GetHostName system call failed. Cannot proceed ons.config?G 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 ??l? "No entry found in formfactor file .I/O error encountered reading formfactor file ?'?'G "oracle/ons/NotificationInformation?m?/?????? java/util/Map$Entry?h?Qkm???k[?m?m?? *Error starting receiver and sender threads?G ,?? java/lang/ObjectjDkD ( SSL SunX509 java/lang/System getSecurityManager ()Ljava/lang/SecurityManager; java/lang/SecurityManager checkPermission (Ljava/security/Permission;)V getProperty append -(Ljava/lang/String;)Ljava/lang/StringBuilder; (I)Ljava/lang/StringBuilder; toString 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/ONS;Ljava/util/List;)V java/io/PrintStream println parseInt 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/net/InetAddress getLocalHost ()Ljava/net/InetAddress; printStackTrace (Ljava/io/PrintStream;)V (I)I @(Ljava/lang/String;ILoracle/ons/ServerElement;Loracle/ons/ONS;)V L(Loracle/ons/ONS;Loracle/ons/ReceiverThread;Loracle/ons/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/SubscriptionNotification;)V listIterator ()Ljava/util/ListIterator; java/util/Iterator hasNext next ()Ljava/lang/Object; waitForReply &(Ljava/lang/Object;)Ljava/lang/Object; remove isReady elements ()Ljava/util/Enumeration; java/util/Enumeration hasMoreElements nextElement oracle/ons/Notification recipients [I wakeup &(ZLoracle/ons/SubscriptionException;)V )(Loracle/ons/SubscriptionNotification;I)V 7(Loracle/ons/ONS;Ljava/lang/String;Ljava/lang/String;)V 8(Loracle/ons/ONS;Ljava/lang/String;Ljava/lang/String;J)V %(Loracle/ons/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 iterator ()Ljava/util/Iterator; java/util/Map getTimestamp getServer getSenderThread ()Loracle/ons/SenderThread; stopThread join getSenderQueue ()Loracle/ons/NotificationQueue; isConnected split '(Ljava/lang/String;)[Ljava/lang/String; ! ? 8 ! " #$ %$ &' (' )' *+ ,' -. /0 12 34 54 64 7 8 9' :; <' =' >' ?' @' A+ B+ CD ED F G H I J K L J M N J O P J Q R' J S T' J U V' J W X' J F Y' J W Z' J X [' J \' J Z ]' J I ^_ J K `' J a J b c J d - ef g U *? *? +? +? ? h ? ? ? ? ?i jD kD lm g ? ?*? *? *? *? LN? :? ? Y ? ? *? ? *? ? *? ? *? ? ? Y? ? Y? ? *? ? ? ? L? :N-? ? Y? ? *? ? ? ? L*? *+? ? ? Y? ?? M,? ,? ? ? !? :? !? Y s v ? ? ? "