| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/les/utils/ |
| H A D | expiredvalue.go | 60 func ExpFactor(logOffset Fixed64) ExpirationFactor {
61 return ExpirationFactor{Exp: logOffset.ToUint64(), Factor: logOffset.Fraction().Pow2()}
71 func (e ExpiredValue) Value(logOffset Fixed64) uint64 {
72 offset := Uint64ToFixed64(e.Exp) - logOffset
77 func (e *ExpiredValue) Add(amount int64, logOffset Fixed64) int64 {
78 integer, frac := logOffset.ToUint64(), logOffset.Fraction()
185 SetLogOffset(now mclock.AbsTime, logOffset Fixed64)
196 logOffset Fixed64 member
209 e.logOffset += Fixed64(logToFixedFactor * float64(dt) * e.rate)
221 e.logOffset = logOffset
[all …]
|
| /dports/security/modsecurity3/modsecurity-v3.0.5/src/operators/ |
| H A D | validate_utf8_encoding.cc | 142 logOffset(ruleMessage, i, str.size()); in evaluate()
152 logOffset(ruleMessage, i, str.size()); in evaluate()
162 logOffset(ruleMessage, i, str.size()); in evaluate()
171 logOffset(ruleMessage, i, str.size()); in evaluate()
182 logOffset(ruleMessage, i, str.size()); in evaluate()
|
| H A D | contains_word.cc | 56 logOffset(ruleMessage, 0, paramTarget.size()); in evaluate()
61 logOffset(ruleMessage, pos, paramTarget.size()); in evaluate()
66 logOffset(ruleMessage, pos, paramTarget.size()); in evaluate()
|
| H A D | validate_url_encoding.cc | 93 logOffset(ruleMessage, offset, input.size()); in evaluate()
101 logOffset(ruleMessage, offset, input.size()); in evaluate()
111 logOffset(ruleMessage, offset, input.size()); in evaluate()
|
| H A D | begins_with.cc | 34 logOffset(ruleMessage, 0, p.size()); in evaluate()
|
| H A D | within.cc | 40 logOffset(ruleMessage, pos, str.size()); in evaluate()
|
| H A D | contains.cc | 32 logOffset(ruleMessage, offset, p.size()); in evaluate()
|
| H A D | ends_with.cc | 35 logOffset(ruleMessage, str.length() - p.length(), in evaluate()
|
| H A D | rx.cc | 69 logOffset(ruleMessage, capture.m_offset, capture.m_length); in evaluate()
|
| H A D | rx_global.cc | 69 logOffset(ruleMessage, capture.m_offset, capture.m_length); in evaluate()
|
| H A D | verify_svnr.cc | 96 logOffset(ruleMessage, j.offset(), j.str().size()); in evaluate()
|
| H A D | verify_cpf.cc | 126 logOffset(ruleMessage, m.offset(), m.str().size()); in evaluate()
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/les/vflux/client/ |
| H A D | timestats_test.go | 76 logOffset utils.Fixed64
79 exp := utils.ExpFactor(logOffset)
90 logOffset += utils.Float64ToFixed64(0.001 / math.Log(2))
94 exp := utils.ExpFactor(logOffset)
|
| H A D | requestbasket_test.go | 138 var logOffset utils.Fixed64
140 exp := utils.ExpFactor(logOffset)
156 logOffset += utils.Float64ToFixed64(0.1)
|
| H A D | valuetracker.go | 267 logOffset := utils.Fixed64(vte.ExpOffset)
270 logOffset += utils.Float64ToFixed64(float64(dt) * vt.offlineExpRate / math.Log(2))
272 vt.statsExpirer.SetLogOffset(vt.clock.Now(), logOffset)
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/les/ |
| H A D | freeclient.go | 110 recentUsage = int64(math.Exp(float64(e.logUsage-f.logOffset(now)) / fixedPointMultiplier))
168 func (f *freeClientPool) logOffset(now mclock.AbsTime) int64 { func
182 e.logUsage = int64(math.Log(float64(dt))*fixedPointMultiplier) + f.logOffset(now)
218 LogOffset: uint64(f.logOffset(now)),
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ |
| H A D | FileStreamSource.scala | 147 val startOffset = start.map(FileStreamSourceOffset(_).logOffset).getOrElse(-1L)
148 val endOffset = FileStreamSourceOffset(end).logOffset
188 override def getOffset: Option[Offset] = Some(fetchMaxOffset()).filterNot(_.logOffset == -1)
|
| H A D | FileStreamSourceOffset.scala | 29 case class FileStreamSourceOffset(logOffset: Long) extends Offset {
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/test/resources/structured-streaming/offset-log-version-2.1.0/ |
| H A D | 0 | 3 {"logOffset":345}
|
| /dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ |
| H A D | ReplicationQueuesZKImpl.java | 326 byte[] logOffset = ZKUtil.getData(this.zookeeper, oldWalZnode); in copyQueuesFromRSUsingMulti()
327 LOG.debug("Creating " + wal + " with data " + Bytes.toString(logOffset)); in copyQueuesFromRSUsingMulti()
329 listOfOps.add(ZKUtilOp.createAndFailSilent(newLogZnode, logOffset)); in copyQueuesFromRSUsingMulti()
|
| /dports/devel/llvm-cheri/llvm-project-37c49ff00e3eadce5d8703fdc4497f28458c64a8/openmp/runtime/src/ |
| H A D | kmp_stats.cpp | 163 return i - logOffset; in minBin()
165 return -logOffset; in minBin()
172 return i - logOffset; in maxBin()
174 return -logOffset; in maxBin()
|
| /dports/devel/llvm-devel/llvm-project-f05c95f10fc1d8171071735af8ad3a9e87633120/openmp/runtime/src/ |
| H A D | kmp_stats.cpp | 165 return i - logOffset; in minBin()
167 return -logOffset; in minBin()
174 return i - logOffset; in maxBin()
176 return -logOffset; in maxBin()
|
| /dports/devel/llvm10/llvm-10.0.1.src/projects/openmp/runtime/src/ |
| H A D | kmp_stats.cpp | 163 return i - logOffset; in minBin()
165 return -logOffset; in minBin()
172 return i - logOffset; in maxBin()
174 return -logOffset; in maxBin()
|
| /dports/devel/llvm11/llvm-11.0.1.src/projects/openmp/runtime/src/ |
| H A D | kmp_stats.cpp | 163 return i - logOffset; in minBin()
165 return -logOffset; in minBin()
172 return i - logOffset; in maxBin()
174 return -logOffset; in maxBin()
|
| /dports/devel/wasi-compiler-rt12/llvm-project-12.0.1.src/openmp/runtime/src/ |
| H A D | kmp_stats.cpp | 165 return i - logOffset; in minBin()
167 return -logOffset; in minBin()
174 return i - logOffset; in maxBin()
176 return -logOffset; in maxBin()
|