@@ -45,7 +45,7 @@ type refCountedLock struct {
45
45
// eventually probably need fine grained management)
46
46
type VMController struct {
47
47
sync.RWMutex
48
- containerLocks map [string ]* refCountedLock
48
+ containerLocks map [ccintf. CCID ]* refCountedLock
49
49
vmProviders map [string ]VMProvider
50
50
}
51
51
@@ -54,7 +54,7 @@ var vmLogger = flogging.MustGetLogger("container")
54
54
// NewVMController creates a new instance of VMController
55
55
func NewVMController (vmProviders map [string ]VMProvider ) * VMController {
56
56
return & VMController {
57
- containerLocks : make (map [string ]* refCountedLock ),
57
+ containerLocks : make (map [ccintf. CCID ]* refCountedLock ),
58
58
vmProviders : vmProviders ,
59
59
}
60
60
}
@@ -67,7 +67,7 @@ func (vmc *VMController) newVM(typ string) VM {
67
67
return v .NewVM ()
68
68
}
69
69
70
- func (vmc * VMController ) lockContainer (id string ) {
70
+ func (vmc * VMController ) lockContainer (id ccintf. CCID ) {
71
71
//get the container lock under global lock
72
72
vmc .Lock ()
73
73
var refLck * refCountedLock
@@ -85,7 +85,7 @@ func (vmc *VMController) lockContainer(id string) {
85
85
vmLogger .Debugf ("got container (%s) lock" , id )
86
86
}
87
87
88
- func (vmc * VMController ) unlockContainer (id string ) {
88
+ func (vmc * VMController ) unlockContainer (id ccintf. CCID ) {
89
89
vmc .Lock ()
90
90
if refLck , ok := vmc .containerLocks [id ]; ok {
91
91
if refLck .refCount <= 0 {
@@ -202,8 +202,8 @@ func (vmc *VMController) Process(vmtype string, req VMCReq) error {
202
202
v := vmc .newVM (vmtype )
203
203
ccid := req .GetCCID ()
204
204
205
- vmc .lockContainer (string ( ccid ) )
206
- defer vmc .unlockContainer (string ( ccid ) )
205
+ vmc .lockContainer (ccid )
206
+ defer vmc .unlockContainer (ccid )
207
207
return req .Do (v )
208
208
}
209
209
0 commit comments