summaryrefslogtreecommitdiff
path: root/src/main/cpp/loggingevent.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/cpp/loggingevent.cpp')
-rw-r--r--src/main/cpp/loggingevent.cpp326
1 files changed, 326 insertions, 0 deletions
diff --git a/src/main/cpp/loggingevent.cpp b/src/main/cpp/loggingevent.cpp
new file mode 100644
index 0000000..1c0d4be
--- /dev/null
+++ b/src/main/cpp/loggingevent.cpp
@@ -0,0 +1,326 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <log4cxx/spi/loggingevent.h>
+#include <log4cxx/ndc.h>
+
+#include <log4cxx/level.h>
+#include <log4cxx/helpers/loglog.h>
+#include <log4cxx/helpers/system.h>
+#include <log4cxx/helpers/socket.h>
+#if !defined(LOG4CXX)
+#define LOG4CXX 1
+#endif
+#include <log4cxx/helpers/aprinitializer.h>
+#include <log4cxx/helpers/threadspecificdata.h>
+#include <log4cxx/helpers/transcoder.h>
+
+#include <apr_time.h>
+#include <apr_portable.h>
+#include <apr_strings.h>
+#include <log4cxx/helpers/stringhelper.h>
+#include <log4cxx/helpers/objectoutputstream.h>
+#include <log4cxx/helpers/bytebuffer.h>
+#include <log4cxx/logger.h>
+#include <log4cxx/private/log4cxx_private.h>
+
+using namespace log4cxx;
+using namespace log4cxx::spi;
+using namespace log4cxx::helpers;
+
+IMPLEMENT_LOG4CXX_OBJECT(LoggingEvent)
+
+
+//
+// Accessor for start time.
+//
+log4cxx_time_t LoggingEvent::getStartTime() {
+ return log4cxx::helpers::APRInitializer::initialize();
+}
+
+LoggingEvent::LoggingEvent() :
+ ndc(0),
+ mdcCopy(0),
+ properties(0),
+ ndcLookupRequired(true),
+ mdcCopyLookupRequired(true),
+ timeStamp(0),
+ locationInfo() {
+}
+
+LoggingEvent::LoggingEvent(
+ const LogString& logger1, const LevelPtr& level1,
+ const LogString& message1, const LocationInfo& locationInfo1) :
+ logger(logger1),
+ level(level1),
+ ndc(0),
+ mdcCopy(0),
+ properties(0),
+ ndcLookupRequired(true),
+ mdcCopyLookupRequired(true),
+ message(message1),
+ timeStamp(apr_time_now()),
+ locationInfo(locationInfo1),
+ threadName(getCurrentThreadName()) {
+}
+
+LoggingEvent::~LoggingEvent()
+{
+ delete ndc;
+ delete mdcCopy;
+ delete properties;
+}
+
+bool LoggingEvent::getNDC(LogString& dest) const
+{
+ if(ndcLookupRequired)
+ {
+ ndcLookupRequired = false;
+ LogString val;
+ if(NDC::get(val)) {
+ ndc = new LogString(val);
+ }
+ }
+ if (ndc) {
+ dest.append(*ndc);
+ return true;
+ }
+ return false;
+}
+
+bool LoggingEvent::getMDC(const LogString& key, LogString& dest) const
+{
+ // Note the mdcCopy is used if it exists. Otherwise we use the MDC
+ // that is associated with the thread.
+ if (mdcCopy != 0 && !mdcCopy->empty())
+ {
+ MDC::Map::const_iterator it = mdcCopy->find(key);
+
+ if (it != mdcCopy->end())
+ {
+ if (!it->second.empty())
+ {
+ dest.append(it->second);
+ return true;
+ }
+ }
+ }
+
+ return MDC::get(key, dest);
+
+}
+
+LoggingEvent::KeySet LoggingEvent::getMDCKeySet() const
+{
+ LoggingEvent::KeySet set;
+
+ if (mdcCopy != 0 && !mdcCopy->empty())
+ {
+ MDC::Map::const_iterator it;
+ for (it = mdcCopy->begin(); it != mdcCopy->end(); it++)
+ {
+ set.push_back(it->first);
+
+ }
+ }
+ else
+ {
+ ThreadSpecificData* data = ThreadSpecificData::getCurrentData();
+ if (data != 0) {
+ MDC::Map& m = data->getMap();
+
+ for(MDC::Map::const_iterator it = m.begin(); it != m.end(); it++) {
+ set.push_back(it->first);
+ }
+ }
+ }
+
+ return set;
+}
+
+void LoggingEvent::getMDCCopy() const
+{
+ if(mdcCopyLookupRequired)
+ {
+ mdcCopyLookupRequired = false;
+ // the clone call is required for asynchronous logging.
+ ThreadSpecificData* data = ThreadSpecificData::getCurrentData();
+ if (data != 0) {
+ mdcCopy = new MDC::Map(data->getMap());
+ } else {
+ mdcCopy = new MDC::Map();
+ }
+ }
+}
+
+bool LoggingEvent::getProperty(const LogString& key, LogString& dest) const
+{
+ if (properties == 0)
+ {
+ return false;
+ }
+
+ std::map<LogString, LogString>::const_iterator it = properties->find(key);
+
+ if (it != properties->end())
+ {
+ dest.append(it->second);
+ return true;
+ }
+
+ return false;
+}
+
+LoggingEvent::KeySet LoggingEvent::getPropertyKeySet() const
+{
+ LoggingEvent::KeySet set;
+
+ if (properties != 0)
+ {
+ std::map<LogString, LogString>::const_iterator it;
+ for (it = properties->begin(); it != properties->end(); it++)
+ {
+ set.push_back(it->first);
+ }
+ }
+
+ return set;
+}
+
+
+const LogString LoggingEvent::getCurrentThreadName() {
+#if APR_HAS_THREADS
+#if defined(_WIN32)
+ char result[20];
+ DWORD threadId = GetCurrentThreadId();
+ apr_snprintf(result, sizeof(result), LOG4CXX_WIN32_THREAD_FMTSPEC, threadId);
+#else
+ // apr_os_thread_t encoded in HEX takes needs as many characters
+ // as two times the size of the type, plus an additional null byte.
+ char result[sizeof(apr_os_thread_t) * 3 + 10];
+ apr_os_thread_t threadId = apr_os_thread_current();
+ apr_snprintf(result, sizeof(result), LOG4CXX_APR_THREAD_FMTSPEC, (void*) &threadId);
+#endif
+ LOG4CXX_DECODE_CHAR(str, (const char*) result);
+ return str;
+#else
+ return LOG4CXX_STR("0x00000000");
+#endif
+}
+
+
+void LoggingEvent::setProperty(const LogString& key, const LogString& value)
+{
+ if (properties == 0)
+ {
+ properties = new std::map<LogString, LogString>;
+ }
+
+ (*properties)[key] = value;
+}
+
+
+
+void LoggingEvent::writeProlog(ObjectOutputStream& os, Pool& p) {
+ char classDesc[] = {
+ 0x72, 0x00, 0x21,
+ 0x6F, 0x72, 0x67, 0x2E, 0x61, 0x70, 0x61, 0x63,
+ 0x68, 0x65, 0x2E, 0x6C, 0x6F, 0x67, 0x34, 0x6A,
+ 0x2E, 0x73, 0x70, 0x69, 0x2E, 0x4C, 0x6F, 0x67,
+ 0x67, 0x69, 0x6E, 0x67, 0x45, 0x76, 0x65, 0x6E,
+ 0x74, 0xF3, 0xF2, 0xB9, 0x23, 0x74, 0x0B, 0xB5,
+ 0x3F, 0x03, 0x00, 0x0A, 0x5A, 0x00, 0x15, 0x6D,
+ 0x64, 0x63, 0x43, 0x6F, 0x70, 0x79, 0x4C, 0x6F,
+ 0x6F, 0x6B, 0x75, 0x70, 0x52, 0x65, 0x71, 0x75,
+ 0x69, 0x72, 0x65, 0x64, 0x5A, 0x00, 0x11, 0x6E,
+ 0x64, 0x63, 0x4C, 0x6F, 0x6F, 0x6B, 0x75, 0x70,
+ 0x52, 0x65, 0x71, 0x75, 0x69, 0x72, 0x65, 0x64,
+ 0x4A, 0x00, 0x09, 0x74, 0x69, 0x6D, 0x65, 0x53,
+ 0x74, 0x61, 0x6D, 0x70, 0x4C, 0x00, 0x0C, 0x63,
+ 0x61, 0x74, 0x65, 0x67, 0x6F, 0x72, 0x79, 0x4E,
+ 0x61, 0x6D, 0x65, 0x74, 0x00, 0x12, 0x4C, 0x6A,
+ 0x61, 0x76, 0x61, 0x2F, 0x6C, 0x61, 0x6E, 0x67,
+ 0x2F, 0x53, 0x74, 0x72, 0x69, 0x6E, 0x67, 0x3B,
+ 0x4C, 0x00, 0x0C, 0x6C, 0x6F, 0x63, 0x61, 0x74,
+ 0x69, 0x6F, 0x6E, 0x49, 0x6E, 0x66, 0x6F, 0x74,
+ 0x00, 0x23, 0x4C, 0x6F, 0x72, 0x67, 0x2F, 0x61,
+ 0x70, 0x61, 0x63, 0x68, 0x65, 0x2F, 0x6C, 0x6F,
+ 0x67, 0x34, 0x6A, 0x2F, 0x73, 0x70, 0x69, 0x2F,
+ 0x4C, 0x6F, 0x63, 0x61, 0x74, 0x69, 0x6F, 0x6E,
+ 0x49, 0x6E, 0x66, 0x6F, 0x3B, 0x4C, 0x00, 0x07,
+ 0x6D, 0x64, 0x63, 0x43, 0x6F, 0x70, 0x79, 0x74,
+ 0x00, 0x15, 0x4C, 0x6A, 0x61, 0x76, 0x61, 0x2F,
+ 0x75, 0x74, 0x69, 0x6C, 0x2F, 0x48, 0x61, 0x73,
+ 0x68, 0x74, 0x61, 0x62, 0x6C, 0x65, 0x3B, 0x4C,
+ 0x00, 0x03, 0x6E, 0x64, 0x63,
+ 0x74, 0x00, 0x12, 0x4C, 0x6A,
+ 0x61, 0x76, 0x61, 0x2F, 0x6C, 0x61, 0x6E, 0x67,
+ 0x2F, 0x53, 0x74, 0x72, 0x69, 0x6E, 0x67, 0x3B,
+ 0x4C, 0x00, 0x0F, 0x72, 0x65, 0x6E,
+ 0x64, 0x65, 0x72, 0x65, 0x64, 0x4D, 0x65, 0x73,
+ 0x73, 0x61, 0x67, 0x65,
+ 0x74, 0x00, 0x12, 0x4C, 0x6A,
+ 0x61, 0x76, 0x61, 0x2F, 0x6C, 0x61, 0x6E, 0x67,
+ 0x2F, 0x53, 0x74, 0x72, 0x69, 0x6E, 0x67, 0x3B,
+ 0x4C, 0x00, 0x0A, 0x74, 0x68, 0x72, 0x65,
+ 0x61, 0x64, 0x4E, 0x61, 0x6D, 0x65,
+ 0x74, 0x00, 0x12, 0x4C, 0x6A,
+ 0x61, 0x76, 0x61, 0x2F, 0x6C, 0x61, 0x6E, 0x67,
+ 0x2F, 0x53, 0x74, 0x72, 0x69, 0x6E, 0x67, 0x3B,
+ 0x4C, 0x00, 0x0D, 0x74, 0x68,
+ 0x72, 0x6F, 0x77, 0x61, 0x62, 0x6C, 0x65, 0x49,
+ 0x6E, 0x66, 0x6F, 0x74, 0x00, 0x2B, 0x4C, 0x6F,
+ 0x72, 0x67, 0x2F, 0x61, 0x70, 0x61, 0x63, 0x68,
+ 0x65, 0x2F, 0x6C, 0x6F, 0x67, 0x34, 0x6A, 0x2F,
+ 0x73, 0x70, 0x69, 0x2F, 0x54, 0x68, 0x72, 0x6F,
+ 0x77, 0x61, 0x62, 0x6C, 0x65, 0x49, 0x6E, 0x66,
+ 0x6F, 0x72, 0x6D, 0x61, 0x74, 0x69, 0x6F, 0x6E,
+ 0x3B, 0x78, 0x70 };
+
+ os.writeProlog("org.apache.log4j.spi.LoggingEvent",
+ 8, classDesc, sizeof(classDesc), p);
+}
+
+void LoggingEvent::write(helpers::ObjectOutputStream& os, Pool& p) const {
+ writeProlog(os, p);
+ // mdc and ndc lookup required should always be false
+ char lookupsRequired[] = { 0, 0 };
+ os.writeBytes(lookupsRequired, sizeof(lookupsRequired), p);
+ os.writeLong(timeStamp/1000, p);
+ os.writeObject(logger, p);
+ locationInfo.write(os, p);
+ if (mdcCopy == 0 || mdcCopy->size() == 0) {
+ os.writeNull(p);
+ } else {
+ os.writeObject(*mdcCopy, p);
+ }
+ if (ndc == 0) {
+ os.writeNull(p);
+ } else {
+ os.writeObject(*ndc, p);
+ }
+ os.writeObject(message, p);
+ os.writeObject(threadName, p);
+ // throwable
+ os.writeNull(p);
+ os.writeByte(ObjectOutputStream::TC_BLOCKDATA, p);
+ os.writeByte(0x04, p);
+ os.writeInt(level->toInt(), p);
+ os.writeNull(p);
+ os.writeByte(ObjectOutputStream::TC_ENDBLOCKDATA, p);
+}
+
View Lorry Controller Status