Home
last modified time | relevance | path

Searched refs:threshold (Results 1 - 25 of 30) sorted by relevance

12

/6.6.0/phosphor/tests/include/
H A Dbarrier.h53 const size_t threshold = go + 1; in wait() local
56 cv.wait(lh, [this, threshold](){ in wait()
57 return go >= threshold; in wait()
/6.6.0/kv_engine/protocol/mcbp/
H A Dsla.cc54 static std::array<std::atomic<std::chrono::nanoseconds>, 0x100> threshold; member
87 for (auto& ts : threshold) { in getDefaultValue()
109 for (unsigned int ii = 0; ii < threshold.size(); ++ii) { in to_json()
113 const auto ns = threshold[ii].load(std::memory_order_relaxed); in to_json()
135 return threshold[uint8_t(opcode)].load(std::memory_order_relaxed); in getSlowOpThreshold()
269 for (auto& t : threshold) { in reconfigure()
293 threshold[uint8_t(opcode)].store(value, std::memory_order_relaxed); in reconfigure()
/6.6.0/kv_engine/engines/ep/src/
H A Dhlc.h57 * @param aheadThresholdAhead threshold a peer can be ahead before we
120 // If the difference is less than our -ve threshold.. count that in setMaxHLCAndTrackDrift()
153 * Set the drift threshold for ahead exception counting
157 void setDriftAheadThreshold(std::chrono::microseconds threshold) { in setDriftAheadThreshold() argument
159 std::chrono::duration_cast<std::chrono::nanoseconds>(threshold).count(); in setDriftAheadThreshold()
163 * Set the drift threshold for behind exception counting
167 void setDriftBehindThreshold(std::chrono::microseconds threshold) { in setDriftBehindThreshold() argument
169 std::chrono::duration_cast<std::chrono::nanoseconds>(threshold).count(); in setDriftBehindThreshold()
H A Dvbucketmap.cc155 void VBucketMap::setHLCDriftAheadThreshold(std::chrono::microseconds threshold) { in setHLCDriftAheadThreshold() argument
159 vb->setHLCDriftAheadThreshold(threshold); in setHLCDriftAheadThreshold()
164 void VBucketMap::setHLCDriftBehindThreshold(std::chrono::microseconds threshold) { in setHLCDriftBehindThreshold() argument
168 vb->setHLCDriftBehindThreshold(threshold); in setHLCDriftBehindThreshold()
H A Dvbucketmap.h111 void setHLCDriftAheadThreshold(std::chrono::microseconds threshold);
112 void setHLCDriftBehindThreshold(std::chrono::microseconds threshold);
H A Dvbucket.h290 void setHLCDriftAheadThreshold(std::chrono::microseconds threshold) { in setHLCDriftAheadThreshold() argument
291 hlc.setDriftAheadThreshold(threshold); in setHLCDriftAheadThreshold()
294 void setHLCDriftBehindThreshold(std::chrono::microseconds threshold) { in setHLCDriftBehindThreshold() argument
295 hlc.setDriftBehindThreshold(threshold); in setHLCDriftBehindThreshold()
707 bool isResidentRatioUnderThreshold(float threshold);
1608 * Set the memory threshold on the current bucket quota for accepting a
2062 * @param useActiveVBMemThreshold whether active VB memory threshold
2552 // The seqno threshold below which we may replace a prepare with another
H A Dkv_bucket_iface.h623 virtual void setBackfillMemoryThreshold(double threshold) = 0;
H A Dkv_bucket.h478 void setBackfillMemoryThreshold(double threshold) override;
/6.6.0/phosphor/include/phosphor/
H A Dscoped_event_guard.h77 * @threshold Minimum duration that either the lock or acquire span must
90 threshold(threshold_) { in MutexEventGuard()
107 if (waitTime > threshold || heldTime > threshold) { in ~MutexEventGuard()
128 const std::chrono::steady_clock::duration threshold; member in phosphor::MutexEventGuard
/6.6.0/kv_engine/engines/ep/tests/mock/
H A Dmock_paging_visitor.h63 void setFreqCounterThreshold(uint16_t threshold) { in setFreqCounterThreshold() argument
64 freqCounterThreshold = threshold; in setFreqCounterThreshold()
/6.6.0/goproj/src/github.com/couchbase/query/server/
H A Dcompleted_requests.go92 func RequestsInit(threshold int, limit int) {
97 // requests exceeding a time threshold
98 tq, tErr := newTimeThreshold(threshold)
167 case "threshold":
205 case "threshold":
251 case "threshold":
523 // 1- threshold
525 threshold time.Duration
531 return &timeThreshold{threshold: time.Duration(c.(int))}, nil
533 return &timeThreshold{threshold
[all...]
/6.6.0/testrunner/pytests/memcachedops/
H A Dstats_ops.py74 threshold = int(self.input.param('threshold', stats[ep_threshold]))
79 # load items till reached threshold or mem-ratio is less than resident ratio threshold
82 if mem_used < threshold or int(mc.stats()["vb_active_perc_mem_resident"]) >= active_resident_threshold:
83 self.log.info("mem_used and vb_active_perc_mem_resident_ratio reached at %s/%s and %s " % (mem_used, threshold, mc.stats()["vb_active_perc_mem_resident"]))
/6.6.0/godeps/src/github.com/etcd-io/bbolt/
H A Dnode.go280 // Determine the threshold before starting a new node.
287 threshold := int(float64(pageSize) * fillPercent)
290 splitIndex, _ := n.splitIndex(threshold)
312 // splitIndex finds the position where a page will fill a given threshold.
315 func (n *node) splitIndex(threshold int) (index, sz int) {
325 // node would put us over the threshold then exit and return.
326 if i >= minKeysPerPage && sz+elsize > threshold {
408 // size is below a threshold or if there are not enough keys.
418 // Ignore if node is above threshold (25%) and has enough keys.
419 var threshold var
[all...]
/6.6.0/goproj/src/github.com/couchbase/gometa/server/
H A DembeddedServer.go56 threshold uint8
88 threshold uint8,
98 server.threshold = threshold
514 s.repo, err = r.OpenRepositoryWithName2(s.repoName, s.quota, s.sleepDur, s.threshold, s.minFileSize)
/6.6.0/goproj/src/github.com/couchbase/indexing/secondary/indexer/
H A Dcompaction_manager.go386 // Plasma instance is mandatory for compaction if fragmentation is over min fragmentation threshold.
388 // is important to compact as soon as the index cross the min_frag threshold, so the log cleaner
401 threshold := config["min_frag"].Int()
408 // if index frag threshold is over limit
411 partnStats.fragPercent.Value() > int64(threshold) &&
417 inst.InstId, partn.GetPartitionId(), partnStats.fragPercent.Value(), threshold)
418 compactMsgs = append(compactMsgs, newMsgIndexCompact(inst.InstId, partn.GetPartitionId(), threshold))
429 // min_frag threshold. If the number of ongoing compactions is below a quota (compaction.plasma.optional.quota),
432 // keeping them under mandatory min_frag threshold. Since this is done in a continous, rotating basis, it
454 // 2) optional threshold
[all...]
H A Drebalancer.go189 threshold := cfg["planner.variationThreshold"].Float64()
194 r.nodeId, onEjectOnly, disableReplicaRepair, threshold, timeout, cpuProfile)
/6.6.0/godeps/src/github.com/couchbase/goforestdb/
H A Dfile.go133 // threshold is set to the threshold passed to this API
134 func (f *File) SwitchCompactionMode(mode CompactOpt, threshold int) error {
135 errNo := C.fdb_switch_compaction_mode(f.dbfile, C.fdb_compaction_mode_t(mode), C.size_t(threshold))
/6.6.0/goproj/src/github.com/couchbase/indexing/secondary/manager/
H A Dmanager.go182 threshold := config["metadata.compaction.threshold"].Int()
184 logging.Infof("Starting metadadta repo: quota %v sleep duration %v threshold %v min file size %v",
185 mgr.quota, sleepDur, threshold, minFileSize)
187 uint64(sleepDur), uint8(threshold), uint64(minFileSize))
H A Dmeta_repo.go130 threshold uint8,
133 ref, err := newLocalRepoRef(msgAddr, eventMgr, reqHandler, repoName, quota, sleepDur, threshold, minFileSize)
659 threshold uint8,
663 server, err := gometa.RunEmbeddedServerWithCustomHandler2(msgAddr, nil, reqHandler, repoName, quota, sleepDur, threshold, minFileSize)
/6.6.0/forestdb/src/
H A Dcompactor.cc137 // check if the compaction threshold is satisfied
142 int threshold; in _compactor_is_threshold_satisfied() local
158 threshold = elem->config.compaction_threshold; in _compactor_is_threshold_satisfied()
160 threshold > 0) in _compactor_is_threshold_satisfied()
169 return ((filesize / 100.0 * threshold) < (filesize - active_data)); in _compactor_is_threshold_satisfied()
/6.6.0/goproj/src/github.com/couchbase/query/server/http/
H A Dadmin_clustering_endpoint.go456 threshold, _ := server.RequestsGetQualifier("threshold", "")
457 settings[server.CMPTHRESHOLD] = threshold
/6.6.0/goproj/src/github.com/couchbase/indexing/secondary/planner/
H A Dexecutor.go132 disableReplicaRepair bool, threshold float64, timeout int, cpuProfile bool) (map[string]*common.TransferToken, error) {
135 timeout, threshold, cpuProfile, &runtime)
140 disableReplicaRepair bool, timeout int, threshold float64, cpuProfile bool, runtime *time.Time) (map[string]*common.TransferToken, error) {
180 config.Threshold = threshold
H A Dplanner.go339 threshold float64
820 if p.threshold > 0 && current.cost.ComputeResourceVariation() <= p.threshold {
867 func (p *SAPlanner) SetVariationThreshold(threshold float64) {
868 p.threshold = threshold
2845 threshold := float64(0.2)
2865 if freeMem > 0 && freeMemRatio > threshold {
2877 if len(indexers) == 0 && threshold > 0.05 {
2878 threshold
[all...]
/6.6.0/goproj/src/github.com/couchbase/gometa/repository/
H A Drepo.go75 func OpenRepositoryWithName2(name string, memory_quota uint64, sleepDur uint64, threshold uint8, minFileSize uint64) (repo *Repository, err error) {
91 config.SetCompactionThreshold(threshold)
/6.6.0/goproj/src/github.com/couchbase/goxdcr/parts/
H A Dxmem_nozzle.go122 notifych chan bool /*notify channel is set when the buffer is below threshold*/
131 func newReqBuffer(size uint16, threshold uint16, token_ch chan int, logger *log.CommonLogger) *requestBuffer {
139 notify_threshold: threshold,
160 func (buf *requestBuffer) setNotifyThreshold(threshold uint16) {
161 buf.notify_threshold = threshold
190 //blocking until the occupied slots are below threshold
313 buf.logger.Debugf("buffer's occupied slots is below threshold %v, no notify channel is specified though", buf.notify_threshold)
1572 * batch call to memcached GetMeta command for document size larger than the optimistic threshold
2944 xmem.Logger().Infof("%v updated optimistic replication threshold to %v\n", xmem.Id(), optimisticReplicationThresholdInt)

Completed in 98 milliseconds

12