blob: afc0a4f0414a6fc4b76e758b03eb7176a424bc38 [file] [log] [blame]
#include <uds/channel_manager.h>
#include <log/log.h>
namespace android {
namespace pdx {
namespace uds {
ChannelManager& ChannelManager::Get() {
static ChannelManager instance;
return instance;
}
void ChannelManager::CloseHandle(int32_t handle) {
std::lock_guard<std::mutex> autolock(mutex_);
auto channel = channels_.find(handle);
if (channel == channels_.end()) {
ALOGE("Invalid channel handle: %d", handle);
} else {
channels_.erase(channel);
}
}
LocalChannelHandle ChannelManager::CreateHandle(LocalHandle data_fd,
LocalHandle event_fd) {
if (data_fd && event_fd) {
std::lock_guard<std::mutex> autolock(mutex_);
int32_t handle = data_fd.Get();
channels_.emplace(handle,
ChannelData{std::move(data_fd), std::move(event_fd)});
return LocalChannelHandle(this, handle);
}
return LocalChannelHandle(nullptr, -1);
}
ChannelManager::ChannelData* ChannelManager::GetChannelData(int32_t handle) {
std::lock_guard<std::mutex> autolock(mutex_);
auto channel = channels_.find(handle);
return channel != channels_.end() ? &channel->second : nullptr;
}
} // namespace uds
} // namespace pdx
} // namespace android