Home
last modified time | relevance | path

Searched refs:backlog (Results 1 – 25 of 9893) sorted by relevance

12345678910>>...396

/dports/net/kea/kea-2.0.1/src/hooks/dhcp/high_availability/tests/
H A Dlease_update_backlog_unittest.cc28 LeaseUpdateBacklog backlog(5); in TEST() local
38 EXPECT_FALSE(backlog.wasOverflown()); in TEST()
47 EXPECT_TRUE(backlog.wasOverflown()); in TEST()
52 auto lease = backlog.pop(op_type); in TEST()
60 EXPECT_TRUE(backlog.wasOverflown()); in TEST()
63 ASSERT_NO_THROW(backlog.clear()); in TEST()
64 EXPECT_FALSE(backlog.wasOverflown()); in TEST()
70 LeaseUpdateBacklog backlog(5); in TEST() local
82 EXPECT_EQ(3, backlog.size()); in TEST()
85 ASSERT_NO_THROW(backlog.clear()); in TEST()
[all …]
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/in_storage_backlog/
H A Dsb.c162 if (backlog == NULL) { in sb_allocate_backlogs()
182 struct sb_out_queue *backlog; in sb_destroy_backlogs() local
191 flb_free(backlog); in sb_destroy_backlogs()
200 struct sb_out_queue *backlog; in sb_find_segregated_backlog_by_output_plugin_instance() local
206 return backlog; in sb_find_segregated_backlog_by_output_plugin_instance()
242 struct sb_out_queue *backlog; in sb_remove_chunk_from_segregated_backlogs() local
279 struct sb_out_queue *backlog; in sb_append_chunk_to_segregated_backlogs() local
383 struct sb_out_queue *backlog; in sb_get_releasable_output_queue_space() local
395 if (backlog == NULL) { in sb_get_releasable_output_queue_space()
423 struct sb_out_queue *backlog; in sb_release_output_queue_space() local
[all …]
/dports/net/libunp/unpv12e/debug/
H A Dbacklog.c49 int backlog, j, k, junk, fd[MAXBACKLOG + 1]; in do_parent() local
54 for (backlog = 0; backlog <= 14; backlog++) { in do_parent()
55 printf("backlog = %d: ", backlog); in do_parent()
56 Write(pfd, &backlog, sizeof(int)); /* tell child value */ in do_parent()
75 backlog = -1; /* tell child we're all done */ in do_parent()
76 Write(pfd, &backlog, sizeof(int)); in do_parent()
82 int listenfd, backlog, junk; in do_child() local
87 Read(cfd, &backlog, sizeof(int)); /* wait for parent */ in do_child()
88 while (backlog >= 0) { in do_child()
92 Listen(listenfd, backlog); /* start the listen */ in do_child()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/crypto/ccp/
H A Dccp-crypto-main.c55 struct list_head *backlog; member
102 *backlog = NULL; in ccp_crypto_cmd_complete()
126 *backlog = container_of(req_queue.backlog, in ccp_crypto_cmd_complete()
128 req_queue.backlog = req_queue.backlog->next; in ccp_crypto_cmd_complete()
167 if (backlog) { in ccp_crypto_complete()
168 backlog->ret = -EINPROGRESS; in ccp_crypto_complete()
169 backlog->req->complete(backlog->req, -EINPROGRESS); in ccp_crypto_complete()
199 if (backlog) { in ccp_crypto_complete()
200 backlog->ret = -EINPROGRESS; in ccp_crypto_complete()
201 backlog->req->complete(backlog->req, -EINPROGRESS); in ccp_crypto_complete()
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/crypto/ccp/
H A Dccp-crypto-main.c55 struct list_head *backlog; member
102 *backlog = NULL; in ccp_crypto_cmd_complete()
126 *backlog = container_of(req_queue.backlog, in ccp_crypto_cmd_complete()
128 req_queue.backlog = req_queue.backlog->next; in ccp_crypto_cmd_complete()
167 if (backlog) { in ccp_crypto_complete()
168 backlog->ret = -EINPROGRESS; in ccp_crypto_complete()
169 backlog->req->complete(backlog->req, -EINPROGRESS); in ccp_crypto_complete()
199 if (backlog) { in ccp_crypto_complete()
200 backlog->ret = -EINPROGRESS; in ccp_crypto_complete()
201 backlog->req->complete(backlog->req, -EINPROGRESS); in ccp_crypto_complete()
[all …]
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/crypto/ccp/
H A Dccp-crypto-main.c55 struct list_head *backlog; member
102 *backlog = NULL; in ccp_crypto_cmd_complete()
126 *backlog = container_of(req_queue.backlog, in ccp_crypto_cmd_complete()
128 req_queue.backlog = req_queue.backlog->next; in ccp_crypto_cmd_complete()
167 if (backlog) { in ccp_crypto_complete()
168 backlog->ret = -EINPROGRESS; in ccp_crypto_complete()
169 backlog->req->complete(backlog->req, -EINPROGRESS); in ccp_crypto_complete()
199 if (backlog) { in ccp_crypto_complete()
200 backlog->ret = -EINPROGRESS; in ccp_crypto_complete()
201 backlog->req->complete(backlog->req, -EINPROGRESS); in ccp_crypto_complete()
[all …]
/dports/irc/quassel/quassel-0.14-rc2/src/core/
H A Dcorebacklogmanager.cpp38 QVariantList backlog; in requestBacklog() local
41 std::transform(msgList.cbegin(), msgList.cend(), std::back_inserter(backlog), [](auto&& msg) { in requestBacklog()
71 return backlog; in requestBacklog()
76 QVariantList backlog; in requestBacklogFiltered() local
109 return backlog; in requestBacklogFiltered()
114 QVariantList backlog; in requestBacklogForward() local
121 return backlog; in requestBacklogForward()
126 QVariantList backlog; in requestBacklogAll() local
152 return backlog; in requestBacklogAll()
157 QVariantList backlog; in requestBacklogAllFiltered() local
[all …]
/dports/irc/quassel-core/quassel-0.14-rc2/src/core/
H A Dcorebacklogmanager.cpp38 QVariantList backlog; in requestBacklog() local
41 std::transform(msgList.cbegin(), msgList.cend(), std::back_inserter(backlog), [](auto&& msg) { in requestBacklog()
71 return backlog; in requestBacklog()
76 QVariantList backlog; in requestBacklogFiltered() local
109 return backlog; in requestBacklogFiltered()
114 QVariantList backlog; in requestBacklogForward() local
121 return backlog; in requestBacklogForward()
126 QVariantList backlog; in requestBacklogAll() local
152 return backlog; in requestBacklogAll()
157 QVariantList backlog; in requestBacklogAllFiltered() local
[all …]
/dports/net/grpcui/grpcui-1.1.0/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/security/lego/lego-4.5.3/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/net/rclone/rclone-1.57.0/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/security/vault/vault-1.8.2/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/net/evans/evans-0.9.1/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/net/drive/drive-0.4.0/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-terraform/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/cli/cli-20.10.2/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/www/gohugo/hugo-0.91.2/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/sysutils/helmfile/helmfile-0.138.7/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-database-mongodbatlas/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-openldap/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-azure/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-ad/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/www/pomerium/pomerium-0.8.3/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-database-couchbase/vendor/google.golang.org/grpc/internal/buffer/
H A Dunbounded.go39 backlog []interface{} member
50 if len(b.backlog) == 0 {
58 b.backlog = append(b.backlog, t)
67 if len(b.backlog) > 0 {
69 case b.c <- b.backlog[0]:
70 b.backlog[0] = nil
71 b.backlog = b.backlog[1:]

12345678910>>...396