| /dports/devel/folly/folly-2021.12.27.00/folly/experimental/test/ |
| H A D | ReadMostlySharedPtrStressTest.cpp | 36 Data writerDone; in TEST_F() local
37 writerDone.lastValue.store(0, std::memory_order_relaxed); in TEST_F()
51 while (writerDone.lastValue.load(std::memory_order_acquire) != i) { in TEST_F()
63 writerDone.lastValue.store(i, std::memory_order_release); in TEST_F()
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/neilalexander/utp/cmd/ucat/ |
| H A D | ucat.go | 49 writerDone := make(chan struct{})
52 defer close(writerDone)
73 case <-writerDone:
|
| /dports/net/rclone/rclone-1.57.0/vendor/storj.io/common/sync2/ |
| H A D | tee.go | 105 writerDone bool member
145 if tee.writerDone {
176 if tee.writerDone {
231 if tee.writerDone {
235 tee.writerDone = true
|
| /dports/net/storj/storj-1.45.3/vendor/storj.io/common/sync2/ |
| H A D | tee.go | 105 writerDone bool member
145 if tee.writerDone {
176 if tee.writerDone {
231 if tee.writerDone {
235 tee.writerDone = true
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/ |
| H A D | TestFileConcurrentReader.java | 242 final AtomicBoolean writerDone = new AtomicBoolean(false); in runTestUnfinishedBlockCRCError() local
271 writerDone.set(true); in runTestUnfinishedBlockCRCError()
284 while (!writerDone.get() && !error.get()) { in runTestUnfinishedBlockCRCError()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/ |
| H A D | TestFileConcurrentReader.java | 336 final AtomicBoolean writerDone = new AtomicBoolean(false); in runTestUnfinishedBlockCRCError() local
365 writerDone.set(true); in runTestUnfinishedBlockCRCError()
378 while (!writerDone.get() && !error.get()) { in runTestUnfinishedBlockCRCError()
|
| /dports/biology/sra-tools/sra-tools-2.11.0/ncbi-vdb/libs/axf/ |
| H A D | range-list.c | 105 static void writerDone(RangeList *const list) in writerDone() function
117 writerDone(list); in updateRanges()
|
| /dports/biology/ncbi-vdb/ncbi-vdb-2.11.0/libs/axf/ |
| H A D | range-list.c | 105 static void writerDone(RangeList *const list) in writerDone() function
117 writerDone(list); in updateRanges()
|
| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 73 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
287 close(t.writerDone)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/consul/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 73 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
287 close(t.writerDone)
|
| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/prometheus/prometheus/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 68 writerDone chan struct{} // sync point to enable testing. member
211 writerDone: make(chan struct{}),
280 close(t.writerDone)
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/containerd/containerd/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 73 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
287 close(t.writerDone)
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 73 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
287 close(t.writerDone)
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 73 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
287 close(t.writerDone)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-auth-kerberos/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 73 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
287 close(t.writerDone)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-mongodbatlas/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 73 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
287 close(t.writerDone)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-gcpkms/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 73 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
287 close(t.writerDone)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-kv/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 73 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
287 close(t.writerDone)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-auth-cf/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 73 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
287 close(t.writerDone)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-auth-kubernetes/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 73 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
287 close(t.writerDone)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-auth-azure/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 73 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
287 close(t.writerDone)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-alicloud/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 73 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
287 close(t.writerDone)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-gcp/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 73 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
287 close(t.writerDone)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-auth-gcp/vendor/google.golang.org/grpc/internal/transport/ |
| H A D | http2_server.go | 73 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
287 close(t.writerDone)
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/vendor/google.golang.org/grpc/transport/ |
| H A D | http2_client.go | 58 writerDone chan struct{} // sync point to enable testing. member
217 writerDone: make(chan struct{}),
300 close(t.writerDone)
|