bookkeeper-distributedlog-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From si...@apache.org
Subject [01/20] incubator-distributedlog git commit: DL-101: Improve session expire handling on fetching log segments for readers
Date Wed, 28 Dec 2016 01:05:09 GMT
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();


Mime
View raw message