Home
last modified time | relevance | path

Searched defs:localStream (Results 1 – 25 of 25) sorted by relevance

/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/containerd/containerd/containerd-1.4.3/services/containers/
H A Dlocal.go210 type localStream struct { struct
211 ctx context.Context
212 containers []api.Container
213 i int
216 func (s *localStream) Recv() (*api.ListContainerMessage, error) {
227 func (s *localStream) Context() context.Context {
231 func (s *localStream) CloseSend() error {
235 func (s *localStream) Header() (grpcm.MD, error) {
239 func (s *localStream) Trailer() grpcm.MD {
243 func (s *localStream) SendMsg(m interface{}) error {
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/containerd/containerd/services/containers/
H A Dlocal.go210 type localStream struct { struct
211 ctx context.Context
212 containers []api.Container
213 i int
216 func (s *localStream) Recv() (*api.ListContainerMessage, error) {
227 func (s *localStream) Context() context.Context {
231 func (s *localStream) CloseSend() error {
235 func (s *localStream) Header() (grpcm.MD, error) {
239 func (s *localStream) Trailer() grpcm.MD {
243 func (s *localStream) SendMsg(m interface{}) error {
[all …]
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/containerd/containerd/services/containers/
H A Dlocal.go210 type localStream struct { struct
211 ctx context.Context
212 containers []api.Container
213 i int
216 func (s *localStream) Recv() (*api.ListContainerMessage, error) {
227 func (s *localStream) Context() context.Context {
231 func (s *localStream) CloseSend() error {
235 func (s *localStream) Header() (grpcm.MD, error) {
239 func (s *localStream) Trailer() grpcm.MD {
243 func (s *localStream) SendMsg(m interface{}) error {
[all …]
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/containerd/containerd/services/containers/
H A Dlocal.go210 type localStream struct { struct
211 ctx context.Context
212 containers []api.Container
213 i int
216 func (s *localStream) Recv() (*api.ListContainerMessage, error) {
227 func (s *localStream) Context() context.Context {
231 func (s *localStream) CloseSend() error {
235 func (s *localStream) Header() (grpcm.MD, error) {
239 func (s *localStream) Trailer() grpcm.MD {
243 func (s *localStream) SendMsg(m interface{}) error {
[all …]
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/containerd/containerd/services/containers/
H A Dlocal.go210 type localStream struct { struct
211 ctx context.Context
212 containers []api.Container
213 i int
216 func (s *localStream) Recv() (*api.ListContainerMessage, error) {
227 func (s *localStream) Context() context.Context {
231 func (s *localStream) CloseSend() error {
235 func (s *localStream) Header() (grpcm.MD, error) {
239 func (s *localStream) Trailer() grpcm.MD {
243 func (s *localStream) SendMsg(m interface{}) error {
[all …]
/dports/sysutils/helm/helm-3.5.2/vendor/github.com/containerd/containerd/services/containers/
H A Dlocal.go210 type localStream struct { struct
211 ctx context.Context
212 containers []api.Container
213 i int
216 func (s *localStream) Recv() (*api.ListContainerMessage, error) {
227 func (s *localStream) Context() context.Context {
231 func (s *localStream) CloseSend() error {
235 func (s *localStream) Header() (grpcm.MD, error) {
239 func (s *localStream) Trailer() grpcm.MD {
243 func (s *localStream) SendMsg(m interface{}) error {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/containerd/containerd/services/containers/
H A Dlocal.go210 type localStream struct { struct
211 ctx context.Context
212 containers []api.Container
213 i int
216 func (s *localStream) Recv() (*api.ListContainerMessage, error) {
227 func (s *localStream) Context() context.Context {
231 func (s *localStream) CloseSend() error {
235 func (s *localStream) Header() (grpcm.MD, error) {
239 func (s *localStream) Trailer() grpcm.MD {
243 func (s *localStream) SendMsg(m interface{}) error {
[all …]
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/containerd/containerd/services/containers/
H A Dlocal.go210 type localStream struct { struct
211 ctx context.Context
212 containers []api.Container
213 i int
216 func (s *localStream) Recv() (*api.ListContainerMessage, error) {
227 func (s *localStream) Context() context.Context {
231 func (s *localStream) CloseSend() error {
235 func (s *localStream) Header() (grpcm.MD, error) {
239 func (s *localStream) Trailer() grpcm.MD {
243 func (s *localStream) SendMsg(m interface{}) error {
[all …]
/dports/security/snowflake-tor/snowflake-ead5a960d7fa19dc890ccbfc0765c5ab6629eaa9/vendor/github.com/pion/interceptor/pkg/nack/
H A Dresponder_interceptor.go22 type localStream struct { struct
23 sendBuffer *sendBuffer
24 rtpWriter interceptor.RTPWriter
/dports/science/gromacs/gromacs-2021.4/src/gromacs/nbnxm/cuda/
H A Dnbnxm_cuda_data_mgmt.cu336 const DeviceStream& localStream = *nb->deviceStreams[InteractionLocality::Local]; in gpu_upload_shiftvec() local
353 const DeviceStream& localStream = *nb->deviceStreams[InteractionLocality::Local]; in nbnxn_cuda_clear_f() local
361 const DeviceStream& localStream = *nb->deviceStreams[InteractionLocality::Local]; in nbnxn_cuda_clear_e_fshift() local
387 const DeviceStream& localStream = *nb->deviceStreams[InteractionLocality::Local]; in gpu_init_atomdata() local
/dports/science/InsightToolkit/ITK-5.0.1/Modules/Video/BridgeVXL/src/
H A DitkVXLVideoIO.cxx224 vidl_ffmpeg_istream localStream(filename); in CanReadFile() local
260 vidl_ffmpeg_istream localStream(this->GetFileName()); in ReadImageInformation() local
/dports/science/gromacs/gromacs-2021.4/src/gromacs/domdec/
H A Dgpuhaloexchange_impl.cu464 const DeviceStream& localStream, in Impl()
510 const DeviceStream& localStream, in GpuHaloExchange()
/dports/archivers/quazip/quazip-1.2/qztest/
H A Dtestquazipfileinfo.cpp187 QDataStream localStream(&buffer); in makeExtTimeField() local
/dports/cad/librepcb/librepcb-0.1.6/libs/quazip/qztest/
H A Dtestquazipfileinfo.cpp187 QDataStream localStream(&buffer); in makeExtTimeField() local
/dports/science/gromacs/gromacs-2021.4/src/gromacs/nbnxm/opencl/
H A Dnbnxm_ocl_data_mgmt.cpp443 const DeviceStream& localStream = *nb->deviceStreams[InteractionLocality::Local]; in nbnxn_ocl_clear_f() local
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/jdk.javadoc/share/classes/jdk/javadoc/internal/doclets/toolkit/util/
H A DVisibleMemberTable.java537 Stream<ExecutableElement> localStream = lmt.getOrderedMembers(Kind.METHODS) in computeVisibleMethods() local
/dports/security/cryptlib/cryptlib-3.4.3/mechs/
H A Dkeyex_rw.c415 STREAM localStream; in writeCryptlibKek() local
/dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/rt.equinox.p2/bundles/org.eclipse.equinox.p2.repository/src/org/eclipse/equinox/internal/p2/repository/helpers/
H A DAbstractRepositoryManager.java739 try (InputStream localStream = new FileInputStream(indexFile)) { in handleLocalIndexFile()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/sdk/android/instrumentationtests/src/org/webrtc/
H A DPeerConnectionEndToEndTest.java1402 MediaStream localStream = factory.createLocalMediaStream("stream"); in testRemoteStreamUpdatedWhenTracksAddedOrRemoved() local
/dports/www/firefox/firefox-99.0/third_party/libwebrtc/sdk/android/instrumentationtests/src/org/webrtc/
H A DPeerConnectionEndToEndTest.java1402 MediaStream localStream = factory.createLocalMediaStream("stream"); in testRemoteStreamUpdatedWhenTracksAddedOrRemoved() local
/dports/science/plumed/plumed2-2.7.2/patches/gromacs-2020.6.diff/src/gromacs/mdrun/
H A Drunner.cpp1575 const void* localStream = in mdrunner() local
/dports/devel/py-twisted/Twisted-22.1.0/src/twisted/conch/scripts/
H A Dcftp.py538 def _putRemoteFile(self, localStream, remotePath): argument
/dports/net-im/tg_owt/tg_owt-d578c76/src/sdk/android/instrumentationtests/src/org/webrtc/
H A DPeerConnectionEndToEndTest.java1402 MediaStream localStream = factory.createLocalMediaStream("stream"); in testRemoteStreamUpdatedWhenTracksAddedOrRemoved() local
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/sdk/android/instrumentationtests/src/org/webrtc/
H A DPeerConnectionEndToEndTest.java1402 MediaStream localStream = factory.createLocalMediaStream("stream"); in testRemoteStreamUpdatedWhenTracksAddedOrRemoved() local
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/state/test/
H A DQuicStreamFunctionsTest.cpp1718 StreamId localStream = 12; in TEST_F() local