Skip to content

Commit

Permalink
change port interval from 100 to 1000
Browse files Browse the repository at this point in the history
  • Loading branch information
KernelMaker committed Jun 30, 2016
1 parent 4ec72d1 commit 1ac98b0
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions src/pika_server.cc
Original file line number Diff line number Diff line change
Expand Up @@ -60,8 +60,8 @@ PikaServer::PikaServer() :
}

pika_dispatch_thread_ = new PikaDispatchThread(port_, worker_num_, pika_worker_thread_, 3000);
pika_binlog_receiver_thread_ = new PikaBinlogReceiverThread(port_ + 100, 1000);
pika_heartbeat_thread_ = new PikaHeartbeatThread(port_ + 200, 1000);
pika_binlog_receiver_thread_ = new PikaBinlogReceiverThread(port_ + 1000, 1000);
pika_heartbeat_thread_ = new PikaHeartbeatThread(port_ + 2000, 1000);
pika_trysync_thread_ = new PikaTrysyncThread();
monitor_thread_ = new PikaMonitorThread();

Expand Down
2 changes: 1 addition & 1 deletion src/pika_trysync_thread.cc
Original file line number Diff line number Diff line change
Expand Up @@ -208,7 +208,7 @@ void* PikaTrysyncThread::ThreadMain() {
std::string ip_port = slash::IpPortString(master_ip, master_port);
// We append the master ip port after module name
// To make sure only data from current master is received
int ret = slash::StartRsync(dbsync_path, kDBSyncModule + "_" + ip_port, g_pika_conf->port() + 300);
int ret = slash::StartRsync(dbsync_path, kDBSyncModule + "_" + ip_port, g_pika_conf->port() + 3000);
if (0 != ret) {
LOG(WARNING) << "Failed to start rsync, path:" << dbsync_path << " error : " << ret;
}
Expand Down
2 changes: 1 addition & 1 deletion third/pink
Submodule pink updated from a0b3f5 to 577473

0 comments on commit 1ac98b0

Please sign in to comment.