Êþº¾ 4 publicway/SerialProtocolParser java/lang/Object START_MARKER [B MIN_PACKET_LENGTH I ConstantValue FUNCTION_01 B FUNCTION_51 Q FUNCTION_52 R FUNCTION_80ÿÿÿ FUNCTION_81ÿÿÿ FUNCTION_82ÿÿÿ FUNCTION_83ÿÿÿ
|
dataBuffer bufferPosition dataQueue $Ljava/util/concurrent/BlockingQueue; Signature (Ljava/util/concurrent/BlockingQueue<[B>;
|
batchQueue batchExecutor /Ljava/util/concurrent/ScheduledExecutorService; isRunning Z processorThread Ljava/lang/Thread;
|
hexBuilder Ljava/lang/StringBuilder; lastMemoryCheckTime J MEMORY_CHECK_INTERVAL u0 packetPoolLock Ljava/lang/Object; <clinit> ()V Code 4 LineNumberTable LocalVariableTable <init>
|
9 7 1 ; = ? 'java/util/concurrent/ArrayBlockingQueue
|
> A 7 B (I)V D F
|
H J I java/util/concurrent/Executors K L newSingleThreadScheduledExecutor 1()Ljava/util/concurrent/ScheduledExecutorService; N ! " P # $ R java/lang/StringBuilder
|
Q A U ' ( W ) * Y . / this Lpublicway/SerialProtocolParser; start ^ _ ` run 6(Lpublicway/SerialProtocolParser;)Ljava/lang/Runnable; 2 d f e java/util/concurrent/TimeUnit g h MILLISECONDS Ljava/util/concurrent/TimeUnit; j l k -java/util/concurrent/ScheduledExecutorService m n scheduleAtFixedRate ](Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture; p java/lang/Thread ^ s Serial-Protocol-Parser
|
o u 7 v )(Ljava/lang/Runnable;Ljava/lang/String;)V x % &
|
o z { | setDaemon (Z)V
|
o ~ \ 1 StackMapTable stop j 1 shutdown d
h SECONDS j awaitTermination #(JLjava/util/concurrent/TimeUnit;)Z j shutdownNow ()Ljava/util/List;
|
o currentThread ()Ljava/lang/Thread;
|
o 1 interrupt è
|
o join (J)V
|
1 clearQueues java/lang/InterruptedException e Ljava/lang/InterruptedException; ¤ ¦ ¥ "java/util/concurrent/BlockingQueue § 1 clear ()Z receiveData ([B)V
|
~ ¤ ® ¯ size ()I ¤ ± ² ¯ remainingCapacity?é ¤ ¶ · ¨ isEmpty ¤ ¹ º » poll ()Ljava/lang/Object; ¤ ½ ¾ ¿ offer (Ljava/lang/Object;)Z
|
Á  1 handleQueueFull rawData Å Ç Æ chushihua/lunxun È $ DEBUG_ENABLED Ê ?è¦åï¼æ°æ®å¤çéå已满ï¼å·²æ¸
空éåéæ°å¼å§
|
Ì Î Í xitongshezhi/SystemDebugDialog Ï Ð appendAsciiData (Ljava/lang/String;)V batchProcess Ó java/util/ArrayList
|
Ò A ¤ Ö × Ø drainTo (Ljava/util/Collection;I)I Ú Ü Û java/util/List Ý Þ iterator ()Ljava/util/Iterator; à â á java/util/Iterator ã » next
|
æ ç ª handleOversizedPacket
|
é ê B compactBuffer
|
ì î í java/lang/System ï ð arraycopy *(Ljava/lang/Object;ILjava/lang/Object;II)V
|
ò ó 1 processBuffer à õ ö ¨ hasNext
|
ø ù 1 checkMemory ì û ü ý err Ljava/io/PrintStream; ÿ #æ¹éå¤çæ°æ®æ¶åçå¼å¸¸:
|
Q 7 Ð
|
java/lang/Exception
|
getMessage ()Ljava/lang/String;
|
Q
|
append -(Ljava/lang/String;)Ljava/lang/StringBuilder;
|
Q toString
|
java/io/PrintStream Ð println
|
1 resetParserState maxBatchSize batch Ljava/util/List; Ljava/lang/Exception; LocalVariableTypeTable Ljava/util/List<[B>;
|
findStartMarkerInArray ([BI)I oversizedData
|
startIndex remainingLength data startPos i
|
ì( )* currentTimeMillis ()J
|
,.- java/lang/Runtime /0
|
getRuntime ()Ljava/lang/Runtime;
|
,2 3* totalMemory
|
,5 6*
|
freeMemory
|
,8 9* maxMemory?è
|
ì= > 1 gc@ Aå
å使ç¨çè¶
è¿75%ï¼å·²è§¦ååå¾åæ¶ã使ç¨å
å:
|
QD
|
E (J)Ljava/lang/StringBuilder;G MB currentTime runtime Ljava/lang/Runtime; usedMem maxMem
|
N O ¯ findStartMarker
|
Q RS extractPacket (II)[B
|
U V 1 handleDataQueueFull processedCount MAX_PACKETS_PER_BATCH
|
dataLength totalPacketLength packet remaining^ 0æ°æ®è§£æéå已满ï¼ä¸¢å¼æèæ°æ®å
processPackets ìa b ý outd '串å£æ°æ®å
å¤ç线ç¨å¼å§è¿è¡ ¤f g » take
|
i j ª parsePacketl $串å£æ°æ®å
å¤ç线ç¨è¢«ä¸æn å¤çæ°æ®å
æ¶åçå¼å¸¸:
|
op q ¨ isInterrupteds '串å£æ°æ®å
å¤ç线ç¨ç»æè¿è¡
|
uwv chuankou/SerialPortService x getReceivedDataCount
|
z|{ publicway/ProtocolParser01 }~ parseDDCC01Data ,([B)Lpublicway/ProtocolParser01$ParseResult;
|
&publicway/ProtocolParser01$ParseResult 1 fuzhi
|
|
|
bytesToHex ([B)Ljava/lang/String;
|
publicway/ProtocolParser51 parse (Ljava/lang/String;)I
|
chushihua/SlotManager changgehaska (II)Z
|
java/lang/String valueOf (I)Ljava/lang/String; å·å¡æ§½åå¡å¤±è´¥
|
dialog/Charulog ¡ Ð logOperation£ æªç¥åè½ç : 0x
|
¥§¦ java/lang/Integer ¨ toHexStringª 解ææ°æ®å
æ¶åçé误: hostAddress slotAddress functionCode returnValueLength returnValue rst (Lpublicway/ProtocolParser01$ParseResult; hexPacket Ljava/lang/String; result slot message¸
|
Qº » B setLength½ %02X
|
¿ÁÀ java/lang/Byte  (B)Ljava/lang/Byte;
|
Ä ÅÆ format 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; bytes b hexStringToBytes (Ljava/lang/String;)[B
|
Ì Í trim
|
¶Ð \s
|
Ò ÓÔ
|
replaceAll 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
|
Ö × ¯ lengthÙ "java/lang/IllegalArgumentExceptionÛ #HEXå符串é¿åº¦å¿
须为å¶æ°:
|
Ø
|
Þ ßà substring (II)Ljava/lang/String;
|
¥â ãä parseInt (Ljava/lang/String;I)Iæ æ æçHEXå符:
|
Øè 7é *(Ljava/lang/String;Ljava/lang/Throwable;)Vë java/lang/NumberFormatException hexString
|
cleanedHex byteStr !Ljava/lang/NumberFormatException; getStatusInfoò U串å£è§£æå¨ç¶æ: %s, éå大å°: %d/%d, æ¹ééå: %d/%d, ç¼å²åº: %d/%dô è¿è¡ä¸ö å·²åæ¢
|
¥ø ù (I)Ljava/lang/Integer;û [Ljava/lang/Object; setMaxRawDataPrintLength cleanup
|
ÿ 1
|
SourceFile SerialProtocolParser.java BootstrapMethods
|
"java/lang/invoke/LambdaMetafactory metafactory Ì(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite; 1
|
Ñ 1 1 1
|
_ 1 1 InnerClasses %java/lang/invoke/MethodHandles$Lookup java/lang/invoke/MethodHandles Lookup ParseResult !
|
! " B # $ % & ' ( ) * + * , . / 0 1 2 5 ¼YÝTYÌT³ 3± 5
|
4 6 7 1 2 ® X*· 8* ¼µ :*µ <*» >Y2· @µ C*» >Y È· @µ E*¸ Gµ M*µ O*» QY · Sµ T* µ V*» Y· 8µ X± 5 2 ! $ ' - ( . ) 4 , 9 0 G 3 L 7 W 6 X Z [ \ 1 2 I*´ O ±*µ O*´ M*º ] a a² c¹ i W*» oY*º q r· tµ w*´ w¶ y*´ w¶ }± 5 " = > A D & F 9 G A H H I 6 I Z [ 1 2 u*´ O ±*µ O*´ M¹ *´ M
|
² ¹ !*´ M¹ W§ L*´ M¹ W¸ ¶ *´ wÆ #*´ w¶ *´ w ¶ §
|
L¸ ¶ *µ w*· *µ <± 0 3 R \ _ 5 J O P S V X & Y 0 [ 4 \ > ] D ` K a R c \ d ` e f g k k o l t m 6 u Z [ 4 ¡ ¢ ` ¡ ¢ j Z 1 2 E *´ C¹ £ *´ E¹ £ ± 5 s t u 6 Z [ # ¨ 2 / *´ O¬ 5 { 6 Z [ © ª 2 ¾ Y*´ O *¶ «+Æ +¾ ±*´ E¹ ¬ *´ E¹ ° ³k *´ E¹ µ *´ E¹ ¸ W*´ E+¹ ¼ *· À± 5 *
|
1 = G T X 6 Y Z [ Y à 1  1 2 X *· *µ <² Ä É¸ ˱ 5 ¢ £ ¥ 6 Z [ Ñ 1 2 · ¯*´ E¹ µ ±2<» ÒY· ÔM*´ E,¹ Õ W,¹ Ù :§ R¹ ß À äN*´ <-¾`*´ :¾¤ -¾*´ :¾¤ *-· å§ &*· è-*´ :*´ <-¾¸ ë*Y´ <-¾`µ <*· ñ¹ ô ÿª*· ÷§ !L² ú» QYþ· +¶¶¶ ¶*·± 5 R « ¬ ± ² ³ % µ ; · J ¹ T » Y ¼ \ ¿ a Ä p Å { È µ Ì Î Ï ª Ñ ® Ó 6 4 ¯ Z [ } t ; D à ¡ t J ÿ " Ú à ÿ + Ú ä à ÿ Ú à ÿ ç ª 2 /*+· = %+¾ d> *´ :¾£ + *´ : ¸ ë* µ <*· ñ± 5 " Ú Û Ý Þ ß % à * á . å 6 * / Z [ /! (" # ü . 2 / >§ + 3² 33 + `3² 33 ¬ +¾² 3¾d¤ÿÛ¬ 5 ë ì í ë - ð 6 * / Z [ /$ /% +& ü 1 2 <
|
*µ <*· ± 5 ÷ ø ù 6
|
Z [ ù 1 2 g¸'@ *´ Ve , ±* µ V¸+N-¶1-¶4e7-¶77:k /¸<² Ä &» QY?· AmAm¶CF¶¶ ¸ ˱ 5 : ÿ & ,
|
: = C M ` f 6 4 g Z [ cH * LIJ & AK * , ;L * ü þ S, ó 1 2 ï ×<=§ Â*·M> *µ <± `*´ <¤ * · è±*´ : `3 ÿ~x*´ : `3 ÿ~6``6 *´ :¾¤ * `· è§ c `*´ <¤ * · è±* ·P:Æ *´ C¹ ¼ :*·T±*´ < `d6 *´ : `*´ :¸ ë*µ <*´ < ¡ ¡ÿ5± 5 ~ ! " & "( ') (- F. N1 ]3 d4 g8 r: w; x? @ B D E F K §L ¬M ¾O ÄQ Ç ÖS 6 R × Z [ ÕW ÒX º" F Y N yZ F[ § \ *
|
ý ü ý 4 ü # äü !ÿ RS 2 a ¼N*´ :- ¸ ë-° 5 Y Z [ 6 * Z [ " Z [ V 1 2 V *´ C¹ ¸ W² Ä ]¸ ˱ 5 c
|
e f h 6 Z [ O ¯ 2 7<§ &*´ :3² 33 *´ :`3² 33 ¬*´ <² 3¾d¤ÿÓ¬ 5 n o #p %n 5s 6 7 Z [ 3& ü ê B 2 s * (*´ <¤ *´ :*´ :*´ <d¸ ë*Y´ <dµ <± 5 z { | )~ 6 * Z [ *" ) _ 1 2 i²`c¶§ F*´ C¹e À äL*+·h§ 1L²`k¶¸ ¶ § .L² ú» QYm· +¶¶¶ ¶*´ O ¸ ¶oÿ°²`r¶± ! 4 5 6 " + 1 4 5 O _ h 6 * i Z [ [ " ¡ ¢ 5 ¡ T R j ª 2 ê Z+Æ
|
+¾ ¢ ±¸tW+3=+3>+36+3 ÿ~x+3 ÿ~6d6: +¾d£ ¼:+¸ ë« ¹ ÿÿÿ ÿÿÿ °ÿÿÿ ³ÿÿÿ ¶ C Q i R ªÆ ·+¸y:Æ ¬¶² Ä ¡¶¸ ˧ *+·
:¸6 6
|
|
¸W§ t» QY
|
¸· ¶¶ : ¸§ U§ R§ O§ L§ I§ F² Ä @² ú» QY¢· ÿ~¸¤¶¶ ¶§ M² ú» QY©· ,¶¶¶ ¶± ;> 5 ' ¢ £ ¤ ¦ 2© 8ª ;« J¬ P [± ³ ¥µ «¶ °· µ¸ »¹ ý ÆÀ ÍÁ Ô ×à ÝÄ åÅ èÆ ÿÇÉÌ
|
Ï ÒÕØÚ Û;à?áYä 6 Z Z [ Z[ '« #¬ 2 Y 8® ; ¯ « °± Í :²³ Ô 3´ × 0µ
|
ÿ ¶³ ? ¡ > ÿ N ä ä û D%þ !ø ÿ ' ä 2 Ä P+Æ +¾ ·°*´ T¶¹+Y:¾6>§ $ 3=*´ T¼½ Y ¸¾S¸Ã¶W ¡ÿÜ*´ T¶ ° 5 ê ë î ï &ð ?ï Hò 6 P Z [ PÇ & È ÿ ä ä ÉÊ 2 X *Æ *¶Ë¶Î ¼°*Ï·¶ÑL+¶Õp »ØY» QYÚ· +¶¶ ·Ü¿+¶Õl¼M>§ >+ `¶Ý:, l¸áT§ !:»ØY» QYå· ¶¶ ·ç¿ +¶Õ¡ÿÀ,° W d gê 5 6 ö ÷ û þ &ÿ ? H M W d i
6 > ì³ uí³ H J´ J F& W .î³ i ¡ï , ü ,ý äÿ ä êú ð 2
ñ½ Y*´ O ó§ õSY*´ C¹ ¬ ¸÷SY*´ C¹ ° *´ C¹ ¬ `¸÷SY*´ E¹ ¬ ¸÷SY*´ E¹ ° *´ E¹ ¬ `¸÷SY*´ <¸÷SY*´ :¾¸÷S¸Ã° 5 &
|
, E T m x 6
Z [ - ÿ úúÿ úú ü B 2 5 ± 5 # 6 Z [ × ý 1 2 P *¶þ*· *µ <*´ T¶¹± 5 ) * + , - 6 Z [
|
z
|
