source_manager.hpp

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: Copyright (c) 2025 NVIDIA CORPORATION & AFFILIATES. All rights reserved.
 * SPDX-License-Identifier: LicenseRef-NvidiaProprietary
 *
 * NVIDIA CORPORATION, its affiliates and licensors retain all intellectual
 * property and proprietary rights in and to this material, related
 * documentation and any modifications thereto. Any use, reproduction,
 * disclosure or distribution of this material and related documentation
 * without an express license agreement from NVIDIA CORPORATION or
 * its affiliates is strictly prohibited.
 */
 
#ifndef NVIDIA_DEEPSTREAM_SOURCE_MANAGER
#define NVIDIA_DEEPSTREAM_SOURCE_MANAGER
 
#include "signal_emitter.hpp"
#include <mutex>
namespace deepstream {
 
class DefaultActionOwner : public SignalEmitter::IActionOwner {
public:
  std::vector<std::string> list() override {
    std::vector<std::string> actions = {"add-source", "remove-source", "terminate"};
    return actions;
  }
 
  void onAttached(SignalEmitter* emitter, const std::string& action, const std::string& object) override {
    object_ = object;
    return;
  }
 
  std::string getObject() {
    return object_;
  }
 
protected:
  std::string object_;
};
 
class SourceManager : public SignalEmitter {
public:
  SourceManager(const std::string& name)
          : SignalEmitter(name, new DefaultActionOwner()) {}
 
  int addSource(const std::string& source_name);
 
  void removeSource(int source_id);
 
  void terminate();
 
 protected:
  static int gen_number_;
  static std::mutex gen_number_mutex_;
};;
 
} // namespace deepstream
 
#endif