Home
last modified time | relevance | path

Searched refs:pollers (Results 1 – 25 of 573) sorted by relevance

12345678910>>...23

/dports/net/haproxy17/haproxy-1.7.14/src/
H A Dfd.c166 struct poller pollers[MAX_POLLERS]; variable
243 pollers[p].pref = 0; in disable_poller()
264 if (!bp || (pollers[p].pref > bp->pref)) in init_pollers()
265 bp = &pollers[p]; in init_pollers()
292 bp = &pollers[p]; in deinit_pollers()
324 next = pollers[p].pref; in list_pollers()
326 bp = &pollers[p]; in list_pollers()
334 if (pollers[p].pref == next) { in list_pollers()
336 if (pollers[p].pref == 0) in list_pollers()
340 if (pollers[p].test(&pollers[p])) { in list_pollers()
[all …]
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/armcore/internal/pollers/loc/
H A Dloc.go37 locURL := resp.Header.Get(pollers.HeaderLocation)
41 if !pollers.IsValidURL(locURL) {
45 Type: pollers.MakeID(pollerID, "loc"),
47 CurState: pollers.StatusInProgress,
59 return pollers.IsTerminalState(p.Status())
65 if h := resp.Header.Get(pollers.HeaderLocation); h != "" {
70 state, err := pollers.GetProvisioningState(resp)
71 if err != nil && !errors.Is(err, pollers.ErrNoBody) {
78 p.CurState = pollers.StatusSucceeded
81 p.CurState = pollers.StatusSucceeded
[all …]
/dports/sysutils/restic/restic-0.12.1/vendor/github.com/Azure/azure-sdk-for-go/sdk/armcore/internal/pollers/loc/
H A Dloc.go37 locURL := resp.Header.Get(pollers.HeaderLocation)
41 if !pollers.IsValidURL(locURL) {
45 Type: pollers.MakeID(pollerID, "loc"),
47 CurState: pollers.StatusInProgress,
59 return pollers.IsTerminalState(p.Status())
65 if h := resp.Header.Get(pollers.HeaderLocation); h != "" {
70 state, err := pollers.GetProvisioningState(resp)
71 if err != nil && !errors.Is(err, pollers.ErrNoBody) {
78 p.CurState = pollers.StatusSucceeded
81 p.CurState = pollers.StatusSucceeded
[all …]
/dports/www/grafana8/azure-sdk-for-go-sdk-internal-v0.7.0/sdk/armcore/internal/pollers/loc/
H A Dloc.go37 locURL := resp.Header.Get(pollers.HeaderLocation)
41 if !pollers.IsValidURL(locURL) {
45 Type: pollers.MakeID(pollerID, "loc"),
47 CurState: pollers.StatusInProgress,
59 return pollers.IsTerminalState(p.Status())
65 if h := resp.Header.Get(pollers.HeaderLocation); h != "" {
70 state, err := pollers.GetProvisioningState(resp)
71 if err != nil && !errors.Is(err, pollers.ErrNoBody) {
78 p.CurState = pollers.StatusSucceeded
81 p.CurState = pollers.StatusSucceeded
[all …]
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/armcore/internal/pollers/body/
H A Dbody.go40 Type: pollers.MakeID(pollerID, "body"),
45 curState := pollers.StatusInProgress
46 provState, err := pollers.GetProvisioningState(resp)
47 if err != nil && !errors.Is(err, pollers.ErrNoBody) {
58 curState = pollers.StatusSucceeded
61 curState = pollers.StatusSucceeded
74 return pollers.IsTerminalState(p.Status())
80 p.CurState = pollers.StatusSucceeded
83 state, err := pollers.GetProvisioningState(resp)
84 if errors.Is(err, pollers.ErrNoBody) {
[all …]
/dports/sysutils/restic/restic-0.12.1/vendor/github.com/Azure/azure-sdk-for-go/sdk/armcore/internal/pollers/body/
H A Dbody.go40 Type: pollers.MakeID(pollerID, "body"),
45 curState := pollers.StatusInProgress
46 provState, err := pollers.GetProvisioningState(resp)
47 if err != nil && !errors.Is(err, pollers.ErrNoBody) {
58 curState = pollers.StatusSucceeded
61 curState = pollers.StatusSucceeded
74 return pollers.IsTerminalState(p.Status())
80 p.CurState = pollers.StatusSucceeded
83 state, err := pollers.GetProvisioningState(resp)
84 if errors.Is(err, pollers.ErrNoBody) {
[all …]
/dports/www/grafana8/azure-sdk-for-go-sdk-internal-v0.7.0/sdk/armcore/internal/pollers/body/
H A Dbody.go40 Type: pollers.MakeID(pollerID, "body"),
45 curState := pollers.StatusInProgress
46 provState, err := pollers.GetProvisioningState(resp)
47 if err != nil && !errors.Is(err, pollers.ErrNoBody) {
58 curState = pollers.StatusSucceeded
61 curState = pollers.StatusSucceeded
74 return pollers.IsTerminalState(p.Status())
80 p.CurState = pollers.StatusSucceeded
83 state, err := pollers.GetProvisioningState(resp)
84 if errors.Is(err, pollers.ErrNoBody) {
[all …]
/dports/www/grafana8/azure-sdk-for-go-sdk-azidentity-v0.10.0/sdk/azcore/runtime/
H A Dpoller.go24 …esp *http.Response, pl pipeline.Pipeline, eu func(*http.Response) error) (*pollers.Poller, error) {
27 if !pollers.StatusCodeValid(resp) {
31 var lro pollers.Operation
39 lro = &pollers.NopPoller{}
44 return pollers.NewPoller(lro, resp, pl, eu), nil
49 …ring, token string, pl pipeline.Pipeline, eu func(*http.Response) error) (*pollers.Poller, error) {
50 kind, err := pollers.KindFromToken(pollerID, token)
55 var lro pollers.Operation
69 return pollers.NewPoller(lro, nil, pl, eu), nil
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/azcore/runtime/
H A Dpoller.go24 …esp *http.Response, pl pipeline.Pipeline, eu func(*http.Response) error) (*pollers.Poller, error) {
27 if !pollers.StatusCodeValid(resp) {
31 var lro pollers.Operation
39 lro = &pollers.NopPoller{}
44 return pollers.NewPoller(lro, resp, pl, eu), nil
49 …ring, token string, pl pipeline.Pipeline, eu func(*http.Response) error) (*pollers.Poller, error) {
50 kind, err := pollers.KindFromToken(pollerID, token)
55 var lro pollers.Operation
69 return pollers.NewPoller(lro, nil, pl, eu), nil
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/Azure/azure-sdk-for-go/sdk/azcore/runtime/
H A Dpoller.go24 …esp *http.Response, pl pipeline.Pipeline, eu func(*http.Response) error) (*pollers.Poller, error) {
27 if !pollers.StatusCodeValid(resp) {
31 var lro pollers.Operation
39 lro = &pollers.NopPoller{}
44 return pollers.NewPoller(lro, resp, pl, eu), nil
49 …ring, token string, pl pipeline.Pipeline, eu func(*http.Response) error) (*pollers.Poller, error) {
50 kind, err := pollers.KindFromToken(pollerID, token)
55 var lro pollers.Operation
69 return pollers.NewPoller(lro, nil, pl, eu), nil
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/armcore/internal/pollers/async/
H A Dasync.go25 return resp.Header.Get(pollers.HeaderAzureAsync) != ""
55 asyncURL := resp.Header.Get(pollers.HeaderAzureAsync)
59 if !pollers.IsValidURL(asyncURL) {
63 Type: pollers.MakeID(pollerID, "async"),
65 LocURL: resp.Header.Get(pollers.HeaderLocation),
71 state, err := pollers.GetProvisioningState(resp)
72 if errors.Is(err, pollers.ErrNoBody) || state == "" {
81 state = pollers.StatusInProgress
91 return pollers.IsTerminalState(p.Status())
96 state, err := pollers.GetStatus(resp)
/dports/sysutils/restic/restic-0.12.1/vendor/github.com/Azure/azure-sdk-for-go/sdk/armcore/internal/pollers/async/
H A Dasync.go25 return resp.Header.Get(pollers.HeaderAzureAsync) != ""
55 asyncURL := resp.Header.Get(pollers.HeaderAzureAsync)
59 if !pollers.IsValidURL(asyncURL) {
63 Type: pollers.MakeID(pollerID, "async"),
65 LocURL: resp.Header.Get(pollers.HeaderLocation),
71 state, err := pollers.GetProvisioningState(resp)
72 if errors.Is(err, pollers.ErrNoBody) || state == "" {
81 state = pollers.StatusInProgress
91 return pollers.IsTerminalState(p.Status())
96 state, err := pollers.GetStatus(resp)
/dports/www/grafana8/azure-sdk-for-go-sdk-internal-v0.7.0/sdk/armcore/internal/pollers/async/
H A Dasync.go25 return resp.Header.Get(pollers.HeaderAzureAsync) != ""
55 asyncURL := resp.Header.Get(pollers.HeaderAzureAsync)
59 if !pollers.IsValidURL(asyncURL) {
63 Type: pollers.MakeID(pollerID, "async"),
65 LocURL: resp.Header.Get(pollers.HeaderLocation),
71 state, err := pollers.GetProvisioningState(resp)
72 if errors.Is(err, pollers.ErrNoBody) || state == "" {
81 state = pollers.StatusInProgress
91 return pollers.IsTerminalState(p.Status())
96 state, err := pollers.GetStatus(resp)
/dports/net/haproxy18/haproxy-1.8.30/src/
H A Dfd.c167 struct poller pollers[MAX_POLLERS]; variable
301 pollers[p].pref = 0; in disable_poller()
352 if (!bp || (pollers[p].pref > bp->pref)) in init_pollers()
353 bp = &pollers[p]; in init_pollers()
385 bp = &pollers[p]; in deinit_pollers()
420 next = pollers[p].pref; in list_pollers()
422 bp = &pollers[p]; in list_pollers()
430 if (pollers[p].pref == next) { in list_pollers()
432 if (pollers[p].pref == 0) in list_pollers()
436 if (pollers[p].test(&pollers[p])) { in list_pollers()
[all …]
/dports/www/grafana8/azure-sdk-for-go-sdk-azidentity-v0.10.0/sdk/azcore/arm/runtime/
H A Dpoller.go25 …esp *http.Response, pl pipeline.Pipeline, eu func(*http.Response) error) (*pollers.Poller, error) {
28 if !pollers.StatusCodeValid(resp) {
32 var lro pollers.Operation
47 lro = &pollers.NopPoller{}
52 return pollers.NewPoller(lro, resp, pl, eu), nil
57 …ring, token string, pl pipeline.Pipeline, eu func(*http.Response) error) (*pollers.Poller, error) {
58 kind, err := pollers.KindFromToken(pollerID, token)
63 var lro pollers.Operation
80 return pollers.NewPoller(lro, nil, pl, eu), nil
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/azcore/arm/runtime/
H A Dpoller.go25 …esp *http.Response, pl pipeline.Pipeline, eu func(*http.Response) error) (*pollers.Poller, error) {
28 if !pollers.StatusCodeValid(resp) {
32 var lro pollers.Operation
47 lro = &pollers.NopPoller{}
52 return pollers.NewPoller(lro, resp, pl, eu), nil
57 …ring, token string, pl pipeline.Pipeline, eu func(*http.Response) error) (*pollers.Poller, error) {
58 kind, err := pollers.KindFromToken(pollerID, token)
63 var lro pollers.Operation
80 return pollers.NewPoller(lro, nil, pl, eu), nil
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/Azure/azure-sdk-for-go/sdk/azcore/arm/runtime/
H A Dpoller.go25 …esp *http.Response, pl pipeline.Pipeline, eu func(*http.Response) error) (*pollers.Poller, error) {
28 if !pollers.StatusCodeValid(resp) {
32 var lro pollers.Operation
47 lro = &pollers.NopPoller{}
52 return pollers.NewPoller(lro, resp, pl, eu), nil
57 …ring, token string, pl pipeline.Pipeline, eu func(*http.Response) error) (*pollers.Poller, error) {
58 kind, err := pollers.KindFromToken(pollerID, token)
63 var lro pollers.Operation
80 return pollers.NewPoller(lro, nil, pl, eu), nil
/dports/devel/efl/efl-1.25.1/src/lib/ecore/
H A Decore_poller.c40 static Ecore_Poller *pollers[16] = variable
60 …pollers[poller->ibit] = (Ecore_Poller *)eina_inlist_remove(EINA_INLIST_GET(pollers[poller->ibit]),… in _ecore_poller_cleanup()
76 if (pollers[i]) in _ecore_poller_next_tick_eval()
154 EINA_INLIST_FOREACH(pollers[i], poller) in _ecore_poller_cb_timer()
180 EINA_INLIST_FOREACH_SAFE(pollers[i], l, poller) in _ecore_poller_cb_timer()
272 …pollers[poller->ibit] = (Ecore_Poller *)eina_inlist_prepend(EINA_INLIST_GET(pollers[poller->ibit])… in ecore_poller_add()
302 …pollers[poller->ibit] = (Ecore_Poller *)eina_inlist_remove(EINA_INLIST_GET(pollers[poller->ibit]),… in ecore_poller_poller_interval_set()
304 …pollers[poller->ibit] = (Ecore_Poller *)eina_inlist_prepend(EINA_INLIST_GET(pollers[poller->ibit])… in ecore_poller_poller_interval_set()
363 while ((poller = pollers[i])) in _ecore_poller_shutdown()
/dports/www/grafana8/azure-sdk-for-go-sdk-azidentity-v0.10.0/sdk/azcore/arm/internal/pollers/body/
H A Dbody.go46 Type: pollers.MakeID(pollerID, Kind),
51 curState := pollers.StatusInProgress
64 curState = pollers.StatusSucceeded
67 curState = pollers.StatusSucceeded
80 return pollers.IsTerminalState(p.Status())
86 p.CurState = pollers.StatusSucceeded
95 state = pollers.StatusSucceeded
/dports/www/grafana8/azure-sdk-for-go-sdk-azidentity-v0.10.0/sdk/azcore/arm/internal/pollers/loc/
H A Dloc.go48 if !pollers.IsValidURL(locURL) {
52 Type: pollers.MakeID(pollerID, Kind),
54 CurState: pollers.StatusInProgress,
66 return pollers.IsTerminalState(p.Status())
85 p.CurState = pollers.StatusSucceeded
88 p.CurState = pollers.StatusSucceeded
90 p.CurState = pollers.StatusFailed
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/azcore/arm/internal/pollers/body/
H A Dbody.go46 Type: pollers.MakeID(pollerID, Kind),
51 curState := pollers.StatusInProgress
64 curState = pollers.StatusSucceeded
67 curState = pollers.StatusSucceeded
80 return pollers.IsTerminalState(p.Status())
86 p.CurState = pollers.StatusSucceeded
95 state = pollers.StatusSucceeded
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/azcore/arm/internal/pollers/loc/
H A Dloc.go48 if !pollers.IsValidURL(locURL) {
52 Type: pollers.MakeID(pollerID, Kind),
54 CurState: pollers.StatusInProgress,
66 return pollers.IsTerminalState(p.Status())
85 p.CurState = pollers.StatusSucceeded
88 p.CurState = pollers.StatusSucceeded
90 p.CurState = pollers.StatusFailed
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/Azure/azure-sdk-for-go/sdk/azcore/arm/internal/pollers/body/
H A Dbody.go46 Type: pollers.MakeID(pollerID, Kind),
51 curState := pollers.StatusInProgress
64 curState = pollers.StatusSucceeded
67 curState = pollers.StatusSucceeded
80 return pollers.IsTerminalState(p.Status())
86 p.CurState = pollers.StatusSucceeded
95 state = pollers.StatusSucceeded
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/Azure/azure-sdk-for-go/sdk/azcore/arm/internal/pollers/loc/
H A Dloc.go48 if !pollers.IsValidURL(locURL) {
52 Type: pollers.MakeID(pollerID, Kind),
54 CurState: pollers.StatusInProgress,
66 return pollers.IsTerminalState(p.Status())
85 p.CurState = pollers.StatusSucceeded
88 p.CurState = pollers.StatusSucceeded
90 p.CurState = pollers.StatusFailed
/dports/net/haproxy19/haproxy-1.9.16/src/
H A Dfd.c168 struct poller pollers[MAX_POLLERS]; variable
474 pollers[p].pref = 0; in disable_poller()
554 if (!bp || (pollers[p].pref > bp->pref)) in init_pollers()
555 bp = &pollers[p]; in init_pollers()
587 bp = &pollers[p]; in deinit_pollers()
618 next = pollers[p].pref; in list_pollers()
620 bp = &pollers[p]; in list_pollers()
628 if (pollers[p].pref == next) { in list_pollers()
630 if (pollers[p].pref == 0) in list_pollers()
634 if (pollers[p].test(&pollers[p])) { in list_pollers()
[all …]

12345678910>>...23