e3ad52be-90a5-48eb-a6ca-9cf3a154e4d3

Committed 19 Jun 2025 03:58AM UTC coverage: 70.705% (-0.5%) from 71.186%

Build # e3ad52be-90a5-48eb-a6ca-9cf3a154e4d3

Build Type

push

prow

Committed by

web-flow

Commit Message

Merge pull request #14923 from orelmisan/storage-hotplug-rm-param

vmi ctrl, template: Rm unused function parameter

Coverage Stats

3 of 3 new or added lines in 2 files covered. (100.0%)

1306 existing lines in 15 files now uncovered.

66217 of 93652 relevant lines covered (70.71%)

0.79 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/pkg/virt-handler/cache/maps.go

package cache

import (
        "fmt"
        "sync"
        "time"

        "k8s.io/apimachinery/pkg/types"

        cmdclient "kubevirt.io/kubevirt/pkg/virt-handler/cmd-client"
)

type LauncherClientInfo struct {
        Client              cmdclient.LauncherClient
        SocketFile          string
        DomainPipeStopChan  chan struct{}
        NotInitializedSince time.Time
        Ready               bool
}

type LauncherClientInfoByVMI struct {
        syncMap sync.Map
}

func (l *LauncherClientInfoByVMI) Delete(vmiUID types.UID) {
        l.syncMap.Delete(vmiUID)
}

func (l *LauncherClientInfoByVMI) Store(vmiUID types.UID, launcherClientInfo *LauncherClientInfo) {
        l.syncMap.Store(vmiUID, launcherClientInfo)
}

func (l *LauncherClientInfoByVMI) Load(vmiUID types.UID) (*LauncherClientInfo, bool) {
        result, exists := l.syncMap.Load(vmiUID)
        if !exists {
                return nil, exists
        }
        return l.cast(result), exists
}

func (*LauncherClientInfoByVMI) cast(result interface{}) *LauncherClientInfo {
        launcherClientInfo, ok := result.(*LauncherClientInfo)
        if !ok {
                panic(fmt.Sprintf("failed casting %+v to *LauncherClientInfo", result))
        }
        return launcherClientInfo
}

1	package cache
2
3	import (
4	"fmt"
5	"sync"
6	"time"
7
8	"k8s.io/apimachinery/pkg/types"
9
10	cmdclient "kubevirt.io/kubevirt/pkg/virt-handler/cmd-client"
11	)
12
13	type LauncherClientInfo struct {
14	Client cmdclient.LauncherClient
15	SocketFile string
16	DomainPipeStopChan chan struct{}
17	NotInitializedSince time.Time
18	Ready bool
19	}
20
21	type LauncherClientInfoByVMI struct {
22	syncMap sync.Map
23	}
24
UNCOV 25	func (l *LauncherClientInfoByVMI) Delete(vmiUID types.UID) {	×
UNCOV 26	l.syncMap.Delete(vmiUID)	×
UNCOV 27	}	×
28
UNCOV 29	func (l LauncherClientInfoByVMI) Store(vmiUID types.UID, launcherClientInfo LauncherClientInfo) {	×
UNCOV 30	l.syncMap.Store(vmiUID, launcherClientInfo)	×
UNCOV 31	}	×
32
UNCOV 33	func (l LauncherClientInfoByVMI) Load(vmiUID types.UID) (LauncherClientInfo, bool) {	×
UNCOV 34	result, exists := l.syncMap.Load(vmiUID)	×
UNCOV 35	if !exists {	×
36	return nil, exists	×
37	}	×
UNCOV 38	return l.cast(result), exists	×
39	}
40
UNCOV 41	func (LauncherClientInfoByVMI) cast(result interface{}) LauncherClientInfo {	×
UNCOV 42	launcherClientInfo, ok := result.(*LauncherClientInfo)	×
UNCOV 43	if !ok {	×
44	panic(fmt.Sprintf("failed casting %+v to *LauncherClientInfo", result))	×
45	}
UNCOV 46	return launcherClientInfo	×
47	}

kubevirt / kubevirt / e3ad52be-90a5-48eb-a6ca-9cf3a154e4d3

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous