Fix superfluous decision re-evaluations
This commit is contained in:
@@ -178,7 +178,8 @@ func NewConnectionFromFirstPacket(pkt packet.Packet) *Connection {
|
|||||||
// remote endpoint
|
// remote endpoint
|
||||||
Entity: entity,
|
Entity: entity,
|
||||||
// meta
|
// meta
|
||||||
Started: time.Now().Unix(),
|
Started: time.Now().Unix(),
|
||||||
|
profileRevisionCounter: proc.Profile().RevisionCnt(),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -126,6 +126,18 @@ func (lp *LayeredProfile) getValidityFlag() *abool.AtomicBool {
|
|||||||
return lp.validityFlag
|
return lp.validityFlag
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// RevisionCnt returns the current profile revision counter.
|
||||||
|
func (lp *LayeredProfile) RevisionCnt() (revisionCounter uint64) {
|
||||||
|
if lp == nil {
|
||||||
|
return 0
|
||||||
|
}
|
||||||
|
|
||||||
|
lp.lock.Lock()
|
||||||
|
defer lp.lock.Unlock()
|
||||||
|
|
||||||
|
return lp.revisionCounter
|
||||||
|
}
|
||||||
|
|
||||||
// Update checks for updated profiles and replaces any outdated profiles.
|
// Update checks for updated profiles and replaces any outdated profiles.
|
||||||
func (lp *LayeredProfile) Update() (revisionCounter uint64) {
|
func (lp *LayeredProfile) Update() (revisionCounter uint64) {
|
||||||
lp.lock.Lock()
|
lp.lock.Lock()
|
||||||
|
|||||||
Reference in New Issue
Block a user