Êþº¾ 4} (com/dev/btse/data/TmpSensor_SocketThread java/lang/Thread autoUpdateTime I ConstantValue maxTmpSensorCount
|
tmpSensors Ljava/util/List; Signature 4Ljava/util/List<Lcom/dev/btse/data/TmpSensorState;>; m_socket Ljava/net/Socket; pool #Lcom/battmonitor/sql/MysqlConnPool; hadreg_flag Z tmpState "Lcom/dev/btse/data/TmpSensorState; tmpinf !Lcom/dev/btse/data/TmpSensor_inf; m_TMP_Cmd !Lcom/dev/btse/data/TmpSensor_Cmd; S_thread_run_flag rx_errcount_for_live_of_thread bytebuffer_for_socket_RX Ljava/nio/ByteBuffer; <init> 7(Ljava/net/Socket;Lcom/battmonitor/sql/MysqlConnPool;)V Code
|
# $ ()V & java/util/ArrayList
|
% # ) + - com/dev/btse/data/TmpSensorState
|
, # 0 2 com/dev/btse/data/TmpSensor_Cmd
|
1 # 5 7 9
|
; = < java/nio/ByteBuffer > ? allocate (I)Ljava/nio/ByteBuffer; A C E G I H java/util/List J K add (Ljava/lang/Object;)Z LineNumberTable LocalVariableTable this *Lcom/dev/btse/data/TmpSensor_SocketThread; i StackMapTable S java/net/Socket U !com/battmonitor/sql/MysqlConnPool initDev_addr
|
X Y ? createSingleBuffer
|
[ \ ]
|
SocketComm +(IILjava/nio/ByteBuffer;Ljava/net/Socket;)Z È
|
a b c sleep (J)V e g f java/lang/System h i out Ljava/io/PrintStream; k java/lang/StringBuilder m è·å设å¤idæå
|
j o p (Ljava/lang/String;)V , r s sensor_dev_id
|
j u v w append (I)Ljava/lang/StringBuilder; y java/util/Date
|
x # | yyyy-MM-dd HH:mm:ss
|
~ com/battmonitor/base/Com getDateTimeFormat 6(Ljava/util/Date;Ljava/lang/String;)Ljava/lang/String;
|
j v
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
|
j toString ()Ljava/lang/String;
|
java/io/PrintStream p println
|
java/lang/String valueOf (I)Ljava/lang/String;
|
, getSensor_dev_id ()I
|
java/lang/InterruptedException $ printStackTrace e Ljava/lang/InterruptedException; run ¢ TmpSensor_SocketThread start at
|
¤ V $
|
¦ ¨ § com/dev/btse/data/TmpSensor_SQL © ª queryTmpSensorById G(Lcom/battmonitor/sql/MysqlConnPool;I)Lcom/dev/btse/data/TmpSensor_inf;
|
, ¬ ® getReadBuffer ()Ljava/nio/ByteBuffer; è
|
a cnt ´ com/dev/btse/data/TmpSensor_inf
|
Exceptions
|
R · ¸ ¹ setSoTimeout (I)V
|
R » ¼ ½ getInputStream ()Ljava/io/InputStream;
|
R ¿ À Á getOutputStream ()Ljava/io/OutputStream; Ã com/dev/btse/data/Ecb_Aes
|
 #
|
; Æ Ç limit
|
; É Ê Ë get ([B)Ljava/nio/ByteBuffer;
|
Í Î Ï makeCommBuf (IILjava/nio/ByteBuffer;Z)[B
|
Ñ Ó Ò java/io/OutputStream Ô Õ write ([B)V
|
Ñ × Ø $ flush Ú Ü Û java/nio/ByteOrder Ý Þ
|
BIG_ENDIAN Ljava/nio/ByteOrder;
|
; à á â order +(Ljava/nio/ByteOrder;)Ljava/nio/ByteBuffer;
|
; ä å æ clear ()Ljava/nio/Buffer;
|
è ê é java/io/InputStream ë available
|
è í î ï read ([B)I
|
; ñ ò position
|
; ô õ capacity
|
; ÷ ø ù put ([BII)Ljava/nio/ByteBuffer;
|
|
; ý þ æ flip
|
x getTime ()J 1 RES_Index
|
getDataFromCommBuf ([B)Z
|
, $ setDev_commcount
|
, $ setDev_errcommcount java/io/IOException cmd reg_index bf socket res_t in Ljava/io/InputStream; Ljava/io/OutputStream; rx_buf_t [B cipher_tx_t my_aes Lcom/dev/btse/data/Ecb_Aes; d1 Ljava/util/Date; rx_read_time_out rx_len_t d2 comm_tms J
|
cipher_buf plain_buf Ljava/io/IOException;+ java/lang/Throwable
|
;- ø Ë
|
1/ 01 putByteBuffer (Ljava/nio/ByteBuffer;)Z
|
,/
|
4 5 (Ljava/lang/Object;)V
|
¦7 89 insertOrUpdateTmpSensorState H(Lcom/battmonitor/sql/MysqlConnPool;Lcom/dev/btse/data/TmpSensorState;)V
|
;; <= getShort ()S
|
?A@ com/battmonitor/base/ComBase BC changeShortToInt (S)I
|
,E F ¹ createTmpDevid eH I i err
|
K ¹ bytes isSuccess addr_id
|
PRQ "com/dev/btse/data/TmpSensor_ComBuf ST makeTmpSensorCommBuf 0(IIILjava/nio/ByteBuffer;Z)Ljava/nio/ByteBuffer; aes_en bbf byte_rest
|
?Y Z[ changeIntToShort (I)S
|
;] ^_ putShort (S)Ljava/nio/ByteBuffer; regcount tmp main ([Ljava/lang/String;)Ve 127.0.0.1
|
Tg h (Ljava/lang/String;II)Vj 118.89.139.230
|
Rl m (Ljava/lang/String;I)V
|
o
|
q r $ start
|
t u java/net/UnknownHostException
|
args [Ljava/lang/String; thread Ljava/net/UnknownHostException;
|
SourceFile TmpSensor_SocketThread.java !
|
! þ h*· "*» %Y· 'µ (*µ **» ,Y· .µ /*» 1Y· 3µ 4*µ 6*µ 8*ܸ :µ @*+µ B*,µ D>§ *´ (» ,Y· .¹ F W ¡ÿé± L : # * / 4 ! > $ C % H & M ' ^ & g ) M * h N O h h J P Q ÿ M R T V $ ! <§ x*´ * "**¶ W*´ B¶ ZW ^¸ `*µ 8§ 1² d» jYl· n*´ /´ q¶ t» xY· z{¸ }¶ ¶ ¶ § 1² d» jY¸ · n*´ /¶ ¶ t¶ ¶ ¡ÿ§ L+¶ ± L 6 - . / 1 # 2 ( 4 + 5 V 6 Y 8 w - : ; = M N O } P Q ü %- ÿ $ ! o² d» jY¡· n» xY· z{¸ }¶ ¶ ¶ *¶ £*´ D*´ /¶ ¸ ¥L=§ - p **´ /¶ «*´ B¶ ZW ¯¸ ±§ N-¶ *´ 6 +Çÿα 9 [ ^ L 6 A ! C % E 4 G 6 H 9 J @ L R N U O [ P _ Q c H n T M * o N O 4 ; 6 9 ² _ Q ý 9 ³K
|
\ ] µ ! é6 ¸¶ ¶*´ 6¶ º:¶ ¾: ¼:: » ÂY· Ä:
|
-¶ ż: - ¶ ÈW§ * -¶ Ì: » xY· z: 6 ¶ ж Ö*´ @² Ù¶ ßW*´ @¶ ãW¶ ç 56 ¶ ì6 *´ @¶ ð `*´ @¶ ód¢ :*´ @ ¶ öW§ * *´ @¶ ð¡
|
¤ 6§ ܤ § ú¸ `§ÿ*´ @¶ üW» xY· z: ¶ ÿ ¶ ÿe7 ^ ^e¸ `*´ @¶ ż:*´ @¶ ż:*´ @¶ ÈW *´ @¶ Ť *µ 86§ *´ 4 µ¾¡ *· *´ /¶
|
*µ 86§ Y6*´ /¶ *Y´ 8`µ 8§ B*µ 6*´ /¶ § 3:*´ /¶ *µ 6*´ 8¡ **µ 6§ ":*´ 8¡ *µ 6¿*´ 8¡ *µ 6¬ ¦© ·Ç L G a c d e f h ' x * y 3 z : { B | I } L ~ V _ b
i n y « ¸ » ¾ Ñ Ô × ß â è ë ó ¢ ü £ ¤ ¥ ²& ³1 ´; ¶B ·M ¸R ¹U ¿X À` Áq Âx Ã} Ä Å Æ Ç È Ì Í Î¦ Ы Ò² Ó· Ö¿ ×Ç ÔÉ ÖÑ ×Ö ÙÙ Öá ×æ Ú M À é N O é é é é æ ~ w h 'p *m 3d
|
_8 b5! #" ü # $% & q& 1 f' « ( Q ÿ L ; R è Ñ)) Â ý * x9
|
ý / xý <))*ÿ ; R N]*ÿ ; R * ÿ ; R ! - =+¾¸ :N-² Ù¶ ßW-+¶,W-¶ üW*´ 4-¶. X*´ 4´ (*´ /-¶2 L² d*´ /¶3=*´ D*´ /¸6§ 2*´ 4´ &*µ *-¶:¸>6*´ /¶D§ ²GW¶J ¬ L J Þ ß à á â ã & å 0 ç ; è E é G ê R ì a î f ï o ð x ò { ó õ M 4 N O L M ~ o N Q ý U ;% Î Ï ! -¸O:¶ ż:¶ ÈW° L þ ÿ M H N O U V W Y ? ! k ¸ :M,² Ù¶ ßW,¸X¶\W,¶ üW,° L
|
M N O ` a bc ! Ú =» TYd d·fM» RYi"×·kL» Y+,·nN-¶p§ M,¶s§ M,¶v± , /t , 7 L & ( , 0 7 8 < M > =wx ( y O 0 z 8 ( Q otG { |
|
