rename namespace

master
Claudius Holeksa 2021-12-29 19:26:22 +01:00
parent 55402c1171
commit 5dd7860b92
29 changed files with 55 additions and 55 deletions

View File

@ -1,4 +1,4 @@
# kelgin
# forst-io
Asynchronous framework mostly inspired by [Capn'Proto](https://github.com/capnproto/capnproto) with the key difference of not
using Promises, but more reusable Pipelines/Conveyors. This introduces some challenges since I can't assume that only one

View File

@ -29,7 +29,7 @@ def add_kel_source_files(self, sources, filetype, lib_env=None, shared=False, ta
sources.append( self.StaticObject( target=target_name, source=path ) )
pass
env=Environment(ENV=os.environ, CPPPATH=['#source/kelgin','#source','#','#driver'],
env=Environment(ENV=os.environ, CPPPATH=['#source/forst-io','#source','#','#driver'],
CXX='clang++',
CPPDEFINES=['GIN_UNIX'],
CXXFLAGS=['-std=c++20','-g','-Wall','-Wextra'],

View File

@ -2,7 +2,7 @@
#include <sstream>
namespace gin {
namespace saw {
namespace unix {
IFdOwner::IFdOwner(UnixEventPort &event_port, int file_descriptor, int fd_flags,
uint32_t event_mask)
@ -279,4 +279,4 @@ ErrorOr<AsyncIoContext> setupAsyncIo() {
return criticalError("Out of memory");
}
}
} // namespace gin
} // namespace saw

View File

@ -29,7 +29,7 @@
#include "./io.h"
#include "kelgin/io.h"
namespace gin {
namespace saw {
namespace unix {
constexpr int MAX_EPOLL_EVENTS = 256;
@ -439,4 +439,4 @@ public:
EventLoop &eventLoop();
};
} // namespace unix
} // namespace gin
} // namespace saw

View File

@ -3,7 +3,7 @@
#include <algorithm>
#include <cassert>
namespace gin {
namespace saw {
namespace {
thread_local EventLoop *local_loop = nullptr;
@ -344,4 +344,4 @@ void detachConveyor(Conveyor<void> &&conveyor) {
ConveyorSinks &sink = loop.daemon();
sink.add(std::move(conveyor));
}
} // namespace gin
} // namespace saw

View File

@ -10,7 +10,7 @@
#include <queue>
#include <type_traits>
namespace gin {
namespace saw {
class ConveyorNode {
public:
ConveyorNode();
@ -409,11 +409,11 @@ template <typename Func> ConveyorResult<Func, void> yieldNext(Func &&func);
template <typename Func> ConveyorResult<Func, void> yieldLater(Func &&func);
template <typename Func> ConveyorResult<Func, void> yieldLast(Func &&func);
} // namespace gin
} // namespace saw
// Secret stuff
// Aka private semi hidden classes
namespace gin {
namespace saw {
template <typename Out, typename In> struct FixVoidCaller {
template <typename Func> static Out apply(Func &func, In &&in) {
@ -878,6 +878,6 @@ public:
*/
} // namespace gin
} // namespace saw
#include "async.tmpl.h"

View File

@ -7,7 +7,7 @@
#include <iostream>
namespace gin {
namespace saw {
template <typename Func> ConveyorResult<Func, void> execLater(Func &&func) {
Conveyor<void> conveyor{FixVoid<void>{}};
@ -644,4 +644,4 @@ template <typename T> void OneTimeConveyorNode<T>::fire() {
}
}
} // namespace gin
} // namespace saw

View File

@ -6,7 +6,7 @@
#include <iomanip>
#include <sstream>
namespace gin {
namespace saw {
Error Buffer::push(const uint8_t &value) {
size_t write_remain = writeCompositeLength();
if (write_remain > 0) {
@ -429,4 +429,4 @@ Error ArrayBuffer::writeRequireLength(size_t bytes) {
return noError();
}
} // namespace gin
} // namespace saw

View File

@ -9,7 +9,7 @@
#include <string>
#include <vector>
namespace gin {
namespace saw {
/*
* Access class to reduce templated BufferSegments bloat
*/
@ -189,4 +189,4 @@ public:
Error writeRequireLength(size_t bytes) override;
};
} // namespace gin
} // namespace saw

View File

@ -5,7 +5,7 @@
#include <optional>
#include <utility>
namespace gin {
namespace saw {
#define GIN_CONCAT_(x, y) x##y
#define GIN_CONCAT(x, y) GIN_CONCAT_(x, y)
@ -69,4 +69,4 @@ template <typename T> struct VoidUnfix { typedef T Type; };
template <> struct VoidUnfix<Void> { typedef void Type; };
template <typename T> using UnfixVoid = typename VoidUnfix<T>::Type;
} // namespace gin
} // namespace saw

View File

@ -1,6 +1,6 @@
#include "error.h"
namespace gin {
namespace saw {
Error::Error() : error_{static_cast<Error::Code>(0)} {}
Error::Error(const std::string_view &msg, Error::Code code)
@ -70,4 +70,4 @@ Error recoverableError(const std::string_view &generic, Error::Code c) {
Error noError() { return Error{}; }
} // namespace gin
} // namespace saw

View File

@ -6,7 +6,7 @@
#include "common.h"
namespace gin {
namespace saw {
/**
* Utility class for generating errors. Has a base distinction between
* critical and recoverable errors. Additional code ids can be provided to the
@ -138,4 +138,4 @@ private:
ErrorOr() = delete;
};
} // namespace gin
} // namespace saw

View File

@ -2,7 +2,7 @@
#include <cassert>
namespace gin {
namespace saw {
AsyncIoStream::AsyncIoStream(Own<IoStream> str)
: stream{std::move(str)}, read_ready{stream->readReady()
@ -58,4 +58,4 @@ Conveyor<size_t> AsyncIoStream::writeDone() {
write_stepper.write_done = std::move(caf.feeder);
return std::move(caf.conveyor);
}
} // namespace gin
} // namespace saw

View File

@ -6,7 +6,7 @@
#include <string>
namespace gin {
namespace saw {
/*
* Input stream
*/
@ -132,4 +132,4 @@ struct AsyncIoContext {
};
ErrorOr<AsyncIoContext> setupAsyncIo();
} // namespace gin
} // namespace saw

View File

@ -4,7 +4,7 @@
#include <cassert>
namespace gin {
namespace saw {
void ReadTaskAndStepHelper::readStep(InputStream &reader) {
while (read_task.has_value()) {
ReadIoTask &task = *read_task;
@ -82,4 +82,4 @@ void WriteTaskAndStepHelper::writeStep(OutputStream &writer) {
}
}
} // namespace gin
} // namespace saw

View File

@ -6,7 +6,7 @@
#include <cstdint>
#include <optional>
namespace gin {
namespace saw {
/*
* Helper classes for the specific driver implementations
*/
@ -50,4 +50,4 @@ public:
public:
void writeStep(OutputStream &writer);
};
} // namespace gin
} // namespace saw

View File

@ -3,7 +3,7 @@
#include "async.h"
#include "io.h"
namespace gin {
namespace saw {
template <typename Codec, typename Incoming, typename Outgoing>
class StreamingIoPeer {
@ -22,4 +22,4 @@ public:
Conveyor<Incoming> startReadPump();
};
} // namespace gin
} // namespace saw

View File

@ -1,7 +1,7 @@
#include "log.h"
namespace gin {
namespace saw {
LogIo::LogIo(EventLoop &loop) : loop{loop} {}
Log::Log(LogIo &central, EventLoop &loop) : central{central}, loop{loop} {}
} // namespace gin
} // namespace saw

View File

@ -2,7 +2,7 @@
#include "common.h"
namespace gin {
namespace saw {
class EventLoop;
class LogIo;
class Log {
@ -23,4 +23,4 @@ private:
public:
LogIo(EventLoop &loop);
};
} // namespace gin
} // namespace saw

View File

@ -14,7 +14,7 @@
#include "schema.h"
#include "string_literal.h"
namespace gin {
namespace saw {
class MessageBase {
protected:
bool set_explicitly = false;
@ -557,4 +557,4 @@ inline HeapMessageRoot<Schema, Container> heapMessageRoot() {
Own<Message<Schema, Container>> root = heap<Message<Schema, Container>>();
return HeapMessageRoot<Schema, Container>{std::move(root)};
}
} // namespace gin
} // namespace saw

View File

@ -2,7 +2,7 @@
#include "schema.h"
namespace gin {
namespace saw {
template <class T> class MessageContainer;
template <class T, class Container = MessageContainer<T>> class Message;
@ -238,4 +238,4 @@ public:
const ValueType &get() const { return value; }
};
} // namespace gin
} // namespace saw

View File

@ -6,7 +6,7 @@
#include <iostream>
namespace gin {
namespace saw {
/// @todo replace types with these
/*
* I'm not really sure if anyone will use a union which is
@ -582,4 +582,4 @@ Error ProtoKelCodec::decode(
return noError();
}
} // namespace gin
} // namespace saw

View File

@ -2,7 +2,7 @@
#include "string_literal.h"
namespace gin {
namespace saw {
namespace schema {
template <class T, StringLiteral Literal> struct NamedMember {};
@ -48,4 +48,4 @@ using Float32 = Primitive<FloatingPoint, 4>;
using Float64 = Primitive<FloatingPoint, 8>;
} // namespace schema
} // namespace gin
} // namespace saw

View File

@ -8,7 +8,7 @@
#include <iostream>
namespace gin {
namespace saw {
/**
* Helper class to encode/decode any primtive type into/from litte endian.
* The shift class does this by shifting bytes. This type of procedure is
@ -149,4 +149,4 @@ public:
template <typename T> using StreamValue = ShiftStreamValue<T>;
} // namespace gin
} // namespace saw

View File

@ -3,7 +3,7 @@
#include <array>
#include <string_view>
namespace gin {
namespace saw {
/**
* Helper object which creates a templated string from the provided string
* literal. It guarantees compile time uniqueness and thus allows using strings
@ -37,4 +37,4 @@ template <typename T, T... Chars>
constexpr gin::StringLiteral<T, sizeof...(Chars)> operator""_key() {
return gin::StringLiteral<T, sizeof...(Chars) + 1u>{Chars..., '\0'};
}
} // namespace gin
} // namespace saw

View File

@ -2,4 +2,4 @@
#include <chrono>
namespace gin {}
namespace saw {}

View File

@ -9,7 +9,7 @@
#include <iostream>
namespace gin {
namespace saw {
class Tls::Impl {
public:
@ -263,4 +263,4 @@ Conveyor<Own<NetworkAddress>> TlsNetwork::parseAddress(const std::string &addr,
std::optional<Own<TlsNetwork>> setupTlsNetwork(Network &network) {
return std::nullopt;
}
} // namespace gin
} // namespace saw

View File

@ -6,7 +6,7 @@
#include <optional>
#include <variant>
namespace gin {
namespace saw {
class Tls {
private:
class Impl;
@ -66,4 +66,4 @@ public:
std::optional<Own<TlsNetwork>> setupTlsNetwork(Network &network);
} // namespace gin
} // namespace saw