X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/e7672a0b679659d6ba90d23b4e102fba747fa9ef..91f976b99d4e7f00d2c1fbfee75812c3b1b780c6:/services/keep-web/cache_test.go diff --git a/services/keep-web/cache_test.go b/services/keep-web/cache_test.go index f3b891ee9b..cddeaf4897 100644 --- a/services/keep-web/cache_test.go +++ b/services/keep-web/cache_test.go @@ -1,6 +1,11 @@ +// Copyright (C) The Arvados Authors. All rights reserved. +// +// SPDX-License-Identifier: AGPL-3.0 + package main import ( + "git.curoverse.com/arvados.git/sdk/go/arvados" "git.curoverse.com/arvados.git/sdk/go/arvadosclient" "git.curoverse.com/arvados.git/sdk/go/arvadostest" "gopkg.in/check.v1" @@ -16,12 +21,13 @@ func (s *UnitSuite) TestCache(c *check.C) { // the first req should cause an API call; the next 4 should // hit all caches. arv.ApiToken = arvadostest.AdminToken + var coll *arvados.Collection for i := 0; i < 5; i++ { - coll, err := cache.Get(arv, arvadostest.FooCollection, false) + coll, err = cache.Get(arv, arvadostest.FooCollection, false) c.Check(err, check.Equals, nil) c.Assert(coll, check.NotNil) - c.Check(coll["portable_data_hash"], check.Equals, arvadostest.FooPdh) - c.Check(coll["manifest_text"].(string)[:2], check.Equals, ". ") + c.Check(coll.PortableDataHash, check.Equals, arvadostest.FooPdh) + c.Check(coll.ManifestText[:2], check.Equals, ". ") } c.Check(cache.Stats().Requests, check.Equals, uint64(5)) c.Check(cache.Stats().CollectionHits, check.Equals, uint64(4)) @@ -31,18 +37,32 @@ func (s *UnitSuite) TestCache(c *check.C) { // Hit the same collection 2 more times, this time requesting // it by PDH and using a different token. The first req should - // miss the permission cache. Both reqs should hit the - // Collection cache and skip the API lookup. + // miss the permission cache and fetch the new manifest; the + // second should hit the Collection cache and skip the API + // lookup. arv.ApiToken = arvadostest.ActiveToken - for i := 0; i < 2; i++ { - coll, err := cache.Get(arv, arvadostest.FooPdh, false) - c.Check(err, check.Equals, nil) - c.Assert(coll, check.NotNil) - c.Check(coll["portable_data_hash"], check.Equals, arvadostest.FooPdh) - c.Check(coll["manifest_text"].(string)[:2], check.Equals, ". ") - } + + coll2, err := cache.Get(arv, arvadostest.FooPdh, false) + c.Check(err, check.Equals, nil) + c.Assert(coll2, check.NotNil) + c.Check(coll2.PortableDataHash, check.Equals, arvadostest.FooPdh) + c.Check(coll2.ManifestText[:2], check.Equals, ". ") + c.Check(coll2.ManifestText, check.Not(check.Equals), coll.ManifestText) + + c.Check(cache.Stats().Requests, check.Equals, uint64(5+1)) + c.Check(cache.Stats().CollectionHits, check.Equals, uint64(4+0)) + c.Check(cache.Stats().PermissionHits, check.Equals, uint64(4+0)) + c.Check(cache.Stats().PDHHits, check.Equals, uint64(4+0)) + c.Check(cache.Stats().APICalls, check.Equals, uint64(1+1)) + + coll2, err = cache.Get(arv, arvadostest.FooPdh, false) + c.Check(err, check.Equals, nil) + c.Assert(coll2, check.NotNil) + c.Check(coll2.PortableDataHash, check.Equals, arvadostest.FooPdh) + c.Check(coll2.ManifestText[:2], check.Equals, ". ") + c.Check(cache.Stats().Requests, check.Equals, uint64(5+2)) - c.Check(cache.Stats().CollectionHits, check.Equals, uint64(4+2)) + c.Check(cache.Stats().CollectionHits, check.Equals, uint64(4+1)) c.Check(cache.Stats().PermissionHits, check.Equals, uint64(4+1)) c.Check(cache.Stats().PDHHits, check.Equals, uint64(4+0)) c.Check(cache.Stats().APICalls, check.Equals, uint64(1+1)) @@ -61,7 +81,7 @@ func (s *UnitSuite) TestCache(c *check.C) { c.Check(err, check.Equals, nil) } c.Check(cache.Stats().Requests, check.Equals, uint64(5+2+20)) - c.Check(cache.Stats().CollectionHits, check.Equals, uint64(4+2+18)) + c.Check(cache.Stats().CollectionHits, check.Equals, uint64(4+1+18)) c.Check(cache.Stats().PermissionHits, check.Equals, uint64(4+1+18)) c.Check(cache.Stats().PDHHits, check.Equals, uint64(4+0+18)) c.Check(cache.Stats().APICalls, check.Equals, uint64(1+1+2))