Repository: incubator-distributedlog Updated Branches: refs/heads/master f9a078330 -> dd8ee62ae
http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/blob/9ee7d016/distributedlog-protocol/src/main/thrift/service.thrift ---------------------------------------------------------------------- diff --git a/distributedlog-protocol/src/main/thrift/service.thrift b/distributedlog-protocol/src/main/thrift/service.thrift index ba0de74..4c0eaf1 100644 --- a/distributedlog-protocol/src/main/thrift/service.thrift +++ b/distributedlog-protocol/src/main/thrift/service.thrift @@ -94,6 +94,8 @@ enum StatusCode { CHECKSUM_FAILED = 523, /* Overcapacity: too many streams */ TOO_MANY_STREAMS = 524, + // Log Segment Not Found + LOG_SEGMENT_NOT_FOUND = 525, /* 6xx: unexpected */ http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/blob/9ee7d016/distributedlog-service/src/main/java/com/twitter/distributedlog/service/MonitorService.java ---------------------------------------------------------------------- diff --git a/distributedlog-service/src/main/java/com/twitter/distributedlog/service/MonitorService.java b/distributedlog-service/src/main/java/com/twitter/distributedlog/service/MonitorService.java index 6b58eff..2c6cccc 100644 --- a/distributedlog-service/src/main/java/com/twitter/distributedlog/service/MonitorService.java +++ b/distributedlog-service/src/main/java/com/twitter/distributedlog/service/MonitorService.java @@ -177,6 +177,11 @@ public class MonitorService implements NamespaceListener { } @Override + public void onLogStreamDeleted() { + logger.info("Stream {} is deleted", name); + } + + @Override public void onSuccess(Void value) { successStat.add(stopwatch.stop().elapsed(TimeUnit.MICROSECONDS)); scheduleCheck();
