(sourceSpec SourceSpec)
| 1008 | } |
| 1009 | |
| 1010 | func GetSourcePartitionSeqs(sourceSpec SourceSpec) map[string]cbgt.UUIDSeq { |
| 1011 | mapSourcePartitionSeqsM.Lock() |
| 1012 | s := mapSourcePartitionSeqs[sourceSpec] |
| 1013 | if s == nil { |
| 1014 | s = &SourcePartitionSeqs{} |
| 1015 | mapSourcePartitionSeqs[sourceSpec] = s |
| 1016 | } |
| 1017 | s.LastUsed = time.Now() |
| 1018 | rv := s.PartitionSeqs |
| 1019 | mapSourcePartitionSeqsM.Unlock() |
| 1020 | return rv |
| 1021 | } |
| 1022 | |
| 1023 | func DropSourcePartitionSeqs(sourceName, sourceUUID string) { |
| 1024 | mapSourcePartitionSeqsM.Lock() |
no outgoing calls
no test coverage detected