Skip to content

Commit

Permalink
[ISSUE #436] Fix typo errors for runtime package (#441)
Browse files Browse the repository at this point in the history
* fix typo

* fix typo
  • Loading branch information
liutaohua authored Jul 16, 2021
1 parent 8bcdc2e commit ae25d2e
Show file tree
Hide file tree
Showing 6 changed files with 15 additions and 15 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ public class ConfigurationWrapper {

private boolean reload = true;

private ScheduledExecutorService configLoader = ThreadPoolFactory.createSingleScheduledExecutor("eventMesh-configloader-");
private ScheduledExecutorService configLoader = ThreadPoolFactory.createSingleScheduledExecutor("eventMesh-configLoader-");

public ConfigurationWrapper(String file, boolean reload) {
this.file = file;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,7 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public abstract class AbrstractHTTPServer extends AbstractRemotingServer {
public abstract class AbstractHTTPServer extends AbstractRemotingServer {

public Logger httpServerLogger = LoggerFactory.getLogger(this.getClass());

Expand All @@ -106,7 +106,7 @@ public abstract class AbrstractHTTPServer extends AbstractRemotingServer {
protected HashMap<Integer/* request code */, Pair<HttpRequestProcessor, ThreadPoolExecutor>> processorTable =
new HashMap<Integer, Pair<HttpRequestProcessor, ThreadPoolExecutor>>(64);

public AbrstractHTTPServer(int port, boolean useTLS) {
public AbstractHTTPServer(int port, boolean useTLS) {
this.port = port;
this.useTLS = useTLS;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ public Thread newThread(Runnable r) {
return ioGroup;
}

private EventLoopGroup initWokerGroup(String threadPrefix) {
private EventLoopGroup initWorkerGroup(String threadPrefix) {
workerGroup = new NioEventLoopGroup(Runtime.getRuntime().availableProcessors(), new ThreadFactory() {
AtomicInteger count = new AtomicInteger(0);

Expand All @@ -83,7 +83,7 @@ public Thread newThread(Runnable r) {
public void init(String threadPrefix) throws Exception {
initBossGroup(threadPrefix);
initIOGroup(threadPrefix);
initWokerGroup(threadPrefix);
initWorkerGroup(threadPrefix);
}

public void shutdown() throws Exception {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@
import org.apache.eventmesh.runtime.core.protocol.http.retry.HttpRetryer;
import org.apache.eventmesh.runtime.metrics.http.HTTPMetricsServer;

public class EventMeshHTTPServer extends AbrstractHTTPServer {
public class EventMeshHTTPServer extends AbstractHTTPServer {

private EventMeshServer eventMeshServer;

Expand Down Expand Up @@ -102,27 +102,27 @@ public void initThreadPool() throws Exception {

BlockingQueue<Runnable> batchMsgThreadPoolQueue = new LinkedBlockingQueue<Runnable>(eventMeshHttpConfiguration.eventMeshServerBatchBlockQSize);
batchMsgExecutor = ThreadPoolFactory.createThreadPoolExecutor(eventMeshHttpConfiguration.eventMeshServerBatchMsgThreadNum,
eventMeshHttpConfiguration.eventMeshServerBatchMsgThreadNum, batchMsgThreadPoolQueue, "eventMesh-batchmsg-", true);
eventMeshHttpConfiguration.eventMeshServerBatchMsgThreadNum, batchMsgThreadPoolQueue, "eventMesh-batchMsg-", true);

BlockingQueue<Runnable> sendMsgThreadPoolQueue = new LinkedBlockingQueue<Runnable>(eventMeshHttpConfiguration.eventMeshServerSendMsgBlockQSize);
sendMsgExecutor = ThreadPoolFactory.createThreadPoolExecutor(eventMeshHttpConfiguration.eventMeshServerSendMsgThreadNum,
eventMeshHttpConfiguration.eventMeshServerSendMsgThreadNum, sendMsgThreadPoolQueue, "eventMesh-sendmsg-", true);
eventMeshHttpConfiguration.eventMeshServerSendMsgThreadNum, sendMsgThreadPoolQueue, "eventMesh-sendMsg-", true);

BlockingQueue<Runnable> pushMsgThreadPoolQueue = new LinkedBlockingQueue<Runnable>(eventMeshHttpConfiguration.eventMeshServerPushMsgBlockQSize);
pushMsgExecutor = ThreadPoolFactory.createThreadPoolExecutor(eventMeshHttpConfiguration.eventMeshServerPushMsgThreadNum,
eventMeshHttpConfiguration.eventMeshServerPushMsgThreadNum, pushMsgThreadPoolQueue, "eventMesh-pushmsg-", true);
eventMeshHttpConfiguration.eventMeshServerPushMsgThreadNum, pushMsgThreadPoolQueue, "eventMesh-pushMsg-", true);

BlockingQueue<Runnable> clientManageThreadPoolQueue = new LinkedBlockingQueue<Runnable>(eventMeshHttpConfiguration.eventMeshServerClientManageBlockQSize);
clientManageExecutor = ThreadPoolFactory.createThreadPoolExecutor(eventMeshHttpConfiguration.eventMeshServerClientManageThreadNum,
eventMeshHttpConfiguration.eventMeshServerClientManageThreadNum, clientManageThreadPoolQueue, "eventMesh-clientmanage-", true);
eventMeshHttpConfiguration.eventMeshServerClientManageThreadNum, clientManageThreadPoolQueue, "eventMesh-clientManage-", true);

BlockingQueue<Runnable> adminThreadPoolQueue = new LinkedBlockingQueue<Runnable>(50);
adminExecutor = ThreadPoolFactory.createThreadPoolExecutor(eventMeshHttpConfiguration.eventMeshServerAdminThreadNum,
eventMeshHttpConfiguration.eventMeshServerAdminThreadNum, adminThreadPoolQueue, "eventMesh-admin-", true);

BlockingQueue<Runnable> replyMessageThreadPoolQueue = new LinkedBlockingQueue<Runnable>(100);
replyMsgExecutor = ThreadPoolFactory.createThreadPoolExecutor(eventMeshHttpConfiguration.eventMeshServerReplyMsgThreadNum,
eventMeshHttpConfiguration.eventMeshServerReplyMsgThreadNum, replyMessageThreadPoolQueue, "eventMesh-replymsg-", true);
eventMeshHttpConfiguration.eventMeshServerReplyMsgThreadNum, replyMessageThreadPoolQueue, "eventMesh-replyMsg-", true);
}

public ThreadPoolExecutor getBatchMsgExecutor() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,8 +52,8 @@ public void init() throws Exception {
eventMeshTCPServer.init();
}

String eventstore = System.getProperty(EventMeshConstants.EVENT_STORE_PROPERTIES, System.getenv(EventMeshConstants.EVENT_STORE_ENV));
logger.info("eventstore : {}", eventstore);
String eventStore = System.getProperty(EventMeshConstants.EVENT_STORE_PROPERTIES, System.getenv(EventMeshConstants.EVENT_STORE_ENV));
logger.info("eventStore : {}", eventStore);

serviceState = ServiceState.INITED;
logger.info("server state:{}", serviceState);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -60,11 +60,11 @@ public void init() {
60000,
TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(eventMeshHTTPServer.getEventMeshHttpConfiguration().eventMeshServerRetryBlockQSize),
new ThreadFactory() {
private AtomicInteger ai = new AtomicInteger();
private AtomicInteger count = new AtomicInteger();

@Override
public Thread newThread(Runnable r) {
Thread thread = new Thread(r, "http-retry-" + ai.incrementAndGet());
Thread thread = new Thread(r, "http-retry-" + count.incrementAndGet());
thread.setPriority(Thread.NORM_PRIORITY);
thread.setDaemon(true);
return thread;
Expand Down

0 comments on commit ae25d2e

Please sign in to comment.