/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Runtime.Remoting/System.Runtime.Remoting.Channels.Tcp/ |
H A D | TcpMessageIO.cs | 54 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 D | UnixMessageIO.cs | 57 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 D | FtpDataStream.cs | 22 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 D | MonoTlsStream.cs | 57 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 D | InputStreamsSuite.scala | 58 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 D | ostream.hpp | 295 class networkStream : public bufferedStream { class 301 networkStream(); 302 ~networkStream();
|
H A D | ostream.cpp | 1079 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 D | ostream.hpp | 289 class networkStream : public bufferedStream { class 295 networkStream(); 296 ~networkStream();
|
H A D | ostream.cpp | 1045 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 D | ostream.hpp | 279 class networkStream : public bufferedStream { class 285 networkStream(); 286 ~networkStream();
|
H A D | ostream.cpp | 1020 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 D | ostream.hpp | 289 class networkStream : public bufferedStream { class 295 networkStream(); 296 ~networkStream();
|
H A D | ostream.cpp | 1047 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 D | ostream.hpp | 291 class networkStream : public bufferedStream { class 297 networkStream(); 298 ~networkStream();
|
H A D | ostream.cpp | 1078 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 D | ostream.hpp | 295 class networkStream : public bufferedStream { class 301 networkStream(); 302 ~networkStream();
|
H A D | ostream.cpp | 1079 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 D | ostream.hpp | 290 class networkStream : public bufferedStream { class 296 networkStream(); 297 ~networkStream();
|
H A D | ostream.cpp | 1059 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 D | ostream.hpp | 289 class networkStream : public bufferedStream { class 295 networkStream(); 296 ~networkStream();
|
H A D | ostream.cpp | 1046 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 D | ostream.hpp | 317 class networkStream : public bufferedStream { class 323 networkStream(); 324 ~networkStream();
|
/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/hotspot/src/share/vm/utilities/ |
H A D | ostream.hpp | 317 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 D | FtpDataStream.cs | 27 … 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.cs | 30 … internal FtpDataStream(NetworkStream networkStream, FtpWebRequest request, TriState writeOnly) { in FtpDataStream() argument 39 m_NetworkStream = networkStream; in FtpDataStream()
|