Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\engine\PollingThr.class
?? 1& ? R ? ? ? Q ? ? ? Q ? Q ? ? ? Q ? ? ? Q ? Q ? ? ? ? ? ? ? Q ? Q ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? Q ? ? ? ? ? ? ? ? ? ? ? Q ???????? ? ? ? ? ? * ? ? * ? ? * ? ? ? * ? ? * ? * ? * ? * ? * ? ? ? * ? ? ? * ? * ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? agent Loracle/mgw/engine/Agent; jobMgr Loracle/mgw/engine/JobMgr; jlist Ljava/util/Enumeration; logger Loracle/mgw/common/MgwLog; defaultPoll J pollWaiting Ljava/lang/Object; lastRound FACILITY Ljava/lang/String; COMPONENT I <init> (Loracle/mgw/engine/Agent;)V Code LineNumberTable LocalVariableTable this Loracle/mgw/engine/PollingThr; myRun ()V newCount me $Loracle/mgw/common/GatewayException; job Loracle/mgw/engine/JobData; srcq Loracle/mgw/common/DestData; timeLeft jobLatency currentTime e Ljava/lang/InterruptedException; timeToWaitToPoll re Ljava/lang/RuntimeException; ee Ljava/lang/Error; notifyPollWaiting forceStop <clinit> SourceFile PollingThr.java Polling d ? java/lang/Object d l ] ^ ? ? ? _ \ S T ? ? ? Y Z ? ? ? [ \ ` a ? ? ? ? ? ? ? ? U V b c ? ? java/lang/StringBuilder totalMemory = ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? freeMemory = ? ? ? ? l ? l W X ? oracle/mgw/engine/JobData ^ Polling checking job: a state = c ? status = c retryCount = c ? ? s ? a ? Polling thread: new msgCount = Polling thread: skip polling msg count= l "oracle/mgw/common/GatewayException failed to poll its source. l Polling thread waits for java/lang/InterruptedException java/lang/RuntimeException!"#$ java/lang/Error% l Engine oracle/mgw/engine/PollingThr oracle/mgw/engine/ManagedThr (Ljava/lang/String;)V java/lang/System currentTimeMillis ()J oracle/mgw/common/MgwLog getMgwLogger ()Loracle/mgw/common/MgwLog; oracle/mgw/common/MgwConstants pollingInterval ()I java/lang/String valueOf (J)Ljava/lang/String; logMsg ((Ljava/lang/String;ILjava/lang/String;)V oracle/mgw/engine/Agent getJobMgr ()Loracle/mgw/engine/JobMgr; isTRACE_HIGH (I)Z append -(Ljava/lang/String;)Ljava/lang/StringBuilder; java/lang/Runtime getRuntime ()Ljava/lang/Runtime; totalMemory (J)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; trace )(Ljava/lang/String;Ljava/lang/String;II)V getStop ()Z freeMemory java/lang/Thread yield oracle/mgw/engine/JobMgr lockJobsForScan getJobs ()Ljava/util/Enumeration; java/util/Enumeration hasMoreElements nextElement ()Ljava/lang/Object; jobMutex pid jobState (I)Ljava/lang/StringBuilder; jobStatus retryCount getLatency getLastPollingTime srcQ getMsgCount oracle/mgw/common/DestData getLink ()Loracle/mgw/common/MsgLink; guid oracle/mgw/common/MsgLink (Ljava/lang/String;)I setMsgCount (I)V setLastPollingTime (J)V isTRACE_LITE notifyAll logMsgEx =(Ljava/lang/String;ILjava/lang/String;Ljava/lang/Throwable;)V unlockJobsForScan wait getMsg (I)Ljava/lang/String; shutdown *(Ljava/lang/String;Ljava/lang/Throwable;)V notify 0 Q R S T U V W X Y Z [ \ ] ^ _ \ ` a b c d e f ? @*? *? Y? ? *? ? *+? *? ? *? ? *? ? *? ? ? ? g "