summaryrefslogtreecommitdiff
path: root/src/components/time_tester/include/time_tester/time_manager.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/components/time_tester/include/time_tester/time_manager.h')
-rw-r--r--src/components/time_tester/include/time_tester/time_manager.h98
1 files changed, 0 insertions, 98 deletions
diff --git a/src/components/time_tester/include/time_tester/time_manager.h b/src/components/time_tester/include/time_tester/time_manager.h
deleted file mode 100644
index dc56d3682c..0000000000
--- a/src/components/time_tester/include/time_tester/time_manager.h
+++ /dev/null
@@ -1,98 +0,0 @@
-/*
- * Copyright (c) 2014, Ford Motor Company
- * All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- *
- * Redistributions of source code must retain the above copyright notice, this
- * list of conditions and the following disclaimer.
- *
- * Redistributions in binary form must reproduce the above copyright notice,
- * this list of conditions and the following
- * disclaimer in the documentation and/or other materials provided with the
- * distribution.
- *
- * Neither the name of the Ford Motor Company nor the names of its contributors
- * may be used to endorse or promote products derived from this software
- * without specific prior written permission.
- *
- * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
- * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
- * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
- * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
- * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
- * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
- * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
- * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
- * POSSIBILITY OF SUCH DAMAGE.
- */
-
-#ifndef SRC_COMPONENTS_TIME_MANAGER_INCLUDE_TIME_MANAGER_MEDIA_MANAGER_H_
-#define SRC_COMPONENTS_TIME_MANAGER_INCLUDE_TIME_MANAGER_MEDIA_MANAGER_H_
-
-#include <string>
-
-#include "utils/shared_ptr.h"
-#include "utils/message_queue.h"
-#include "utils/threads/thread.h"
-#include "utils/singleton.h"
-#include "utils/threads/thread_delegate.h"
-#include "metric_wrapper.h"
-#include "application_manager_observer.h"
-#include "application_manager/application_manager_impl.h"
-#include "transport_manager_observer.h"
-#include "transport_manager/transport_manager_impl.h"
-#include "protocol_handler_observer.h"
-#include "protocol_handler/protocol_handler_impl.h"
-
-namespace time_tester {
-
-using ::utils::MessageQueue;
-
-class TimeManager {
- public:
- TimeManager();
- ~TimeManager();
- void Init(protocol_handler::ProtocolHandlerImpl* ph);
- void Stop();
- void SendMetric(utils::SharedPtr<MetricWrapper> metric);
- private:
-
- class Streamer : public threads::ThreadDelegate {
- public:
- explicit Streamer(TimeManager* const server);
- ~Streamer();
- void threadMain() OVERRIDE;
- void exitThreadMain() OVERRIDE;
- bool IsReady() const;
- void Start();
- void Stop();
- bool Send(const std::string &msg);
- void PushMessage(utils::SharedPtr<MetricWrapper> metric);
- volatile bool is_client_connected_;
- private:
- void ShutDownAndCloseSocket(int32_t socket_fd);
- TimeManager* const server_;
- int32_t server_socket_fd_;
- int32_t client_socket_fd_;
- volatile bool stop_flag_;
- MessageQueue<utils::SharedPtr<MetricWrapper> > messages_;
- DISALLOW_COPY_AND_ASSIGN(Streamer);
- };
-
- int16_t port_;
- std::string ip_;
- bool is_ready_;
- threads::Thread* thread_;
- Streamer* streamer_;
- ApplicationManagerObserver app_observer;
- TransportManagerObserver tm_observer;
- ProtocolHandlerObserver ph_observer;
-
- DISALLOW_COPY_AND_ASSIGN(TimeManager);
-};
-} // namespace time_manager
-#endif // SRC_COMPONENTS_TIME_MANAGER_INCLUDE_TIME_MANAGER_MEDIA_MANAGER_H_