diff options
| author | Adam Ierymenko <adam.ierymenko@gmail.com> | 2019-03-21 16:42:52 -0700 |
|---|---|---|
| committer | Adam Ierymenko <adam.ierymenko@gmail.com> | 2019-03-21 16:42:52 -0700 |
| commit | e37eb0aa542ef8aee8532c5bfdde7f09ed343a28 (patch) | |
| tree | c2900b4814847fb3249b41e7dcfe5ab6dbac9215 /ext/librethinkdbxx/src/connection.h | |
| parent | 130fa35bb1707ea232015c1a3672f0585632dea1 (diff) | |
| download | infinitytier-e37eb0aa542ef8aee8532c5bfdde7f09ed343a28.tar.gz infinitytier-e37eb0aa542ef8aee8532c5bfdde7f09ed343a28.zip | |
More cleanup of old stuff no longer used.
Diffstat (limited to 'ext/librethinkdbxx/src/connection.h')
| -rw-r--r-- | ext/librethinkdbxx/src/connection.h | 59 |
1 files changed, 0 insertions, 59 deletions
diff --git a/ext/librethinkdbxx/src/connection.h b/ext/librethinkdbxx/src/connection.h deleted file mode 100644 index d3882857..00000000 --- a/ext/librethinkdbxx/src/connection.h +++ /dev/null @@ -1,59 +0,0 @@ -#pragma once - -#include <string> -#include <queue> -#include <mutex> -#include <memory> -#include <condition_variable> - -#include "protocol_defs.h" -#include "datum.h" -#include "error.h" - -#define FOREVER (-1) -#define SECOND 1 -#define MICROSECOND 0.000001 - -namespace RethinkDB { - -class Term; -using OptArgs = std::map<std::string, Term>; - -// A connection to a RethinkDB server -// It contains: -// * A socket -// * Read and write locks -// * A cache of responses that have not been read by the corresponding Cursor -class ConnectionPrivate; -class Connection { -public: - Connection() = delete; - Connection(const Connection&) noexcept = delete; - Connection(Connection&&) noexcept = delete; - Connection& operator=(Connection&&) noexcept = delete; - Connection& operator=(const Connection&) noexcept = delete; - ~Connection(); - - void close(); - -private: - explicit Connection(ConnectionPrivate *dd); - std::unique_ptr<ConnectionPrivate> d; - - Cursor start_query(Term *term, OptArgs&& args); - void stop_query(uint64_t); - void continue_query(uint64_t); - - friend class Cursor; - friend class CursorPrivate; - friend class Token; - friend class Term; - friend std::unique_ptr<Connection> - connect(std::string host, int port, std::string auth_key); - -}; - -// $doc(connect) -std::unique_ptr<Connection> connect(std::string host = "localhost", int port = 28015, std::string auth_key = ""); - -} |
