| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/hashicorp/go-plugin/ |
| H A D | server_test.go | 22 closeCh := make(chan struct{})
30 CloseCh: closeCh,
76 <-closeCh
152 closeCh := make(chan struct{})
185 CloseCh: closeCh,
203 <-closeCh
|
| /dports/sysutils/terraform-docs/terraform-docs-0.16.0/vendor/github.com/hashicorp/go-plugin/ |
| H A D | server_test.go | 22 closeCh := make(chan struct{})
30 CloseCh: closeCh,
76 <-closeCh
152 closeCh := make(chan struct{})
185 CloseCh: closeCh,
203 <-closeCh
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/aliyun/aliyun-tablestore-go-sdk/tunnel/ |
| H A D | state.go | 22 closeCh chan struct{} member
44 closeCh: make(chan struct{}),
62 case <-s.closeCh:
70 case <-s.closeCh:
85 case <-s.closeCh:
92 close(s.closeCh)
111 case <-s.closeCh:
|
| /dports/www/gitea/gitea-1.16.5/vendor/github.com/blevesearch/zapx/v14/ |
| H A D | merge.go | 40 closeCh chan struct{}, s seg.StatsReporter) (
78 MergeToWriter(segmentBases, drops, chunkMode, cr, closeCh)
126 if isClosed(closeCh) {
132 fieldsMap, fieldsInv, fieldsSame, numDocs, cr, closeCh)
139 newDocNums, numDocs, chunkMode, cr, closeCh)
218 if isClosed(closeCh) {
300 if isClosed(closeCh) {
401 if isClosed(closeCh) {
620 if isClosed(closeCh) {
836 func isClosed(closeCh chan struct{}) bool {
[all …]
|
| /dports/www/gitea/gitea-1.16.5/vendor/github.com/blevesearch/zapx/v13/ |
| H A D | merge.go | 40 closeCh chan struct{}, s seg.StatsReporter) (
78 MergeToWriter(segmentBases, drops, chunkMode, cr, closeCh)
126 if isClosed(closeCh) {
132 fieldsMap, fieldsInv, fieldsSame, numDocs, cr, closeCh)
139 newDocNums, numDocs, chunkMode, cr, closeCh)
218 if isClosed(closeCh) {
300 if isClosed(closeCh) {
401 if isClosed(closeCh) {
620 if isClosed(closeCh) {
836 func isClosed(closeCh chan struct{}) bool {
[all …]
|
| /dports/www/gitea/gitea-1.16.5/vendor/github.com/blevesearch/zapx/v12/ |
| H A D | merge.go | 40 closeCh chan struct{}, s seg.StatsReporter) (
78 MergeToWriter(segmentBases, drops, chunkMode, cr, closeCh)
126 if isClosed(closeCh) {
132 fieldsMap, fieldsInv, fieldsSame, numDocs, cr, closeCh)
139 newDocNums, numDocs, chunkMode, cr, closeCh)
218 if isClosed(closeCh) {
300 if isClosed(closeCh) {
401 if isClosed(closeCh) {
620 if isClosed(closeCh) {
836 func isClosed(closeCh chan struct{}) bool {
[all …]
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/vendor/github.com/blevesearch/zap/v13/ |
| H A D | merge.go | 40 closeCh chan struct{}, s seg.StatsReporter) (
79 MergeToWriter(segmentBases, drops, chunkMode, cr, closeCh)
127 if isClosed(closeCh) {
133 fieldsMap, fieldsInv, fieldsSame, numDocs, cr, closeCh)
140 newDocNums, numDocs, chunkMode, cr, closeCh)
222 if isClosed(closeCh) {
304 if isClosed(closeCh) {
405 if isClosed(closeCh) {
624 if isClosed(closeCh) {
840 func isClosed(closeCh chan struct{}) bool {
[all …]
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/vendor/github.com/blevesearch/zap/v14/ |
| H A D | merge.go | 40 closeCh chan struct{}, s seg.StatsReporter) (
79 MergeToWriter(segmentBases, drops, chunkMode, cr, closeCh)
127 if isClosed(closeCh) {
133 fieldsMap, fieldsInv, fieldsSame, numDocs, cr, closeCh)
140 newDocNums, numDocs, chunkMode, cr, closeCh)
222 if isClosed(closeCh) {
304 if isClosed(closeCh) {
405 if isClosed(closeCh) {
624 if isClosed(closeCh) {
840 func isClosed(closeCh chan struct{}) bool {
[all …]
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/vendor/github.com/blevesearch/zap/v12/ |
| H A D | merge.go | 40 closeCh chan struct{}, s seg.StatsReporter) (
79 MergeToWriter(segmentBases, drops, chunkMode, cr, closeCh)
127 if isClosed(closeCh) {
133 fieldsMap, fieldsInv, fieldsSame, numDocs, cr, closeCh)
140 newDocNums, numDocs, chunkMode, cr, closeCh)
222 if isClosed(closeCh) {
304 if isClosed(closeCh) {
405 if isClosed(closeCh) {
624 if isClosed(closeCh) {
840 func isClosed(closeCh chan struct{}) bool {
[all …]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | listener_wrapper_test.go | 116 closeCh *testutils.Channel member
125 fl.closeCh.Send(nil)
140 closeCh *testutils.Channel member
152 fc.closeCh.Send(nil)
163 closeCh: testutils.NewChannel(),
307 closeCh: testutils.NewChannel(),
310 if _, err := fc.closeCh.Receive(ctx); err != nil {
319 closeCh: testutils.NewChannel(),
|
| /dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | listener_wrapper_test.go | 116 closeCh *testutils.Channel member
125 fl.closeCh.Send(nil)
140 closeCh *testutils.Channel member
152 fc.closeCh.Send(nil)
163 closeCh: testutils.NewChannel(),
307 closeCh: testutils.NewChannel(),
310 if _, err := fc.closeCh.Receive(ctx); err != nil {
319 closeCh: testutils.NewChannel(),
|
| /dports/sysutils/terraform-docs/terraform-docs-0.16.0/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | listener_wrapper_test.go | 116 closeCh *testutils.Channel member
125 fl.closeCh.Send(nil)
140 closeCh *testutils.Channel member
152 fc.closeCh.Send(nil)
163 closeCh: testutils.NewChannel(),
307 closeCh: testutils.NewChannel(),
310 if _, err := fc.closeCh.Receive(ctx); err != nil {
319 closeCh: testutils.NewChannel(),
|
| /dports/sysutils/restic/restic-0.12.1/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | listener_wrapper_test.go | 116 closeCh *testutils.Channel member
125 fl.closeCh.Send(nil)
140 closeCh *testutils.Channel member
152 fc.closeCh.Send(nil)
163 closeCh: testutils.NewChannel(),
307 closeCh: testutils.NewChannel(),
310 if _, err := fc.closeCh.Receive(ctx); err != nil {
319 closeCh: testutils.NewChannel(),
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/centrifugal/centrifuge/_examples/custom_ws_gobwas/ |
| H A D | transport.go | 19 closeCh chan struct{} member
29 closeCh: make(chan struct{}),
76 case <-t.closeCh:
97 case <-t.closeCh:
125 close(t.closeCh)
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/centrifugal/centrifuge/_examples/ws_benchmarks/benchmark_gobwas/ |
| H A D | transport.go | 19 closeCh chan struct{} member
29 closeCh: make(chan struct{}),
74 case <-t.closeCh:
95 case <-t.closeCh:
123 close(t.closeCh)
|
| /dports/audio/pms-devel/pms-c94e3c6/vendor/github.com/blevesearch/bleve/index/scorch/ |
| H A D | merge.go | 44 case <-s.closeCh:
79 case <-s.closeCh:
86 case <-s.closeCh:
190 case <-s.closeCh:
198 case <-s.closeCh:
270 case <-s.closeCh:
277 case <-s.closeCh:
|
| /dports/net/rclone/rclone-1.57.0/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | listener_wrapper_test.go | 125 closeCh *testutils.Channel member
137 fl.closeCh.Send(nil)
152 closeCh *testutils.Channel member
164 fc.closeCh.Send(nil)
175 closeCh: testutils.NewChannel(),
320 closeCh: testutils.NewChannel(),
323 if _, err := fc.closeCh.Receive(ctx); err != nil {
332 closeCh: testutils.NewChannel(),
|
| /dports/net/drive/drive-0.4.0/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | listener_wrapper_test.go | 125 closeCh *testutils.Channel member
137 fl.closeCh.Send(nil)
152 closeCh *testutils.Channel member
164 fc.closeCh.Send(nil)
175 closeCh: testutils.NewChannel(),
320 closeCh: testutils.NewChannel(),
323 if _, err := fc.closeCh.Receive(ctx); err != nil {
332 closeCh: testutils.NewChannel(),
|
| /dports/www/gohugo/hugo-0.91.2/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | listener_wrapper_test.go | 125 closeCh *testutils.Channel member
137 fl.closeCh.Send(nil)
152 closeCh *testutils.Channel member
164 fc.closeCh.Send(nil)
175 closeCh: testutils.NewChannel(),
320 closeCh: testutils.NewChannel(),
323 if _, err := fc.closeCh.Receive(ctx); err != nil {
332 closeCh: testutils.NewChannel(),
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | listener_wrapper_test.go | 125 closeCh *testutils.Channel member
137 fl.closeCh.Send(nil)
152 closeCh *testutils.Channel member
164 fc.closeCh.Send(nil)
175 closeCh: testutils.NewChannel(),
320 closeCh: testutils.NewChannel(),
323 if _, err := fc.closeCh.Receive(ctx); err != nil {
332 closeCh: testutils.NewChannel(),
|
| /dports/security/xray-core/Xray-core-1.5.0/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | listener_wrapper_test.go | 125 closeCh *testutils.Channel member
137 fl.closeCh.Send(nil)
152 closeCh *testutils.Channel member
164 fc.closeCh.Send(nil)
175 closeCh: testutils.NewChannel(),
320 closeCh: testutils.NewChannel(),
323 if _, err := fc.closeCh.Receive(ctx); err != nil {
332 closeCh: testutils.NewChannel(),
|
| /dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | listener_wrapper_test.go | 125 closeCh *testutils.Channel member
137 fl.closeCh.Send(nil)
152 closeCh *testutils.Channel member
164 fc.closeCh.Send(nil)
175 closeCh: testutils.NewChannel(),
320 closeCh: testutils.NewChannel(),
323 if _, err := fc.closeCh.Receive(ctx); err != nil {
332 closeCh: testutils.NewChannel(),
|
| /dports/www/gitea/gitea-1.16.5/vendor/github.com/blevesearch/zapx/v11/ |
| H A D | merge.go | 40 closeCh chan struct{}, s seg.StatsReporter) (
78 MergeToWriter(segmentBases, drops, chunkFactor, cr, closeCh)
126 if isClosed(closeCh) {
132 fieldsMap, fieldsInv, fieldsSame, numDocs, cr, closeCh)
139 newDocNums, numDocs, chunkFactor, cr, closeCh)
215 if isClosed(closeCh) {
297 if isClosed(closeCh) {
378 if isClosed(closeCh) {
633 if isClosed(closeCh) {
849 func isClosed(closeCh chan struct{}) bool {
[all …]
|
| /dports/www/gitea/gitea-1.16.5/vendor/github.com/blevesearch/zapx/v15/ |
| H A D | merge.go | 40 closeCh chan struct{}, s seg.StatsReporter) (
78 MergeToWriter(segmentBases, drops, chunkMode, cr, closeCh)
126 if isClosed(closeCh) {
132 fieldsMap, fieldsInv, fieldsSame, numDocs, cr, closeCh)
139 newDocNums, numDocs, chunkMode, cr, closeCh)
218 if isClosed(closeCh) {
300 if isClosed(closeCh) {
406 if isClosed(closeCh) {
672 if isClosed(closeCh) {
888 func isClosed(closeCh chan struct{}) bool {
[all …]
|
| /dports/security/keybase/client-v5.7.1/go/vendor/github.com/blevesearch/bleve/index/scorch/segment/zap/ |
| H A D | merge.go | 49 chunkFactor uint32, closeCh chan struct{}, s seg.StatsReporter) (
81 MergeToWriter(segmentBases, drops, chunkFactor, cr, closeCh)
129 if isClosed(closeCh) {
135 fieldsMap, fieldsInv, fieldsSame, numDocs, cr, closeCh)
142 newDocNums, numDocs, chunkFactor, cr, closeCh)
221 if isClosed(closeCh) {
303 if isClosed(closeCh) {
384 if isClosed(closeCh) {
639 if isClosed(closeCh) {
855 func isClosed(closeCh chan struct{}) bool {
[all …]
|