| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gitlab.com/gitlab-org/gitlab-terminal/gitlab-terminal-2a71b03b44621289b28493d8bf3eaa9f64dbb6c9/ |
| H A D | stream_proxy_test.go | 26 downstream := bytes.Buffer{}
32 downstream.Write([]byte(writeString))
35 err := encProxy.Serve(&upstream, &downstream)
53 downstream := errorReadWriter{}
56 err := encProxy.Serve(&upstream, &downstream)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/sysutils/consul/consul-1.10.3/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/consul/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/hashicorp/consul/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/science/cantera/cantera-2.5.1-611-gc4d6ecc15/interfaces/matlab/toolbox/@FlowDevice/ |
| H A D | install.m | 1 function install(f, upstream, downstream)
3 % install(f, upstream, downstream)
8 % :param downstream:
15 if ~isa(upstream, 'Reactor') || ~isa(downstream, 'Reactor')
20 j = reactor_hndl(downstream);
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/consul/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/hashicorp/consul/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/consul/consul-1.4.2/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/net/bosh-bootloader/bosh-bootloader-7.2.12/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/consul/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/go-discover/provider/vsphere/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/vendor/github.com/hashicorp/go-discover/provider/vsphere/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/sysutils/nomad/nomad-1.1.0/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/machine/machine-7b7a141da844/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/sysutils/docker-machine/machine-0.16.2/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/consul/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/vmware/govmomi/vim25/progress/ |
| H A D | scale.go | 38 downstream := s.s.Sink()
39 go s.loop(upstream, downstream)
43 func (s scaleOne) loop(upstream <-chan Report, downstream chan<- Report) {
44 defer close(downstream)
47 downstream <- scaledReport{
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/tools/content_decoder_tool/ |
| H A D | content_decoder_tool.cc | 72 std::unique_ptr<SourceStream> downstream = nullptr; in ContentDecoderToolProcessInput() local
74 downstream = CreateBrotliSourceStream(std::move(upstream)); in ContentDecoderToolProcessInput()
76 downstream = GzipSourceStream::Create(std::move(upstream), in ContentDecoderToolProcessInput()
80 downstream = GzipSourceStream::Create(std::move(upstream), in ContentDecoderToolProcessInput()
86 if (downstream == nullptr) { in ContentDecoderToolProcessInput()
90 upstream = std::move(downstream); in ContentDecoderToolProcessInput()
|
| /dports/devel/hwloc2/hwloc-2.5.0/tests/hwloc/ |
| H A D | hwloc_iodevs.c | 32 obj->attr->bridge.downstream.pci.domain, in main()
33 obj->attr->bridge.downstream.pci.secondary_bus, in main()
34 obj->attr->bridge.downstream.pci.subordinate_bus); in main()
41 obj->attr->bridge.downstream.pci.domain, in main()
42 obj->attr->bridge.downstream.pci.secondary_bus, in main()
43 obj->attr->bridge.downstream.pci.subordinate_bus); in main()
|
| /dports/net/mpich/mpich-3.4.3/src/pm/hydra2/libhydra/topo/hwloc/hwloc/tests/hwloc/ |
| H A D | hwloc_iodevs.c | 32 obj->attr->bridge.downstream.pci.domain, in main()
33 obj->attr->bridge.downstream.pci.secondary_bus, in main()
34 obj->attr->bridge.downstream.pci.subordinate_bus); in main()
41 obj->attr->bridge.downstream.pci.domain, in main()
42 obj->attr->bridge.downstream.pci.secondary_bus, in main()
43 obj->attr->bridge.downstream.pci.subordinate_bus); in main()
|
| /dports/net/mpich/mpich-3.4.3/modules/hwloc/tests/hwloc/ |
| H A D | hwloc_iodevs.c | 32 obj->attr->bridge.downstream.pci.domain, in main()
33 obj->attr->bridge.downstream.pci.secondary_bus, in main()
34 obj->attr->bridge.downstream.pci.subordinate_bus); in main()
41 obj->attr->bridge.downstream.pci.domain, in main()
42 obj->attr->bridge.downstream.pci.secondary_bus, in main()
43 obj->attr->bridge.downstream.pci.subordinate_bus); in main()
|
| /dports/net/mpich/mpich-3.4.3/src/pm/hydra/tools/topo/hwloc/hwloc/tests/hwloc/ |
| H A D | hwloc_iodevs.c | 32 obj->attr->bridge.downstream.pci.domain, in main()
33 obj->attr->bridge.downstream.pci.secondary_bus, in main()
34 obj->attr->bridge.downstream.pci.subordinate_bus); in main()
41 obj->attr->bridge.downstream.pci.domain, in main()
42 obj->attr->bridge.downstream.pci.secondary_bus, in main()
43 obj->attr->bridge.downstream.pci.subordinate_bus); in main()
|