home/pinpoint
2
0
Fork 0
mirror of https://github.com/wahyd4/pinpoint.git synced 2026-08-16 08:16:15 +10:00
Code Issues Packages Projects Releases Wiki Activity

#5 Pinpoint 클러스터 개발

Browse Source 
1. 개발 리얼 설정 
2. CommandDispatcher 수정
This commit is contained in:
koo-taejin
2014-10-23 10:18:02 +09:00
parent b20c26935f
commit ac14197256
5 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
collector/src/main/resources-dev/pinpoint-collector.properties
+3 -3
View File
@@ -43,6 +43,6 @@ collector.udpSpanSocketReceiveBufferSize=4194304
# 통계값 flush 주기
statistics.flushPeriod=1000
cluster.enable=false
cluster.zookeeper.address=
cluster.zookeeper.sessiontimeout=
cluster.enable=true
cluster.zookeeper.address=dev.zk.pinpoint.navercorp.com
cluster.zookeeper.sessiontimeout=3000
collector/src/main/resources-release/pinpoint-collector.properties
+3 -3
View File
@@ -43,6 +43,6 @@ collector.udpSpanSocketReceiveBufferSize=4194304
# 통계값 flush 주기
statistics.flushPeriod=1000
cluster.enable=false
cluster.zookeeper.address=
cluster.zookeeper.sessiontimeout=
cluster.enable=true
cluster.zookeeper.address=zk.pinpoint.nhncorp.com
cluster.zookeeper.sessiontimeout=3000
profiler/src/main/java/com/navercorp/pinpoint/profiler/receiver/CommandDispatcher.java
+4 -2
View File
@@ -26,6 +26,7 @@ import com.nhn.pinpoint.thrift.io.SerializerFactory;
import com.nhn.pinpoint.thrift.io.TBaseLocator;
import com.nhn.pinpoint.thrift.io.TCommandRegistry;
import com.nhn.pinpoint.thrift.io.TCommandTypeVersion;
import com.nhn.pinpoint.thrift.io.ThreadLocalHeaderTBaseSerializerFactory;
/**
* @author koo.taejin
@@ -43,8 +44,9 @@ public class CommandDispatcher implements MessageListener {
private final TBaseBOLocator locator;
private final SerializerFactory serializerFactory = new HeaderTBaseSerializerFactory(true, HeaderTBaseSerializerFactory.DEFAULT_UDP_STREAM_MAX_SIZE, DEFAULT_PROTOCOL_FACTORY, commandTbaseLocator);
private final HeaderTBaseDeserializerFactory deserializerFactory = new HeaderTBaseDeserializerFactory(DEFAULT_PROTOCOL_FACTORY, commandTbaseLocator);
private final SerializerFactory serializerFactory = new ThreadLocalHeaderTBaseSerializerFactory(new HeaderTBaseSerializerFactory(true, HeaderTBaseSerializerFactory.DEFAULT_UDP_STREAM_MAX_SIZE, DEFAULT_PROTOCOL_FACTORY, commandTbaseLocator));
private final HeaderTBaseDeserializerFactory deserializerFactory = new HeaderTBaseDeserializerFactory(DEFAULT_PROTOCOL_FACTORY, commandTbaseLocator);
public CommandDispatcher() {
TBaseBORegistry registry = new TBaseBORegistry();
web/src/main/resources-dev/pinpoint-web.properties
+1 -1
View File
@@ -1,5 +1,5 @@
# dev
cluster.enable=false
cluster.enable=true
cluster.web.tcp.port=9995
cluster.zookeeper.address=dev.zk.pinpoint.navercorp.com
cluster.zookeeper.sessiontimeout=3000
web/src/main/resources-release/pinpoint-web.properties
+1 -1
View File
@@ -1,5 +1,5 @@
# release
cluster.enable=false
cluster.enable=true
cluster.web.tcp.port=9995
cluster.zookeeper.address=zk.pinpoint.nhncorp.com
cluster.zookeeper.sessiontimeout=3000