| /external/chromium_org/net/quic/ |
| quic_alarm.cc | 18 void QuicAlarm::Set(QuicTime deadline) {
20 DCHECK(deadline.IsInitialized());
21 deadline_ = deadline;
40 QuicTime deadline = delegate_->OnAlarm(); local
43 if (!deadline_.IsInitialized() && deadline.IsInitialized()) {
44 Set(deadline);
|
| quic_alarm_test.cc | 38 DCHECK(deadline().IsInitialized());
43 DCHECK(!deadline().IsInitialized());
77 QuicTime deadline = QuicTime::Zero().Add(QuicTime::Delta::FromSeconds(7)); local
78 alarm_.Set(deadline);
81 EXPECT_EQ(deadline, alarm_.deadline());
85 QuicTime deadline = QuicTime::Zero().Add(QuicTime::Delta::FromSeconds(7)); local
86 alarm_.Set(deadline);
90 EXPECT_EQ(QuicTime::Zero(), alarm_.deadline());
94 QuicTime deadline = QuicTime::Zero().Add(QuicTime::Delta::FromSeconds(7)) local
[all...] |
| quic_alarm.h | 34 // Sets the alarm to fire at |deadline|. Must not be called while
37 void Set(QuicTime deadline);
47 QuicTime deadline() const { return deadline_; } function in class:net::QuicAlarm
52 // deadline has been updated.
60 // delegates |OnAlarm| if a delegate is set, and if the deadline
63 // the situation where the task executes before the deadline has been
|
| quic_connection_helper.cc | 32 DCHECK(deadline().IsInitialized());
35 // will notice that deadline has not yet been reached, and will set
36 // the alarm for the new deadline.
40 int64 delay_us = deadline().Subtract(clock_->Now()).ToMicroseconds();
52 DCHECK(!deadline().IsInitialized());
54 // will notice that deadline is not Initialized and will do nothing.
62 if (!deadline().IsInitialized()) {
67 if (clock_->Now() < deadline()) {
|
| /external/libvpx/libvpx/test/ |
| codec_factory.h | 36 unsigned long deadline) const = 0;
39 unsigned long deadline,
72 VP8Decoder(vpx_codec_dec_cfg_t cfg, unsigned long deadline)
73 : Decoder(cfg, deadline) {}
87 VP8Encoder(vpx_codec_enc_cfg_t cfg, unsigned long deadline,
89 : Encoder(cfg, deadline, init_flags, stats) {}
106 unsigned long deadline) const {
108 return new VP8Decoder(cfg, deadline);
115 unsigned long deadline,
119 return new VP8Encoder(cfg, deadline, init_flags, stats)
[all...] |
| decode_test_driver.h | 43 Decoder(vpx_codec_dec_cfg_t cfg, unsigned long deadline)
44 : cfg_(cfg), deadline_(deadline), init_done_(false) {
58 void set_deadline(unsigned long deadline) {
59 deadline_ = deadline;
|
| encode_test_driver.h | 90 Encoder(vpx_codec_enc_cfg_t cfg, unsigned long deadline,
92 : cfg_(cfg), deadline_(deadline), init_flags_(init_flags), stats_(stats) {
126 void set_deadline(unsigned long deadline) {
127 deadline_ = deadline;
|
| /external/chromium_org/cc/output/ |
| begin_frame_args.h | 20 base::TimeTicks deadline,
26 // This is the default delta that will be used to adjust the deadline when
36 // deadline has passed, since the deadline is also used to trigger BeginFrame
45 base::TimeTicks deadline; member in struct:cc::BeginFrameArgs
50 base::TimeTicks deadline,
|
| begin_frame_args.cc | 11 deadline(base::TimeTicks()),
16 base::TimeTicks deadline,
19 deadline(deadline),
24 base::TimeTicks deadline,
26 return BeginFrameArgs(frame_time, deadline, interval);
31 // so we set the deadline to 0 and guess that the interval is 16 milliseconds.
52 // Using a large deadline adjustment will effectively revert BeginFrame
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/layout_tests/port/ |
| server_process_mock.py | 47 def read_stdout_line(self, deadline):
50 def read_stdout(self, deadline, size):
57 return first_line + "\n" + self.read_stdout(deadline, remaining_size)
65 def read_either_stdout_or_stderr_line(self, deadline):
67 return self.read_stdout_line(deadline), None
|
| server_process.py | 58 is that reading responses takes a deadline, so that we don't ever block
173 def read_stdout_line(self, deadline):
174 return self._read(deadline, self._pop_stdout_line_if_ready)
176 def read_stderr_line(self, deadline):
177 return self._read(deadline, self._pop_stderr_line_if_ready)
179 def read_either_stdout_or_stderr_line(self, deadline):
189 return_value = self._read(deadline, retrieve_bytes_from_buffers)
195 def read_stdout(self, deadline, size):
204 return self._read(deadline, retrieve_bytes_from_stdout_buffer)
227 def _wait_for_data_and_update_buffers_using_select(self, deadline, stopping=False)
[all...] |
| /libcore/luni/src/main/java/java/util/concurrent/locks/ |
| Condition.java | 348 * or the specified deadline elapses.
361 * <li>The specified deadline elapses; or
382 * <p>The return value indicates whether the deadline has elapsed,
385 * boolean aMethod(Date deadline) {
392 * stillWaiting = theCondition.awaitUntil(deadline);
411 * of the specified deadline. In either case the implementation
415 * @param deadline the absolute time to wait until
416 * @return {@code false} if the deadline has elapsed upon return, else
421 boolean awaitUntil(Date deadline) throws InterruptedException;
|
| LockSupport.java | 204 * the specified deadline, unless the permit is available.
218 * <li>The specified deadline passes; or
231 * @param deadline the absolute time, in milliseconds from the Epoch,
235 public static void parkUntil(Object blocker, long deadline) {
238 unsafe.park(true, deadline);
325 * the specified deadline, unless the permit is available.
339 * <li>The specified deadline passes; or
350 * @param deadline the absolute time, in milliseconds from the Epoch,
353 public static void parkUntil(long deadline) {
354 unsafe.park(true, deadline);
[all...] |
| /external/guava/guava-testlib/src/com/google/common/testing/ |
| GcFinalization.java | 120 final long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds); local
139 } while (System.nanoTime() - deadline < 0);
155 final long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds); local
169 } while (System.nanoTime() - deadline < 0);
208 final long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds); local
220 } while (System.nanoTime() - deadline < 0);
|
| /external/valgrind/main/drd/tests/ |
| pth_inconsistent_cond_wait.c | 78 struct timespec deadline; local
83 memset(&deadline, 0, sizeof(deadline));
84 deadline.tv_sec = now.tv_sec + 2;
85 deadline.tv_nsec = now.tv_usec * 1000;
86 PTH_CALL(pthread_cond_timedwait(&s_cond, mutex, &deadline));
|
| /external/qemu/android/ |
| looper-generic.c | 37 Duration deadline; member in struct:GLoopTimer
55 if (tt->deadline != DURATION_INFINITE) {
57 tt->deadline = DURATION_INFINITE;
67 if (tt->deadline != DURATION_INFINITE)
74 tt->deadline = deadline_ms;
94 return (tt->deadline != DURATION_INFINITE);
102 if (tt->deadline != DURATION_INFINITE)
127 tt->deadline = DURATION_INFINITE;
291 Duration deadline = tt->deadline; local
[all...] |
| sync-utils.h | 125 * deadline - Absoulte deadline time to complete the reading.
132 int64_t deadline);
160 * deadline - Absoulte deadline time to complete the writing.
167 int64_t deadline);
195 * deadline - Absoulte deadline time to complete the reading.
197 * Number of chracters read on success, 0 on deadline expiration,
203 int64_t deadline);
[all...] |
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| WaitingThread.java | 125 * @param deadline when to time out, or <code>null</code> for no timeout
137 public boolean await(Date deadline)
156 if (deadline != null) {
157 success = this.cond.awaitUntil(deadline);
|
| /external/chromium_org/cc/scheduler/ |
| frame_rate_controller.cc | 86 // TODO(brianderson): Use an adaptive parent compositor deadline.
88 base::TimeTicks deadline = NextTickTime(); local
89 return BeginFrameArgs::Create(frame_time, deadline, interval_);
120 // TODO(brianderson): Use an adaptive parent compositor deadline.
122 base::TimeTicks deadline = NextTickTime() + deadline_adjustment_; local
125 BeginFrameArgs::Create(frame_time, deadline, interval_));
|
| /external/qemu/android/protocol/ |
| core-connection.c | 88 int64_t deadline; local
115 deadline = iolooper_now() + CORE_PORT_TIMEOUT_MS;
117 status = syncsocket_read_line_absolute(ssocket, buf, sizeof(buf), deadline);
130 status = syncsocket_read_line_absolute(ssocket, buf, sizeof(buf), deadline);
260 int64_t deadline; local
279 deadline = iolooper_now() + CORE_PORT_TIMEOUT_MS;
281 syncsocket_read_line_absolute(desc->ssocket, buf, sizeof(buf), deadline);
299 deadline);
|
| /frameworks/base/packages/Keyguard/src/com/android/keyguard/ |
| KeyguardAbsKeyInputView.java | 84 long deadline = mLockPatternUtils.getLockoutAttemptDeadline(); local
85 if (shouldLockout(deadline)) {
86 handleAttemptLockout(deadline);
93 protected boolean shouldLockout(long deadline) {
94 return deadline != 0;
165 long deadline = mLockPatternUtils.setLockoutAttemptDeadline(); local
166 handleAttemptLockout(deadline);
173 // Prevent user from using the PIN/Password entry until scheduled deadline.
|
| /external/chromium_org/net/tools/quic/ |
| quic_epoll_connection_helper.cc | 32 DCHECK(deadline().IsInitialized());
34 deadline().Subtract(QuicTime::Zero()).ToMicroseconds(),
39 DCHECK(!deadline().IsInitialized());
|
| /external/chromium_org/chrome/test/chromedriver/chrome/ |
| chrome_desktop_impl.cc | 32 base::Time deadline = base::Time::Now() + base::TimeDelta::FromSeconds(5); local
33 while (base::Time::Now() < deadline) {
93 base::Time deadline = base::Time::Now() + base::TimeDelta::FromSeconds(10); local
95 while (base::Time::Now() < deadline) {
|
| /external/guava/guava/src/com/google/common/collect/ |
| Queues.java | 211 long deadline = System.nanoTime() + unit.toNanos(timeout); local
218 E e = q.poll(deadline - System.nanoTime(), TimeUnit.NANOSECONDS);
245 long deadline = System.nanoTime() + unit.toNanos(timeout); local
257 e = q.poll(deadline - System.nanoTime(), TimeUnit.NANOSECONDS);
|
| /external/qemu/ |
| iolooper.h | 49 * would be better to assign a deadline for both reads before the first read,
50 * and call iolooper_wait_absoulte with the same deadline value:
51 * int64_t deadline = iolooper_now() + TIMEOUT;
52 * if (iolooper_wait_absoulte(iol, deadline)) {
54 * (iolooper_wait_absoulte(iol, deadline)) {
60 * deadline Deadline (absoulte time in milliseconds) before which an I/O should
64 * occurred before the deadline, or -1 on error.
66 int iolooper_wait_absolute(IoLooper* iol, int64_t deadline);
|
