tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add release logging without core dump.

Browse Source 
Reviewers: buda, teon.banek

Reviewed By: teon.banek

Subscribers: pullbot

Differential Revision: https://phabricator.memgraph.io/D447
This commit is contained in:
Dominik Gleich 2017-06-09 11:11:18 +02:00
parent 1057d253ca
commit 0fb29a7ce0
3 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/communication/worker.hpp
View File

@ -77,7 +77,9 @@ class Worker
}
void OnClose(Session &session) {
logger_.trace("Client closed the connection");
logger_.info("Client {}:{} closed the connection.",
session.socket_.endpoint().address(),
session.socket_.endpoint().port());
// TODO: remove socket from epoll object
session.Close();
delete &session;

8
src/io/network/stream_reader.hpp
View File

@ -17,13 +17,15 @@ class StreamReader : public StreamListener<Derived, Stream> {
: StreamListener<Derived, Stream>(flags),
logger_(logging::log->logger("io::StreamReader")) {}
bool Accept(Socket& socket) {
bool Accept(Socket &socket) {
logger_.trace("Accept");
// accept a connection from a socket
Socket s;
if (!socket.Accept(&s)) return false;
logger_.info("Client {}:{} connected.", s.endpoint().address(),
s.endpoint().port());
logger_.trace(
"Accepted a connection: scoket {}, address '{}', family {}, port {}",
s.id(), s.endpoint().address(), s.endpoint().family(),
@ -32,7 +34,7 @@ class StreamReader : public StreamListener<Derived, Stream> {
if (!s.SetKeepAlive()) return false;
if (!s.SetNoDelay()) return false;
auto& stream = this->derived().OnConnect(std::move(s));
auto &stream = this->derived().OnConnect(std::move(s));
// we want to listen to an incoming event which is edge triggered and
// we also want to listen on the hangup event
@ -44,7 +46,7 @@ class StreamReader : public StreamListener<Derived, Stream> {
return true;
}
void OnData(Stream& stream) {
void OnData(Stream &stream) {
logger_.trace("On data");
if (UNLIKELY(!stream.Alive())) {

4
src/query/interpreter.hpp
View File

@ -14,8 +14,9 @@
namespace query {
class Interpreter {
class Interpreter : public Loggable {
public:
Interpreter() : Loggable("Interpreter") {}
template <typename Stream>
void Interpret(const std::string &query, GraphDbAccessor &db_accessor,
Stream &stream) {
@ -132,6 +133,7 @@ class Interpreter {
// have to be correct (for Bolt clients)
summary["type"] = "rw";
stream.Summary(summary);
logger.info("Execute '{}', {}", query, summary);
}
private: