intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 30 insertions, 0 deletions

diff --git a/library/cpp/messagebus/coreconn.cpp b/library/cpp/messagebus/coreconn.cpp
new file mode 100644
index 0000000000..d9411bb5db
--- /dev/null
+++ b/library/cpp/messagebus/coreconn.cpp
@@ -0,0 +1,30 @@
+#include "coreconn.h"
+
+#include "remote_connection.h"
+
+#include <util/datetime/base.h>
+#include <util/generic/yexception.h>
+#include <util/network/socket.h>
+#include <util/string/util.h>
+#include <util/system/thread.h>
+
+namespace NBus {
+    TBusInstant Now() {
+        return millisec();
+    }
+
+    EIpVersion MakeIpVersion(bool allowIpv4, bool allowIpv6) {
+        if (allowIpv4) {
+            if (allowIpv6) {
+                return EIP_VERSION_ANY;
+            } else {
+                return EIP_VERSION_4;
+            }
+        } else if (allowIpv6) {
+            return EIP_VERSION_6;
+        }
+
+        ythrow yexception() << "Neither of IPv4/IPv6 is allowed.";
+    }
+
+}