/dports/www/minio-client/etcd-3.5.0/server/etcdserver/api/v2store/ |
H A D | event_history.go | 44 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 D | event_history.go | 44 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 D | event_test.go | 28 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 D | event_history.go | 44 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 D | event_history.go | 44 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 D | event_history.go | 44 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 D | event_history.go | 44 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 D | event_history.go | 44 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 D | event_history.go | 44 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 D | event_history.go | 44 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 D | socketengine_kqueue.cpp | 100 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 D | Makefile.inc | 9 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 D | ppc64_init.c | 47 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 D | sparc_init.c | 50 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 D | ppc_init.c | 45 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 D | arm_init.c | 45 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 D | ext_hdr.c | 27 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 D | dberror.c | 310 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 D | trace.c | 290 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 D | trace.c | 290 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 D | trace.c | 290 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 D | event_test.go | 28 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 D | event_test.go | 28 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 D | event_test.go | 28 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 D | event_test.go | 28 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 …]
|