| /dports/cad/cvc/cvc-1.1.0-4-gd172016/src/ |
| H A D | CEventQueue.cc | 140 eventKey_t CEventSubQueue::QueueTime(eventQueue_t theQueueType) { in QueueTime() function in CEventSubQueue
145 eventKey_t CEventQueue::QueueTime() { in QueueTime() function in CEventQueue
148 return (- min(mainQueue.QueueTime(queueType), delayQueue.QueueTime(queueType))); in QueueTime()
150 return (min(mainQueue.QueueTime(queueType), delayQueue.QueueTime(queueType))); in QueueTime()
156 return ( theEventKey < QueueTime() ); in Later()
158 return ( theEventKey > QueueTime() ); in Later()
|
| H A D | CEventQueue.hh | 75 eventKey_t QueueTime(eventQueue_t theQueueType);
109 eventKey_t QueueTime();
|
| /dports/www/trafficserver/trafficserver-9.1.1/plugins/experimental/rate_limit/ |
| H A D | limiter.h | 32 using QueueTime = std::chrono::time_point<std::chrono::system_clock>; variable
39 using QueueItem = std::tuple<T, TSCont, QueueTime>;
101 QueueTime now = std::chrono::system_clock::now(); in push()
126 hasOldEntity(QueueTime now) const in hasOldEntity()
|
| H A D | sni_selector.cc | 37 QueueTime now = std::chrono::system_clock::now(); // Only do this once per limiter in sni_queue_cont()
|
| H A D | txn_limiter.cc | 65 QueueTime now = std::chrono::system_clock::now(); // Only do this once per "loop" in txn_queue_cont()
|
| /dports/devel/p5-Event/Event-1.28/c/ |
| H A D | ev.c | 4 static NV QueueTime[PE_QUEUES]; variable
273 QueueTime[ev->prio] = wa->cbtime = NVtime(); in pe_event_invoke()
366 memset(QueueTime, 0, sizeof(QueueTime)); in boot_pe_event()
|
| /dports/devel/erlang-sbroker/sbroker-1.0.0/test/ |
| H A D | sbroker_meter_statem.erl | 185 handle_update(Mod, MsgQLen, QueueTime, ProcessTime, RelTime, Time, M) ->
187 Result = Mod:handle_update(QueueTime, ProcessTime, RelTime, Time, M),
192 ?LET({QueueTime, ProcessTime, RelTime},
195 NQueueTime = erlang:convert_time_unit(QueueTime, milli_seconds,
|
| /dports/net/storj/storj-1.45.3/storagenode/pieces/ |
| H A D | deleter.go | 22 QueueTime time.Time member
133 mon.IntVal("piecedeleter-queue-time").Observe(int64(time.Since(r.QueueTime)))
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/aliyun/alibaba-cloud-sdk-go/services/ccc/ |
| H A D | struct_call_detail_agent.go | 24 QueueTime int `json:"QueueTime" xml:"QueueTime"` member
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/aliyun/alibaba-cloud-sdk-go/services/ccc/ |
| H A D | struct_call_detail_agent.go | 24 QueueTime int `json:"QueueTime" xml:"QueueTime"` member
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/gotools/src/github.com/mongodb/mongo-tools/mongoreplay/ |
| H A D | play.go | 25 …QueueTime int `long:"queueTime" description:"don't queue ops much further in the future tha… member
108 if err := Play(context, opChan, play.Speed, play.Repeat, play.QueueTime); err != nil {
|
| /dports/security/lego/lego-4.5.3/vendor/github.com/aliyun/alibaba-cloud-sdk-go/services/cloudcallcenter/ |
| H A D | struct_call_detail_agent.go | 29 QueueTime int `json:"QueueTime" xml:"QueueTime"` member
|
| /dports/databases/mongodb42-tools/mongo-tools-r4.2.17/mongoreplay/ |
| H A D | play.go | 27 …QueueTime int `long:"queueTime" description:"don't queue ops much further in the futur… member
132 if err := Play(context, opChan, play.Speed, play.Repeat, play.QueueTime); err != nil {
|
| /dports/security/lego/lego-4.5.3/vendor/github.com/aliyun/alibaba-cloud-sdk-go/services/adb/ |
| H A D | struct_slow_log_record.go | 21 QueueTime int64 `json:"QueueTime" xml:"QueueTime"` member
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/vmware/govmomi/simulator/ |
| H A D | task.go | 67 task.Info.QueueTime = time.Now()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/vmware/govmomi/simulator/ |
| H A D | task.go | 67 task.Info.QueueTime = time.Now()
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/vmware/govmomi/simulator/ |
| H A D | task.go | 67 task.Info.QueueTime = time.Now()
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/vendor/github.com/vmware/govmomi/simulator/ |
| H A D | task.go | 66 task.Info.QueueTime = time.Now()
|
| /dports/net-im/climm/climm-0.7.1/include/ |
| H A D | msg_queue.h | 26 UDWORD QueueTime (void);
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/vmware/govmomi/govc/task/ |
| H A D | recent.go | 187 queued := info.QueueTime.Format(stamp)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/vmware/govmomi/govc/task/ |
| H A D | recent.go | 187 queued := info.QueueTime.Format(stamp)
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/vmware/govmomi/govc/task/ |
| H A D | recent.go | 187 queued := info.QueueTime.Format(stamp)
|
| /dports/games/openrct2/OpenRCT2-0.3.5.1/src/openrct2/actions/ |
| H A D | RideCreateAction.cpp | 141 ride->stations[i].QueueTime = 0; in Execute()
|
| /dports/devel/p5-Event/Event-1.28/ |
| H A D | Event.xs | 526 if (max < QueueTime[xx]) max = QueueTime[xx];
|
| /dports/net-im/climm/climm-0.7.1/src/ |
| H A D | climm.c | 626 i = QueueTime (); in main()
|