Home
last modified time | relevance | path

Searched refs:eh (Results 26 – 50 of 11072) sorted by relevance

12345678910>>...443

/dports/www/minio-client/etcd-3.5.0/server/etcdserver/api/v2store/
H A Devent_history.go44 eh.rwl.Lock()
45 defer eh.rwl.Unlock()
47 eh.Queue.insert(e)
49 eh.LastIndex = e.Index()
51 eh.StartIndex = eh.Queue.Events[eh.Queue.Front].Index()
59 eh.rwl.RLock()
60 defer eh.rwl.RUnlock()
63 if index < eh.StartIndex {
76 i := (eh.Queue.Front + int(offset)) % eh.Queue.Capacity
79 e := eh.Queue.Events[i]
[all …]
/dports/devel/etcd31/etcd-3.1.20/store/
H A Devent_history.go44 eh.rwl.Lock()
45 defer eh.rwl.Unlock()
47 eh.Queue.insert(e)
49 eh.LastIndex = e.Index()
51 eh.StartIndex = eh.Queue.Events[eh.Queue.Front].Index()
59 eh.rwl.RLock()
60 defer eh.rwl.RUnlock()
63 if index < eh.StartIndex {
76 i := (eh.Queue.Front + int(offset)) % eh.Queue.Capacity
79 e := eh.Queue.Events[i]
[all …]
H A Devent_test.go28 eh := newEventHistory(100)
33 eh.addEvent(e)
38 i := eh.Queue.Front
39 n := eh.Queue.Size
41 e := eh.Queue.Events[i]
46 i = (i + 1) % eh.Queue.Capacity
51 eh := newEventHistory(100)
63 eh.addEvent(de)
94 eh := newEventHistory(5)
118 eh := newEventHistory(10)
[all …]
/dports/devel/etcd33/etcd-3.3.23/store/
H A Devent_history.go44 eh.rwl.Lock()
45 defer eh.rwl.Unlock()
47 eh.Queue.insert(e)
49 eh.LastIndex = e.Index()
51 eh.StartIndex = eh.Queue.Events[eh.Queue.Front].Index()
59 eh.rwl.RLock()
60 defer eh.rwl.RUnlock()
63 if index < eh.StartIndex {
76 i := (eh.Queue.Front + int(offset)) % eh.Queue.Capacity
79 e := eh.Queue.Events[i]
[all …]
/dports/devel/etcd32/etcd-3.2.32/store/
H A Devent_history.go44 eh.rwl.Lock()
45 defer eh.rwl.Unlock()
47 eh.Queue.insert(e)
49 eh.LastIndex = e.Index()
51 eh.StartIndex = eh.Queue.Events[eh.Queue.Front].Index()
59 eh.rwl.RLock()
60 defer eh.rwl.RUnlock()
63 if index < eh.StartIndex {
76 i := (eh.Queue.Front + int(offset)) % eh.Queue.Capacity
79 e := eh.Queue.Events[i]
[all …]
/dports/devel/etcd/etcd-2.3.8/store/
H A Devent_history.go44 eh.rwl.Lock()
45 defer eh.rwl.Unlock()
47 eh.Queue.insert(e)
49 eh.LastIndex = e.Index()
51 eh.StartIndex = eh.Queue.Events[eh.Queue.Front].Index()
59 eh.rwl.RLock()
60 defer eh.rwl.RUnlock()
63 if index < eh.StartIndex {
76 i := (eh.Queue.Front + int(offset)) % eh.Queue.Capacity
79 e := eh.Queue.Events[i]
[all …]
/dports/devel/etcd34/etcd-3.4.18/etcdserver/api/v2store/
H A Devent_history.go44 eh.rwl.Lock()
45 defer eh.rwl.Unlock()
47 eh.Queue.insert(e)
49 eh.LastIndex = e.Index()
51 eh.StartIndex = eh.Queue.Events[eh.Queue.Front].Index()
59 eh.rwl.RLock()
60 defer eh.rwl.RUnlock()
63 if index < eh.StartIndex {
76 i := (eh.Queue.Front + int(offset)) % eh.Queue.Capacity
79 e := eh.Queue.Events[i]
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/store/
H A Devent_history.go44 eh.rwl.Lock()
45 defer eh.rwl.Unlock()
47 eh.Queue.insert(e)
49 eh.LastIndex = e.Index()
51 eh.StartIndex = eh.Queue.Events[eh.Queue.Front].Index()
59 eh.rwl.RLock()
60 defer eh.rwl.RUnlock()
63 if index < eh.StartIndex {
76 i := (eh.Queue.Front + int(offset)) % eh.Queue.Capacity
79 e := eh.Queue.Events[i]
[all …]
/dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/etcdserver/api/v2store/
H A Devent_history.go44 eh.rwl.Lock()
45 defer eh.rwl.Unlock()
47 eh.Queue.insert(e)
49 eh.LastIndex = e.Index()
51 eh.StartIndex = eh.Queue.Events[eh.Queue.Front].Index()
59 eh.rwl.RLock()
60 defer eh.rwl.RUnlock()
63 if index < eh.StartIndex {
76 i := (eh.Queue.Front + int(offset)) % eh.Queue.Capacity
79 e := eh.Queue.Events[i]
[all …]
/dports/sysutils/sensu-go/sensu-go-5.11.1/vendor/github.com/coreos/etcd/store/
H A Devent_history.go44 eh.rwl.Lock()
45 defer eh.rwl.Unlock()
47 eh.Queue.insert(e)
49 eh.LastIndex = e.Index()
51 eh.StartIndex = eh.Queue.Events[eh.Queue.Front].Index()
59 eh.rwl.RLock()
60 defer eh.rwl.RUnlock()
63 if index < eh.StartIndex {
76 i := (eh.Queue.Front + int(offset)) % eh.Queue.Capacity
79 e := eh.Queue.Events[i]
[all …]
/dports/irc/inspircd/inspircd-3.11.0/src/socketengines/
H A Dsocketengine_kqueue.cpp100 int fd = eh->GetFd(); in AddFd()
114 eh->SetEventMask(event_mask); in AddFd()
123 int fd = eh->GetFd(); in DelFd()
140 SocketEngine::DelFdRef(eh); in DelFd()
151 EV_SET(ke, eh->GetFd(), EVFILT_WRITE, EV_ADD, 0, 0, udata_cast(eh)); in OnSetEvent()
162 EV_SET(ke, eh->GetFd(), EVFILT_WRITE, EV_ADD | EV_ONESHOT, 0, 0, udata_cast(eh)); in OnSetEvent()
186 if (!eh) in DispatchEvents()
190 const int fd = eh->GetFd(); in DispatchEvents()
208 eh->SetEventMask(eh->GetEventMask() & ~bits_to_clr); in DispatchEvents()
213 eh->SetEventMask(eh->GetEventMask() & ~FD_READ_WILL_BLOCK); in DispatchEvents()
[all …]
/dports/games/diaspora/Diaspora_R1_Linux/Diaspora/fs2_open/STLport-5.2.1/build/test/eh/
H A DMakefile.inc9 SRC_CPP = ../../../test/eh/TestClass.cpp \
10 ../../../test/eh/main.cpp \
11 ../../../test/eh/nc_alloc.cpp \
12 ../../../test/eh/random_number.cpp \
13 ../../../test/eh/test_algo.cpp \
15 ../../../test/eh/test_list.cpp \
16 ../../../test/eh/test_slist.cpp \
19 ../../../test/eh/test_deque.cpp \
20 ../../../test/eh/test_set.cpp \
21 ../../../test/eh/test_map.cpp \
[all …]
/dports/devel/elfutils/elfutils-0.179/backends/
H A Dppc64_init.c47 Ebl *eh, in ppc64_init() argument
55 ppc64_init_reloc (eh); in ppc64_init()
60 HOOK (eh, copy_reloc_p); in ppc64_init()
63 HOOK (eh, bss_plt_p); in ppc64_init()
65 HOOK (eh, register_info); in ppc64_init()
66 HOOK (eh, syscall_abi); in ppc64_init()
67 HOOK (eh, core_note); in ppc64_init()
68 HOOK (eh, auxv_info); in ppc64_init()
70 HOOK (eh, abi_cfi); in ppc64_init()
74 HOOK (eh, dwarf_to_regno); in ppc64_init()
[all …]
H A Dsparc_init.c50 Ebl *eh, in sparc_init() argument
58 sparc_init_reloc (eh); in sparc_init()
62 HOOK (eh, symbol_type_name); in sparc_init()
63 HOOK (eh, dynamic_tag_name); in sparc_init()
65 if (eh->class == ELFCLASS64) in sparc_init()
68 HOOK (eh, core_note); in sparc_init()
69 HOOK (eh, auxv_info); in sparc_init()
70 HOOK (eh, register_info); in sparc_init()
73 HOOK (eh, abi_cfi); in sparc_init()
75 eh->frame_nregs = 103; in sparc_init()
[all …]
H A Dppc_init.c45 Ebl *eh, in ppc_init() argument
53 ppc_init_reloc (eh); in ppc_init()
54 HOOK (eh, reloc_simple_type); in ppc_init()
56 HOOK (eh, dynamic_tag_name); in ppc_init()
59 HOOK (eh, bss_plt_p); in ppc_init()
61 HOOK (eh, register_info); in ppc_init()
62 HOOK (eh, syscall_abi); in ppc_init()
63 HOOK (eh, core_note); in ppc_init()
64 HOOK (eh, auxv_info); in ppc_init()
66 HOOK (eh, abi_cfi); in ppc_init()
[all …]
H A Darm_init.c45 Ebl *eh, in arm_init() argument
53 arm_init_reloc (eh); in arm_init()
54 HOOK (eh, segment_type_name); in arm_init()
55 HOOK (eh, section_type_name); in arm_init()
57 HOOK (eh, reloc_simple_type); in arm_init()
58 HOOK (eh, register_info); in arm_init()
59 HOOK (eh, core_note); in arm_init()
60 HOOK (eh, auxv_info); in arm_init()
63 HOOK (eh, abi_cfi); in arm_init()
65 HOOK (eh, symbol_type_name); in arm_init()
[all …]
/dports/archivers/arj/arj-3.10.22/
H A Dext_hdr.c27 while(eh->next!=NULL) in eh_lookup()
29 if(eh->tag==tag) in eh_lookup()
30 return(eh); in eh_lookup()
31 eh=eh->next; in eh_lookup()
40 if(eh==NULL) in eh_find_pending()
45 return(eh); in eh_find_pending()
46 eh=eh->next; in eh_find_pending()
79 if(eh->raw!=NULL) in eh_release()
80 farfree(eh->raw); in eh_release()
81 farfree(eh); in eh_release()
[all …]
/dports/cad/electric/electric-7.00/src/db/
H A Ddberror.c310 if (eh->pathlen > 0) efree((CHAR *)eh->path); in db_clearerrorlist()
415 eh->pp = pp; in addexporttoerror()
434 eh->x1 = x1; in addlinetoerror()
435 eh->y1 = y1; in addlinetoerror()
481 eh->x1 = x; in addpointtoerror()
482 eh->y1 = y; in addpointtoerror()
665 return(eh); in geterrorgeom()
1031 if (eh->type == ERRORTYPEGEOM && eh->showgeom && eh->pathlen > 0) in db_reportcurrenterror()
1058 (void)asktool(us_tool, x_("show-line"), eh->x1, eh->y1, eh->x2, eh->y2, in db_reportcurrenterror()
1066 eh->x1+consize, eh->y1+consize, el->cell); in db_reportcurrenterror()
[all …]
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/infiniband/hw/hfi1/
H A Dtrace.c290 union ib_ehdrs *eh = ehdrs; in parse_everbs_hdrs() local
307 be32_to_cpu(eh->imm_data)); in parse_everbs_hdrs()
314 be32_to_cpu(eh->rc.reth.rkey), in parse_everbs_hdrs()
316 be32_to_cpu(eh->rc.imm_data)); in parse_everbs_hdrs()
326 be32_to_cpu(eh->rc.reth.rkey), in parse_everbs_hdrs()
433 be32_to_cpu(eh->at.aeth) >> 24, in parse_everbs_hdrs()
443 eh->atomic_eth.rkey, in parse_everbs_hdrs()
450 be32_to_cpu(eh->ud.deth[0]), in parse_everbs_hdrs()
452 be32_to_cpu(eh->ud.deth[1]) >> in parse_everbs_hdrs()
457 be32_to_cpu(eh->ud.deth[0]), in parse_everbs_hdrs()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/infiniband/hw/hfi1/
H A Dtrace.c290 union ib_ehdrs *eh = ehdrs; in parse_everbs_hdrs() local
307 be32_to_cpu(eh->imm_data)); in parse_everbs_hdrs()
314 be32_to_cpu(eh->rc.reth.rkey), in parse_everbs_hdrs()
316 be32_to_cpu(eh->rc.imm_data)); in parse_everbs_hdrs()
326 be32_to_cpu(eh->rc.reth.rkey), in parse_everbs_hdrs()
433 be32_to_cpu(eh->at.aeth) >> 24, in parse_everbs_hdrs()
443 eh->atomic_eth.rkey, in parse_everbs_hdrs()
450 be32_to_cpu(eh->ud.deth[0]), in parse_everbs_hdrs()
452 be32_to_cpu(eh->ud.deth[1]) >> in parse_everbs_hdrs()
457 be32_to_cpu(eh->ud.deth[0]), in parse_everbs_hdrs()
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/infiniband/hw/hfi1/
H A Dtrace.c290 union ib_ehdrs *eh = ehdrs; in parse_everbs_hdrs() local
307 be32_to_cpu(eh->imm_data)); in parse_everbs_hdrs()
314 be32_to_cpu(eh->rc.reth.rkey), in parse_everbs_hdrs()
316 be32_to_cpu(eh->rc.imm_data)); in parse_everbs_hdrs()
326 be32_to_cpu(eh->rc.reth.rkey), in parse_everbs_hdrs()
433 be32_to_cpu(eh->at.aeth) >> 24, in parse_everbs_hdrs()
443 eh->atomic_eth.rkey, in parse_everbs_hdrs()
450 be32_to_cpu(eh->ud.deth[0]), in parse_everbs_hdrs()
452 be32_to_cpu(eh->ud.deth[1]) >> in parse_everbs_hdrs()
457 be32_to_cpu(eh->ud.deth[0]), in parse_everbs_hdrs()
[all …]
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/etcdserver/api/v2store/
H A Devent_test.go28 eh := newEventHistory(100)
33 eh.addEvent(e)
38 i := eh.Queue.Front
39 n := eh.Queue.Size
41 e := eh.Queue.Events[i]
46 i = (i + 1) % eh.Queue.Capacity
51 eh := newEventHistory(100)
63 eh.addEvent(de)
94 eh := newEventHistory(5)
118 eh := newEventHistory(10)
[all …]
/dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/vendor/github.com/coreos/etcd/store/
H A Devent_test.go28 eh := newEventHistory(100)
33 eh.addEvent(e)
38 i := eh.Queue.Front
39 n := eh.Queue.Size
41 e := eh.Queue.Events[i]
46 i = (i + 1) % eh.Queue.Capacity
51 eh := newEventHistory(100)
63 eh.addEvent(de)
94 eh := newEventHistory(5)
118 eh := newEventHistory(10)
[all …]
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/etcdserver/api/v2store/
H A Devent_test.go28 eh := newEventHistory(100)
33 eh.addEvent(e)
38 i := eh.Queue.Front
39 n := eh.Queue.Size
41 e := eh.Queue.Events[i]
46 i = (i + 1) % eh.Queue.Capacity
51 eh := newEventHistory(100)
63 eh.addEvent(de)
94 eh := newEventHistory(5)
118 eh := newEventHistory(10)
[all …]
/dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/store/
H A Devent_test.go28 eh := newEventHistory(100)
33 eh.addEvent(e)
38 i := eh.Queue.Front
39 n := eh.Queue.Size
41 e := eh.Queue.Events[i]
46 i = (i + 1) % eh.Queue.Capacity
51 eh := newEventHistory(100)
63 eh.addEvent(de)
94 eh := newEventHistory(5)
118 eh := newEventHistory(10)
[all …]

12345678910>>...443