Home
last modified time | relevance | path

Searched refs:networkStream (Results 1 – 25 of 57) sorted by relevance

123

/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Runtime.Remoting/System.Runtime.Remoting.Channels.Tcp/
H A DTcpMessageIO.cs54 StreamRead (networkStream, buffer, 6); in ReceiveMessageStatus()
135 networkStream.Write(buffer, 0, 8); in SendMessageStream()
156 networkStream.Write (buffer, 0, nread); in SendMessageStream()
170 if (networkStream != null) in SendHeaders()
187 networkStream.WriteByte (1); in SendHeaders()
198 StreamRead (networkStream, buffer, 2); in ReceiveHeaders()
217 StreamRead (networkStream, buffer, 2); in ReceiveHeaders()
233 StreamRead (networkStream, buffer, 8); in ReceiveMessageStream()
269 networkStream.Write (buffer, 0, num + 4); in SendString()
274 StreamRead (networkStream, buffer, 4); in ReceiveString()
[all …]
/dports/lang/mono/mono-5.10.1.57/mcs/class/Mono.Posix/Mono.Remoting.Channels.Unix/
H A DUnixMessageIO.cs57 StreamRead (networkStream, buffer, 6); in ReceiveMessageStatus()
126 networkStream.Write(buffer, 0, 8); in SendMessageStream()
144 networkStream.Write (buffer, 0, nread); in SendMessageStream()
158 if (networkStream != null) in SendHeaders()
175 networkStream.WriteByte (1); in SendHeaders()
186 StreamRead (networkStream, buffer, 2); in ReceiveHeaders()
205 StreamRead (networkStream, buffer, 2); in ReceiveHeaders()
221 StreamRead (networkStream, buffer, 8); in ReceiveMessageStream()
254 networkStream.Write (buffer, 0, num + 4); in SendString()
259 StreamRead (networkStream, buffer, 4); in ReceiveString()
[all …]
/dports/lang/mono/mono-5.10.1.57/mcs/class/System/System.Net/
H A DFtpDataStream.cs22 Stream networkStream; field in System.Net.FtpDataStream
33 this.networkStream = stream; in FtpDataStream()
73 return networkStream;
104 nbytes = networkStream.Read (buffer, offset, size); in ReadInternal()
111 networkStream = null; in ReadInternal()
169 networkStream.Write (buffer, offset, size); in WriteInternal()
234 if (networkStream != null) { in Dispose()
238 networkStream = null; in Dispose()
/dports/lang/mono/mono-5.10.1.57/mcs/class/System/Mono.Net.Security/
H A DMonoTlsStream.cs57 readonly NetworkStream networkStream; field in Mono.Net.Security.MonoTlsStream
85 public MonoTlsStream (HttpWebRequest request, NetworkStream networkStream) in MonoTlsStream() argument
89 this.networkStream = networkStream; in MonoTlsStream()
105 sslStream = provider.CreateSslStream (networkStream, false, settings); in CreateStream()
/dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/
H A DInputStreamsSuite.scala58 val networkStream = ssc.socketTextStream( constant
61 val outputStream = new TestOutputStream(networkStream, outputQueue)
110 val networkStream = ssc.socketTextStream( constant
113 val outputStream = new TestOutputStream(networkStream, outputQueue)
125 networkStream.generatedRDDs.foreach { case (_, rdd) =>
266 val networkStream = ssc.receiverStream[Int](testReceiver) constant
267 val countStream = networkStream.count
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/hotspot/share/utilities/
H A Dostream.hpp295 class networkStream : public bufferedStream { class
301 networkStream();
302 ~networkStream();
H A Dostream.cpp1079 networkStream::networkStream() : bufferedStream(1024*10, 1024*10) { in networkStream() function in networkStream
1091 int networkStream::read(char *buf, size_t len) { in read()
1095 void networkStream::flush() { in flush()
1104 networkStream::~networkStream() { in ~networkStream()
1108 void networkStream::close() { in close()
1116 bool networkStream::connect(const char *ip, short port) { in connect()
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/hotspot/share/utilities/
H A Dostream.hpp289 class networkStream : public bufferedStream { class
295 networkStream();
296 ~networkStream();
H A Dostream.cpp1045 networkStream::networkStream() : bufferedStream(1024*10, 1024*10) { in networkStream() function in networkStream
1057 int networkStream::read(char *buf, size_t len) { in read()
1061 void networkStream::flush() { in flush()
1070 networkStream::~networkStream() { in ~networkStream()
1074 void networkStream::close() { in close()
1082 bool networkStream::connect(const char *ip, short port) { in connect()
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/hotspot/share/utilities/
H A Dostream.hpp279 class networkStream : public bufferedStream { class
285 networkStream();
286 ~networkStream();
H A Dostream.cpp1020 networkStream::networkStream() : bufferedStream(1024*10, 1024*10) { in networkStream() function in networkStream
1032 int networkStream::read(char *buf, size_t len) { in read()
1036 void networkStream::flush() { in flush()
1045 networkStream::~networkStream() { in ~networkStream()
1049 void networkStream::close() { in close()
1057 bool networkStream::connect(const char *ip, short port) { in connect()
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/hotspot/share/utilities/
H A Dostream.hpp289 class networkStream : public bufferedStream { class
295 networkStream();
296 ~networkStream();
H A Dostream.cpp1047 networkStream::networkStream() : bufferedStream(1024*10, 1024*10) { in networkStream() function in networkStream
1059 int networkStream::read(char *buf, size_t len) { in read()
1063 void networkStream::flush() { in flush()
1072 networkStream::~networkStream() { in ~networkStream()
1076 void networkStream::close() { in close()
1084 bool networkStream::connect(const char *ip, short port) { in connect()
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/hotspot/share/utilities/
H A Dostream.hpp291 class networkStream : public bufferedStream { class
297 networkStream();
298 ~networkStream();
H A Dostream.cpp1078 networkStream::networkStream() : bufferedStream(1024*10, 1024*10) { in networkStream() function in networkStream
1090 int networkStream::read(char *buf, size_t len) { in read()
1094 void networkStream::flush() { in flush()
1103 networkStream::~networkStream() { in ~networkStream()
1107 void networkStream::close() { in close()
1115 bool networkStream::connect(const char *ip, short port) { in connect()
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/src/hotspot/share/utilities/
H A Dostream.hpp295 class networkStream : public bufferedStream { class
301 networkStream();
302 ~networkStream();
H A Dostream.cpp1079 networkStream::networkStream() : bufferedStream(1024*10, 1024*10) { in networkStream() function in networkStream
1091 int networkStream::read(char *buf, size_t len) { in read()
1095 void networkStream::flush() { in flush()
1104 networkStream::~networkStream() { in ~networkStream()
1108 void networkStream::close() { in close()
1116 bool networkStream::connect(const char *ip, short port) { in connect()
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/src/hotspot/share/utilities/
H A Dostream.hpp290 class networkStream : public bufferedStream { class
296 networkStream();
297 ~networkStream();
H A Dostream.cpp1059 networkStream::networkStream() : bufferedStream(1024*10, 1024*10) { in networkStream() function in networkStream
1071 int networkStream::read(char *buf, size_t len) { in read()
1075 void networkStream::flush() { in flush()
1084 networkStream::~networkStream() { in ~networkStream()
1088 void networkStream::close() { in close()
1096 bool networkStream::connect(const char *ip, short port) { in connect()
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/src/hotspot/share/utilities/
H A Dostream.hpp289 class networkStream : public bufferedStream { class
295 networkStream();
296 ~networkStream();
H A Dostream.cpp1046 networkStream::networkStream() : bufferedStream(1024*10, 1024*10) { in networkStream() function in networkStream
1058 int networkStream::read(char *buf, size_t len) { in read()
1062 void networkStream::flush() { in flush()
1071 networkStream::~networkStream() { in ~networkStream()
1075 void networkStream::close() { in close()
1083 bool networkStream::connect(const char *ip, short port) { in connect()
/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/hotspot/src/share/vm/utilities/
H A Dostream.hpp317 class networkStream : public bufferedStream { class
323 networkStream();
324 ~networkStream();
/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/hotspot/src/share/vm/utilities/
H A Dostream.hpp317 class networkStream : public bufferedStream { class
323 networkStream();
324 ~networkStream();
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.Requests/src/System/Net/
H A DFtpDataStream.cs27 … internal FtpDataStream(NetworkStream networkStream, FtpWebRequest request, TriState writeOnly) in FtpDataStream() argument
41 _networkStream = networkStream; in FtpDataStream()
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System/net/System/Net/
H A D_FtpDataStream.cs30 … internal FtpDataStream(NetworkStream networkStream, FtpWebRequest request, TriState writeOnly) { in FtpDataStream() argument
39 m_NetworkStream = networkStream; in FtpDataStream()

123