93 lines
1.6 KiB
Go
93 lines
1.6 KiB
Go
package rpc
|
|
|
|
import (
|
|
"github.com/mitchellh/packer/packer"
|
|
"testing"
|
|
)
|
|
|
|
type testCache struct {
|
|
lockCalled bool
|
|
lockKey string
|
|
unlockCalled bool
|
|
unlockKey string
|
|
rlockCalled bool
|
|
rlockKey string
|
|
runlockCalled bool
|
|
runlockKey string
|
|
}
|
|
|
|
func (t *testCache) Lock(key string) string {
|
|
t.lockCalled = true
|
|
t.lockKey = key
|
|
return "foo"
|
|
}
|
|
|
|
func (t *testCache) RLock(key string) (string, bool) {
|
|
t.rlockCalled = true
|
|
t.rlockKey = key
|
|
return "foo", true
|
|
}
|
|
|
|
func (t *testCache) Unlock(key string) {
|
|
t.unlockCalled = true
|
|
t.unlockKey = key
|
|
}
|
|
|
|
func (t *testCache) RUnlock(key string) {
|
|
t.runlockCalled = true
|
|
t.runlockKey = key
|
|
}
|
|
|
|
func TestCache_Implements(t *testing.T) {
|
|
var _ packer.Cache = new(cache)
|
|
}
|
|
|
|
func TestCacheRPC(t *testing.T) {
|
|
// Create the interface to test
|
|
c := new(testCache)
|
|
|
|
// Start the server
|
|
client, server := testClientServer(t)
|
|
defer client.Close()
|
|
defer server.Close()
|
|
server.RegisterCache(c)
|
|
|
|
cacheClient := client.Cache()
|
|
|
|
// Test Lock
|
|
cacheClient.Lock("foo")
|
|
if !c.lockCalled {
|
|
t.Fatal("should be called")
|
|
}
|
|
if c.lockKey != "foo" {
|
|
t.Fatalf("bad: %s", c.lockKey)
|
|
}
|
|
|
|
// Test Unlock
|
|
cacheClient.Unlock("foo")
|
|
if !c.unlockCalled {
|
|
t.Fatal("should be called")
|
|
}
|
|
if c.unlockKey != "foo" {
|
|
t.Fatalf("bad: %s", c.unlockKey)
|
|
}
|
|
|
|
// Test RLock
|
|
cacheClient.RLock("foo")
|
|
if !c.rlockCalled {
|
|
t.Fatal("should be called")
|
|
}
|
|
if c.rlockKey != "foo" {
|
|
t.Fatalf("bad: %s", c.rlockKey)
|
|
}
|
|
|
|
// Test RUnlock
|
|
cacheClient.RUnlock("foo")
|
|
if !c.runlockCalled {
|
|
t.Fatal("should be called")
|
|
}
|
|
if c.runlockKey != "foo" {
|
|
t.Fatalf("bad: %s", c.runlockKey)
|
|
}
|
|
}
|