Changeset 29:0a619f9e8e02 in vscpl

Timestamp:

12/15/22 15:56:58 (17 months ago)

Author:

István Váradi <ivaradi@…>

Branch:

default

hg-Phase:

(<MercurialRepository 1 'hg:/home/ivaradi/xplane/hg/vscpl' '/'>, 'public')

Message:

LocalAcceptor implements the BufferStreamAcceptor interface

Location:

src/hu/varadiistvan/scpl/io/_win32

Files:

• LocalAcceptor.cc (modified) (2 diffs)
• LocalAcceptor.h (modified) (3 diffs)

src/hu/varadiistvan/scpl/io/_win32/LocalAcceptor.cc

@@ -34 +34 @@
 
 using hu::varadiistvan::scpl::io::LocalAcceptor;
+
+using hu::varadiistvan::scpl::io::BufferedStream;
 
 //------------------------------------------------------------------------------
@@ -73 +75 @@
 //------------------------------------------------------------------------------
 
+BufferedStream* LocalAcceptor::getAcceptedBufferedStream(Waiter* waiter)
+{
+    return (waiter==nullptr) ? getSocket() : getSocket(waiter);
+}
+
+//------------------------------------------------------------------------------
+
 void LocalAcceptor::handleWaitedResult(DWORD /*size*/)
 {

src/hu/varadiistvan/scpl/io/_win32/LocalAcceptor.h

@@ -31 +31 @@
 //------------------------------------------------------------------------------
 
+#include "../BufferedStreamAcceptor.h"
+
 #include "Completer.h"
 
@@ -46 +48 @@
  * local server socket, i.e. named pipe.
  */
-class LocalAcceptor : public Completer
+class LocalAcceptor : public Completer,
+                      public BufferedStreamAcceptor
 {
 private:
@@ -104 +107 @@
 
 
+    /**
+     * Get the last accepted socket as a buffered stream with the given waiter,
+     * if any.
+     */
+    BufferedStream* getAcceptedBufferedStream(Waiter* waiter = nullptr) override;
+
 protected:
     /**