mirrors/phobos
1
0
Fork 0
mirror of https://github.com/dlang/phobos.git synced 2025-05-01 15:40:36 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

std.socketstream: Clean up Ddoc formatting and code indentation.

Browse source
This commit is contained in:
Vladimir Panteleev 2011-08-24 04:37:40 +03:00
parent 1f2cc3ac74
commit a8992d8eb1
1 changed files with 36 additions and 36 deletions
Download patch file Download diff file Expand all files Collapse all files

72
std/socketstream.d
View file

@ -21,8 +21,8 @@
*/ */
/************** /**************
* <b>SocketStream</b> is a stream for a blocking, * $(D SocketStream) is a stream for a blocking,
* connected <b>Socket</b>. * connected $(D Socket).
* *
* For Win32 systems, link with <tt>ws2_32.lib</tt>. * For Win32 systems, link with <tt>ws2_32.lib</tt>.
* *
@ -41,8 +41,8 @@ private import std.stream;
private import std.socket; private import std.socket;
/************** /**************
* <b>SocketStream</b> is a stream for a blocking, * $(D SocketStream) is a stream for a blocking,
* connected <b>Socket</b>. * connected $(D Socket).
*/ */
class SocketStream: Stream class SocketStream: Stream
{ {
@ -56,29 +56,29 @@ class SocketStream: Stream
*/ */
this(Socket sock, FileMode mode) this(Socket sock, FileMode mode)
{ {
if(mode & FileMode.In) if(mode & FileMode.In)
readable = true; readable = true;
if(mode & FileMode.Out) if(mode & FileMode.Out)
writeable = true; writeable = true;
this.sock = sock; this.sock = sock;
} }
/** /**
* Uses mode <b>FileMode.In | FileMode.Out</b>. * Uses mode $(D FileMode.In | FileMode.Out).
*/ */
this(Socket sock) this(Socket sock)
{ {
writeable = readable = true; writeable = readable = true;
this.sock = sock; this.sock = sock;
} }
/** /**
* Property to get the <b>Socket</b> that is being streamed. * Property to get the $(D Socket) that is being streamed.
*/ */
Socket socket() Socket socket()
{ {
return sock; return sock;
} }
/** /**
@ -86,17 +86,17 @@ class SocketStream: Stream
*/ */
override size_t readBlock(void* _buffer, size_t size) override size_t readBlock(void* _buffer, size_t size)
{ {
ubyte* buffer = cast(ubyte*)_buffer; ubyte* buffer = cast(ubyte*)_buffer;
assertReadable(); assertReadable();
if (size == 0) if (size == 0)
return size; return size;
auto len = sock.receive(buffer[0 .. size]); auto len = sock.receive(buffer[0 .. size]);
readEOF = cast(bool)(len == 0); readEOF = cast(bool)(len == 0);
if (len == sock.ERROR) if (len == sock.ERROR)
len = 0; len = 0;
return len; return len;
} }
/** /**
@ -104,17 +104,17 @@ class SocketStream: Stream
*/ */
override size_t writeBlock(const void* _buffer, size_t size) override size_t writeBlock(const void* _buffer, size_t size)
{ {
ubyte* buffer = cast(ubyte*)_buffer; ubyte* buffer = cast(ubyte*)_buffer;
assertWriteable(); assertWriteable();
if (size == 0) if (size == 0)
return size; return size;
auto len = sock.send(buffer[0 .. size]); auto len = sock.send(buffer[0 .. size]);
readEOF = cast(bool)(len == 0); readEOF = cast(bool)(len == 0);
if (len == sock.ERROR) if (len == sock.ERROR)
len = 0; len = 0;
return len; return len;
} }
/** /**
@ -122,7 +122,7 @@ class SocketStream: Stream
*/ */
override ulong seek(long offset, SeekPos whence) override ulong seek(long offset, SeekPos whence)
{ {
throw new SeekException("Cannot seek a socket."); throw new SeekException("Cannot seek a socket.");
} }
/** /**
@ -131,15 +131,15 @@ class SocketStream: Stream
*/ */
override string toString() override string toString()
{ {
return sock.toString(); return sock.toString();
} }
/** /**
* Close the <b>Socket</b>. * Close the $(D Socket).
*/ */
override void close() override void close()
{ {
sock.close(); sock.close();
} }
} }