LogRecordPrivate.hh

Go to the documentation of this file.

/*
 * Copyright (C) 2015-2016 Open Source Robotics Foundation
 *
 * Licensed 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.
 *
*/
#ifndef _GAZEBO_UTIL_LOGRECORD_PRIVATE_HH_
#define _GAZEBO_UTIL_LOGRECORD_PRIVATE_HH_

#include <map>
#include <string>
#include <thread>
#include <functional>
#include <condition_variable>
#include <boost/filesystem.hpp>

namespace gazebo
{
  namespace util
  {
    class LogRecord;

    class LogRecordPrivate
    {
      public: virtual ~LogRecordPrivate() = default;

      public: class Log
      {
        public: Log(LogRecord *_parent, const std::string &_relativeFilename,
                    std::function<bool (std::ostringstream &)> _logCB);

        public: virtual ~Log();

        public: void Start(const boost::filesystem::path &_path);

        public: void Stop();

        public: void Write();

        public: unsigned int Update();

        public: void ClearBuffer();

        public: unsigned int BufferSize();

        public: std::string RelativeFilename() const;

        public: std::string CompleteFilename() const;

        public: LogRecord *parent;

        public: std::function<bool (std::ostringstream &)> logCB;

        public: std::string buffer;

        public: std::ofstream logFile;

        public: std::string relativeFilename;

        public: boost::filesystem::path completePath;
      };

      public: typedef std::map<std::string, Log*> Log_M;

      public: Log_M logs;

      public: Log_M::iterator updateIter;

      public: Log_M::iterator logsEnd;

      public: std::condition_variable startThreadCondition;

      public: std::condition_variable updateCondition;

      public: std::condition_variable cleanupCondition;

      public: bool running;

      public: std::unique_ptr<std::thread> writeThread;

      public: std::unique_ptr<std::thread> updateThread;

      public: std::unique_ptr<std::thread> cleanupThread;

      public: mutable std::mutex writeMutex;

      public: mutable std::mutex runWriteMutex;

      public: mutable std::mutex updateMutex;

      public: std::mutex controlMutex;

      public: std::condition_variable dataAvailableCondition;

      public: boost::filesystem::path logBasePath;

      public: boost::filesystem::path logCompletePath;

      public: std::string logSubDir;

      public: std::string encoding;

      public: bool initialized;

      public: bool paused;

      public: bool firstUpdate;

      public: bool stopThread;

      public: common::Time startTime;

      public: common::Time currTime;

      public: transport::NodePtr node;

      public: transport::SubscriberPtr logControlSub;

      public: transport::PublisherPtr logStatusPub;

      public: event::Connection_V connections;

      public: bool pauseState;

      public: bool readyToStart;
    };
  }
}
#endif