Home
last modified time | relevance | path

Searched refs:incomingStream (Results 1 – 25 of 65) sorted by relevance

123

/dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/rt.equinox.p2/bundles/org.eclipse.equinox.p2.artifact.repository/src/org/eclipse/equinox/internal/p2/artifact/processing/
H A DAbstractBufferingStep.java33 protected OutputStream incomingStream; field in AbstractBufferingStep
47 if (incomingStream != null) in getOutputStream()
48 return incomingStream; in getOutputStream()
50 incomingStream = createIncomingStream(); in getOutputStream()
51 return incomingStream; in getOutputStream()
64 if (incomingStream != null) { in close()
65 incomingStream.close(); in close()
73 incomingStream = null; in close()
/dports/polish/kadu/kadu-4.3/plugins/jabber_protocol/services/
H A Djabber-stream-debug-service.h39 void incomingStream(const QString &streamData);
H A Djabber-stream-debug-service.cpp50 emit incomingStream(filterPrivateData(message)); in message() local
/dports/polish/kadu/kadu-4.3/plugins/jabber_protocol/gui/windows/
H A Dxml-console.cpp44 …connect(protocol->streamDebugService(), SIGNAL(incomingStream(QString)), this, SLOT(xmlIncomingSlo… in XmlConsole()
/dports/security/i2pd/i2pd-2.40.0/libi2pd/
H A DStreaming.cpp1168 auto incomingStream = CreateNewIncomingStream (receiveStreamID); in HandleNextPacket() local
1169 incomingStream->HandleNextPacket (packet); // SYN in HandleNextPacket()
1170 auto ident = incomingStream->GetRemoteIdentity(); in HandleNextPacket()
1179 incomingStream->HandleNextPacket (it1); in HandleNextPacket()
1185 m_Acceptor (incomingStream); in HandleNextPacket()
1191 m_PendingIncomingStreams.push_back (incomingStream); in HandleNextPacket()
1201 incomingStream->Close (); in HandleNextPacket()
/dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/vault/vault-0.6.0/vendor/github.com/hashicorp/yamux/
H A Dsession.go458 if err := s.incomingStream(id); err != nil {
553 func (s *Session) incomingStream(id uint32) error { func
/dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/hashicorp/consul/vendor/github.com/hashicorp/yamux/
H A Dsession.go458 if err := s.incomingStream(id); err != nil {
553 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-database-elasticsearch/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-database-couchbase/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func
/dports/sysutils/helmfile/vault-f6547fa8e820/vendor/github.com/hashicorp/yamux/
H A Dsession.go483 if err := s.incomingStream(id); err != nil {
578 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-terraform/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-gcp/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-kv/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-mongodbatlas/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-auth-jwt/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-auth-kubernetes/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-alicloud/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-database-mongodbatlas/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-ad/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-auth-centrify/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-auth-azure/vendor/github.com/hashicorp/yamux/
H A Dsession.go483 if err := s.incomingStream(id); err != nil {
578 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-auth-alicloud/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-azure/vendor/github.com/hashicorp/yamux/
H A Dsession.go488 if err := s.incomingStream(id); err != nil {
583 func (s *Session) incomingStream(id uint32) error { func

123