metacache_test.go

// Copyright (C) 2015  The GoHBase Authors.  All rights reserved.
// This file is part of GoHBase.
// Use of this source code is governed by the Apache License 2.0
// that can be found in the COPYING file.

package gohbase

import (
	"bytes"
	"fmt"
	"reflect"
	"sort"
	"testing"

	"github.com/aristanetworks/goarista/test"
	"github.com/golang/mock/gomock"
	"github.com/tsuna/gohbase/hrpc"
	"github.com/tsuna/gohbase/region"
	mockRegion "github.com/tsuna/gohbase/test/mock/region"
)

func TestMetaCache(t *testing.T) {
	client := newClient("~invalid.quorum~") // We shouldn't connect to ZK.

	reg := client.getRegionFromCache([]byte("test"), []byte("theKey"))
	if reg != nil {
		t.Errorf("Found region %v even though the cache was empty?!", reg)
	}

	// Inject an entry in the cache.  This entry covers the entire key range.
	wholeTable := region.NewInfo(
		0,
		nil,
		[]byte("test"),
		[]byte("test,,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
		nil,
		nil,
	)
	ctrl := gomock.NewController(t)
	defer ctrl.Finish()
	regClient := mockRegion.NewMockRegionClient(ctrl)
	regClient.EXPECT().String().Return("mock region client").AnyTimes()
	regClient.EXPECT().Addr().Return("regionserver:1").AnyTimes()

	client.regions.put(wholeTable)
	client.clients.put(regClient, wholeTable)

	reg = client.getRegionFromCache([]byte("test"), []byte("theKey"))
	if !reflect.DeepEqual(reg, wholeTable) {
		t.Errorf("Found region %v but expected %v", reg, wholeTable)
	}
	reg = client.getRegionFromCache([]byte("test"), []byte("")) // edge case.
	if !reflect.DeepEqual(reg, wholeTable) {
		t.Errorf("Found region %v but expected %v", reg, wholeTable)
	}

	// Clear our client.
	client = newClient("~invalid.quorum~")

	// Inject 3 entries in the cache.
	region1 := region.NewInfo(
		0,
		nil,
		[]byte("test"),
		[]byte("test,,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
		[]byte(""),
		[]byte("foo"),
	)
	if os, replaced := client.regions.put(region1); !replaced {
		t.Errorf("Expected to put new region into cache, got: %v", os)
	} else if len(os) != 0 {
		t.Errorf("Didn't expect any overlaps, got: %v", os)
	}
	client.clients.put(regClient, region1)

	region2 := region.NewInfo(
		0,
		nil,
		[]byte("test"),
		[]byte("test,foo,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
		[]byte("foo"),
		[]byte("gohbase"),
	)
	if os, replaced := client.regions.put(region2); !replaced {
		t.Errorf("Expected to put new region into cache, got: %v", os)
	} else if len(os) != 0 {
		t.Errorf("Didn't expect any overlaps, got: %v", os)
	}
	client.clients.put(regClient, region2)

	region3 := region.NewInfo(
		0,
		nil,
		[]byte("test"),
		[]byte("test,gohbase,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
		[]byte("gohbase"),
		[]byte(""),
	)
	if os, replaced := client.regions.put(region3); !replaced {
		t.Errorf("Expected to put new region into cache, got: %v", os)
	} else if len(os) != 0 {
		t.Errorf("Didn't expect any overlaps, got: %v", os)
	}
	client.clients.put(regClient, region3)

	testcases := []struct {
		key string
		reg hrpc.RegionInfo
	}{
		{key: "theKey", reg: region3},
		{key: "", reg: region1},
		{key: "bar", reg: region1},
		{key: "fon\xFF", reg: region1},
		{key: "foo", reg: region2},
		{key: "foo\x00", reg: region2},
		{key: "gohbase", reg: region3},
	}
	for i, testcase := range testcases {
		reg = client.getRegionFromCache([]byte("test"), []byte(testcase.key))
		if !reflect.DeepEqual(reg, testcase.reg) {
			t.Errorf("[#%d] Found region %v but expected %v", i, reg, testcase.reg)
		}
	}

	// Change the last region (maybe it got split).
	region4 := region.NewInfo(
		0,
		nil,
		[]byte("test"),
		[]byte("test,gohbase,1234567890042.swagswagswagswagswagswagswagswag."),
		[]byte("gohbase"),
		[]byte("zab"),
	)
	if os, replaced := client.regions.put(region4); !replaced {
		t.Errorf("Expected to put new region into cache, got: %v", os)
	} else if len(os) != 1 || os[0] != region3 {
		t.Errorf("Expected one overlap, got: %v", os)
	}
	client.clients.put(regClient, region4)

	reg = client.getRegionFromCache([]byte("test"), []byte("theKey"))
	if !reflect.DeepEqual(reg, region4) {
		t.Errorf("Found region %v but expected %v", reg, region4)
	}
	reg = client.getRegionFromCache([]byte("test"), []byte("zoo"))
	if reg != nil {
		t.Errorf("Shouldn't have found any region yet found %v", reg)
	}

	// attempt putting a region with same name
	region5 := region.NewInfo(
		0,
		nil,
		[]byte("test"),
		[]byte("test,gohbase,1234567890042.swagswagswagswagswagswagswagswag."),
		nil,
		[]byte("zab"),
	)
	if os, replaced := client.regions.put(region5); replaced {
		t.Errorf("Expected to not replace a region in cache, got: %v", os)
	} else if len(os) != 1 || os[0] != region4 {
		t.Errorf("Expected overlaps, got: %v", os)
	}
}

func TestMetaCacheGet(t *testing.T) {
	tcases := []struct {
		in             []hrpc.RegionInfo
		table          []byte
		key            []byte
		outIndexFromIn int
	}{
		{
			table:          []byte("yolo"),
			key:            []byte("swag"),
			outIndexFromIn: -1,
		},
		{ // the whole table
			in: []hrpc.RegionInfo{
				region.NewInfo(0, nil, []byte("test"),
					[]byte("test,,1234567890042.swagswagswagswagswagswagswagswag."),
					nil, nil),
			},
			table:          []byte("test"),
			key:            []byte("swag"),
			outIndexFromIn: 0,
		},
		{ // one region in cache, different table
			in: []hrpc.RegionInfo{
				region.NewInfo(0, nil, []byte("test"),
					[]byte("test,,1234567890042.swagswagswagswagswagswagswagswag."),
					nil, nil),
			},
			table:          []byte("yolo"),
			key:            []byte("swag"),
			outIndexFromIn: -1,
		},
		{ // key is before the first region in cache
			in: []hrpc.RegionInfo{
				region.NewInfo(0, nil, []byte("test"),
					[]byte("test,foo,1234567890042.swagswagswagswagswagswagswagswag."),
					[]byte("foo"), nil),
			},
			table:          []byte("test"),
			key:            []byte("bar"),
			outIndexFromIn: -1,
		},
		{ // key is between two regions in cache
			in: []hrpc.RegionInfo{
				region.NewInfo(0, nil, []byte("meow"),
					[]byte("meow,bar,1234567890042.swagswagswagswagswagswagswagswag."),
					[]byte("bar"), []byte("foo")),
				region.NewInfo(0, nil, []byte("test"),
					[]byte("test,foo,1234567890042.swagswagswagswagswagswagswagswag."),
					[]byte("foo"), nil),
			},
			table:          []byte("meow"),
			key:            []byte("swag"),
			outIndexFromIn: -1,
		},
		{ // test with namespace region in cache
			in: []hrpc.RegionInfo{
				region.NewInfo(0, []byte("n1"), []byte("test"),
					[]byte("n1:test,,1234567890042.swagswagswagswagswagswagswagswag."),
					nil, nil),
			},
			table:          []byte("test"),
			key:            []byte("swag"),
			outIndexFromIn: -1,
		},
		{ // test with namespace region in cache
			in: []hrpc.RegionInfo{
				region.NewInfo(0, []byte("n1"), []byte("test"),
					[]byte("n1:test,,1234567890042.swagswagswagswagswagswagswagswag."),
					nil, nil),
			},
			table:          []byte("n1:test"),
			key:            []byte("swag"),
			outIndexFromIn: 0,
		},
		{ // test with default namespace in cache, but non-default key
			in: []hrpc.RegionInfo{
				region.NewInfo(0, nil, []byte("test"),
					[]byte("test,,1234567890042.swagswagswagswagswagswagswagswag."),
					nil, nil),
			},
			table:          []byte("n1:test"),
			key:            []byte("swag"),
			outIndexFromIn: -1,
		},
		{ // test with non-default namespace region in cache, but default key
			in: []hrpc.RegionInfo{
				region.NewInfo(0, []byte("n1"), []byte("test"),
					[]byte("n1:test,,1234567890042.swagswagswagswagswagswagswagswag."),
					nil, nil),
			},
			table:          []byte("test"),
			key:            []byte("swag"),
			outIndexFromIn: -1,
		},
		{ // test 3 regions
			in: []hrpc.RegionInfo{
				region.NewInfo(0, nil, []byte("test"),
					[]byte("test,,1234567890042.swagswagswagswagswagswagswagswag."),
					nil, []byte("bar")),
				region.NewInfo(0, nil, []byte("test"),
					[]byte("test,bar,1234567890042.swagswagswagswagswagswagswagswag."),
					[]byte("bar"), []byte("foo")),
				region.NewInfo(0, nil, []byte("test"),
					[]byte("test,foo,1234567890042.swagswagswagswagswagswagswagswag."),
					[]byte("foo"), []byte("yolo")),
			},
			table:          []byte("test"),
			key:            []byte("baz"),
			outIndexFromIn: 1,
		},
	}

	for i, tcase := range tcases {
		t.Run(fmt.Sprintf("Test %d", i), func(t *testing.T) {
			client := newClient("~invalid.quorum~") // We shouldn't connect to ZK.

			for _, r := range tcase.in {
				overlaps, replaced := client.regions.put(r)
				if len(overlaps) != 0 {
					t.Fatalf("Didn't expect any overlaps, got %q", overlaps)
				}
				if !replaced {
					t.Fatal("Didn't expect to replace anything in cache")
				}
			}

			// lookup region in cache
			region := client.getRegionFromCache(tcase.table, tcase.key)

			if tcase.outIndexFromIn == -1 && region != nil {
				t.Fatalf("expected to get nil region, got %v", region)
			} else {
				return
			}

			if len(tcase.in) == 0 && region != nil {
				t.Fatalf("didn't expect to get anything from empty cache, got %v", region)
			}

			if tcase.in[tcase.outIndexFromIn].String() != region.String() {
				t.Errorf("Expected %v, Got %v",
					tcase.in[tcase.outIndexFromIn].String(), region.String())
			}
		})
	}
}

func TestRegionCacheAge(t *testing.T) {
	tcases := []struct {
		cachedRegions []hrpc.RegionInfo
		newRegion     hrpc.RegionInfo
		replaced      bool
	}{
		{ // all older
			cachedRegions: []hrpc.RegionInfo{
				region.NewInfo(
					1, nil, []byte("hello"),
					[]byte("hello,,1.yoloyoloyoloyoloyoloyoloyoloyolo."),
					[]byte(""), []byte("foo"),
				),
				region.NewInfo(
					1, nil, []byte("hello"),
					[]byte("hello,foo,1.swagswagswagswagswagswagswagswag."),
					[]byte("foo"), []byte(""),
				)},
			newRegion: region.NewInfo(
				2, nil, []byte("hello"),
				[]byte("hello,,2.meowmemowmeowmemowmeowmemowmeow."),
				[]byte(""), []byte(""),
			),
			replaced: true,
		},
		{ // all younger
			cachedRegions: []hrpc.RegionInfo{
				region.NewInfo(
					2, nil, []byte("hello"),
					[]byte("hello,,2.yoloyoloyoloyoloyoloyoloyoloyolo."),
					[]byte(""), []byte("foo"),
				),
				region.NewInfo(
					2, nil, []byte("hello"),
					[]byte("hello,foo,2.swagswagswagswagswagswagswagswag."),
					[]byte("foo"), []byte(""),
				)},
			newRegion: region.NewInfo(
				1, nil, []byte("hello"),
				[]byte("hello,,1.meowmemowmeowmemowmeowmemowmeow."),
				[]byte(""), []byte(""),
			),
			replaced: false,
		},
		{ // one younger, one older
			cachedRegions: []hrpc.RegionInfo{
				region.NewInfo(
					1, nil, []byte("hello"),
					[]byte("hello,,1.yoloyoloyoloyoloyoloyoloyoloyolo."),
					[]byte(""), []byte("foo"),
				),
				region.NewInfo(
					3, nil, []byte("hello"),
					[]byte("hello,foo,3.swagswagswagswagswagswagswagswag."),
					[]byte("foo"), []byte(""),
				)},
			newRegion: region.NewInfo(
				2, nil, []byte("hello"),
				[]byte("hello,,1.meowmemowmeowmemowmeowmemowmeow."),
				[]byte(""), []byte(""),
			),
			replaced: false,
		},
	}

	client := newClient("~invalid.quorum~")
	for i, tcase := range tcases {
		client.regions.regions.Clear()
		// set up initial cache
		for _, region := range tcase.cachedRegions {
			client.regions.put(region)
		}

		overlaps, replaced := client.regions.put(tcase.newRegion)
		if replaced != tcase.replaced {
			t.Errorf("Test %d: Expected %v, got %v", i, tcase.replaced, replaced)
		}

		expectedNames := make(regionNames, len(tcase.cachedRegions))
		for i, r := range tcase.cachedRegions {
			expectedNames[i] = r.Name()
		}
		osNames := make(regionNames, len(overlaps))
		for i, o := range overlaps {
			osNames[i] = o.Name()
		}

		// check overlaps are correct
		if diff := test.Diff(expectedNames, osNames); diff != "" {
			t.Errorf("Test %d: Expected: %v\nReceived: %v\nDiff:%s",
				i, expectedNames, osNames, diff)
		}
	}
}

type regionNames [][]byte

func (a regionNames) Len() int           { return len(a) }
func (a regionNames) Less(i, j int) bool { return bytes.Compare(a[i], a[j]) < 0 }
func (a regionNames) Swap(i, j int)      { a[i], a[j] = a[j], a[i] }

func TestMetaCacheGetOverlaps(t *testing.T) {
	region1 := region.NewInfo(
		0,
		nil,
		[]byte("test"),
		[]byte("test,,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
		[]byte(""),
		[]byte("foo"),
	)

	regionA := region.NewInfo(
		0,
		nil,
		[]byte("hello"),
		[]byte("hello,,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
		[]byte(""),
		[]byte("foo"),
	)

	regionB := region.NewInfo(
		0,
		nil,
		[]byte("hello"),
		[]byte("hello,foo,987654321042.56f833d5569a27c7a43fbf547b4924a4."),
		[]byte("foo"),
		[]byte("fox"),
	)

	regionC := region.NewInfo(
		0,
		nil,
		[]byte("hello"),
		[]byte("hello,fox,987654321042.56f833d5569a27c7a43fbf547b4924a4."),
		[]byte("fox"),
		[]byte("yolo"),
	)

	regionWhole := region.NewInfo(
		0,
		nil,
		[]byte("hello"),
		[]byte("hello,,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
		nil,
		nil,
	)

	regionTests := []struct {
		cachedRegions []hrpc.RegionInfo
		newRegion     hrpc.RegionInfo
		expected      []hrpc.RegionInfo
	}{
		{[]hrpc.RegionInfo{}, region1, []hrpc.RegionInfo{}},               // empty cache
		{[]hrpc.RegionInfo{region1}, region1, []hrpc.RegionInfo{region1}}, // with itself
		{ // different table
			[]hrpc.RegionInfo{region1},
			region.NewInfo(
				0,
				nil,
				[]byte("hello"),
				[]byte("hello,,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
				[]byte(""),
				[]byte("fake"),
			),
			[]hrpc.RegionInfo{},
		},
		{ // different namespace
			[]hrpc.RegionInfo{
				region.NewInfo(
					0,
					[]byte("ns1"),
					[]byte("test"),
					[]byte("ns1:test,,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
					[]byte(""),
					[]byte("foo"),
				),
			},
			region.NewInfo(
				0,
				nil,
				[]byte("test"),
				[]byte("test,,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
				[]byte(""),
				[]byte("foo"),
			),
			[]hrpc.RegionInfo{},
		},
		{ // overlaps with both
			[]hrpc.RegionInfo{regionA, regionB},
			region.NewInfo(
				0,
				nil,
				[]byte("hello"),
				[]byte("hello,bar,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
				[]byte("bar"),
				[]byte("fop"),
			),
			[]hrpc.RegionInfo{regionA, regionB},
		},
		{ // overlaps with both, key start == old one
			[]hrpc.RegionInfo{regionA, regionB},
			region.NewInfo(
				0,
				nil,
				[]byte("hello"),
				[]byte("hello,,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
				[]byte(""),
				[]byte("yolo"),
			),
			[]hrpc.RegionInfo{regionA, regionB},
		},
		{ // overlaps with second
			[]hrpc.RegionInfo{regionA, regionB},
			region.NewInfo(
				0,
				nil,
				[]byte("hello"),
				[]byte("hello,fop,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
				[]byte("fop"),
				[]byte("yolo"),
			),
			[]hrpc.RegionInfo{regionB},
		},
		{ // overlaps with first, new key start == old one
			[]hrpc.RegionInfo{regionA, regionB},
			region.NewInfo(
				0,
				nil,
				[]byte("hello"),
				[]byte("hello,,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
				[]byte(""),
				[]byte("abc"),
			),
			[]hrpc.RegionInfo{regionA},
		},
		{ // doesn't overlap, is between existing
			[]hrpc.RegionInfo{regionA, regionC},
			regionB,
			[]hrpc.RegionInfo{},
		},
		{ // without bounds in cache, replaced by region with both bounds
			[]hrpc.RegionInfo{regionWhole},
			regionB,
			[]hrpc.RegionInfo{regionWhole},
		},
		{ // without bounds in cache, replaced by the empty stop key only
			[]hrpc.RegionInfo{regionWhole},
			region.NewInfo(
				0,
				nil,
				[]byte("hello"),
				[]byte("hello,,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
				[]byte("yolo"),
				nil,
			),
			[]hrpc.RegionInfo{regionWhole},
		},
		{ // without bounds in cache, replaced by the empty start key only
			[]hrpc.RegionInfo{regionWhole},
			region.NewInfo(
				0,
				nil,
				[]byte("hello"),
				[]byte("hello,,1234567890042.56f833d5569a27c7a43fbf547b4924a4."),
				nil,
				[]byte("yolo"),
			),
			[]hrpc.RegionInfo{regionWhole},
		},
		{ // regions with bounds in cache, replaced by without bounds
			[]hrpc.RegionInfo{regionB, regionC},
			regionWhole,
			[]hrpc.RegionInfo{regionB, regionC},
		},
		{ // without bounds in cache, replaced by without bounds
			[]hrpc.RegionInfo{regionWhole},
			region.NewInfo(
				0,
				nil,
				[]byte("hello"),
				[]byte("hello,,1234567890042.yoloyoloyoloyoloyoloyoloyoloyolo."),
				nil,
				nil,
			),
			[]hrpc.RegionInfo{regionWhole},
		},
	}

	for i, tt := range regionTests {
		t.Run(fmt.Sprintf("Test %d", i), func(t *testing.T) {
			client := newClient("~invalid.quorum~") // fake client
			// set up initial cache
			for _, region := range tt.cachedRegions {
				client.regions.regions.Set(region.Name(), region)
			}

			expectedNames := make(regionNames, len(tt.expected))
			for i, r := range tt.expected {
				expectedNames[i] = r.Name()
			}
			os := client.regions.getOverlaps(tt.newRegion)
			osNames := make(regionNames, len(os))
			for i, o := range os {
				osNames[i] = o.Name()
			}
			sort.Sort(expectedNames)
			sort.Sort(osNames)
			if !reflect.DeepEqual(expectedNames, osNames) {
				t.Errorf("Expected overlaps %q, found %q", expectedNames, osNames)
			}
		})
	}
}

func TestClientCachePut(t *testing.T) {
	client := newClient("~invalid.quorum~")

	ctrl := gomock.NewController(t)
	defer ctrl.Finish()
	regClient := mockRegion.NewMockRegionClient(ctrl)
	regClient.EXPECT().String().Return("mock region client").AnyTimes()
	regClient.EXPECT().Addr().Return("regionserver:1").AnyTimes()

	existing := client.clients.put(regClient, region.NewInfo(
		0,
		nil,
		[]byte("test"),
		[]byte("test,,1234567890042.yoloyoloyoloyoloyoloyoloyoloyolo."),
		nil, nil))

	if existing != regClient {
		t.Errorf("Unexpected regClient from put: %v", existing)
	}

	if len(client.clients.regions) != 1 {
		t.Errorf("Expected 1 client in cache, got %d", len(client.clients.regions))
	}

	if len(client.clients.regions[regClient]) != 1 {
		t.Errorf("Expected 1 region for client in cache, got %d",
			len(client.clients.regions[regClient]))
	}

	// try putting client with the same host port
	regClient2 := mockRegion.NewMockRegionClient(ctrl)
	regClient.EXPECT().String().Return("mock region client").AnyTimes()
	regClient2.EXPECT().Addr().Return("regionserver:1").AnyTimes()

	// but put a different region
	existing = client.clients.put(regClient, region.NewInfo(
		0,
		nil,
		[]byte("yolo"),
		[]byte("yolo,,1234567890042.yoloyoloyoloyoloyoloyoloyoloyolo."),
		nil, nil))

	if existing != regClient {
		t.Errorf("Unexpected regClient from put: %v", existing)
	}

	// nothing should have changed in clients cache
	if len(client.clients.regions) != 1 {
		t.Errorf("Expected 1 client in cache, got %d", len(client.clients.regions))
	}

	if len(client.clients.regions[regClient]) != 2 {
		t.Errorf("Expected 2 regions for client in cache, got %d",
			len(client.clients.regions[regClient]))
	}
}