Êþº¾ 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; <clinit> ()V Code - LineNumberTable LocalVariableTable <init>
|
2 0 * 4 6 8 'java/util/concurrent/ArrayBlockingQueue
|
7 : 0 ; (I)V = ?
|
A C B java/util/concurrent/Executors D E newSingleThreadScheduledExecutor 1()Ljava/util/concurrent/ScheduledExecutorService; G ! " I # $ K java/lang/StringBuilder
|
J : N ' ( this Lpublicway/SerialProtocolParser; start S T U run 6(Lpublicway/SerialProtocolParser;)Ljava/lang/Runnable; 2 Y [ Z java/util/concurrent/TimeUnit \ ] MILLISECONDS Ljava/util/concurrent/TimeUnit; _ a ` -java/util/concurrent/ScheduledExecutorService b c scheduleAtFixedRate ](Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture; e java/lang/Thread S h Serial-Protocol-Parser
|
d j 0 k )(Ljava/lang/Runnable;Ljava/lang/String;)V m % &
|
d o p q setDaemon (Z)V
|
d s Q * StackMapTable stop _ w x * shutdown Y z { ] SECONDS _ } ~ awaitTermination #(JLjava/util/concurrent/TimeUnit;)Z _ shutdownNow ()Ljava/util/List;
|
d
currentThread ()Ljava/lang/Thread;
|
d * interrupt è
|
d join (J)V "java/util/concurrent/BlockingQueue * clear java/lang/InterruptedException e Ljava/lang/InterruptedException; ()Z receiveData ([B)V offer (Ljava/lang/Object;)Z ¢ ¤ £ java/lang/System ¥ ¦ err Ljava/io/PrintStream; ¨ !æ¹ééå已满ï¼ä¸¢å¼æ°æ®
|
ª ¬ « java/io/PrintStream ® println (Ljava/lang/String;)V rawData batchProcess ² ³ isEmpty µ java/util/ArrayList
|
´ : ¸ ¹ º drainTo (Ljava/util/Collection;I)I ¼ ¾ ½ java/util/List ¿ À iterator ()Ljava/util/Iterator; Â Ä Ã java/util/Iterator Å Æ next ()Ljava/lang/Object;
|
¢ É Ê Ë arraycopy *(Ljava/lang/Object;ILjava/lang/Object;II)V
|
Í Î * processBuffer Â Ð Ñ hasNext
|
Ó Ô * checkMemory batch Ljava/util/List; LocalVariableTypeTable Ljava/util/List<[B>;
|
Ú Ü Û java/lang/Runtime Ý Þ
|
getRuntime ()Ljava/lang/Runtime;
|
Ú à á â totalMemory ()J
|
Ú ä å â
|
freeMemory
|
Ú ç è â maxMemory runtime Ljava/lang/Runtime; usedMem J maxMem
|
ï ð ñ findStartMarker ()I
|
ó ô ; compactBuffer ö $æ°æ®éå已满ï¼ä¸¢å¼æ°æ®å
ø #æ¾å
¥æ°æ®éåæ¶åçå¼å¸¸:
|
J ú 0 ®
|
ü þ ý java/lang/Exception ÿ
|
getMessage ()Ljava/lang/String;
|
J append -(Ljava/lang/String;)Ljava/lang/StringBuilder;
|
J toString
|
startIndex
|
dataLength totalPacketLength packet Ljava/lang/Exception; remaining i processPackets Æ take
|
parsePacket å¤çæ°æ®å
æ¶åçå¼å¸¸:
|
ü * printStackTrace
|
d isInterrupted
|
! chuankou/SerialPortService " getReceivedDataCount
|
$&% publicway/ProtocolParser01 '( parseDDCC01Data ,([B)Lpublicway/ProtocolParser01$ParseResult;
|
*,+ &publicway/ProtocolParser01$ParseResult - * fuzhi
|
/ 01
|
bytesToHex ([B)Ljava/lang/String;
|
354 publicway/ProtocolParser51 67 parse (Ljava/lang/String;)I9 æªç¥åè½ç : 0x
|
;=< java/lang/Integer >? toHexString (I)Ljava/lang/String;A 解ææ°æ®å
æ¶åçé误: hostAddress slotAddress functionCode returnValueLength returnValue rst (Lpublicway/ProtocolParser01$ParseResult; hexPacket Ljava/lang/String; result
|
JM N ; setLengthP %02X
|
RTS java/lang/Byte UV valueOf (B)Ljava/lang/Byte;
|
XZY java/lang/String [\ format 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; bytes b hexStringToBytes (Ljava/lang/String;)[B
|
Xb c trim
|
X ²f \sh
|
Xj kl
|
replaceAll 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
|
Xn o ñ lengthq "java/lang/IllegalArgumentExceptions #HEXå符串é¿åº¦å¿
须为å¶æ°:
|
p ú
|
Xv wx substring (II)Ljava/lang/String;
|
;z {| parseInt (Ljava/lang/String;I)I~ æ æçHEXå符:
|
p 0 *(Ljava/lang/String;Ljava/lang/Throwable;)V java/lang/NumberFormatException hexString
|
cleanedHex byteStr !Ljava/lang/NumberFormatException; getStatusInfo C串å£è§£æå¨ç¶æ: %s, éå大å°: %d/%d, æ¹ééå: %d/%d è¿è¡ä¸ å·²åæ¢ ñ size
|
; U (I)Ljava/lang/Integer; ñ remainingCapacity [Ljava/lang/Object; setMaxRawDataPrintLength
|
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; *
|
§ ° *¦ * *
|
¬ *« * InnerClasses± %java/lang/invoke/MethodHandles$Lookup³ java/lang/invoke/MethodHandles Lookup ParseResult !
|
! " B # $ % & ' ( ) * + 5 ¼YÝTYÌT³ ,± .
|
/ 0 * + H*· 1* ¼µ 3*µ 5*» 7Yd· 9µ <*» 7Yè· 9µ >*¸ @µ F*µ H*» JY · Lµ M± . *
|
! - " . # 4 & 9 * G / H O P Q * + I*´ H ±*µ H*´ F*º R V V² X¹ ^ W*» dY*º f g· iµ l*´ l¶ n*´ l¶ r± . " 0 2 5 8 & : 9 ; A < H ? / I O P t u * + - *´ H ±*µ H*´ F¹ v *´ F
|
² y¹ | !*´ F¹ W§ L*´ F¹ W¸ ¶ *´ lÆ #*´ l¶ *´ l ¶ §
|
L¸ ¶ *µ l*´ <¹ *´ >¹ *µ 5± 0 3 R \ _ . N E F I L N & O 0 Q 4 R > S D V K W R Y \ Z ` [ f ] k a t b } c f / O P 4 ` t j Z # + / *´ H¬ . l / O P + (*´ H ±+Æ +¾ ±*´ >+¹ ² ¡§¶ ©± . s u x y } ~ ' / ( O P ( ¯ t ° * + X *´ >¹ ± ±» ´Yd· ¶L*´ >+d¹ · W+¹ » N§ X-¹ Á À ÇM*´ 5,¾`*´ 3¾¤ !*´ 3*´ 5,¾d*´ 3,¾¸ È*,¾µ 5§ ,*´ 3*´ 5,¾¸ È*Y´ 5,¾`µ 5*· Ì-¹ Ï ÿ¥*· Ò± . > $ 8 G \ b e t / O P z Õ Ö 8 K ¯ × z Õ Ø t 9 ÿ ¼  ÿ 6 ¼ Ç Â ÿ ¼ Â Ô * + i ¸ ÙL+¶ ß+¶ ãeA+¶ æ7± . ¥ ¦ § ¬ / * O P é ê ë ì í ì Î * + Ï Ì§ Â*· î< *µ 5±`*´ 5¤ *· ò±*´ 3`3 ÿ~x*´ 3`3 ÿ~= ``> `*´ 5¤ *· ò± ¼:*´ 3 ¸ È*´ <¹ *² ¡õ¶ ©§ :² ¡» JY÷· ù¶ û¶¶¶ ©*´ 5 `d6 *´ 3 `*´ 3¸ È*µ 5*´ 5 ¢ÿ;± g } ü . f ² ´ µ · ¸ ¼ ¾ " ¿ # à @ Ä F Ç P É U Ê V Î [ Ï g Ó u Ô } Ö × Û ¦ Ü « Ý ¼ ß Â ² Ë á / H Ì O P º @ F |
|
[ g ¦ t / ü ý 2ÿ ) Ç üü ÿ ð ñ + 7<§ &*´ 33² ,3 *´ 3`3² ,3 ¬*´ 5² ,¾d¤ÿÓ¬ . ç è # é % ç 5 ì / 7 O P 3 t ü ô ; + k " *´ 3*´ 3*´ 5d¸ È*Y´ 5dµ 5± . ó ô õ ! ÷ / " O P " t ! * + å R§ A*´ <¹ À ÇL*+·§ ,L¸ ¶ § 2L² ¡» JY· ù+¶ û¶¶¶ ©+¶*´ H ¸ ¶ÿµ± " ü . . ÿ " # = A ÿ Q / * R O P # t T I ü + A
|
ý¸ W+3=+3>+36+3 ÿ~x+3 ÿ~6d6: ¼:+¸ È« t ÿÿÿ hÿÿÿ kÿÿÿ nÿÿÿ q A Q T R eÆ r+¸#:¶)§ d*+·.:¸26 § S§ P§ M§ J§ G§ D² ¡» JY8· ù ÿ~¸:¶¶¶ ©§ "M² ¡» JY@· ù,¶ û¶¶¶ ©,¶± Ú Ý ü . r & , /! 4" :# E' ) + , / 2 ¢3 ©9 ¬< ¯? ²B µE ¸H »J ÚN ÞO øP üR / z ý O P ý ÒB ÎC ÈD & ´ , ®E / «F GH ¢
|
IJ © K Þ t 2 ÿ E Ç Ç û Bÿ ! Ç ü 01 + C*´ M¶L+Y:¾6>§ $ 3=*´ MO½ Y ¸QS¸W¶W ¡ÿÜ*´ M¶° . X Y Z 2Y ;\ / C O P C] ^ t ÿ Ç Ç _` + X *Æ *¶a¶d ¼°*eg¶iL+¶mp »pY» JYr· ù+¶¶·t¿+¶ml¼M>§ >+ `¶u:, l¸yT§ !:»pY» JY}· ù¶¶·¿ +¶m¡ÿÀ,° W d g . 6 ` a e h &i ?l Hn Mo Wq dr is
n w / > J u
J H JK J F W .J i t , ü ,Xý Çÿ XX ÇX ú + ã n½ Y*´ H § SY*´ <¹ ¸SY*´ <¹ *´ <¹ `¸SY*´ >¹ ¸SY*´ >¹ *´ >¹ `¸S¸W° . ~ + D S j~ / n O P t - ÿ Xÿ XX ; + 5 ± . / O P o ¤ ¥¨©¤ ª®¯ °²´ *$µ
|
