tests/cpp/fwklib/FwkLog.cpp

/*
 * 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 <cinttypes>
#include <fwklib/FwkLog.hpp>

#include <geode/Exception.hpp>

#include "hacks/AceThreadId.h"

namespace apache {
namespace geode {
namespace client {
namespace testframework {

static ACE_utsname u;

const char* getNodeName() { return u.nodename; }

const char* dirAndFile(const char* str) {
  if (!str) {
    return "NULL";
  }

  const char* ptr = str + strlen(str);
  int32_t found = 0;
  while (ptr > str) {
    ptr--;
    if ((*ptr == '/') || (*ptr == '\\')) {
      found++;
      if (found >= 2) {
        if (ptr == str) {
          return str;
        }
        return ++ptr;
      }
    }
  }
  return ptr;
}

void plog(const char* l, const char* s, const char* filename, int32_t lineno) {
  // ACE_TCHAR tstamp[64];
  // ACE::timestamp( tstamp, 64, 1 );
  // tstamp is like "Tue May 17 2005 12:54:22.546780"
  // for our purpose we just want "12:54:22.546780"
  char buf[256] = {0};
  const size_t MINBUFSIZE = 128;
  ACE_Time_Value clock = ACE_OS::gettimeofday();
  time_t secs = clock.sec();
  struct tm* tm_val = ACE_OS::localtime(&secs);
  char* pbuf = buf;
  pbuf += ACE_OS::strftime(pbuf, MINBUFSIZE, "%Y/%m/%d %H:%M:%S", tm_val);
  pbuf += ACE_OS::snprintf(pbuf, 15, ".%06" PRId64 " ",
                           static_cast<int64_t>(clock.usec()));
  ACE_OS::strftime(pbuf, MINBUFSIZE, "%Z ", tm_val);
  static bool needInit = true;
  if (needInit) {
    ACE_OS::uname(&u);
    needInit = false;
  }

  const char* fil = dirAndFile(filename);

  fprintf(stdout, "[%s %s %s:P%d:T%" PRIu64 "]::%s::%d  %s  %s\n", buf,
          u.sysname, u.nodename, ACE_OS::getpid(),
          hacks::aceThreadId(ACE_OS::thr_self()), fil, lineno, l, s);
  fflush(stdout);
}

void dumpStack() {
  apache::geode::client::Exception trace("StackTrace  ");
  fprintf(stdout, "%s\n", trace.getStackTrace().c_str());
  fflush(stdout);
}

}  // namespace testframework
}  // namespace client
}  // namespace geode
}  // namespace apache