hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSimpleTimeRangeTracker.java

   1 /**
   2  * Licensed to the Apache Software Foundation (ASF) under one
   3  * or more contributor license agreements.  See the NOTICE file
   4  * distributed with this work for additional information
   5  * regarding copyright ownership.  The ASF licenses this file
   6  * to you under the Apache License, Version 2.0 (the
   7  * "License"); you may not use this file except in compliance
   8  * with the License.  You may obtain a copy of the License at
   9  *
  10  *     http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  */
  18 package org.apache.hadoop.hbase.regionserver;
  19
  20 import static org.junit.Assert.assertEquals;
  21 import static org.junit.Assert.assertFalse;
  22 import static org.junit.Assert.assertTrue;
  23
  24 import java.io.DataOutputStream;
  25 import java.io.IOException;
  26 import org.apache.hadoop.hbase.HBaseClassTestRule;
  27 import org.apache.hadoop.hbase.io.ByteArrayOutputStream;
  28 import org.apache.hadoop.hbase.io.TimeRange;
  29 import org.apache.hadoop.hbase.testclassification.RegionServerTests;
  30 import org.apache.hadoop.hbase.testclassification.SmallTests;
  31 import org.junit.ClassRule;
  32 import org.junit.Test;
  33 import org.junit.experimental.categories.Category;
  34
  35 @Category({RegionServerTests.class, SmallTests.class})
  36 public class TestSimpleTimeRangeTracker {
  37
  38   @ClassRule
  39   public static final HBaseClassTestRule CLASS_RULE =
  40       HBaseClassTestRule.forClass(TestSimpleTimeRangeTracker.class);
  41
  42   protected TimeRangeTracker getTimeRangeTracker() {
  43     return TimeRangeTracker.create(TimeRangeTracker.Type.NON_SYNC);
  44   }
  45
  46   protected TimeRangeTracker getTimeRangeTracker(long min, long max) {
  47     return TimeRangeTracker.create(TimeRangeTracker.Type.NON_SYNC, min, max);
  48   }
  49
  50   @Test
  51   public void testExtreme() {
  52     TimeRange tr = TimeRange.allTime();
  53     assertTrue(tr.includesTimeRange(TimeRange.allTime()));
  54     TimeRangeTracker trt = getTimeRangeTracker();
  55     assertFalse(trt.includesTimeRange(TimeRange.allTime()));
  56     trt.includeTimestamp(1);
  57     trt.includeTimestamp(10);
  58     assertTrue(trt.includesTimeRange(TimeRange.allTime()));
  59   }
  60
  61   @Test
  62   public void testTimeRangeInitialized() {
  63     TimeRangeTracker src = getTimeRangeTracker();
  64     TimeRange tr = new TimeRange(System.currentTimeMillis());
  65     assertFalse(src.includesTimeRange(tr));
  66   }
  67
  68   @Test
  69   public void testTimeRangeTrackerNullIsSameAsTimeRangeNull() throws IOException {
  70     TimeRangeTracker src = getTimeRangeTracker(1, 2);
  71     byte[] bytes = TimeRangeTracker.toByteArray(src);
  72     TimeRange tgt = TimeRangeTracker.parseFrom(bytes).toTimeRange();
  73     assertEquals(src.getMin(), tgt.getMin());
  74     assertEquals(src.getMax(), tgt.getMax());
  75   }
  76
  77   @Test
  78   public void testSerialization() throws IOException {
  79     TimeRangeTracker src = getTimeRangeTracker(1, 2);
  80     TimeRangeTracker tgt = TimeRangeTracker.parseFrom(TimeRangeTracker.toByteArray(src));
  81     assertEquals(src.getMin(), tgt.getMin());
  82     assertEquals(src.getMax(), tgt.getMax());
  83   }
  84
  85   @Test
  86   public void testLegacySerialization() throws IOException {
  87     ByteArrayOutputStream data = new ByteArrayOutputStream();
  88     DataOutputStream output = new DataOutputStream(data);
  89     output.writeLong(100);
  90     output.writeLong(200);
  91     TimeRangeTracker tgt = TimeRangeTracker.parseFrom(data.toByteArray());
  92     assertEquals(100, tgt.getMin());
  93     assertEquals(200, tgt.getMax());
  94   }
  95
  96   @Test
  97   public void testAlwaysDecrementingSetsMaximum() {
  98     TimeRangeTracker trr = getTimeRangeTracker();
  99     trr.includeTimestamp(3);
 100     trr.includeTimestamp(2);
 101     trr.includeTimestamp(1);
 102     assertTrue(trr.getMin() != TimeRangeTracker.INITIAL_MIN_TIMESTAMP);
 103     assertTrue(trr.getMax() != -1 /*The initial max value*/);
 104   }
 105
 106   @Test
 107   public void testSimpleInRange() {
 108     TimeRangeTracker trr = getTimeRangeTracker();
 109     trr.includeTimestamp(0);
 110     trr.includeTimestamp(2);
 111     assertTrue(trr.includesTimeRange(new TimeRange(1)));
 112   }
 113
 114   @Test
 115   public void testRangeConstruction() throws IOException {
 116     TimeRange defaultRange = TimeRange.allTime();
 117     assertEquals(0L, defaultRange.getMin());
 118     assertEquals(Long.MAX_VALUE, defaultRange.getMax());
 119     assertTrue(defaultRange.isAllTime());
 120
 121     TimeRange oneArgRange = new TimeRange(0L);
 122     assertEquals(0L, oneArgRange.getMin());
 123     assertEquals(Long.MAX_VALUE, oneArgRange.getMax());
 124     assertTrue(oneArgRange.isAllTime());
 125
 126     TimeRange oneArgRange2 = new TimeRange(1);
 127     assertEquals(1, oneArgRange2.getMin());
 128     assertEquals(Long.MAX_VALUE, oneArgRange2.getMax());
 129     assertFalse(oneArgRange2.isAllTime());
 130
 131     TimeRange twoArgRange = new TimeRange(0L, Long.MAX_VALUE);
 132     assertEquals(0L, twoArgRange.getMin());
 133     assertEquals(Long.MAX_VALUE, twoArgRange.getMax());
 134     assertTrue(twoArgRange.isAllTime());
 135
 136     TimeRange twoArgRange2 = new TimeRange(0L, Long.MAX_VALUE - 1);
 137     assertEquals(0L, twoArgRange2.getMin());
 138     assertEquals(Long.MAX_VALUE - 1, twoArgRange2.getMax());
 139     assertFalse(twoArgRange2.isAllTime());
 140
 141     TimeRange twoArgRange3 = new TimeRange(1, Long.MAX_VALUE);
 142     assertEquals(1, twoArgRange3.getMin());
 143     assertEquals(Long.MAX_VALUE, twoArgRange3.getMax());
 144     assertFalse(twoArgRange3.isAllTime());
 145   }
 146
 147 }