Êþº¾ 4b 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; processedPacketCache Ljava/util/Set; #Ljava/util/Set<Ljava/lang/String;>; MAX_CACHE_SIZE è CACHE_CLEANUP_INTERVAL ê` lastCacheCleanupTime <clinit> ()V Code = LineNumberTable LocalVariableTable <init>
|
B @ : D F H 'java/util/concurrent/ArrayBlockingQueue
|
G J @ K (I)V M O
|
Q S R java/util/concurrent/Executors T U newSingleThreadScheduledExecutor 1()Ljava/util/concurrent/ScheduledExecutorService; W ! " Y # $ [ java/lang/StringBuilder
|
Z J ^ ' ( ` ) * b . / d &java/util/concurrent/ConcurrentHashMap
|
c B
|
g i h java/util/Collections j k newSetFromMap (Ljava/util/Map;)Ljava/util/Set; m 0 1 o 8 * this Lpublicway/SerialProtocolParser; start t u v run 6(Lpublicway/SerialProtocolParser;)Ljava/lang/Runnable;
|
z | { java/util/concurrent/TimeUnit } ~ MILLISECONDS Ljava/util/concurrent/TimeUnit; -java/util/concurrent/ScheduledExecutorService scheduleAtFixedRate ](Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture; java/lang/Thread t Serial-Protocol-Parser
|
@ )(Ljava/lang/Runnable;Ljava/lang/String;)V % &
|
setDaemon (Z)V
|
r : StackMapTable stop : shutdown z ~ SECONDS awaitTermination #(JLjava/util/concurrent/TimeUnit;)Z ¢ £ ¤ shutdownNow ()Ljava/util/List;
|
¦ § ¨ currentThread ()Ljava/lang/Thread;
|
ª « : interrupt è
|
¯ ° ± join (J)V
|
³ ´ : clearQueues ¶ ¸ · java/util/Set ¹ : clear » java/lang/InterruptedException e Ljava/lang/InterruptedException; ¿ ¸ À "java/util/concurrent/BlockingQueue ()Z receiveData ([B)V
|
¿ Æ Ç È size ()I ¿ Ê Ë È remainingCapacity?é ¿ Ï Ð Á isEmpty ¿ Ò Ó Ô poll ()Ljava/lang/Object; ¿ Ö × Ø offer (Ljava/lang/Object;)Z
|
Ú Û : handleQueueFull rawData Þ à ß chushihua/lunxun á $ DEBUG_ENABLED ã ?è¦åï¼æ°æ®å¤çéå已满ï¼å·²æ¸
空éåéæ°å¼å§
|
å ç æ xitongshezhi/SystemDebugDialog è é appendAsciiData (Ljava/lang/String;)V batchProcess ì java/util/ArrayList
|
ë J ¿ ï ð ñ drainTo (Ljava/util/Collection;I)I ó õ ô java/util/List ö ÷ iterator ()Ljava/util/Iterator; ù û ú java/util/Iterator ü Ô next
|
ÿ Ã handleOversizedPacket
|
K compactBuffer
|
java/lang/System arraycopy *(Ljava/lang/Object;ILjava/lang/Object;II)V
|
: processBuffer ù Á hasNext
|
: checkMemory
|
: cleanupPacketCache err Ljava/io/PrintStream; #æ¹éå¤çæ°æ®æ¶åçå¼å¸¸:
|
Z @ é
|
! java/lang/Exception "#
|
getMessage ()Ljava/lang/String;
|
Z% &' append -(Ljava/lang/String;)Ljava/lang/StringBuilder;
|
Z) *# toString
|
,.- java/io/PrintStream / é println
|
1 2 : resetParserState maxBatchSize batch Ljava/util/List; Ljava/lang/Exception; LocalVariableTypeTable Ljava/util/List<[B>;
|
: ;< findStartMarkerInArray ([BI)I oversizedData
|
startIndex remainingLength data startPos i
|
D EF currentTimeMillis ()J
|
HJI java/lang/Runtime KL
|
getRuntime ()Ljava/lang/Runtime;
|
HN OF totalMemory
|
HQ RF
|
freeMemory
|
HT UF maxMemory?è
|
Y Z : gc\ Aå
å使ç¨çè¶
è¿75%ï¼å·²è§¦ååå¾åæ¶ã使ç¨å
å:
|
Z` &a (J)Ljava/lang/StringBuilder;c MB currentTime runtime Ljava/lang/Runtime; usedMem maxMem ¶ Æk /æ°æ®å
å»éç¼åå·²æ¸
空ï¼å½å大å°:
|
Zm &n (I)Ljava/lang/StringBuilder;
|
p q È findStartMarker
|
s tu extractPacket (II)[B
|
w xy generatePacketHash ([B)Ljava/lang/String; ¶{ | Ø contains~ è·³è¿éå¤æ°æ®å
:
|
y
|
bytesToHex ¶ Ø add
|
: handleDataQueueFull processedCount MAX_PACKETS_PER_BATCH
|
dataLength totalPacketLength packet
|
packetHash Ljava/lang/String; remaining java/lang/String :
|
java/lang/Math min (II)I %02X
|
¡ java/lang/Byte ¢£ valueOf (B)Ljava/lang/Byte;
|
¥ ¦§ format 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; key dataStart dataEnd
|
hashLength 0æ°æ®è§£æéå已满ï¼ä¸¢å¼æèæ°æ®å
processPackets ° ± out³ '串å£æ°æ®å
å¤ç线ç¨å¼å§è¿è¡ ¿µ ¶ Ô take
|
¸ ¹ à parsePacket» $串å£æ°æ®å
å¤ç线ç¨è¢«ä¸æ½ å¤çæ°æ®å
æ¶åçå¼å¸¸:
|
¿ À Á isInterrupted '串å£æ°æ®å
å¤ç线ç¨ç»æè¿è¡Ä å¼å§è§£ææ¶å°çæ°æ®Æ æ¶é´
|
ÈÊÉ publicway/TimestampUtil Ë# getTimestamp
|
ÍÏÎ chuankou/SerialPortService Ð# getReceivedDataCount
|
ÒÔÓ publicway/ProtocolParser01 ÕÖ parseDDCC01Data ,([B)Lpublicway/ProtocolParser01$ParseResult;
|
ØÚÙ &publicway/ProtocolParser01$ParseResult Û : fuzhi
|
Ø)
|
Þàß publicway/ProtocolParser51 áâ parse (Ljava/lang/String;)I
|
äæå chushihua/SlotManager çè changgehaska (II)Z
|
ê ¢ë (I)Ljava/lang/String;í å·å¡æ§½åå¡å¤±è´¥
|
ïñð dialog/Charulog ò é logOperationô æªç¥åè½ç : 0x
|
öø÷ java/lang/Integer ùë toHexStringû 解ææ°æ®å
æ¶åçé误: hostAddress slotAddress functionCode returnValueLength returnValue rst (Lpublicway/ProtocolParser01$ParseResult; hexPacket result slot message
|
Z K setLength 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å符:
|
+ @, *(Ljava/lang/String;Ljava/lang/Throwable;)V. java/lang/NumberFormatException hexString
|
cleanedHex byteStr !Ljava/lang/NumberFormatException; getStatusInfo5 j串å£è§£æå¨ç¶æ: %s, éå大å°: %d/%d, æ¹ééå: %d/%d, ç¼å²åº: %d/%d, å»éç¼å: %d/%d7 è¿è¡ä¸9 å·²åæ¢
|
ö; ¢< (I)Ljava/lang/Integer;> [Ljava/lang/Object; setMaxRawDataPrintLength cleanup
|
B : clearPacketCacheE $æ°æ®å
å»éç¼åå·²æå¨æ¸
空 getPacketCacheSize
|
SourceFile SerialProtocolParser.java BootstrapMethods
|
KML "java/lang/invoke/LambdaMetafactory NO 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;J :
|
S ê :R : :
|
X ® :W : InnerClasses] %java/lang/invoke/MethodHandles$Lookup_ java/lang/invoke/MethodHandles Lookup ParseResult !
|
! " B # $ % & ' ( ) * + * , . / 0 1 2 3 4 5 * 6 8 * 9 : ; 5 ¼YÝTYÌT³ <± >
|
@ ? @ : ; Ñ k*· A* ¼µ C*µ E*» GY2· Iµ L*» GY È· Iµ N*¸ Pµ V*µ X*» ZY · \µ ]* µ _*» Y· Aµ a*» cY· e¸ fµ l* µ n± > B # $ ' * - + . , 4 / 9 3 G 6 L : W = X > _ = e A j ? k p q r : ; I*´ X ±*µ X*´ V*º s w w² y¹ W*»
Y*º · µ *´ ¶ *´ ¶ ± > " G H K N & O 9 P A Q H R ? I p q : ; ( ~*´ X ±*µ X*´ V¹ *´ V
|
² ¹ !*´ V¹ ¡ W§ L*´ V¹ ¡ W¸ ¥¶ ©*´ Æ #*´ ¶ ©*´ ¬¶ ®§
|
L¸ ¥¶ ©*µ *· ²*µ E*´ l¹ µ ± 0 3 º R \ _ º > N X Y \ _ a & b 0 d 4 e > f D i K j R l \ m ` n f p k t o u t x } y ? ~ p q 4 ¼ ½ ` ¼ ½ j ºZ º ´ : ; E *´ L¹ ¾ *´ N¹ ¾ ± > ? p q # Á ; / *´ X¬ > ? p q  à ; ¾ Y*´ X *¶ Ä+Æ +¾ ±*´ N¹ Å *´ N¹ É Ìk *´ N¹ Î *´ N¹ Ñ W*´ N+¹ Õ *· Ù± > *
|
1 = G T ¢ X ¤ ? Y p q Y Ü 1 Û : ; X *· ²*µ E² Ý â¸ ä± > « ¬ ® ¯ ± ? p q ê : ; À ´*´ N¹ Î ±2<» ëY· íM*´ N,¹ î W,¹ ò :§ R¹ ø À ýN*´ E-¾`*´ C¾¤ -¾*´ C¾¤ *-· þ§ &*·-*´ C*´ E-¾¸*Y´ E-¾`µ E*·
|
¹ ÿª*·*·§ "L²» ZY· +¶ ¶$¶(¶+*·0± > V · ¸ ½ ¾ ¿ % Á ; Ã J Å T Ç Y È \ Ë a Ð p Ñ { Ô Á Ø Û Ý Þ ¯ à ³ â ? 4 ´ p q 3 x45 ; D Ü ¼6 7 x48 J ÿ " ó ù ÿ + ó ý ù ÿ ó ù ÿ Ã ; /*+·9= %+¾ d> *´ C¾£ + *´ C ¸* µ E*·
|
± > " é ê ì í î % ï * ð . ô ? * / p q /= (> ? ü . ;< ; / >§ + 3² <3 + `3² <3 ¬ +¾² <¾d¤ÿÛ¬ > ú û ü ú - ÿ ? * / p q /@ /A +B ü 2 : ; <
|
*µ E*· ²± > ?
|
p q : ; g¸C@ *´ _e , ±* µ _¸GN-¶M-¶Pe7-¶S7Vk /¸X² Ý &» ZY[· ]m]m¶_b¶$¶(¸ ä± > : & , : = C M ` f" ? 4 g p q cd * Lef & Ag * , ;h * ü þ SH : ; ³ R¸C@ *´ ne 6 ±* µ n*´ l¹i è¡ .*´ l¹ µ ² Ý » ZYj· *´ l¹i ¶l¶(¸ ä± > & ( ) * - 0 &1 /2 53 Q6 ? R p q Nd * ü > : ; « F<=§1*·o> *µ E± `*´ E¤ * ·±*´ C `3 ÿ~x*´ C `3 ÿ~6``6 *´ C¾¤ * `·§ Ò `*´ E¤ * ·±* ·r:Æ *·v:*´ l¹z P² Ý » ZY}· *·¶$¶(¸ ä*´ E `d6 *´ C `*´ C¸*µ E§ P*´ l¹ W*´ L¹ Õ :*·
±*´ E `d6 *´ C `*´ C¸*µ E*´ E ¡ ¡þƱ > ª * < = ? A B D E I "K 'L (P FQ NT ]V dW g[ r] w^ xb c e f h ¢i »m Æn Ëo Ýq ãr æs éw õz|}
|
~
-36?E ? f
|
F p q D A )> F ð N è µ } Æ # 7 ý ü ý 4 ý B ýü !ú ú !ü !ÿ xy ; S +Æ
|
+¾¢ °» ZY@· \M,+3 ÿ~¶l¶$W,+3 ÿ~¶l¶$W,+3 ÿ~¶l¶$W>+¾d6 d¸6 6§ ,½ Y+3¸S¸¤¶$W `¢
|
¡ÿ×,¶(° > 6 + = P S Y¢ d£ j¤ £ § ? H p q ¨ ( S H© Y Bª d 7« g /B ÿ Z ý Z ú tu ; a ¼N*´ C- ¸-° > ® ¯ ° ? * p q > : ; V *´ L¹ Ñ W² Ý ¬¸ ä± > ¸
|
º » ½ ? p q q È ; 7<§ &*´ C3² <3 *´ C`3² <3 ¬*´ E² <¾d¤ÿÓ¬ > Ã Ä #Å %à 5È ? 7 p q 3B ü K ; s * (*´ E¤ *´ C*´ C*´ Ed¸*Y´ Edµ E± > Ï Ð Ñ )Ó ? * p q *> ) ® : ; i²¯²¶+§ F*´ L¹´ À ýL*+··§ 1L²¯º¶+¸ ¥¶ ©§ .L²» ZY¼· +¶ ¶$¶(¶+*´ X ¸ ¥¶¾ÿ°²¯Á¶+± ! º 4 > 6 Ù Û Ý Þ ß "à +á 1â 4ã 5ä OÛ _é hê ? * i p q " ¼ ½ 5 ¼6 T ºR ¹ à ; ²¯» ZY÷ *+·¶$Ŷ$¸Ç¶$¶(¶++Æ
|
+¾ ¢ ±¸ÌW+3=+3>+36+3 ÿ~x+3 ÿ~6d6: +¾d£ ¼:+¸« º ÿÿÿ ®ÿÿÿ ±ÿÿÿ ´ÿÿÿ · D Q j R «Æ ·+¸Ñ:Æ ¬¶×² Ý ¡¶Ü¸ ä§ *+·:¸Ý6 6
|
|
¸ãW§ t» ZY
|
¸é· ì¶$¶(: ¸î§ U§ R§ O§ L§ I§ F² Ý @²» ZYó· ÿ~¸õ¶$¶(¶+§ M²» ZYú· ,¶ ¶$¶(¶+± 3cf > ¢ ( ð 'ñ 2ò 3ö 7ø ;ù ?ú Eý Y _ b q w È
|
Í Ó Ø Ý ã ë î õ ü ÿ ' , /#2&5)8,;/>1D2c7g8; ? p q ;(ü ?$ý E þ Y
|
_ÿ b Ó õ : ü 3 ÿ 0
|
' g ¼6 > 2 ÿ N ý ý û E%þ !ø ÿ ' ý y ; Ä P+Æ +¾ °*´ ]¶+Y:¾6>§ $ 3=*´ ]½ Y ¸S¸¤¶$W ¡ÿÜ*´ ]¶(° > A B E F &G ?F HI ? P p q P
|
& ÿ ý ý ; X *Æ *¶¶ ¼°*¶L+¶p »Y» ZY · +¶$¶(· ¿+¶l¼M>§ >+ `¶ :, l¸$T§ !:»Y» ZY(· ¶$¶(·*¿ +¶¡ÿÀ,° W d g- > 6 M N R U &V ?Y H[ M\ W^ d_ i`
[ d ? > / u0 H J J FB W .1 i ¼2 , ü ,ý ýÿ ý -ú 3# ; $ 4 ½ Y*´ X 6§ 8SY*´ L¹ Å ¸:SY*´ L¹ É *´ L¹ Å `¸:SY*´ N¹ Å ¸:SY*´ N¹ É *´ N¹ Å `¸:SY*´ E¸:SY*´ C¾¸:SY*´ l¹i ¸:SYè¸:S¸¤° > . k
|
l m ,n Eo Tp mq xr s t k ? p q - ÿ ==ÿ == ? K ; 5 ± > | ? p q @ : ; ] *¶A*· ²*µ E*´ ]¶*´ l¹ µ ± >
? p q C : ; U *´ l¹ µ ² Ý D¸ ä± > ? p q F È ; 4
|
*´ l¹i ¬ > ?
|
p q G HI P QTUP VYZ[ \^` ØÒa
|
