msb-public
/
hippo4j
mirror of https://github.com/longtai-cn/hippo4j
1
0
Code Issues Projects Releases Wiki Activity

fix all OperatorWrap style error. The OperatorWrap style mandates that operator symbols should begin each new line, hence the need for adjusting the formatting.

Browse Source
pull/1224/head
DDDreame 2 years ago
parent d61260419d
commit 3e2aecf1aa
12 changed files with 50 additions and 50 deletions
Show Stats Download Patch File Download Diff File

4
hippo4j-adapter/hippo4j-adapter-kafka/src/main/java/cn/hippo4j/adapter/kafka/KafkaThreadPoolAdapter.java
Unescape View File

@ -151,8 +151,8 @@ public class KafkaThreadPoolAdapter implements ThreadPoolAdapter, ApplicationLis
ContainerProperties containerProperties = concurrentContainer.getContainerProperties();
TopicPartitionOffset[] topicPartitions = containerProperties.getTopicPartitions();
if (topicPartitions != null && concurrency > topicPartitions.length) {
log.warn("[{}] Kafka consuming thread pool not support modify. " +
"When specific partitions are provided, the concurrency must be less than or "
log.warn("[{}] Kafka consuming thread pool not support modify. "
+ "When specific partitions are provided, the concurrency must be less than or "
+ "equal to the number of partitions;", threadPoolKey);
return false;
}

1
hippo4j-agent/hippo4j-agent-core/src/main/java/cn/hippo4j/agent/core/conf/Config.java
Unescape View File

@ -370,6 +370,7 @@ public class Config {
}
public static class Apollo {
public static class App {
public static String ID;

6
hippo4j-agent/hippo4j-agent-core/src/main/java/cn/hippo4j/agent/core/conf/dynamic/AgentConfigChangeWatcher.java
Unescape View File

@ -44,9 +44,9 @@ public abstract class AgentConfigChangeWatcher {
@Override
public String toString() {
return "AgentConfigChangeWatcher{" +
"propertyKey='" + propertyKey + '\'' +
'}';
return "AgentConfigChangeWatcher{"
+ "propertyKey='" + propertyKey + '\''
+ '}';
}
@Getter

4
hippo4j-agent/hippo4j-agent-core/src/main/java/cn/hippo4j/agent/core/util/ReflectUtil.java
Unescape View File

@ -33,8 +33,8 @@ public class ReflectUtil {
Field[] fields = clazz.getFields();
List<Field> result = new ArrayList<>();
for (Field field : fields) {
if (field.getType().isAssignableFrom(declaredType) &&
Modifier.isStatic(field.getModifiers())) {
if (field.getType().isAssignableFrom(declaredType)
&& Modifier.isStatic(field.getModifiers())) {
result.add(field);
}
}

1
hippo4j-agent/hippo4j-agent-plugin/spring-plugins/spring-boot-1.x-plugin/src/main/java/cn/hippo4j/agent/plugin/spring/boot/v1/ApolloSpringBootProperties.java
Unescape View File

@ -24,7 +24,6 @@ import java.util.List;
public class ApolloSpringBootProperties {
public static class Spring {
public static class Dynamic {

6
hippo4j-common/src/main/java/cn/hippo4j/common/extension/config/ExtensionRegisterBootstrap.java
Unescape View File

@ -50,8 +50,8 @@ public class ExtensionRegisterBootstrap implements ApplicationContextAware, Appl
}
private boolean filterClass(String beanName, Object bean) {
return bean.getClass().isAssignableFrom(IExtension.class) ||
ScopedProxyUtils.isScopedTarget(beanName) ||
!(bean instanceof IExtension);
return bean.getClass().isAssignableFrom(IExtension.class)
|| ScopedProxyUtils.isScopedTarget(beanName)
|| !(bean instanceof IExtension);
}
}

20
hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/IdUtil.java
Unescape View File

@ -74,17 +74,17 @@ public class IdUtil {
long mostSigBits = uuid.getMostSignificantBits();
long leastSigBits = uuid.getLeastSignificantBits();
if (isSimple) {
return (digits(mostSigBits >> 32, 8) +
digits(mostSigBits >> 16, 4) +
digits(mostSigBits, 4) +
digits(leastSigBits >> 48, 4) +
digits(leastSigBits, 12));
return (digits(mostSigBits >> 32, 8)
+ digits(mostSigBits >> 16, 4)
+ digits(mostSigBits, 4)
+ digits(leastSigBits >> 48, 4)
+ digits(leastSigBits, 12));
} else {
return (digits(mostSigBits >> 32, 8) + "-" +
digits(mostSigBits >> 16, 4) + "-" +
digits(mostSigBits, 4) + "-" +
digits(leastSigBits >> 48, 4) + "-" +
digits(leastSigBits, 12));
return (digits(mostSigBits >> 32, 8) + "-"
+ digits(mostSigBits >> 16, 4) + "-"
+ digits(mostSigBits, 4) + "-"
+ digits(leastSigBits >> 48, 4) + "-"
+ digits(leastSigBits, 12));
}
}

4
hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/ReflectUtil.java
Unescape View File

@ -299,8 +299,8 @@ public class ReflectUtil {
public static Field findField(Object obj, String filedName, String fieldType) {
Field[] fields = ReflectUtil.getFields(obj.getClass());
for (Field field : fields) {
if (field.getName().contains(filedName) &&
(field.getType().getName().contains(fieldType))) {
if (field.getName().contains(filedName)
&& (field.getType().getName().contains(fieldType))) {
return field;
}
}

8
hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/AbstractDynamicExecutorSupport.java
Unescape View File

@ -161,14 +161,14 @@ public abstract class AbstractDynamicExecutorSupport extends ThreadPoolExecutor
try {
if (!executor.awaitTermination(this.awaitTerminationMillis, TimeUnit.MILLISECONDS)) {
if (log.isWarnEnabled()) {
log.warn("Timed out while waiting for executor" +
(this.threadPoolId != null ? " '" + this.threadPoolId + "'" : "") + " to terminate.");
log.warn("Timed out while waiting for executor"
+ (this.threadPoolId != null ? " '" + this.threadPoolId + "'" : "") + " to terminate.");
}
}
} catch (InterruptedException ex) {
if (log.isWarnEnabled()) {
log.warn("Interrupted while waiting for executor" +
(this.threadPoolId != null ? " '" + this.threadPoolId + "'" : "") + " to terminate.");
log.warn("Interrupted while waiting for executor"
+ (this.threadPoolId != null ? " '" + this.threadPoolId + "'" : "") + " to terminate.");
}
Thread.currentThread().interrupt();
}

12
hippo4j-core/src/main/java/cn/hippo4j/core/handler/DynamicThreadPoolBannerHandler.java
Unescape View File

@ -58,12 +58,12 @@ public class DynamicThreadPoolBannerHandler implements InitializingBean {
* Print banner.
*/
private void printBanner() {
String banner = " __ __ ___ ___ __ \n" +
" | |--.|__|.-----..-----..-----.| | | |__|\n" +
" | || || _ || _ || _ || | | | |\n" +
" |__|__||__|| __|| __||_____||____ | | |\n" +
" |__| |__| |: ||___|\n" +
" `---' \n";
String banner = " __ __ ___ ___ __ \n"
+ " | |--.|__|.-----..-----..-----.| | | |__|\n"
+ " | || || _ || _ || _ || | | | |\n"
+ " |__|__||__|| __|| __||_____||____ | | |\n"
+ " |__| |__| |: ||___|\n"
+ " `---' \n";
if (Boolean.TRUE.equals(properties.getBanner())) {
String bannerVersion = StringUtil.isNotEmpty(version) ? " (v" + version + ")" : "no version.";
StringBuilder padding = new StringBuilder();

6
hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/HandlerManager.java
Unescape View File

@ -66,9 +66,9 @@ public interface HandlerManager<T> {
boolean b = cls.isAnnotationPresent(ChannelHandler.Sharable.class)
|| HandlerManager.class.isAssignableFrom(cls);
if (!b) {
throw new IllegalException("Join the execution of the handler must add io.netty.channel.ChannelHandler." +
"Sharable annotations, Please for the handler class " + cls.getName() + " add io.netty.channel." +
"ChannelHandler.Sharable annotation");
throw new IllegalException("Join the execution of the handler must add io.netty.channel.ChannelHandler."
+ "Sharable annotations, Please for the handler class " + cls.getName() + " add io.netty.channel."
+ "ChannelHandler.Sharable annotation");
}
return new HandlerEntity<>(order, handler, name);
}

28
hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/mapper/HisRunDataMapper.java
Unescape View File

@ -39,13 +39,13 @@ public interface HisRunDataMapper extends BaseMapper<HisRunDataInfo> {
* @param endTime
* @return
*/
@Select("SELECT " +
"tenant_id, item_id, tp_id, max(completed_task_count) as max_completed_task_count " +
"FROM his_run_data " +
"where timestamp between #{startTime} and #{endTime} " +
"group by tenant_id, item_id, tp_id " +
"order by max_completed_task_count desc " +
"limit 8")
@Select("SELECT "
+ "tenant_id, item_id, tp_id, max(completed_task_count) as max_completed_task_count "
+ "FROM his_run_data "
+ "where timestamp between #{startTime} and #{endTime} "
+ "group by tenant_id, item_id, tp_id "
+ "order by max_completed_task_count desc "
+ "limit 8")
List<ThreadPoolTaskRanking> queryThreadPoolTaskSumRanking(@Param("startTime") Long startTime, @Param("endTime") Long endTime);
/**
@ -55,13 +55,13 @@ public interface HisRunDataMapper extends BaseMapper<HisRunDataInfo> {
* @param endTime
* @return
*/
@Select("SELECT " +
"tenant_id, item_id, tp_id, max(queue_size) as max_queue_size, max(reject_count) as max_reject_count, max(completed_task_count) as max_completed_task_count " +
"FROM his_run_data " +
"where timestamp between #{startTime} and #{endTime} " +
"group by tenant_id, item_id, tp_id " +
"order by max_completed_task_count desc " +
"limit 4")
@Select("SELECT "
+ "tenant_id, item_id, tp_id, max(queue_size) as max_queue_size, max(reject_count) as max_reject_count, max(completed_task_count) as max_completed_task_count "
+ "FROM his_run_data "
+ "where timestamp between #{startTime} and #{endTime} "
+ "group by tenant_id, item_id, tp_id "
+ "order by max_completed_task_count desc "
+ "limit 4")
List<ThreadPoolTaskRanking> queryThreadPoolMaxRanking(@Param("startTime") Long startTime, @Param("endTime") Long endTime);
@Data

Write Preview
Loading…
Cancel
Save