log: move logger to its own namespace and rename macros

Such names as `LogLevel`, `Logger`, `LOG_ERROR` and so on are too common
and our users can use them in their projects. It will lead to conflicts,
so let's move logger to namespace `tnt` just as other utils and rename
macros like `LOG_ERROR` to `TNT_LOG_ERROR`.

Author: drewdzzz

src/Client/Connection.hpp

@@ -522,7 +522,7 @@ static void
 inputBufGC(Connection<BUFFER, NetProvider> &conn)
 {
 	if ((conn.gc_step++ % Connection<BUFFER, NetProvider>::GC_STEP_CNT) == 0) {
-		LOG_DEBUG("Flushed input buffer of the connection %p", &conn);
+		TNT_LOG_DEBUG("Flushed input buffer of the connection %p", &conn);
 		conn.impl->inBuf.flush();
 	}
 }
@@ -539,7 +539,7 @@ processResponse(Connection<BUFFER, NetProvider> &conn, int req_sync, Response<BU
 	Response<BUFFER> response;
 	response.size = conn.impl->dec.decodeResponseSize();
 	if (response.size < 0) {
-		LOG_ERROR("Failed to decode response size");
+		TNT_LOG_ERROR("Failed to decode response size");
 		//In case of corrupted response size all other data in the buffer
 		//is likely to be decoded in the wrong way (since we don't
 		// know how much bytes should be skipped). So let's simply
@@ -559,8 +559,8 @@ processResponse(Connection<BUFFER, NetProvider> &conn, int req_sync, Response<BU
 		conn.impl->endDecoded += response.size;
 		return DECODE_ERR;
 	}
-	LOG_DEBUG("Header: sync=", response.header.sync, ", code=",
-		  response.header.code, ", schema=", response.header.schema_id);
+	TNT_LOG_DEBUG("Header: sync=", response.header.sync, ", code=", response.header.code,
+		      ", schema=", response.header.schema_id);
 	if (result != nullptr && response.header.sync == req_sync) {
 		*result = std::move(response);
 	} else {
@@ -585,7 +585,7 @@ decodeGreeting(Connection<BUFFER, NetProvider> &conn)
 			  conn.impl->greeting) != 0)
 		return -1;
 	conn.impl->is_greeting_received = true;
-	LOG_DEBUG("Version: ", conn.impl->greeting.version_id);
+	TNT_LOG_DEBUG("Version: ", conn.impl->greeting.version_id);
 
 #ifndef NDEBUG
 	//print salt in hex format.
@@ -597,7 +597,7 @@ decodeGreeting(Connection<BUFFER, NetProvider> &conn)
 		hex_salt[i * 2 + 1] = hex[u % 16];
 	}
 	hex_salt[conn.impl->greeting.salt_size * 2] = 0;
-	LOG_DEBUG("Salt: ", hex_salt);
+	TNT_LOG_DEBUG("Salt: ", hex_salt);
 #endif
 	return 0;
 }

src/Client/Connector.hpp

@@ -146,8 +146,7 @@ Connector<BUFFER, NetProvider>::connect(Connection<BUFFER, NetProvider> &conn,
 	//Make sure that connection is not yet established.
 	assert(conn.get_strm().has_status(SS_DEAD));
 	if (m_NetProvider.connect(conn, opts) != 0) {
-		LOG_ERROR("Failed to connect to ",
-			  opts.address, ':', opts.service);
+		TNT_LOG_ERROR("Failed to connect to ", opts.address, ':', opts.service);
 		return -1;
 	}
 	conn.getImpl()->is_greeting_received = false;
@@ -156,8 +155,7 @@ Connector<BUFFER, NetProvider>::connect(Connection<BUFFER, NetProvider> &conn,
 		// Encode auth request to reserve space in buffer.
 		conn.prepare_auth(opts.user, opts.passwd);
 	}
-	LOG_DEBUG("Connection to ", opts.address, ':', opts.service,
-		  " has been established");
+	TNT_LOG_DEBUG("Connection to ", opts.address, ':', opts.service, " has been established");
 	return 0;
 }
 
@@ -258,7 +256,7 @@ Connector<BUFFER, NetProvider>::wait(Connection<BUFFER, NetProvider> &conn,
 				     rid_t future, int timeout,
 				     Response<BUFFER> *result)
 {
-	LOG_DEBUG("Waiting for the future ", future, " with timeout ", timeout);
+	TNT_LOG_DEBUG("Waiting for the future ", future, " with timeout ", timeout);
 	Timer timer{timeout};
 	timer.start();
 	static constexpr int INVALID_SYNC = -1;
@@ -269,7 +267,7 @@ Connector<BUFFER, NetProvider>::wait(Connection<BUFFER, NetProvider> &conn,
 		return -1;
 	if (result != NULL && result->header.sync != INVALID_SYNC) {
 		assert(result->header.sync == req_sync);
-		LOG_DEBUG("Future ", future, " is ready and decoded");
+		TNT_LOG_DEBUG("Future ", future, " is ready and decoded");
 		return 0;
 	}
 	while (!conn.hasError() && !conn.futureIsReady(future)) {
@@ -282,24 +280,23 @@ Connector<BUFFER, NetProvider>::wait(Connection<BUFFER, NetProvider> &conn,
 			return -1;
 		if (result != NULL && result->header.sync != INVALID_SYNC) {
 			assert(result->header.sync == req_sync);
-			LOG_DEBUG("Future ", future, " is ready and decoded");
+			TNT_LOG_DEBUG("Future ", future, " is ready and decoded");
 			return 0;
 		}
 		if (timer.isExpired())
 			break;
 	}
 	if (conn.hasError()) {
-		LOG_ERROR("Connection got an error: ", conn.getError().msg);
+		TNT_LOG_ERROR("Connection got an error: ", conn.getError().msg);
 		return -1;
 	}
 	if (! conn.futureIsReady(future)) {
-		LOG_DEBUG("Connection has been timed out: future ", future,
-			  " is not ready");
+		TNT_LOG_DEBUG("Connection has been timed out: future ", future, " is not ready");
 		return -1;
 	} else if (result != NULL) {
 		*result = std::move(conn.getResponse(future));
 	}
-	LOG_DEBUG("Feature ", future, " is ready and decoded");
+	TNT_LOG_DEBUG("Feature ", future, " is ready and decoded");
 	return 0;
 }
 
@@ -331,10 +328,10 @@ Connector<BUFFER, NetProvider>::waitAll(Connection<BUFFER, NetProvider> &conn,
 			break;
 	}
 	if (conn.hasError()) {
-		LOG_ERROR("Connection got an error: ", conn.getError().msg);
+		TNT_LOG_ERROR("Connection got an error: ", conn.getError().msg);
 		return -1;
 	}
-	LOG_DEBUG("Connection has been timed out: not all futures are ready");
+	TNT_LOG_DEBUG("Connection has been timed out: not all futures are ready");
 	return -1;
 }
 
@@ -346,14 +343,14 @@ Connector<BUFFER, NetProvider>::waitAny(int timeout)
 	timer.start();
 	while (m_ReadyToDecode.empty()) {
 		if (m_NetProvider.wait(timer.timeLeft()) != 0) {
-			LOG_ERROR("Failed to poll connections: ", strerror(errno));
+			TNT_LOG_ERROR("Failed to poll connections: ", strerror(errno));
 			return std::nullopt;
 		}
 		if (timer.isExpired())
 			break;
 	}
 	if (m_ReadyToDecode.empty()) {
-		LOG_DEBUG("wait() has been timed out! No responses are received");
+		TNT_LOG_DEBUG("wait() has been timed out! No responses are received");
 		return std::nullopt;
 	}
 	Connection<BUFFER, NetProvider> conn = *m_ReadyToDecode.begin();
@@ -391,11 +388,10 @@ Connector<BUFFER, NetProvider>::waitCount(Connection<BUFFER, NetProvider> &conn,
 			break;
 	}
 	if (conn.hasError()) {
-		LOG_ERROR("Connection got an error: ", conn.getError().msg);
+		TNT_LOG_ERROR("Connection got an error: ", conn.getError().msg);
 		return -1;
 	}
-	LOG_DEBUG("Connection has been timed out: only ",
-		  conn.getFutureCount() - ready_futures, " are ready");
+	TNT_LOG_DEBUG("Connection has been timed out: only ", conn.getFutureCount() - ready_futures, " are ready");
 	return -1;
 }
 

src/Client/EpollNetProvider.hpp

@@ -142,7 +142,7 @@ EpollNetProvider<BUFFER, Stream>::connect(Conn_t &conn,
 			      opts.address);
 		return -1;
 	}
-	LOG_DEBUG("Connected to ", opts.address, ", socket is ", strm.get_fd());
+	TNT_LOG_DEBUG("Connected to ", opts.address, ", socket is ", strm.get_fd());
 
 	registerEpoll(conn);
 	return 0;
@@ -168,8 +168,7 @@ EpollNetProvider<BUFFER, Stream>::close(Stream_t& strm)
 			struct sockaddr_un *sa_un = (struct sockaddr_un *) &sa;
 			snprintf(addr, 120, "%s", sa_un->sun_path);
 		}
-		LOG_DEBUG("Closed connection to socket ", was_fd,
-			  " corresponding to address ", addr);
+		TNT_LOG_DEBUG("Closed connection to socket ", was_fd, " corresponding to address ", addr);
 	}
 #endif
 	/*
@@ -209,12 +208,12 @@ EpollNetProvider<BUFFER, Stream>::recv(Conn_t &conn)
 		if ((size_t) rcvd < Iproto::GREETING_SIZE)
 			return 0;
 		/* Receive and decode greetings. */
-		LOG_DEBUG("Greetings are received, read bytes ", rcvd);
+		TNT_LOG_DEBUG("Greetings are received, read bytes ", rcvd);
 		if (decodeGreeting(conn) != 0) {
 			conn.setError("Failed to decode greetings");
 			return -1;
 		}
-		LOG_DEBUG("Greetings are decoded");
+		TNT_LOG_DEBUG("Greetings are decoded");
 		rcvd -= Iproto::GREETING_SIZE;
 		if (conn.getImpl()->is_auth_required) {
 			// Finalize auth request in buffer.
@@ -261,7 +260,7 @@ EpollNetProvider<BUFFER, Stream>::wait(int timeout)
 	assert(timeout >= -1);
 	if (timeout == -1)
 		timeout = TIMEOUT_INFINITY;
-	LOG_DEBUG("Network engine wait for ", timeout, " milliseconds");
+	TNT_LOG_DEBUG("Network engine wait for ", timeout, " milliseconds");
 	/* Send pending requests. */
 	for (auto conn = m_Connector.m_ReadyToSend.begin();
 	     conn != m_Connector.m_ReadyToSend.end();) {
@@ -276,7 +275,7 @@ EpollNetProvider<BUFFER, Stream>::wait(int timeout)
 	if (event_cnt < 0) {
 		//Poll error doesn't belong to any connection so just global
 		//log it.
-		LOG_ERROR("Poll failed: ", strerror(errno));
+		TNT_LOG_ERROR("Poll failed: ", strerror(errno));
 		return -1;
 	}
 	for (int i = 0; i < event_cnt; ++i) {

src/Client/LibevNetProvider.hpp

@@ -142,12 +142,12 @@ connectionReceive(Connection<BUFFER,  LibevNetProvider<BUFFER, Stream>> &conn)
 		if ((size_t) rcvd < Iproto::GREETING_SIZE)
 			return 0;
 		/* Receive and decode greetings. */
-		LOG_DEBUG("Greetings are received, read bytes ", rcvd);
+		TNT_LOG_DEBUG("Greetings are received, read bytes ", rcvd);
 		if (decodeGreeting(conn) != 0) {
 			conn.setError("Failed to decode greetings");
 			return -1;
 		}
-		LOG_DEBUG("Greetings are decoded");
+		TNT_LOG_DEBUG("Greetings are decoded");
 		rcvd -= Iproto::GREETING_SIZE;
 		if (conn.getImpl()->is_auth_required) {
 			// Finalize auth request in buffer.
@@ -247,7 +247,7 @@ send_cb(struct ev_loop *loop, struct ev_io *watcher, int /* revents */)
 	}
 	if (rc > 0) {
 		/* Send is not complete, setting the write watcher. */
-		LOG_DEBUG("Send is not complete, setting the write watcher");
+		TNT_LOG_DEBUG("Send is not complete, setting the write watcher");
 		if (conn.get_strm().has_status(SS_NEED_WRITE_EVENT_FOR_WRITE))
 			if (!ev_is_active(&waitWatcher->out))
 				ev_io_start(loop, &waitWatcher->out);
@@ -302,7 +302,7 @@ LibevNetProvider<BUFFER, Stream>::registerWatchers(Conn_t &conn, int fd)
 		new (std::nothrow) WaitWatcher<BUFFER, Stream>(&m_Connector,
 								conn, &m_TimeoutWatcher);
 	if (watcher == nullptr) {
-		LOG_ERROR("Failed to allocate memory for WaitWatcher");
+		TNT_LOG_ERROR("Failed to allocate memory for WaitWatcher");
 		abort();
 	}
 
@@ -325,7 +325,7 @@ LibevNetProvider<BUFFER, Stream>::connect(Conn_t &conn,
 			      opts.address);
 		return -1;
 	}
-	LOG_DEBUG("Connected to ", opts.address, ", socket is ", strm.get_fd());
+	TNT_LOG_DEBUG("Connected to ", opts.address, ", socket is ", strm.get_fd());
 
 	registerWatchers(conn, strm.get_fd());
 	return 0;
@@ -354,7 +354,7 @@ void
 LibevNetProvider<BUFFER, Stream>::timeout_cb(EV_P_ ev_timer *w, int /* revents */)
 {
 	(void) w;
-	LOG_DEBUG("Libev timed out!");
+	TNT_LOG_DEBUG("Libev timed out!");
 	/* Stop external loop */
 	ev_break(EV_A_ EVBREAK_ONE);
 }

src/Client/ResponseDecoder.hpp

@@ -84,11 +84,11 @@ ResponseDecoder<BUFFER>::decodeResponse(Response<BUFFER> &response)
 {
 	/* Decode header and body separately to get more detailed error. */
 	if (!mpp::decode(it, response.header)) {
-		LOG_ERROR("Failed to decode header");
+		TNT_LOG_ERROR("Failed to decode header");
 		return -1;
 	}
 	if (!mpp::decode(it, response.body)) {
-		LOG_ERROR("Failed to decode body");
+		TNT_LOG_ERROR("Failed to decode body");
 		return -1;
 	}
 	return 0;

src/Client/UnixStream.hpp

@@ -68,9 +68,8 @@ class UnixStream : public Stream {
 
 protected:
 	/** Log helpers. */
-	template <class ...MSG>
-	void log_wise(LogLevel level, const char *file, int line,
-		      const char *msg, MSG &&...more);
+	template <class... MSG>
+	void log_wise(tnt::LogLevel level, const char *file, int line, const char *msg, MSG &&...more);
 	template <class ...MSG>
 	int die(const char *file, int line,
 		const char *msg, MSG &&...more);
@@ -109,8 +108,7 @@ class UnixStream : public Stream {
 
 template <class... MSG>
 void
-UnixStream::log_wise(LogLevel level, const char *file, int line,
-		     const char *msg, MSG&& ...more)
+UnixStream::log_wise(tnt::LogLevel level, const char *file, int line, const char *msg, MSG &&...more)
 {
 	if (sizeof...(MSG) == 0 && fd < 0)
 		log(level, file, line, msg);
@@ -127,7 +125,7 @@ template <class ...MSG>
 int
 UnixStream::die(const char *file, int line, const char *msg, MSG&& ...more)
 {
-	log_wise(ERROR, file, line, msg, std::forward<MSG>(more)...);
+	log_wise(tnt::ERROR, file, line, msg, std::forward<MSG>(more)...);
 	set_status(SS_DEAD);
 	return -1;
 }
@@ -137,7 +135,7 @@ int
 UnixStream::tell(StreamStatus st, const char *file, int line,
 		 const char *msg, MSG&& ...more)
 {
-	log_wise(INFO, file, line, msg, std::forward<MSG>(more)...);
+	log_wise(tnt::INFO, file, line, msg, std::forward<MSG>(more)...);
 	set_status(st);
 	return 0;
 }

src/Utils/Logger.hpp

@@ -36,6 +36,8 @@
 #include <sstream>
 #include <string_view>
 
+namespace tnt {
+
 enum LogLevel {
 	DEBUG = 0,
 	INFO = 1,
@@ -120,7 +122,9 @@ log(LogLevel level, const char *file, int line, ARGS&& ...args)
 	gLogger.log(fd, level, file, line, std::forward<ARGS>(args)...);
 }
 
-#define LOG_DEBUG(...) log(DEBUG, __FILE__, __LINE__,  __VA_ARGS__)
-#define LOG_INFO(...) log(INFO, __FILE__, __LINE__,  __VA_ARGS__)
-#define LOG_WARNING(...) log(WARNING, __FILE__, __LINE__, __VA_ARGS__)
-#define LOG_ERROR(...) log(ERROR, __FILE__, __LINE__, __VA_ARGS__)
+} /* namespace tnt */
+
+#define TNT_LOG_DEBUG(...) tnt::log(tnt::DEBUG, __FILE__, __LINE__, __VA_ARGS__)
+#define TNT_LOG_INFO(...) tnt::log(tnt::INFO, __FILE__, __LINE__, __VA_ARGS__)
+#define TNT_LOG_WARNING(...) tnt::log(tnt::WARNING, __FILE__, __LINE__, __VA_ARGS__)
+#define TNT_LOG_ERROR(...) tnt::log(tnt::ERROR, __FILE__, __LINE__, __VA_ARGS__)