Commit Graph

47 Commits

Author SHA1 Message Date
Chuanyi Li
b5a1898cec Prometheus refactor. 2018-08-07 08:18:01 +08:00
Chuanyi Li L
680faea2bb Add listener to write. 2018-08-06 17:22:28 +08:00
Chuanyi Li L
d01195ac82 Merge branch 'master' into metrics_support 2018-08-06 15:26:44 +08:00
Chuanyi Li
8b186d1330 canal server metrics refactor. 2018-08-06 08:12:59 +08:00
qmzhang
3c716e2a43 instance由manager管理时,CanalParameter#MetaMode增加本地文件方式,本地meta.dat存储位点信息; 2018-08-05 19:40:14 +08:00
Chuanyi Li L
b7431eb7d0 Reformat code. 2018-08-03 17:42:57 +08:00
Chuanyi Li L
c7fc149e7e Netty server/client profiler skeleton. 2018-08-03 17:32:48 +08:00
Chuanyi Li L
368554166c Builder of Aggregator. 2018-08-02 17:36:22 +08:00
Chuanyi Li
ae0f43d1c7 netty3 future listener for metrics. 2018-08-01 08:17:55 +08:00
Chuanyi Li
c0a40499b0 Canal monitoring(prometheus module) snapshot version. 2018-07-29 14:55:38 +08:00
七锋
b19eaeb89a fixed issue #726 , 单链接复用ByteBuffer数组 2018-07-19 17:55:53 +08:00
七锋
5582a38930 fixed issue #726, 优化SessionHandler里直接拼byte[],绕过protobuf的多次拷贝 2018-07-19 13:35:38 +08:00
七锋
10bb800f85 fixed issue #726 , 优化SessionHandler的传输处理,提前序列化Entry 2018-07-18 18:21:45 +08:00
七锋
a4255a6377 fixed format 2018-06-14 19:25:34 +08:00
七锋
fa34eb0e59 fixed client idleTimeout 1 hour 2018-06-12 13:20:41 +08:00
Chuanyi Li
00890f87e5 Communication log optimization. 2018-01-18 21:11:46 +08:00
agapple
20942533e6 [maven-release-plugin] prepare for next development iteration 2017-12-04 14:43:29 +08:00
agapple
6b2d80a145 [maven-release-plugin] prepare release canal-1.0.25 2017-12-04 14:43:16 +08:00
kaimingwan
e8da1c884b table meta support 2017-09-22 22:01:57 +08:00
agapple
989a69e7be fixed format & import 2017-07-05 12:41:11 +08:00
Jason Huang
8600e9825b fix bug:
现实运用中出现:client已经不存在但server端的连接仍然是存活状态。
在此种网络异常状态时,stop canal server会一直hang住。
原因:异常网络连接由于无数据传输,导致 io worker线程一直loop selector而无法退出。

解决方案:1. 设置keepalive 由os 监控。
        2. 设置netty idle 机制,定时检测并主动close socket。(fix 时间单位bug)
        3. 每次新创建socket channel时存储在一个容器内,在stop canal
server时,从容器内主动释放所有socket channel。
2017-06-26 19:24:15 +08:00
agapple
4d624cf184 [maven-release-plugin] prepare for next development iteration 2017-04-01 21:18:31 +08:00
agapple
7e026f2495 [maven-release-plugin] prepare release canal-1.0.24 2017-04-01 21:18:11 +08:00
agapple
ff97dcbbc9 format & import 2017-01-19 13:07:53 +08:00
agapple
f745c698e9 [maven-release-plugin] prepare for next development iteration 2016-12-30 14:57:19 +08:00
agapple
5f4bbab722 [maven-release-plugin] prepare release canal-1.0.23 2016-12-30 14:57:07 +08:00
agapple
6284a429a0 fixed lazy 2016-10-11 21:37:39 +08:00
lubiao
8626c6ee24 1、SessionHandler类中执行SUBSCRIPTION时,应该先尝试启动runningMonitor再调用embeddedServer的subscribe方法
2、embeddedServer的subscribe方法中应该首先进行checkStart操作,否则可能引起metaManager的脏启动
3、SessionHandler中增加日志
2016-10-11 18:46:30 +08:00
agapple
3a5a4b06a9 [maven-release-plugin] prepare for next development iteration 2016-06-30 16:59:17 +08:00
agapple
ba173fcd48 [maven-release-plugin] prepare release canal-1.0.22 2016-06-30 16:59:05 +08:00
agapple
4f504aab31 fixed testcase compiler error 2016-02-24 17:05:14 +08:00
agapple
bf10b16138 migrate 2016-02-04 11:22:36 +08:00
agapple
37478f3409 Merge pull request #138 from MarkLinHz/master
make canal server become a single instance
2016-02-04 11:02:23 +08:00
yinxiu
7b29828f60 add AbstractCanalInstance and remove duplicate code 2016-01-08 20:32:08 +08:00
yinxiu
9164fe4ca7 make canal server become a single instance 2016-01-07 17:23:58 +08:00
agapple
643bd5cb71 [maven-release-plugin] prepare for next development iteration 2015-12-30 16:23:30 +08:00
agapple
8375ea4b7d [maven-release-plugin] prepare release canal-1.0.21 2015-12-30 16:23:20 +08:00
agapple
9956b3557f [maven-release-plugin] prepare for next development iteration 2015-06-30 10:23:54 +08:00
agapple
452fae15fc [maven-release-plugin] prepare release canal-1.0.20 2015-06-30 10:23:45 +08:00
agapple
7ebb3fd1ab fixed code template and format 2015-04-28 21:11:41 +08:00
wener
596b060649 cleanup code, extract CanalService 2015-04-27 14:57:01 +08:00
wener
6a0733bbab update guava to 18.0, magriate compute map by package level implement 2015-04-23 22:15:57 +08:00
wener
bdf3b0c861 typo, javadoc,code cleanup 2015-04-23 17:25:36 +08:00
wener
d01e82ce3c fix typo embeded -> embedded 2015-04-23 16:23:34 +08:00
agapple
4ba814da26 [maven-release-plugin] prepare for next development iteration 2014-09-23 16:10:57 +08:00
agapple
a743235eae [maven-release-plugin] prepare release canal-1.0.19 2014-09-23 16:10:43 +08:00
agapple
a0defe575b init 2014-09-23 15:11:35 +08:00