uber / cherami-server

68%

master: 67%

LAST BUILD ON BRANCH v1.23.0-rc0-replicator_hotfix

branch: v1.23.0-rc0-replicator_hotfix

CHANGE BRANCH

x

Reset

• v1.23.0-rc0-replicator_hotfix
• master
• rocksdb
• remove_unused
• upstream_patches
• lockmgr-fix
• update_thrift
• config-cli
• config
• listen
• fixes
• fix
• receiveMsgBatch
• fix_shutdown
• govet_audit
• fix_test
• configExtent
• write_to_cache
• glideUp
• fix_rocksdb_embed
• msgcache-timer-fix
• output_leak_fixes
• latency
• service_start_wait
• docker
• dlq-extent
• replicator_fix
• replicator_hotfix
• schema
• replicator_counter
• fix_cassandra_config
• replicator_busy_loop
• output_msg_cache_cfg
• v0.1.0
• dev
• alert
• metricsTesting
• gocql-tweaks
• smartRetryAutoDisable
• multi_zone_dest_check
• admin
• md-mgr
• fix-retmgr-empty-extents
• output_misc_perf
• reminder
• consist
• fix-retmgr-empty-sealed-extents
• get-latest
• retmgr-non-primary-controller
• input_misc_perf
• testFix
• api-migration
• srLRU
• seal-extents
• docker_fix
• replicator_fix_1
• mock
• queueDepth
• v0.2.0
• seal-seq
• fixQueueDepthInfo
• queueDepthInfo
• input_size_seal
• report-atleast-once
• output_admin
• replicator_reconcile_issue
• replicator_fix_deadlock
• metric
• replicator_reconcile_fix_1
• replicator_reconcilation_fix
• v0.2.0-rc1
• update
• metadata_listrequest_ValidateAgainstPathTable
• coverage
• timeout
• admin-command-store-list-extents
• update_cg
• update_rocksdb
• untagged-f5472780099c97841c0d
• rocksdb-5.0.2-trusty
• use_prebuilt_rocksdb
• tightenAckAggregate
• refactor-replica-stats-reporting
• storehost-notify-optimize
• storetest
• v1.16.0-rc1
• replication_alerts
• fix-cfg
• correct-startfrom-units
• input_admin
• bytes_counter
• tags
• fix-enqueue-timestamp-type
• fix-queue-depth-replica-stats
• multi_zone_cg
• v1.16.1-rc1
• update_client
• v1.17.0-rc1
• untagged
• misc-scripts
• demo-deploy-scripts
• kafkaSchema
• test-kafka-travis
• fix-elk
• more-log-fix
• fix-logs
• fix-replicate-extent-test
• reenable-replicate-extent-test
• output-fix
• multi_zone_cg_extent
• v1.16.0-output-hotfix
• graceful_drain_input
• kafkaCLI
• configmgr
• metrics-input-bytes
• remove-printf
• metrics-output-bytes
• kafkaStream
• client_side_drain
• startfrom-test-fix
• drain
• deadlk_ext
• kafkaAcks
• v1.18.0-rc1
• controller_drain
• fix_integration_test
• govet
• fix_drain
• release-v1.8.0-rc3
• v1.8.0-rc3
• release-v1.18.0-rc3
• bug
• nodestatus
• kafkaClustersConfig
• multi_zong_dlq
• fmt
• autoLocker
• kfcIntegrate
• fix_lock
• active_zone_switch
• getinputhosts
• selectNextExtentsToConsume
• kafka-liveness-ut2
• upgrade_support
• getoutputhosts
• kfc-getoutputhosts
• input_upgrade
• fix_controller
• kfc-extentmon
• minus_kafka
• fast_drain
• fix-frontend-startfrom
• store_upgrade
• fix-TestGetOutputHostsKafka-panic
• storestatus
• fix-test-panic
• phantom-extent
• testbuild
• auth
• lintay
• fix-getoutputhosts
• retention-kafka
• v1.19.0-rc1
• parallelize_tests
• kfcOutMetric
• fix-race-storehost-test
• failovermgr_metrics
• lint
• integtest
• enable-timer-test-logging
• bugs
• cdb
• fix-storehost-elk-logging
• disable-flaky-timer-tests
• fix-commonkafkaconfig-race
• test-verbose-logging
• kfc-integration-test
• v1.18.0-rc3-patch
• active_zone_update
• disable-TestStartFromWithCassandra
• disable-TestQueueDepth
• read-level-resume
• inputEmpty
• outputStuck
• output-fix-tail-loss
• security4
• fix-offsets-bug
• inputEmptyMinimal
• replica-rollover-metric
• log
• v1.20.0-rc0
• glide
• inputDConfig
• fix_race
• fix-delete-destination-kafka-cluster
• real_integration_fix
• v1.20.0-rc1-hotfix0
• kafkaRead
• createdst_urn
• reduce_sizes
• refactor
• benchmark
• fix-fmt
• security7
• security8
• security9
• revert-maxprocessingtime-change
• revert_processing_time
• v1.21.0-rc2
• mz_upgrade
• security10
• security11
• security12
• mz_fix
• rp_fix
• cli_fix
• g
• security15
• delay-metadata
• go-1.8
• delay-and-skipolder
• DLQConsumedMerge
• DLQConsumedMergeHotPatch
• security17
• outputhost-delay-and-skipolder
• release20170626
• v1.22.0-rc2
• v1.22.0-rc1
• validate_input
• fix-cli
• cli-fix
• cli-showcg
• replicator_fd_leak
• storehost-started
• update_checkauth
• cassandra-read-consistency-increase
• replicator_monitoring
• fix-cli-defaults
• v1.22.0-rc2-hotfix1
• cassandra-auth
• fix_tchannal
• r_race
• cli_helper
• syncset
• replicator_host_updater
• r_b
• metadata-client-logs
• disable_read_perm
• metadata-client-module-tag
• throttler
• publatency-threshold
• release-v1.23.0-rc0
• v1.23.0-rc0
• consistency-level-configurable
• fix_FD
• really_fix_FD
• try_FD_leak_again
• flack_test
• r_f
• purge-latency-log
• repl-conn-leak
• cut_release
• v1.24.0-rc0
• port
• throttle
• seal-check-dlq
• rr_f
• smart_retry
• remove_s3
• rp
• distance
• store_counter
• revert
• queue_depth_tabulation
• Update_cherami-client_to_v2.4.0
• v1.25.0-rc0
• store-kafka-dlq
• v1.25.0-rc3-hotfix1
• log-metadata-read-failure
• extent-down-metadata-read-failure
• controller-log-metadata-errors
• r_r
• consumer-group-deletion
• r_bug
• controller_bug
• slow_down
• dlq-zero-uuid
• fix-cli-help
• mingmin/fix-lint
• go1.9
• cg-cleanup
• check-dlq-zero-uuid
• misc-fix
• fix_lint
• v1.26.0
• mingmin/expose-kafkaAddresser
• mingmin/expose-GetDefaultKafkaMessageConverter
• test-v1.26.0
• v1.26.0-rc0
• cg-dest-uuid
• consistency
• v1.26.0-rc1
• cmq
• metametrics-log
• v1.27.0-rc0
• dlq-cleanup
• v1.27.0-rc1
• fix-cnsmid-tag
• ackmgr-stop-ticker
• storehost-replication
• storehost-readonly
• retry
• storehost-readonly-notify
• storehost-readonly-space-threshold
• kafka2
• v1.27.1
• storehost-logs
• spaceMon
• metametrics
• cleanup-dlq-dest
• revert_a
• output
• v1.28.0
• logs
• cache
• v1.28.1
• minor_tuning
• fix-retmgr-logs
• kfc-extents-increase
• cmq-num-delay
• cmq-repair
• unload-all-cg
• cmq-gc
• cmq-delete-cql-consistency-all
• cherami_EOL

Build # 2542

Build Type

push

travis-ci

Committed by datoug

Commit Message

Refactor the replication connections (#280)

* Replictor: refactor the stream closure mechenism

* update

* refactor replicator connections

* outConn close msg channel in read pump so that inConn can be notified and close the write pump

* address comments

* revert change on glide.lock

Run Details

89 of 89 new or added lines in 3 files covered. (100.0%)

21600 of 31600 relevant lines covered (68.35%)

6582.53 hits per line