| /dports/devel/itext/itext-4.2.0/core/com/lowagie/text/html/ |
| H A D | HtmlTagMap.java | 74 HtmlPeer peer; in HtmlTagMap() local
77 put(peer.getAlias(), peer); in HtmlTagMap() local
80 put(peer.getAlias(), peer); in HtmlTagMap() local
86 put(peer.getAlias(), peer); in HtmlTagMap() local
91 put(peer.getAlias(), peer); in HtmlTagMap() local
95 put(peer.getAlias(), peer); in HtmlTagMap() local
99 put(peer.getAlias(), peer); in HtmlTagMap() local
103 put(peer.getAlias(), peer); in HtmlTagMap() local
107 put(peer.getAlias(), peer); in HtmlTagMap() local
111 put(peer.getAlias(), peer); in HtmlTagMap() local
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/matrix-org/pinecone/router/ |
| H A D | peer.go | 49 type peer struct { struct
50 reader phony.Inbox
51 writer phony.Inbox
52 router *Router
53 port types.SwitchPortID // Not mutated after peer setup.
66 func (p *peer) String() string { // to make sim less ugly
79 func (p *peer) local() bool {
88 func (p *peer) send(f *types.Frame) bool {
119 func (p *peer) stop(err error) {
174 func (p *peer) _write() {
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/state/raft/transport/ |
| H A D | peer.go | 26 type peer struct { struct
27 id uint64
29 tr *Transport
31 msgc chan raftpb.Message
33 ctx context.Context
35 done chan struct{}
37 mu sync.Mutex
39 addr string
40 newAddr string
42 active bool
[all …]
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/docker/swarmkit/manager/state/raft/transport/ |
| H A D | peer.go | 26 type peer struct { struct
27 id uint64
29 tr *Transport
31 msgc chan raftpb.Message
33 ctx context.Context
35 done chan struct{}
37 mu sync.Mutex
39 addr string
40 newAddr string
42 active bool
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/state/raft/transport/ |
| H A D | peer.go | 26 type peer struct { struct
27 id uint64
29 tr *Transport
31 msgc chan raftpb.Message
33 ctx context.Context
35 done chan struct{}
37 mu sync.Mutex
39 addr string
40 newAddr string
42 active bool
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/state/raft/transport/ |
| H A D | peer.go | 26 type peer struct { struct
27 id uint64
29 tr *Transport
31 msgc chan raftpb.Message
33 ctx context.Context
35 done chan struct{}
37 mu sync.Mutex
39 addr string
40 newAddr string
42 active bool
[all …]
|
| /dports/sysutils/docker/docker-ce-18.09.5/components/engine/vendor/github.com/docker/swarmkit/manager/state/raft/transport/ |
| H A D | peer.go | 26 type peer struct { struct
27 id uint64
29 tr *Transport
31 msgc chan raftpb.Message
33 ctx context.Context
35 done chan struct{}
37 mu sync.Mutex
39 addr string
40 newAddr string
42 active bool
[all …]
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/state/raft/transport/ |
| H A D | peer.go | 27 type peer struct { struct
28 id uint64
30 tr *Transport
32 msgc chan raftpb.Message
34 ctx context.Context
36 done chan struct{}
38 mu sync.Mutex
40 addr string
41 newAddr string
43 active bool
[all …]
|
| /dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/state/raft/transport/ |
| H A D | peer.go | 26 type peer struct { struct
27 id uint64
29 tr *Transport
31 msgc chan raftpb.Message
33 ctx context.Context
35 done chan struct{}
37 mu sync.Mutex
39 addr string
40 newAddr string
42 active bool
[all …]
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/state/raft/transport/ |
| H A D | peer.go | 26 type peer struct { struct
27 id uint64
29 tr *Transport
31 msgc chan raftpb.Message
33 ctx context.Context
35 done chan struct{}
37 mu sync.Mutex
39 addr string
40 newAddr string
42 active bool
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/state/raft/transport/ |
| H A D | peer.go | 26 type peer struct { struct
27 id uint64
29 tr *Transport
31 msgc chan raftpb.Message
33 ctx context.Context
35 done chan struct{}
37 mu sync.Mutex
39 addr string
40 newAddr string
42 active bool
[all …]
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/state/raft/transport/ |
| H A D | peer.go | 26 type peer struct { struct
27 id uint64
29 tr *Transport
31 msgc chan raftpb.Message
33 ctx context.Context
35 done chan struct{}
37 mu sync.Mutex
39 addr string
40 newAddr string
42 active bool
[all …]
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/state/raft/transport/ |
| H A D | peer.go | 26 type peer struct { struct
27 id uint64
29 tr *Transport
31 msgc chan raftpb.Message
33 ctx context.Context
35 done chan struct{}
37 mu sync.Mutex
39 addr string
40 newAddr string
42 active bool
[all …]
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/les/ |
| H A D | peer.go | 52 type peer struct { struct
53 *p2p.Peer
54 pubKey *ecdsa.PublicKey
56 rw p2p.MsgReadWriter
61 announceType, requestAnnounceType uint64
63 id string
65 headInfo *announceData
66 lock sync.RWMutex
69 sendQueue *execQueue
73 responseErrors int
[all …]
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/eth/ |
| H A D | peer.go | 75 type peer struct { struct
76 id string
78 *p2p.Peer
79 rw p2p.MsgReadWriter
84 head common.Hash
85 td *big.Int
86 lock sync.RWMutex
114 func (p *peer) broadcast() {
142 func (p *peer) close() {
147 func (p *peer) Info() *PeerInfo {
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Arceliar/ironwood/network/ |
| H A D | peers.go | 74 type peer struct { struct
76 peers *peers
77 conn net.Conn
78 key publicKey
79 info *treeInfo
80 port peerPort
81 queue packetQueue
83 writer peerWriter
88 peer *peer member
125 func (p *peer) handler() error {
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/etcdserver/api/rafthttp/ |
| H A D | peer.go | 96 type peer struct { struct
97 lg *zap.Logger
99 localID types.ID
101 id types.ID
103 r Raft
105 status *peerStatus
107 picker *urlPicker
119 mu sync.Mutex
120 paused bool
123 stopc chan struct{}
[all …]
|
| /dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/etcdserver/api/rafthttp/ |
| H A D | peer.go | 96 type peer struct { struct
97 lg *zap.Logger
99 localID types.ID
101 id types.ID
103 r Raft
105 status *peerStatus
107 picker *urlPicker
119 mu sync.Mutex
120 paused bool
123 stopc chan struct{}
[all …]
|
| /dports/www/gitea/gitea-1.16.5/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/rafthttp/ |
| H A D | peer.go | 101 type peer struct { struct
102 lg *zap.Logger
104 localID types.ID
106 id types.ID
108 r Raft
110 status *peerStatus
112 picker *urlPicker
124 mu sync.Mutex
125 paused bool
128 stopc chan struct{}
[all …]
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/rafthttp/ |
| H A D | peer.go | 101 type peer struct { struct
102 lg *zap.Logger
104 localID types.ID
106 id types.ID
108 r Raft
110 status *peerStatus
112 picker *urlPicker
124 mu sync.Mutex
125 paused bool
128 stopc chan struct{}
[all …]
|
| /dports/www/minio-client/etcd-3.5.0/server/etcdserver/api/rafthttp/ |
| H A D | peer.go | 101 type peer struct { struct
102 lg *zap.Logger
104 localID types.ID
106 id types.ID
108 r Raft
110 status *peerStatus
112 picker *urlPicker
124 mu sync.Mutex
125 paused bool
128 stopc chan struct{}
[all …]
|
| /dports/devel/etcd34/etcd-3.4.18/etcdserver/api/rafthttp/ |
| H A D | peer.go | 96 type peer struct { struct
97 lg *zap.Logger
99 localID types.ID
101 id types.ID
103 r Raft
105 status *peerStatus
107 picker *urlPicker
119 mu sync.Mutex
120 paused bool
123 stopc chan struct{}
[all …]
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/etcdserver/api/rafthttp/ |
| H A D | peer.go | 96 type peer struct { struct
97 lg *zap.Logger
99 localID types.ID
101 id types.ID
103 r Raft
105 status *peerStatus
107 picker *urlPicker
119 mu sync.Mutex
120 paused bool
123 stopc chan struct{}
[all …]
|
| /dports/net/yggdrasil/yggdrasil-go-0.3.11/src/yggdrasil/ |
| H A D | peer.go | 94 type peer struct { struct
95 phony.Inbox
96 core *Core
97 intf *linkInterface
98 port switchPort
99 box crypto.BoxPubKey
100 sig crypto.SigPubKey
103 endpoint string
111 bytesSent uint64
112 bytesRecvd uint64
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/wireguard/ |
| H A D | timers.c | 30 static inline void mod_peer_timer(struct wg_peer *peer, in mod_peer_timer()
43 struct wg_peer *peer = from_timer(peer, timer, in wg_expired_retransmit_handshake() local
124 struct wg_peer *peer = container_of(work, struct wg_peer, in wg_queued_expired_zero_key_material() local
137 struct wg_peer *peer = from_timer(peer, timer, in wg_expired_send_persistent_keepalive() local
145 void wg_timers_data_sent(struct wg_peer *peer) in wg_timers_data_sent()
154 void wg_timers_data_received(struct wg_peer *peer) in wg_timers_data_received()
182 void wg_timers_handshake_initiated(struct wg_peer *peer) in wg_timers_handshake_initiated()
192 void wg_timers_handshake_complete(struct wg_peer *peer) in wg_timers_handshake_complete()
203 void wg_timers_session_derived(struct wg_peer *peer) in wg_timers_session_derived()
219 void wg_timers_init(struct wg_peer *peer) in wg_timers_init()
[all …]
|