meso: impl AddServerSession

mesosphere/source/processes/KPort.cpp

@@ -1,5 +1,6 @@
 #include <mesosphere/processes/KPort.hpp>
 #include <mesosphere/core/KCoreContext.hpp>
+#include <mesosphere/threading/KScopedCriticalSection.hpp>
 
 namespace mesosphere
 {
@@ -8,13 +9,27 @@ KPort::~KPort()
 {
 }
 
-Result KPort::Initialize()
+Result KPort::Initialize(int maxSessions, bool isLight)
 {
     SetClientServerParent();
     isClientAlive = true;
     isServerAlive = true;
 
+    client.maxSessions = maxSessions;
+    this->isLight = isLight;
+
     return ResultSuccess();
 }
 
+Result KPort::AddServerSession(KLightServerSession &lightServerSession)
+{
+    KScopedCriticalSection critsec{};
+    if (isClientAlive || isServerAlive) {
+        return ResultKernelConnectionRefused();
+    } else {
+        return server.AddServerSession(lightServerSession);
+    }
+}
+
+
 }

mesosphere/source/processes/KServerPort.cpp

@@ -14,7 +14,23 @@ KServerPort::~KServerPort()
 
 bool KServerPort::IsSignaled() const
 {
-    return false; // TODO
+    if (!parent->isLight) {
+        return false; // TODO
+    } else {
+        return !lightServerSessions.empty();
+    }
+}
+
+Result KServerPort::AddServerSession(KLightServerSession &lightServerSession)
+{
+    KScopedCriticalSection critsec{};
+    bool wasEmpty = lightServerSessions.empty();
+    lightServerSessions.push_back(lightServerSession);
+    if (wasEmpty && !lightServerSessions.empty()) {
+        NotifyWaiters();
+    }
+
+    return ResultSuccess();
 }
 
 }