/dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/draft/ |
H A D | polling.go | 20 type Poller struct { struct 21 items []C.zmq_pollitem_t 22 socks []*Socket 39 func (p *Poller) Add(soc *Socket, events State) int { 54 func (p *Poller) Update(id int, events State) (previous State, err error) { 82 func (p *Poller) Remove(id int) error { 99 func (p *Poller) RemoveBySocket(soc *Socket) error { 135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) { 149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) { 153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) { [all …]
|
/dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/ |
H A D | polling.go | 20 type Poller struct { struct 21 items []C.zmq_pollitem_t 22 socks []*Socket 39 func (p *Poller) Add(soc *Socket, events State) int { 54 func (p *Poller) Update(id int, events State) (previous State, err error) { 82 func (p *Poller) Remove(id int) error { 99 func (p *Poller) RemoveBySocket(soc *Socket) error { 135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) { 149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) { 153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) { [all …]
|
/dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/draft/ |
H A D | polling.go | 20 type Poller struct { struct 21 items []C.zmq_pollitem_t 22 socks []*Socket 39 func (p *Poller) Add(soc *Socket, events State) int { 54 func (p *Poller) Update(id int, events State) (previous State, err error) { 82 func (p *Poller) Remove(id int) error { 99 func (p *Poller) RemoveBySocket(soc *Socket) error { 135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) { 149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) { 153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) { [all …]
|
/dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/ |
H A D | polling.go | 20 type Poller struct { struct 21 items []C.zmq_pollitem_t 22 socks []*Socket 39 func (p *Poller) Add(soc *Socket, events State) int { 54 func (p *Poller) Update(id int, events State) (previous State, err error) { 82 func (p *Poller) Remove(id int) error { 99 func (p *Poller) RemoveBySocket(soc *Socket) error { 135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) { 149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) { 153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) { [all …]
|
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/ |
H A D | polling.go | 20 type Poller struct { struct 21 items []C.zmq_pollitem_t 22 socks []*Socket 39 func (p *Poller) Add(soc *Socket, events State) int { 54 func (p *Poller) Update(id int, events State) (previous State, err error) { 82 func (p *Poller) Remove(id int) error { 99 func (p *Poller) RemoveBySocket(soc *Socket) error { 135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) { 149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) { 153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) { [all …]
|
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/draft/ |
H A D | polling.go | 20 type Poller struct { struct 21 items []C.zmq_pollitem_t 22 socks []*Socket 39 func (p *Poller) Add(soc *Socket, events State) int { 54 func (p *Poller) Update(id int, events State) (previous State, err error) { 82 func (p *Poller) Remove(id int) error { 99 func (p *Poller) RemoveBySocket(soc *Socket) error { 135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) { 149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) { 153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) { [all …]
|
/dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/ |
H A D | polling.go | 20 type Poller struct { struct 21 items []C.zmq_pollitem_t 22 socks []*Socket 39 func (p *Poller) Add(soc *Socket, events State) int { 54 func (p *Poller) Update(id int, events State) (previous State, err error) { 82 func (p *Poller) Remove(id int) error { 99 func (p *Poller) RemoveBySocket(soc *Socket) error { 135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) { 149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) { 153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) { [all …]
|
/dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/draft/ |
H A D | polling.go | 20 type Poller struct { struct 21 items []C.zmq_pollitem_t 22 socks []*Socket 39 func (p *Poller) Add(soc *Socket, events State) int { 54 func (p *Poller) Update(id int, events State) (previous State, err error) { 82 func (p *Poller) Remove(id int) error { 99 func (p *Poller) RemoveBySocket(soc *Socket) error { 135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) { 149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) { 153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) { [all …]
|
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/armcore/internal/pollers/async/ |
H A D | async.go | 29 type Poller struct { struct 31 Type string `json:"type"` 34 AsyncURL string `json:"asyncURL"` 37 LocURL string `json:"locURL"` 40 OrigURL string `json:"origURL"` 43 Method string `json:"method"` 46 FinalState string `json:"finalState"` 49 CurState string `json:"state"` 90 func (p *Poller) Done() bool { 126 func (p *Poller) URL() string { [all …]
|
/dports/sysutils/restic/restic-0.12.1/vendor/github.com/Azure/azure-sdk-for-go/sdk/armcore/internal/pollers/async/ |
H A D | async.go | 29 type Poller struct { struct 31 Type string `json:"type"` 34 AsyncURL string `json:"asyncURL"` 37 LocURL string `json:"locURL"` 40 OrigURL string `json:"origURL"` 43 Method string `json:"method"` 46 FinalState string `json:"finalState"` 49 CurState string `json:"state"` 90 func (p *Poller) Done() bool { 126 func (p *Poller) URL() string { [all …]
|
/dports/www/grafana8/azure-sdk-for-go-sdk-internal-v0.7.0/sdk/armcore/internal/pollers/async/ |
H A D | async.go | 29 type Poller struct { struct 31 Type string `json:"type"` 34 AsyncURL string `json:"asyncURL"` 37 LocURL string `json:"locURL"` 40 OrigURL string `json:"origURL"` 43 Method string `json:"method"` 46 FinalState string `json:"finalState"` 49 CurState string `json:"state"` 90 func (p *Poller) Done() bool { 126 func (p *Poller) URL() string { [all …]
|
/dports/www/grafana8/azure-sdk-for-go-sdk-azidentity-v0.10.0/sdk/azcore/internal/pollers/ |
H A D | poller.go | 53 func PollerType(p *Poller) reflect.Type { 63 type Poller struct { struct 64 lro Operation 65 pl pipeline.Pipeline 66 eu func(*http.Response) error 67 resp *http.Response 68 err error 72 func (l *Poller) Done() bool { 80 func (l *Poller) Poll(ctx context.Context) (*http.Response, error) { 118 func (l *Poller) ResumeToken() (string, error) { [all …]
|
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/azcore/internal/pollers/ |
H A D | poller.go | 53 func PollerType(p *Poller) reflect.Type { 63 type Poller struct { struct 64 lro Operation 65 pl pipeline.Pipeline 66 eu func(*http.Response) error 67 resp *http.Response 68 err error 72 func (l *Poller) Done() bool { 80 func (l *Poller) Poll(ctx context.Context) (*http.Response, error) { 118 func (l *Poller) ResumeToken() (string, error) { [all …]
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/Azure/azure-sdk-for-go/sdk/azcore/internal/pollers/ |
H A D | poller.go | 53 func PollerType(p *Poller) reflect.Type { 63 type Poller struct { struct 64 lro Operation 65 pl pipeline.Pipeline 66 eu func(*http.Response) error 67 resp *http.Response 68 err error 72 func (l *Poller) Done() bool { 80 func (l *Poller) Poll(ctx context.Context) (*http.Response, error) { 118 func (l *Poller) ResumeToken() (string, error) { [all …]
|
/dports/www/grafana8/azure-sdk-for-go-sdk-azidentity-v0.10.0/sdk/azcore/arm/internal/pollers/async/ |
H A D | async.go | 35 type Poller struct { struct 37 Type string `json:"type"` 40 AsyncURL string `json:"asyncURL"` 43 LocURL string `json:"locURL"` 46 OrigURL string `json:"origURL"` 49 Method string `json:"method"` 52 FinalState string `json:"finalState"` 55 CurState string `json:"state"` 96 func (p *Poller) Done() bool { 132 func (p *Poller) URL() string { [all …]
|
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/azcore/arm/internal/pollers/async/ |
H A D | async.go | 35 type Poller struct { struct 37 Type string `json:"type"` 40 AsyncURL string `json:"asyncURL"` 43 LocURL string `json:"locURL"` 46 OrigURL string `json:"origURL"` 49 Method string `json:"method"` 52 FinalState string `json:"finalState"` 55 CurState string `json:"state"` 96 func (p *Poller) Done() bool { 132 func (p *Poller) URL() string { [all …]
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/Azure/azure-sdk-for-go/sdk/azcore/arm/internal/pollers/async/ |
H A D | async.go | 35 type Poller struct { struct 37 Type string `json:"type"` 40 AsyncURL string `json:"asyncURL"` 43 LocURL string `json:"locURL"` 46 OrigURL string `json:"origURL"` 49 Method string `json:"method"` 52 FinalState string `json:"finalState"` 55 CurState string `json:"state"` 96 func (p *Poller) Done() bool { 132 func (p *Poller) URL() string { [all …]
|
/dports/sysutils/sensu-go/sensu-go-5.11.1/vendor/github.com/libp2p/go-reuseport/poll/ |
H A D | poll_linux.go | 13 type Poller struct { struct 14 epfd int 16 eventMain unix.EpollEvent 17 eventWait unix.EpollEvent 18 events []unix.EpollEvent 20 wake *eventfd.EventFD // Use eventfd to wakeup epoll 21 wakeMutex sync.Mutex 57 func (p *Poller) Close() error { 73 func (p *Poller) WaitWriteCtx(ctx context.Context) error {
|
/dports/www/grafana8/azure-sdk-for-go-sdk-azidentity-v0.10.0/sdk/azcore/internal/pollers/op/ |
H A D | op.go | 28 type Poller struct { struct 29 Type string `json:"type"` 30 PollURL string `json:"pollURL"` 31 LocURL string `json:"locURL"` 32 FinalGET string `json:"finalGET"` 33 CurState string `json:"state"` 79 func (p *Poller) URL() string { 83 func (p *Poller) Done() bool { 87 func (p *Poller) Update(resp *http.Response) error { 109 func (p *Poller) FinalGetURL() string { [all …]
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/Azure/azure-sdk-for-go/sdk/azcore/internal/pollers/op/ |
H A D | op.go | 28 type Poller struct { struct 29 Type string `json:"type"` 30 PollURL string `json:"pollURL"` 31 LocURL string `json:"locURL"` 32 FinalGET string `json:"finalGET"` 33 CurState string `json:"state"` 79 func (p *Poller) URL() string { 83 func (p *Poller) Done() bool { 87 func (p *Poller) Update(resp *http.Response) error { 109 func (p *Poller) FinalGetURL() string { [all …]
|
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/azcore/internal/pollers/op/ |
H A D | op.go | 28 type Poller struct { struct 29 Type string `json:"type"` 30 PollURL string `json:"pollURL"` 31 LocURL string `json:"locURL"` 32 FinalGET string `json:"finalGET"` 33 CurState string `json:"state"` 79 func (p *Poller) URL() string { 83 func (p *Poller) Done() bool { 87 func (p *Poller) Update(resp *http.Response) error { 109 func (p *Poller) FinalGetURL() string { [all …]
|
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/armcore/internal/pollers/loc/ |
H A D | loc.go | 23 type Poller struct { struct 25 Type string `json:"type"` 28 PollURL string `json:"pollURL"` 31 CurState string `json:"state"` 53 func (p *Poller) URL() string { 58 func (p *Poller) Done() bool { 63 func (p *Poller) Update(resp *azcore.Response) error { 90 func (p *Poller) FinalGetURL() string { 95 func (p *Poller) Status() string {
|
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/armcore/internal/pollers/body/ |
H A D | body.go | 25 type Poller struct { struct 27 Type string `json:"type"` 30 PollURL string `json:"pollURL"` 33 CurState string `json:"state"` 68 func (p *Poller) URL() string { 73 func (p *Poller) Done() bool { 78 func (p *Poller) Update(resp *azcore.Response) error { 98 func (*Poller) FinalGetURL() string { 103 func (p *Poller) Status() string {
|
/dports/sysutils/restic/restic-0.12.1/vendor/github.com/Azure/azure-sdk-for-go/sdk/armcore/internal/pollers/body/ |
H A D | body.go | 25 type Poller struct { struct 27 Type string `json:"type"` 30 PollURL string `json:"pollURL"` 33 CurState string `json:"state"` 68 func (p *Poller) URL() string { 73 func (p *Poller) Done() bool { 78 func (p *Poller) Update(resp *azcore.Response) error { 98 func (*Poller) FinalGetURL() string { 103 func (p *Poller) Status() string {
|
/dports/sysutils/restic/restic-0.12.1/vendor/github.com/Azure/azure-sdk-for-go/sdk/armcore/internal/pollers/loc/ |
H A D | loc.go | 23 type Poller struct { struct 25 Type string `json:"type"` 28 PollURL string `json:"pollURL"` 31 CurState string `json:"state"` 53 func (p *Poller) URL() string { 58 func (p *Poller) Done() bool { 63 func (p *Poller) Update(resp *azcore.Response) error { 90 func (p *Poller) FinalGetURL() string { 95 func (p *Poller) Status() string {
|