Home
last modified time | relevance | path

Searched refs:pollTimeout (Results 1 – 25 of 85) sorted by relevance

1234

/dports/sysutils/kubectl/kubernetes-1.22.2/test/utils/
H A Ddeployment.go82 err := wait.PollImmediate(pollInterval, pollTimeout, func() (bool, error) {
157 …(c clientset.Interface, d *apps.Deployment, logf LogfFn, pollInterval, pollTimeout time.Duration) …
159 return waitForDeploymentCompleteMaybeCheckRolling(c, d, rolling, logf, pollInterval, pollTimeout)
165 …(c clientset.Interface, d *apps.Deployment, logf LogfFn, pollInterval, pollTimeout time.Duration) …
167 return waitForDeploymentCompleteMaybeCheckRolling(c, d, rolling, logf, pollInterval, pollTimeout)
176 err := wait.PollImmediate(pollInterval, pollTimeout, func() (bool, error) {
272 pollErr := wait.PollImmediate(pollInterval, pollTimeout, func() (bool, error) {
299 …leared(c clientset.Interface, ns, deploymentName string, pollInterval, pollTimeout time.Duration) …
300 err := wait.PollImmediate(pollInterval, pollTimeout, func() (bool, error) {
320 err := wait.PollImmediate(pollInterval, pollTimeout, func() (bool, error) {
[all …]
H A Dreplicaset.go33 …e string, applyUpdate UpdateReplicaSetFunc, logf LogfFn, pollInterval, pollTimeout time.Duration) …
36 pollErr := wait.PollImmediate(pollInterval, pollTimeout, func() (bool, error) {
57 …g.T, clientSet clientset.Interface, rs *apps.ReplicaSet, pollInterval, pollTimeout time.Duration) …
59 if err := wait.PollImmediate(pollInterval, pollTimeout, func() (bool, error) {
71 …e string, applyUpdate UpdateReplicaSetFunc, logf LogfFn, pollInterval, pollTimeout time.Duration) …
74 pollErr := wait.PollImmediate(pollInterval, pollTimeout, func() (bool, error) {
/dports/sysutils/kubectl/kubernetes-1.22.2/test/integration/deployment/
H A Dutil.go45 pollTimeout = 60 * time.Second const
164 …t.Namespace, d.deployment.Name, revision, image, d.t.Logf, pollInterval, pollTimeout); err != nil {
187 err := wait.PollImmediate(pollInterval, pollTimeout, func() (bool, error) {
228 …il.WaitForDeploymentCompleteAndCheckRolling(d.c, d.deployment, d.t.Logf, pollInterval, pollTimeout)
235 return testutil.WaitForDeploymentComplete(d.c, d.deployment, d.t.Logf, pollInterval, pollTimeout)
281 …s(d.c, d.deployment.Namespace, d.deployment.Name, applyUpdate, d.t.Logf, pollInterval, pollTimeout)
326 …SetWithRetries(d.c, d.deployment.Namespace, name, applyUpdate, d.t.Logf, pollInterval, pollTimeout)
334 …, d.deployment.Namespace, d.deployment.Name, reason, condType, d.t.Logf, pollInterval, pollTimeout)
365 return testutil.WaitRSStable(d.t, d.c, replicaset, pollInterval, pollTimeout)
393 if err := wait.PollImmediate(pollInterval, pollTimeout, func() (bool, error) {
[all …]
/dports/net/fbzmq/fbzmq-2021.12.27.00/fbzmq/async/
H A DZmqEventLoop.cpp257 std::chrono::milliseconds pollTimeout; in loopForever() local
276 pollTimeout = std::max(std::chrono::milliseconds(1), waitTime); in loopForever()
279 pollTimeout = healthCheckDuration_; in loopForever()
283 pollTimeout = std::min(pollTimeout, healthCheckDuration_); in loopForever()
287 << pollTimeout.count() << "ms."; in loopForever()
289 int count = fbzmq::poll(pollItems_, pollTimeout).value(); in loopForever()
/dports/security/autossh/autossh-1.4g/
H A Dfakepoll.h55 inline int poll(struct pollfd *pollSet, int pollCount, int pollTimeout) in poll() argument
114 if (pollTimeout >= 0) { in poll()
115 tv.tv_sec = pollTimeout / 1000; in poll()
116 tv.tv_usec = (pollTimeout % 1000) * 1000; in poll()
/dports/www/dfileserver/DFileServer/src/contrib/
H A Dfakepoll.h47 inline int poll(struct pollfd *pollSet, int pollCount, int pollTimeout) in poll() argument
104 if (pollTimeout >= 0) { in poll()
105 tv.tv_sec = pollTimeout / 1000; in poll()
106 tv.tv_usec = (pollTimeout % 1000) * 1000; in poll()
/dports/lang/tcl87/tcl8.7a5/unix/
H A DtclUnixNotfy.c505 int numFound, result = 0, pollTimeout; in TclUnixWaitForFile() local
569 pollTimeout = -1; in TclUnixWaitForFile()
571 pollTimeout = 0; in TclUnixWaitForFile()
573 pollTimeout = (int) timeoutPtr->tv_sec * 1000; in TclUnixWaitForFile()
575 pollTimeout += (int) timeoutPtr->tv_usec / 1000; in TclUnixWaitForFile()
578 numFound = poll(pollFds, 1, pollTimeout); in TclUnixWaitForFile()
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/apps/
H A Ddaemon_restart.go74 pollTimeout time.Duration member
79 func NewRestartConfig(nodeName, daemonName string, healthzPort int, pollInterval, pollTimeout time.…
88 pollTimeout: pollTimeout,
113 err := wait.Poll(r.pollInterval, r.pollTimeout, func() (bool, error) {
128 …xpectNoError(err, "%v did not respond with a 200 via %v within %v", r, healthzCheck, r.pollTimeout)
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/google/gopacket/gopacket-1.1.18/afpacket/
H A Doptions.go125 pollTimeout time.Duration member
136 pollTimeout: DefaultPollTimeout,
154 ret.pollTimeout = time.Duration(v)
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/google/gopacket/afpacket/
H A Doptions.go125 pollTimeout time.Duration member
136 pollTimeout: DefaultPollTimeout,
154 ret.pollTimeout = time.Duration(v)
/dports/misc/fq/fq-0.0.2/vendor/github.com/google/gopacket/afpacket/
H A Doptions.go125 pollTimeout time.Duration member
136 pollTimeout: DefaultPollTimeout,
154 ret.pollTimeout = time.Duration(v)
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/github.com/google/gopacket/afpacket/
H A Doptions.go127 pollTimeout time.Duration member
138 pollTimeout: DefaultPollTimeout,
156 ret.pollTimeout = time.Duration(v)
/dports/databases/mongodb42-tools/mongo-tools-r4.2.17/vendor/github.com/google/gopacket/afpacket/
H A Doptions.go127 pollTimeout time.Duration member
138 pollTimeout: DefaultPollTimeout,
156 ret.pollTimeout = time.Duration(v)
/dports/net/goreplay/goreplay-1.2.0/capture/
H A Dsock_linux.go40 pollTimeout uintptr member
57 pollTimeout: ^uintptr(0),
126 _, _, e := unix.Syscall(unix.SYS_POLL, uintptr(unsafe.Pointer(poll)), 1, sock.pollTimeout)
185 sock.pollTimeout = uintptr(t)
/dports/net/traefik/traefik-2.6.1/docs/content/providers/
H A Dhttp.md53 ### `pollTimeout`
62 pollTimeout: "5s"
67 pollTimeout = "5s"
71 --providers.http.pollTimeout=5s
/dports/net/hanstunnel/hans-1.0/src/
H A Dserver.h34 … const char *passphrase, uint32_t network, bool answerEcho, uid_t uid, gid_t gid, int pollTimeout);
119 Time pollTimeout; variable
H A Dserver.cpp35 …, const char *passphrase, uint32_t network, bool answerEcho, uid_t uid, gid_t gid, int pollTimeout) in Server() argument
39 this->pollTimeout = pollTimeout; in Server()
/dports/www/firefox/firefox-99.0/netwerk/base/
H A DnsSocketTransportService2.cpp629 PRIntervalTime pollTimeout; in Poll() local
641 pollTimeout = pendingEvents ? PR_INTERVAL_NO_WAIT : PollTimeout(ts); in Poll()
650 pollTimeout = in Poll()
659 pollTimeout = std::min(to, pollTimeout); in Poll()
670 PR_IntervalToMilliseconds(pollTimeout))); in Poll()
676 if (pollTimeout != PR_INTERVAL_NO_WAIT) { in Poll()
683 rv = PR_Poll(pollList, pollCount, pollTimeout); in Poll()
686 if (pollTimeout != PR_INTERVAL_NO_WAIT) { in Poll()
693 pollTimeout == PR_INTERVAL_NO_TIMEOUT in Poll()
696 : pollTimeout == PR_INTERVAL_NO_WAIT in Poll()
[all …]
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e_node/
H A Dnode_problem_detector_linux.go49 pollTimeout = 1 * time.Minute
403 }, pollTimeout, pollInterval).Should(gomega.Succeed())
407 }, pollTimeout, pollInterval).Should(gomega.Succeed())
416 }, pollTimeout, pollInterval).Should(gomega.Succeed())
434 ….WaitForPodToDisappear(c, ns, name, labels.Everything(), pollInterval, pollTimeout)).To(gomega.Suc…
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/node/
H A Dnode_problem_detector.go47 pollTimeout = 1 * time.Minute
145 }, pollTimeout, pollInterval).Should(gomega.Succeed())
151 }, pollTimeout, pollInterval).Should(gomega.Succeed())
159 }, pollTimeout, pollInterval).Should(gomega.Succeed())
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/instrumentation/monitoring/
H A Dstackdriver.go54 pollTimeout = time.Minute * 7 var
113 err = wait.Poll(pollFrequency, pollTimeout, pollingFunction)
/dports/www/firefox-esr/firefox-91.8.0/netwerk/base/
H A DnsSocketTransportService2.cpp628 PRIntervalTime pollTimeout; in Poll() local
640 pollTimeout = pendingEvents ? PR_INTERVAL_NO_WAIT : PollTimeout(ts); in Poll()
649 pollTimeout = in Poll()
658 pollTimeout = std::min(to, pollTimeout); in Poll()
669 PR_IntervalToMilliseconds(pollTimeout))); in Poll()
672 if (pollTimeout != PR_INTERVAL_NO_WAIT) { in Poll()
677 return PR_Poll(pollList, pollCount, pollTimeout); in Poll()
679 return PR_Poll(pollList, pollCount, pollTimeout); in Poll()
/dports/mail/thunderbird/thunderbird-91.8.0/netwerk/base/
H A DnsSocketTransportService2.cpp628 PRIntervalTime pollTimeout; in Poll() local
640 pollTimeout = pendingEvents ? PR_INTERVAL_NO_WAIT : PollTimeout(ts); in Poll()
649 pollTimeout = in Poll()
658 pollTimeout = std::min(to, pollTimeout); in Poll()
669 PR_IntervalToMilliseconds(pollTimeout))); in Poll()
672 if (pollTimeout != PR_INTERVAL_NO_WAIT) { in Poll()
677 return PR_Poll(pollList, pollCount, pollTimeout); in Poll()
679 return PR_Poll(pollList, pollCount, pollTimeout); in Poll()
/dports/lang/spidermonkey78/firefox-78.9.0/netwerk/base/
H A DnsSocketTransportService2.cpp624 PRIntervalTime pollTimeout; in Poll() local
636 pollTimeout = pendingEvents ? PR_INTERVAL_NO_WAIT : PollTimeout(ts); in Poll()
644 pollTimeout = in Poll()
653 pollTimeout = std::min(to, pollTimeout); in Poll()
664 PR_IntervalToMilliseconds(pollTimeout))); in Poll()
667 if (pollTimeout != PR_INTERVAL_NO_WAIT) { in Poll()
672 return PR_Poll(pollList, pollCount, pollTimeout); in Poll()
674 return PR_Poll(pollList, pollCount, pollTimeout); in Poll()
/dports/sysutils/kubectl/kubernetes-1.22.2/test/integration/statefulset/
H A Dstatefulset_test.go154 if err := wait.PollImmediate(pollInterval, pollTimeout, func() (bool, error) {
202 if err := wait.PollImmediate(pollInterval, pollTimeout, func() (bool, error) {
228 if err := wait.PollImmediate(pollInterval, pollTimeout, func() (bool, error) {

1234