Home
last modified time | relevance | path

Searched refs:obs (Results 1 - 25 of 26) sorted by relevance

12

/third_party/typescript/tests/baselines/reference/
H A DsymbolProperty61.js4 readonly obs: symbol
8 const observable: typeof Symbol.obs = Symbol.obs
23 [Symbol.obs]: () => { subscribe(next: (val: T) => void): void }
26 function from<T>(obs: InteropObservable<T>) {
27 return obs[Symbol.obs]()
34 const observable = Symbol.obs;
46 function from(obs) {
47 return obs[Symbo
[all...]
/third_party/libcoap/src/
H A Dcoap_resource.c468 coap_subscription_t *obs, *otmp; local
491 LL_FOREACH_SAFE(resource->subscribers, obs, otmp) {
493 resource->context->observe_deleted(obs->session, obs,
495 coap_session_release(obs->session);
496 coap_delete_pdu(obs->pdu);
497 coap_delete_cache_key(obs->cache_key);
498 coap_free_type(COAP_SUBSCRIPTION, obs);
649 COPY_COND_WITH_OFFSET(p, bufend, *offset, ";obs", 4, *len);
989 coap_subscription_t *obs, *otm local
1272 coap_subscription_t *obs, *otmp; global() local
[all...]
H A Dcoap_net.c3645 * by setting obs->fail_cnt = 0. */ in coap_dispatch()
3743 coap_subscription_t *obs, *tmp; in coap_dispatch() local
3744 LL_FOREACH_SAFE(r->subscribers, obs, tmp) { in coap_dispatch()
3745 if (obs->pdu->mid == pdu->mid && obs->session == session) { in coap_dispatch()
3748 coap_delete_observer(r, session, &obs->pdu->actual_token); in coap_dispatch()
/third_party/node/test/parallel/
H A Dtest-performanceobserver.js55 const obs = new PerformanceObserver(common.mustNotCall());
56 obs.observe({ entryTypes: ['mark', 'mark'] });
57 obs.disconnect();
66 function callback(list, obs) {
67 assert.strictEqual(obs, observer);
H A Dtest-http2-pack-end-stream-flag.js33 const obs = new PerformanceObserver(
45 obs.observe({ type: 'http2' });
H A Dtest-dns-perf_hooks.js9 const obs = new PerformanceObserver((items) => {
13 obs.observe({ type: 'dns' });
H A Dtest-perf-hooks-resourcetiming.js277 const obs = new PerformanceObserver(common.mustCall((list) => {
293 obs.disconnect();
295 obs.observe({ entryTypes: ['resource'] });
H A Dtest-http2-perf_hooks.js12 const obs = new PerformanceObserver(common.mustCallAtLeast((items) => {
65 obs.observe({ type: 'http2' });
/third_party/node/deps/v8/src/compiler/
H A Dstore-store-elimination.cc112 // Returns a set that it is the current one, plus the observation obs passed
113 // as parameter. If said obs it's already unobservable, we don't have to
115 UnobservablesSet Add(UnobservableStore obs, Zone* zone) const;
143 bool IsUnobservable(UnobservableStore obs, in IsUnobservable() argument
146 ObservableState state = set_->Get(obs); in IsUnobservable()
158 bool IsGCObservable(UnobservableStore obs) const { in IsGCObservable()
159 return set_ != nullptr && set_->Get(obs) == kGCObservable; in IsGCObservable()
535 UnobservablesSet UnobservablesSet::Add(UnobservableStore obs, in Add() argument
537 if (set()->Get(obs) == kUnobservable) return *this; in Add()
541 SetAdd(new_set, obs); in Add()
553 const UnobservableStore& obs = entry.first; RemoveSameOffset() local
566 const UnobservableStore& obs = entry.first; MarkGCObservable() local
[all...]
/third_party/node/deps/openssl/openssl/crypto/bio/
H A Dbf_lbuf.c210 int obs; in linebuffer_ctrl() local
235 obs = (int)num; in linebuffer_ctrl()
237 if ((obs > DEFAULT_LINEBUFFER_SIZE) && (obs != ctx->obuf_size)) { in linebuffer_ctrl()
238 p = OPENSSL_malloc((size_t)obs); in linebuffer_ctrl()
243 if (ctx->obuf_len > obs) { in linebuffer_ctrl()
244 ctx->obuf_len = obs; in linebuffer_ctrl()
249 ctx->obuf_size = obs; in linebuffer_ctrl()
H A Dbf_buff.c242 int ibs, obs; in buffer_ctrl() local
308 obs = ctx->obuf_size; in buffer_ctrl()
312 obs = (int)num; in buffer_ctrl()
316 obs = (int)num; in buffer_ctrl()
327 if ((obs > DEFAULT_BUFFER_SIZE) && (obs != ctx->obuf_size)) { in buffer_ctrl()
347 ctx->obuf_size = obs; in buffer_ctrl()
/third_party/openssl/crypto/bio/
H A Dbf_lbuf.c210 int obs; in linebuffer_ctrl() local
235 obs = (int)num; in linebuffer_ctrl()
237 if ((obs > DEFAULT_LINEBUFFER_SIZE) && (obs != ctx->obuf_size)) { in linebuffer_ctrl()
238 p = OPENSSL_malloc((size_t)obs); in linebuffer_ctrl()
243 if (ctx->obuf_len > obs) { in linebuffer_ctrl()
244 ctx->obuf_len = obs; in linebuffer_ctrl()
249 ctx->obuf_size = obs; in linebuffer_ctrl()
H A Dbf_buff.c242 int ibs, obs; in buffer_ctrl() local
308 obs = ctx->obuf_size; in buffer_ctrl()
312 obs = (int)num; in buffer_ctrl()
316 obs = (int)num; in buffer_ctrl()
327 if ((obs > DEFAULT_BUFFER_SIZE) && (obs != ctx->obuf_size)) { in buffer_ctrl()
347 ctx->obuf_size = obs; in buffer_ctrl()
/third_party/libcoap/examples/
H A Detsi_testcases.sh635 # server offers an observable resource /obs which changes periodically
638 # client is requested to observe resource /obs on server
652 testaddress=coap://$SERVERTUP/obs
661 # server offers an observable resource /obs which changes periodically
662 # (e.g. every 5s.), client is observing /obs on server
664 # client is requested to stop observing resource /obs on server
678 # testaddress=coap://$SERVERTUP/obs
687 # server offers an observable resource /obs which changes periodically
688 # (e.g. every 5s.), client is observing /obs on server
712 testaddress=coap://$SERVERTUP/obs
[all...]
/third_party/node/benchmark/perf_hooks/
H A Dusertiming.js25 const obs = new PerformanceObserver(() => {
28 obs.observe({ entryTypes, buffered: true });
H A Dresourcetiming.js69 const obs = new PerformanceObserver(() => {
72 obs.observe({ entryTypes: [observe], buffered: true });
/third_party/node/deps/openssl/openssl/crypto/comp/
H A Dc_zlib.c551 int ibs, obs; in bio_zlib_ctrl() local
573 obs = -1; in bio_zlib_ctrl()
579 obs = (int)num; in bio_zlib_ctrl()
582 obs = ibs; in bio_zlib_ctrl()
591 if (obs != -1) { in bio_zlib_ctrl()
594 ctx->obufsize = obs; in bio_zlib_ctrl()
/third_party/openssl/crypto/comp/
H A Dc_zlib.c551 int ibs, obs; in bio_zlib_ctrl() local
573 obs = -1; in bio_zlib_ctrl()
579 obs = (int)num; in bio_zlib_ctrl()
582 obs = ibs; in bio_zlib_ctrl()
591 if (obs != -1) { in bio_zlib_ctrl()
594 ctx->obufsize = obs; in bio_zlib_ctrl()
/third_party/python/Lib/idlelib/
H A Dbrowser.py48 obs = [] # Use list since values should already be sorted.
63 obs.append(obj)
64 return obs
/third_party/python/Lib/
H A Dasynchat.py242 obs = self.ac_out_buffer_size
244 data = first[:obs]
264 if num_sent < len(data) or obs < len(first):
/third_party/mbedtls/programs/
H A Ddemo_common.sh136 dd if=/dev/urandom of=seedfile ibs=64 obs=64 count=1
/third_party/node/lib/internal/perf/
H A Dobserve.js352 for (const obs of kObservers) {
353 obs[kMaybeBuffer](entry);
/third_party/node/test/fixtures/wpt/user-timing/
H A Dmeasure-with-dict.any.js40 t.step_func(function (entryList, obs) {
/third_party/ltp/testcases/kernel/fs/scsi/ltpscsi/
H A Dscsimain.c2193 int obs = 0; in do_scsi_device_read_write() local
2229 if ((ibs && (ibs != bs)) || (obs && (obs != bs))) { in do_scsi_device_read_write()
2231 "If 'ibs' or 'obs' given must be same as 'bs'\n"); in do_scsi_device_read_write()
/third_party/node/deps/v8/src/heap/
H A Dmark-compact.cc1700 for (MigrationObserver* obs : observers_) { in ExecuteMigrationObservers()
1701 obs->Move(dest, src, dst, size); in ExecuteMigrationObservers()

Completed in 32 milliseconds

12