Shortcut aggregation id decompression (#49)

m3db · Jun 12, 2017 · f55a389 · f55a389
1 parent a8d3dce
commit f55a389
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/policy/aggregation_id_compress.go b/policy/aggregation_id_compress.go
@@ -92,6 +92,9 @@ func NewPooledAggregationIDDecompressor(pool AggregationTypesPool) AggregationID
 }
 
 func (c *aggregationIDDecompressor) Decompress(id AggregationID) (AggregationTypes, error) {
+	if id.IsDefault() {
+		return DefaultAggregationTypes, nil
+	}
 	// NB(cw) it's guaranteed that len(c.buf) == len(id) == AggregationIDLen, we need to copy
 	// the words from id into a slice to be used in bitset.
 	for i := range id {

diff --git a/policy/aggregation_id_compress_test.go b/policy/aggregation_id_compress_test.go
@@ -34,7 +34,7 @@ func TestAggregationIDCompressRoundTrip(t *testing.T) {
 		result    AggregationTypes
 		expectErr bool
 	}{
-		{DefaultAggregationTypes, AggregationTypes{}, false},
+		{DefaultAggregationTypes, DefaultAggregationTypes, false},
 		{[]AggregationType{Unknown}, DefaultAggregationTypes, true},
 		{[]AggregationType{Lower, Upper}, []AggregationType{Lower, Upper}, false},
 		{[]AggregationType{Last}, []AggregationType{Last}, false},