RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-01 16:42:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

log: remove unnecessary src/log/Graylog.*

Browse Source 
we have two copies of Graylog.* in src/common and src/log, and turns out
the ones in src/common are what we are using. so remove the other two.

Signed-off-by: Kefu Chai <kchai@redhat.com>
This commit is contained in:
Kefu Chai 2016-04-21 17:43:47 +08:00
parent eff74daf9c
commit 031a27a90a
2 changed files with 0 additions and 164 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

107
src/log/Graylog.cc
View File

@ -1,107 +0,0 @@
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#include "Graylog.h"
#include <iostream>
#include <sstream>
#include <memory>
#include <boost/asio.hpp>
#include <boost/iostreams/filtering_stream.hpp>
#include <boost/iostreams/filter/zlib.hpp>
#include <boost/lexical_cast.hpp>
#include "common/Formatter.h"
#include "include/uuid.h"
namespace ceph {
namespace log {
Graylog::Graylog(const SubsystemMap * const s)
: m_subs(s),
m_log_dst_valid(false),
m_hostname(""),
m_fsid(""),
m_ostream_compressed(std::stringstream::in |
std::stringstream::out |
std::stringstream::binary)
{
m_formatter = std::auto_ptr<Formatter>(Formatter::create("json"));
}
Graylog::~Graylog()
{
}
void Graylog::set_destination(const std::string& host, int port)
{
try {
boost::asio::ip::udp::resolver resolver(m_io_service);
boost::asio::ip::udp::resolver::query query(host,
boost::lexical_cast<std::string>(port));
m_endpoint = *resolver.resolve(query);
m_log_dst_valid = true;
} catch (boost::system::system_error const& e) {
cerr << "Error resolving graylog destination: " << e.what() << std::endl;
m_log_dst_valid = false;
}
}
void Graylog::set_hostname(const std::string& host)
{
m_hostname = host;
}
void Graylog::set_fsid(uuid_d fsid)
{
std::vector<char> buf(40);
fsid.print(&buf[0]);
m_fsid = std::string(&buf[0]);
}
void Graylog::log_entry(Entry const * const e)
{
if (m_log_dst_valid) {
std::string s = e->get_str();
// GELF format
// http://www.graylog2.org/resources/gelf/specification
m_formatter->open_object_section("");
m_formatter->dump_string("version", "1.1");
m_formatter->dump_string("host", m_hostname);
m_formatter->dump_string("short_message", s);
m_formatter->dump_string("_app", "ceph");
m_formatter->dump_float("timestamp", e->m_stamp.sec() + (e->m_stamp.usec() / 1000000.0));
m_formatter->dump_int("_thread", e->m_thread);
m_formatter->dump_int("_prio", e->m_prio);
m_formatter->dump_string("_subsys_name", m_subs->get_name(e->m_subsys));
m_formatter->dump_int("_subsys_id", e->m_subsys);
m_formatter->dump_string("_fsid", m_fsid);
m_formatter->close_section();
m_ostream_compressed.clear();
m_ostream_compressed.str("");
m_ostream.reset();
m_ostream.push(m_compressor);
m_ostream.push(m_ostream_compressed);
m_formatter->flush(m_ostream);
m_ostream << std::endl;
m_ostream.reset();
try {
boost::asio::ip::udp::socket socket(m_io_service);
socket.open(m_endpoint.protocol());
socket.send_to(boost::asio::buffer(m_ostream_compressed.str()), m_endpoint);
} catch (boost::system::system_error const& e) {
cerr << "Error sending graylog message: " << e.what() << std::endl;
}
}
}
} // ceph::log::
} // ceph::

57
src/log/Graylog.h
View File

@ -1,57 +0,0 @@
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#ifndef __CEPH_LOG_GRAYLOG_H
#define __CEPH_LOG_GRAYLOG_H
#include <memory>
#include <boost/thread/mutex.hpp>
#include <boost/asio.hpp>
#include <boost/iostreams/filtering_stream.hpp>
#include <boost/iostreams/filter/zlib.hpp>
#include "Entry.h"
#include "SubsystemMap.h"
namespace ceph {
namespace log {
class Graylog
{
public:
explicit Graylog(const SubsystemMap * const s);
virtual ~Graylog();
void set_hostname(const std::string& host);
void set_fsid(uuid_d fsid);
void set_destination(const std::string& host, int port);
void log_entry(Entry const * const e);
typedef ceph::shared_ptr<Graylog> Ref;
private:
SubsystemMap const * const m_subs;
bool m_log_dst_valid;
std::string m_hostname;
std::string m_fsid;
boost::asio::ip::udp::endpoint m_endpoint;
boost::asio::io_service m_io_service;
std::auto_ptr<Formatter> m_formatter;
std::stringstream m_ostream_compressed;
boost::iostreams::filtering_ostream m_ostream;
boost::iostreams::zlib_compressor m_compressor;
};
}
}
#endif