first commit

xm

2024-06-14 722af26bc6fec32bb289b1df51a9016a4935610f

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
Êþº¾4à    /]
0^
[_
`a
`bcdefeghihjk
lcmcn
`o
pqrs
pt    uv
pw
px
yz{
^|
}~
€
‚
pƒ
p„c…
`†
‡ˆ‰
[Š‹Œ    Ž
 
Ž
$‘’Œ“”•–
this$0
4Lcom/xxl/job/admin/core/thread/JobFailMonitorHelper;
<init>
7(Lcom/xxl/job/admin/core/thread/JobFailMonitorHelper;)V
Code
LineNumberTable
LocalVariableTable
this
InnerClasses
6Lcom/xxl/job/admin/core/thread/JobFailMonitorHelper$1;
run
()V
retryMsg
Ljava/lang/String;
alarmResult

Z
lockRet

I
log
(Lcom/xxl/job/admin/core/model/XxlJobLog;
info
)Lcom/xxl/job/admin/core/model/XxlJobInfo;
newAlarmStatus
    failLogId

J

failLogIds
Ljava/util/List;

e
Ljava/lang/Exception;
LocalVariableTypeTable
"Ljava/util/List<Ljava/lang/Long;>;
 StackMapTable—˜™š”‰

SourceFile
JobFailMonitorHelper.java
EnclosingMethod›œ=234=žŸ ¡¢£¤¥¦—§¨©ª˜«¨¬­
java/lang/Long®¯°±²³´µ™¶·¸¹º»·¼½¾¿ÀÁÀÂÃÄ
java/lang/StringBuilder
2<br><br><span style="color:#F39C12;" > >>>>>>>>>>>ÅÆ
jobconf_trigger_type_retryÇÈÉ
<<<<<<<<<<< </span><br>ÊÀËÀÌÍÎÏÐÑÒÓÔ
java/lang/ExceptionÕÖ
5>>>>>>>>>>> xxl-job, job fail monitor thread error:{}×ØÙÚÛÜÝÞßÀ
1>>>>>>>>>>> xxl-job, job fail monitor thread stopFÍ
4com/xxl/job/admin/core/thread/JobFailMonitorHelper$1
java/lang/Object
java/lang/Runnable
java/util/List
java/util/Iterator
&com/xxl/job/admin/core/model/XxlJobLog
'com/xxl/job/admin/core/model/XxlJobInfo
2com/xxl/job/admin/core/thread/JobFailMonitorHelper
start

access$000
7(Lcom/xxl/job/admin/core/thread/JobFailMonitorHelper;)Z
-com/xxl/job/admin/core/conf/XxlJobAdminConfig
getAdminConfig
1()Lcom/xxl/job/admin/core/conf/XxlJobAdminConfig;
getXxlJobLogDao
&()Lcom/xxl/job/admin/dao/XxlJobLogDao;
"com/xxl/job/admin/dao/XxlJobLogDao
findFailJobLogIds
(I)Ljava/util/List;
isEmpty
()Z
iterator
()Ljava/util/Iterator;
hasNext
next
()Ljava/lang/Object;
    longValue
()J
updateAlarmStatus
(JII)I
load
+(J)Lcom/xxl/job/admin/core/model/XxlJobLog;
getXxlJobInfoDao
'()Lcom/xxl/job/admin/dao/XxlJobInfoDao;
getJobId
()I
#com/xxl/job/admin/dao/XxlJobInfoDao
loadById
,(I)Lcom/xxl/job/admin/core/model/XxlJobInfo;
getExecutorFailRetryCount
.com/xxl/job/admin/core/trigger/TriggerTypeEnum
RETRY
0Lcom/xxl/job/admin/core/trigger/TriggerTypeEnum;
getExecutorShardingParam
()Ljava/lang/String;
getExecutorParam
2com/xxl/job/admin/core/thread/JobTriggerPoolHelper
trigger
k(ILcom/xxl/job/admin/core/trigger/TriggerTypeEnum;ILjava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
$com/xxl/job/admin/core/util/I18nUtil
    getString
&(Ljava/lang/String;)Ljava/lang/String;
toString
 getTriggerMsg
 setTriggerMsg
(Ljava/lang/String;)V
updateTriggerInfo
+(Lcom/xxl/job/admin/core/model/XxlJobLog;)I
 getJobAlarmer
+()Lcom/xxl/job/admin/core/alarm/JobAlarmer;
'com/xxl/job/admin/core/alarm/JobAlarmer
alarm
T(Lcom/xxl/job/admin/core/model/XxlJobInfo;Lcom/xxl/job/admin/core/model/XxlJobLog;)Z

access$100
()Lorg/slf4j/Logger;
org/slf4j/Logger
error
*(Ljava/lang/String;Ljava/lang/Throwable;)V
java/util/concurrent/TimeUnit
SECONDS
Ljava/util/concurrent/TimeUnit;
sleep
(J)V

getMessage /0
1
2345
6>
*+µ
*·±7
"8
9;
23

<=
6ä

p*´
¸š
^¸¶è¹L+Æ
+¹
š
+¹
M,¹    
™ò,¹

À¶B¸¶!¹ 6¢§ÿÔ¸¶!¹:¸¶¶¹:¶žh¶²¶d¶¶
¸»Y·¶¸¶¶¶:»Y·¶¶¶¶¶ ¸¶¹!W6Æ!¸¶"¶#6        ™§6§6¸¶!¹ W§ÿ§L*´
¸š¸%&+¹'²()¶+§þ¹L*´
¸š¸%+¶,+¹'§þž¸%-¹.±

%
($
>
G
J$7Š"(
+,&-C0S1Y2\4j5|8„9¡:¿;Û<é@ìAñB
C
D
E
H
"I
%P
(L
)M
3N
>S
GX
JT
KU
UV
bX
e\
o^8p¿*>?
@A    SÏBCj¸DE|¦FGì6HCCßIJ
KL

)MN

KMN

p9;O

KP
Q:ý,RSý.
ýŒTUý

@
úÿ
VBWKWXYZ[\:

/