Edit D:\app\Administrator\product\11.2.0\dbhome_1\opmn\lib\oracle\ons\ReceiverThread.class
?? 1? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ! ."# 0 ? 0$ 0% &' 0() 6* ?+ 6, - . 6/ ?0 ?1 6234 05 A6 @6 @7 ?8 @9 : ?; < ?= > ?? @ AB C 0DE FG H IJK WLMN ?OPQR ^CS FTU SC ?VW XY Z ?[ ? ?\ ? ?]^ ?_ ?` ?ab ?c ?d efgh zC ? ijk ?lmno ?p ?qrstu hostname Ljava/lang/String; port I s Ljava/net/Socket; oems Loracle/ons/ONS; se Loracle/ons/ServerElement; shutdown Z socketlock Ljava/lang/Object; waiters sender Loracle/ons/SenderThread; firstconnection connectmessage [B selfid endconnect registerSender (Loracle/ons/SenderThread;)V Code LineNumberTable LocalVariableTable this Loracle/ons/ReceiverThread; snd getSocket ()Ljava/net/Socket; e Ljava/lang/Exception; ret <init> @(Ljava/lang/String;ILoracle/ons/ServerElement;Loracle/ons/ONS;)V host p o establishConnection ()V context Ljavax/net/ssl/SSLContext; kmf !Ljavax/net/ssl/KeyManagerFactory; tmf #Ljavax/net/ssl/TrustManagerFactory; factory Ljavax/net/ssl/SSLSocketFactory; ks Ljava/security/KeyStore; owallet "Loracle/security/pki/OracleWallet; raw ex Ljava/io/IOException; ostr Ljava/io/OutputStream; ibuf Loracle/ons/InputBuffer; obuf Loracle/ons/OutputBuffer; contimeout sock addr Ljava/net/InetAddress; sockaddr Ljava/net/SocketAddress; run line stoe !Ljava/net/SocketTimeoutException; ev Loracle/ons/Notification; errors sleeptime J %Loracle/ons/SubscriptionNotification; istr Ljava/io/InputStream; pingServer readStatusMessage (Loracle/ons/InputBuffer;)Z !Ljava/lang/NumberFormatException; headername headervalue colon subscriptionid success message readNotificationMessage 3(Loracle/ons/InputBuffer;)Loracle/ons/Notification; getSenderThread ()Loracle/ons/SenderThread; isReady ()Z getServer ()Loracle/ons/ServerElement; <clinit> SourceFile ReceiverThread.java ? ? ? ? ? ? ? ? ? ?v ? java/lang/Exception ? ?wx ? ? ? ? ? ? ? ? java/lang/Object ? ? ? ?yz ?{ ?|} java/lang/StringBuilder AReceiverThread::establishConnection ==> Using SSL, walletfile is ~????? SSL??? SunX509?????? oracle/security/pki/OracleWallet??????????????????? ?? ???? java/net/InetSocketAddress ?? java/net/Socket????????? oracle/ons/OutputBuffer ?? ? ???? ????? ? ? ? ?? ? oracle/ons/InputBuffer java/io/BufferedInputStream?? ????? ???? ?? ?? ?? ?? ?? ?? ??} 7Caught exception in ReceiverThread::establishConnection??? ? java/io/IOException??x? ?? ? #oracle/ons/SubscriptionNotification ( ?? <Exception occured getting InputStream in ReceiverThread::run :ReceiverThread::run ==> returned from getNextString, line=?? !Got unexpected message start ==> java/net/SocketTimeoutException (Timeout occured reading from InputStream ReceiverThread ==> ping server?? *Exception occured reading from InputStream ? ? *ReceiverThread::run ==> have an event, ev=~? .ReceiverThread::run ==> about to deliver event?? ? ???? ? /Exception occured shutting down receiver thread?????? result?? subscriberid??? java/lang/NumberFormatException 5ReceiverThread.readStatusMessage ==> Caught exception?? +ReceiverThread ==> got server ping response oracle/ons/Notification ?? =ReceiverThread.readNotificationMessage ==> Exception occurred java/lang/String 0POST /connect HTTP/1.1 Version: 4 FormFactor: ???? SelfId: java; Home= oracle/ons/ReceiverThread java/lang/Thread wait setDaemon (Z)V oracle/ons/ONS walletfile debug outstream Ljava/io/PrintStream; append -(Ljava/lang/String;)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; java/io/PrintStream println (Ljava/lang/String;)V javax/net/ssl/SSLContext getInstance .(Ljava/lang/String;)Ljavax/net/ssl/SSLContext; javax/net/ssl/KeyManagerFactory 5(Ljava/lang/String;)Ljavax/net/ssl/KeyManagerFactory; !javax/net/ssl/TrustManagerFactory 7(Ljava/lang/String;)Ljavax/net/ssl/TrustManagerFactory; password [C open (Ljava/lang/String;[C)V getKeyStore ()Ljava/security/KeyStore; init (Ljava/security/KeyStore;[C)V (Ljava/security/KeyStore;)V getKeyManagers ()[Ljavax/net/ssl/KeyManager; getTrustManagers ()[Ljavax/net/ssl/TrustManager; W([Ljavax/net/ssl/KeyManager;[Ljavax/net/ssl/TrustManager;Ljava/security/SecureRandom;)V getSocketFactory "()Ljavax/net/ssl/SSLSocketFactory; localConn remoteIOtimeout java/net/InetAddress getByName *(Ljava/lang/String;)Ljava/net/InetAddress; (Ljava/net/InetAddress;I)V connect (Ljava/net/SocketAddress;I)V setSoTimeout (I)V javax/net/ssl/SSLSocketFactory createSocket 8(Ljava/net/Socket;Ljava/lang/String;IZ)Ljava/net/Socket; getOutputStream ()Ljava/io/OutputStream; (Ljava/io/OutputStream;)V putBytes ([BI)V oraclehome readFormFactor &(Ljava/lang/String;)Ljava/lang/String; putString flush getInputStream ()Ljava/io/InputStream; (Ljava/io/InputStream;)V getNextString clusteridheader skipBytes (I)I clusterid clusternameheader clustername instanceidheader instanceid instancenameheader instancename errstream printStackTrace (Ljava/io/PrintStream;)V close oracle/ons/SenderThread quiescent resendSubscriptions notify (ILjava/lang/String;Z)V charAt (I)C send ((Loracle/ons/SubscriptionNotification;)V -(Ljava/lang/Object;)Ljava/lang/StringBuilder; deliver (Loracle/ons/Notification;)V sleep (J)V interrupt indexOf substring (II)Ljava/lang/String; (I)Ljava/lang/String; equalsIgnoreCase (Ljava/lang/String;)Z java/lang/Integer parseInt (Ljava/lang/String;)I handleSubscriptionReply (IZLjava/lang/String;)V (Loracle/ons/InputBuffer;)V getBytes ()[B ! ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? >