diff --git a/configure.py b/configure.py index ada3c01ca5b..58108f16a30 100755 --- a/configure.py +++ b/configure.py @@ -117,7 +117,6 @@ def debug_flag(compiler): } tests = [ - 'tests/test-reactor', 'tests/fileiotest', 'tests/directory_test', 'tests/linecount', @@ -274,7 +273,6 @@ def have_xen(): 'libseastar.a' : core + libnet, 'seastar.pc': [], 'apps/seastar/seastar': ['apps/seastar/main.cc'] + core, - 'tests/test-reactor': ['tests/test-reactor.cc'] + core, 'apps/httpd/httpd': ['apps/httpd/demo.json', 'apps/httpd/main.cc'] + http + libnet + core, 'apps/memcached/memcached': ['apps/memcached/memcache.cc'] + memcache_base, 'tests/memcached/test_ascii_parser': ['tests/memcached/test_ascii_parser.cc'] + memcache_base + boost_test_lib, diff --git a/tests/test-reactor.cc b/tests/test-reactor.cc deleted file mode 100644 index e7668764e99..00000000000 --- a/tests/test-reactor.cc +++ /dev/null @@ -1,66 +0,0 @@ -/* - * This file is open source software, licensed to you under the terms - * of the Apache License, Version 2.0 (the "License"). See the NOTICE file - * distributed with this work for additional information regarding copyright - * ownership. You may not use this file except in compliance with the License. - * - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -/* - * Copyright 2014 Cloudius Systems - */ - -#include "core/reactor.hh" -#include - -struct test { - test(pollable_fd l) : listener(std::move(l)) {} - pollable_fd listener; - struct connection { - connection(pollable_fd fd) : fd(std::move(fd)) {} - pollable_fd fd; - char buffer[8192]; - void copy_data() { - fd.read_some(buffer, sizeof(buffer)).then([this] (size_t n) { - if (n) { - fd.write_all(buffer, n).then([this] { - copy_data(); - }); - } else { - delete this; - } - }); - } - }; - void new_connection(pollable_fd fd, socket_address sa) { - auto c = new connection(std::move(fd)); - c->copy_data(); - } - void start_accept() { - listener.accept().then([this] (pollable_fd fd, socket_address sa) { - new_connection(std::move(fd), std::move(sa)); - start_accept(); - }); - } -}; - -int main(int ac, char** av) -{ - ipv4_addr addr{10000}; - listen_options lo; - lo.reuse_address = true; - test t(engine().posix_listen(make_ipv4_address(addr), lo)); - t.start_accept(); - engine().run(); - return 0; -} -