1 files changed, 0 insertions, 117 deletions
diff --git a/vespalib/src/tests/websocket/websocket_test.cpp b/vespalib/src/tests/websocket/websocket_test.cpp
deleted file mode 100644
index 5b346df4243..00000000000
--- a/vespalib/src/tests/websocket/websocket_test.cpp
+++ /dev/null
@@ -1,117 +0,0 @@
-// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-#include <vespa/vespalib/testkit/test_kit.h>
-#include <vespa/vespalib/net/socket_spec.h>
-#include <vespa/vespalib/websocket/handler.h>
-#include <vespa/vespalib/websocket/acceptor.h>
-#include <vespa/vespalib/websocket/key.h>
-#include <vespa/vespalib/websocket/buffer.h>
-#include <vespa/vespalib/util/gate.h>
-
-using namespace vespalib;
-using namespace vespalib::ws;
-
-template <typename T>
-struct Receptor : vespalib::ws::Handler<T> {
-    std::unique_ptr<T> obj;
-    vespalib::Gate gate;
-    ~Receptor();
-    void handle(std::unique_ptr<T> t) override {
-        obj = std::move(t);
-        gate.countDown();
-    }
-};
-
-template <typename T>
-Receptor<T>::~Receptor() = default;
-
-vespalib::string read_bytes(Socket &socket, size_t wanted_bytes) {
-    char tmp[64];
-    vespalib::string result;
-    while (result.size() < wanted_bytes) {
-        size_t read_size = std::min(sizeof(tmp), wanted_bytes - result.size());
-        size_t read_result = socket.read(tmp, read_size);
-        if (static_cast<ssize_t>(read_result) <= 0) {
-            return result;
-        }
-        result.append(tmp, read_result);
-    }
-    return result;
-}
-
-void verify_socket_io(bool is_server, Socket &socket) {
-    vespalib::string server_message = "hello, this is the server speaking";
-    vespalib::string client_message = "please pick up, I need to talk to you";
-    if(is_server) {
-        socket.write(server_message.data(), server_message.size());
-        vespalib::string read = read_bytes(socket, client_message.size());
-        EXPECT_EQUAL(client_message, read);
-    } else {
-        socket.write(client_message.data(), client_message.size());
-        vespalib::string read = read_bytes(socket, server_message.size());
-        EXPECT_EQUAL(server_message, read);
-    }
-}
-
-void verify_socket_io_async(Socket &server, Socket &client) {
-    std::thread server_thread(verify_socket_io, true, std::ref(server));
-    std::thread client_thread(verify_socket_io, false, std::ref(client));
-    server_thread.join();
-    client_thread.join();
-}
-
-void check_buffer_stats(const Buffer &buffer, size_t dead, size_t used, size_t free) {
-    EXPECT_EQUAL(dead, buffer.dead());
-    EXPECT_EQUAL(used, buffer.used());
-    EXPECT_EQUAL(free, buffer.free());    
-}
-
-TEST("require that basic reserve/commit/obtain/evict buffer cycle works") {
-    Buffer buffer;
-    check_buffer_stats(buffer, 0, 0, 0);
-    char *a = buffer.reserve(1);
-    check_buffer_stats(buffer, 0, 0, 1);
-    *a = 'x';
-    buffer.commit(1);
-    check_buffer_stats(buffer, 0, 1, 0);
-    EXPECT_EQUAL('x', *buffer.obtain());
-    check_buffer_stats(buffer, 0, 1, 0);
-    buffer.evict(1);
-    check_buffer_stats(buffer, 1, 0, 0);
-}
-
-TEST("require that buffer moves contained data when more space is needed") {    
-    Buffer buffer;
-    memcpy(buffer.reserve(3), "xyz", 3);
-    buffer.commit(3);
-    EXPECT_EQUAL('x', *buffer.obtain());
-    buffer.evict(1);
-    EXPECT_EQUAL('y', *buffer.obtain());
-    check_buffer_stats(buffer, 1, 2, 0);
-    buffer.reserve(1);
-    check_buffer_stats(buffer, 0, 2, 1);
-    EXPECT_EQUAL('y', *buffer.obtain());
-    buffer.evict(1);
-    EXPECT_EQUAL('z', *buffer.obtain());
-    check_buffer_stats(buffer, 1, 1, 1);
-    buffer.reserve(3);
-    check_buffer_stats(buffer, 0, 1, 3);
-    EXPECT_EQUAL('z', *buffer.obtain());
-}
-
-TEST("require that an acceptor can accept connections asynchronously") {
-    Receptor<Socket> server;
-    Acceptor acceptor(0, server);
-    Socket::UP client = SimpleSocket::connect(SocketSpec::from_port(acceptor.port()));
-    server.gate.await(60s);
-    ASSERT_TRUE(server.obj.get() != nullptr);
-    ASSERT_TRUE(client.get() != nullptr);
-    TEST_DO(verify_socket_io_async(*server.obj, *client));
-}
-
-TEST("require that websocket accept tokens are generated correctly") {
-    vespalib::string key("dGhlIHNhbXBsZSBub25jZQ==");
-    vespalib::string accept_token("s3pPLMBiTxaQ9kYGzzhZRbK+xOo=");
-    EXPECT_EQUAL(accept_token, Key::accept(key));
-}
-
-TEST_MAIN() { TEST_RUN_ALL(); }