summaryrefslogtreecommitdiff
path: root/src/protocols/DRMLease.cpp
diff options
context:
space:
mode:
authordavc0n <dconti.dev@gmail.com>2025-05-04 00:13:29 +0200
committerGitHub <noreply@github.com>2025-05-04 00:13:29 +0200
commitadbae0f74d951e06c575bad3c81a944027dfe413 (patch)
tree4ae313af18629596c7e98518c7c1d2c10bc260a3 /src/protocols/DRMLease.cpp
parent46ac115bd19ee3aff5c816033de0b1d55a74e33f (diff)
protocols: refactor class member vars (a-m) (#10265)
Diffstat (limited to 'src/protocols/DRMLease.cpp')
-rw-r--r--src/protocols/DRMLease.cpp202
1 files changed, 101 insertions, 101 deletions
diff --git a/src/protocols/DRMLease.cpp b/src/protocols/DRMLease.cpp
index 80c34d23..c4b5a84a 100644
--- a/src/protocols/DRMLease.cpp
+++ b/src/protocols/DRMLease.cpp
@@ -6,20 +6,20 @@
#include <fcntl.h>
using namespace Hyprutils::OS;
-CDRMLeaseResource::CDRMLeaseResource(SP<CWpDrmLeaseV1> resource_, SP<CDRMLeaseRequestResource> request) : resource(resource_) {
+CDRMLeaseResource::CDRMLeaseResource(SP<CWpDrmLeaseV1> resource_, SP<CDRMLeaseRequestResource> request) : m_resource(resource_) {
if UNLIKELY (!good())
return;
- resource->setOnDestroy([this](CWpDrmLeaseV1* r) { PROTO::lease->destroyResource(this); });
- resource->setDestroy([this](CWpDrmLeaseV1* r) { PROTO::lease->destroyResource(this); });
+ m_resource->setOnDestroy([this](CWpDrmLeaseV1* r) { PROTO::lease->destroyResource(this); });
+ m_resource->setDestroy([this](CWpDrmLeaseV1* r) { PROTO::lease->destroyResource(this); });
- parent = request->parent;
- requested = request->requested;
+ m_parent = request->m_parent;
+ m_requested = request->m_requested;
- for (auto const& m : requested) {
- if (!m->monitor || m->monitor->m_isBeingLeased) {
- LOGM(ERR, "Rejecting lease: no monitor or monitor is being leased for {}", (m->monitor ? m->monitor->m_name : "null"));
- resource->sendFinished();
+ for (auto const& m : m_requested) {
+ if (!m->m_monitor || m->m_monitor->m_isBeingLeased) {
+ LOGM(ERR, "Rejecting lease: no monitor or monitor is being leased for {}", (m->m_monitor ? m->m_monitor->m_name : "null"));
+ m_resource->sendFinished();
return;
}
}
@@ -28,97 +28,97 @@ CDRMLeaseResource::CDRMLeaseResource(SP<CWpDrmLeaseV1> resource_, SP<CDRMLeaseRe
LOGM(LOG, "Leasing outputs: {}", [this]() {
std::string roll;
- for (auto const& o : requested) {
- roll += std::format("{} ", o->monitor->m_name);
+ for (auto const& o : m_requested) {
+ roll += std::format("{} ", o->m_monitor->m_name);
}
return roll;
}());
std::vector<SP<Aquamarine::IOutput>> outputs;
// reserve to avoid reallocations
- outputs.reserve(requested.size());
+ outputs.reserve(m_requested.size());
- for (auto const& m : requested) {
- outputs.emplace_back(m->monitor->m_output);
+ for (auto const& m : m_requested) {
+ outputs.emplace_back(m->m_monitor->m_output);
}
auto aqlease = Aquamarine::CDRMLease::create(outputs);
if (!aqlease) {
LOGM(ERR, "Rejecting lease: backend failed to alloc a lease");
- resource->sendFinished();
+ m_resource->sendFinished();
return;
}
- lease = aqlease;
+ m_lease = aqlease;
- for (auto const& m : requested) {
- m->monitor->m_isBeingLeased = true;
+ for (auto const& m : m_requested) {
+ m->m_monitor->m_isBeingLeased = true;
}
- listeners.destroyLease = lease->events.destroy.registerListener([this](std::any d) {
- for (auto const& m : requested) {
- if (m && m->monitor)
- m->monitor->m_isBeingLeased = false;
+ m_listeners.destroyLease = m_lease->events.destroy.registerListener([this](std::any d) {
+ for (auto const& m : m_requested) {
+ if (m && m->m_monitor)
+ m->m_monitor->m_isBeingLeased = false;
}
- resource->sendFinished();
- LOGM(LOG, "Revoking lease for fd {}", lease->leaseFD);
+ m_resource->sendFinished();
+ LOGM(LOG, "Revoking lease for fd {}", m_lease->leaseFD);
});
- LOGM(LOG, "Granting lease, sending fd {}", lease->leaseFD);
+ LOGM(LOG, "Granting lease, sending fd {}", m_lease->leaseFD);
- resource->sendLeaseFd(lease->leaseFD);
+ m_resource->sendLeaseFd(m_lease->leaseFD);
- close(lease->leaseFD);
+ close(m_lease->leaseFD);
}
bool CDRMLeaseResource::good() {
- return resource->resource();
+ return m_resource->resource();
}
CDRMLeaseResource::~CDRMLeaseResource() {
// destroy in this order to ensure listener gets called
- lease.reset();
- listeners.destroyLease.reset();
+ m_lease.reset();
+ m_listeners.destroyLease.reset();
}
-CDRMLeaseRequestResource::CDRMLeaseRequestResource(SP<CWpDrmLeaseRequestV1> resource_) : resource(resource_) {
+CDRMLeaseRequestResource::CDRMLeaseRequestResource(SP<CWpDrmLeaseRequestV1> resource_) : m_resource(resource_) {
if UNLIKELY (!good())
return;
- resource->setOnDestroy([this](CWpDrmLeaseRequestV1* r) { PROTO::lease->destroyResource(this); });
+ m_resource->setOnDestroy([this](CWpDrmLeaseRequestV1* r) { PROTO::lease->destroyResource(this); });
- resource->setRequestConnector([this](CWpDrmLeaseRequestV1* r, wl_resource* conn) {
+ m_resource->setRequestConnector([this](CWpDrmLeaseRequestV1* r, wl_resource* conn) {
if (!conn) {
- resource->error(-1, "Null connector");
+ m_resource->error(-1, "Null connector");
return;
}
auto CONNECTOR = CDRMLeaseConnectorResource::fromResource(conn);
- if (std::find(requested.begin(), requested.end(), CONNECTOR) != requested.end()) {
- resource->error(WP_DRM_LEASE_REQUEST_V1_ERROR_DUPLICATE_CONNECTOR, "Connector already requested");
+ if (std::find(m_requested.begin(), m_requested.end(), CONNECTOR) != m_requested.end()) {
+ m_resource->error(WP_DRM_LEASE_REQUEST_V1_ERROR_DUPLICATE_CONNECTOR, "Connector already requested");
return;
}
// TODO: when (if) we add multi, make sure this is from the correct device.
- requested.emplace_back(CONNECTOR);
+ m_requested.emplace_back(CONNECTOR);
});
- resource->setSubmit([this](CWpDrmLeaseRequestV1* r, uint32_t id) {
- if (requested.empty()) {
- resource->error(WP_DRM_LEASE_REQUEST_V1_ERROR_EMPTY_LEASE, "No connectors added");
+ m_resource->setSubmit([this](CWpDrmLeaseRequestV1* r, uint32_t id) {
+ if (m_requested.empty()) {
+ m_resource->error(WP_DRM_LEASE_REQUEST_V1_ERROR_EMPTY_LEASE, "No connectors added");
return;
}
- auto RESOURCE = makeShared<CDRMLeaseResource>(makeShared<CWpDrmLeaseV1>(resource->client(), resource->version(), id), self.lock());
+ auto RESOURCE = makeShared<CDRMLeaseResource>(makeShared<CWpDrmLeaseV1>(m_resource->client(), m_resource->version(), id), m_self.lock());
if UNLIKELY (!RESOURCE) {
- resource->noMemory();
+ m_resource->noMemory();
return;
}
- PROTO::lease->m_vLeases.emplace_back(RESOURCE);
+ PROTO::lease->m_leases.emplace_back(RESOURCE);
// per protcol, after submit, this is dead.
PROTO::lease->destroyResource(this);
@@ -126,111 +126,111 @@ CDRMLeaseRequestResource::CDRMLeaseRequestResource(SP<CWpDrmLeaseRequestV1> reso
}
bool CDRMLeaseRequestResource::good() {
- return resource->resource();
+ return m_resource->resource();
}
SP<CDRMLeaseConnectorResource> CDRMLeaseConnectorResource::fromResource(wl_resource* res) {
auto data = (CDRMLeaseConnectorResource*)(((CWpDrmLeaseConnectorV1*)wl_resource_get_user_data(res))->data());
- return data ? data->self.lock() : nullptr;
+ return data ? data->m_self.lock() : nullptr;
}
-CDRMLeaseConnectorResource::CDRMLeaseConnectorResource(SP<CWpDrmLeaseConnectorV1> resource_, PHLMONITOR monitor_) : monitor(monitor_), resource(resource_) {
+CDRMLeaseConnectorResource::CDRMLeaseConnectorResource(SP<CWpDrmLeaseConnectorV1> resource_, PHLMONITOR monitor_) : m_monitor(monitor_), m_resource(resource_) {
if UNLIKELY (!good())
return;
- resource->setOnDestroy([this](CWpDrmLeaseConnectorV1* r) { PROTO::lease->destroyResource(this); });
- resource->setDestroy([this](CWpDrmLeaseConnectorV1* r) { PROTO::lease->destroyResource(this); });
+ m_resource->setOnDestroy([this](CWpDrmLeaseConnectorV1* r) { PROTO::lease->destroyResource(this); });
+ m_resource->setDestroy([this](CWpDrmLeaseConnectorV1* r) { PROTO::lease->destroyResource(this); });
- resource->setData(this);
+ m_resource->setData(this);
- listeners.destroyMonitor = monitor->m_events.destroy.registerListener([this](std::any d) {
- resource->sendWithdrawn();
- dead = true;
+ m_listeners.destroyMonitor = m_monitor->m_events.destroy.registerListener([this](std::any d) {
+ m_resource->sendWithdrawn();
+ m_dead = true;
});
}
bool CDRMLeaseConnectorResource::good() {
- return resource->resource();
+ return m_resource->resource();
}
void CDRMLeaseConnectorResource::sendData() {
- resource->sendName(monitor->m_name.c_str());
- resource->sendDescription(monitor->m_description.c_str());
+ m_resource->sendName(m_monitor->m_name.c_str());
+ m_resource->sendDescription(m_monitor->m_description.c_str());
- auto AQDRMOutput = (Aquamarine::CDRMOutput*)monitor->m_output.get();
- resource->sendConnectorId(AQDRMOutput->getConnectorID());
+ auto AQDRMOutput = (Aquamarine::CDRMOutput*)m_monitor->m_output.get();
+ m_resource->sendConnectorId(AQDRMOutput->getConnectorID());
- resource->sendDone();
+ m_resource->sendDone();
}
-CDRMLeaseDeviceResource::CDRMLeaseDeviceResource(SP<CWpDrmLeaseDeviceV1> resource_) : resource(resource_) {
+CDRMLeaseDeviceResource::CDRMLeaseDeviceResource(SP<CWpDrmLeaseDeviceV1> resource_) : m_resource(resource_) {
if UNLIKELY (!good())
return;
- resource->setOnDestroy([this](CWpDrmLeaseDeviceV1* r) { PROTO::lease->destroyResource(this); });
- resource->setRelease([this](CWpDrmLeaseDeviceV1* r) { PROTO::lease->destroyResource(this); });
+ m_resource->setOnDestroy([this](CWpDrmLeaseDeviceV1* r) { PROTO::lease->destroyResource(this); });
+ m_resource->setRelease([this](CWpDrmLeaseDeviceV1* r) { PROTO::lease->destroyResource(this); });
- resource->setCreateLeaseRequest([this](CWpDrmLeaseDeviceV1* r, uint32_t id) {
- auto RESOURCE = makeShared<CDRMLeaseRequestResource>(makeShared<CWpDrmLeaseRequestV1>(resource->client(), resource->version(), id));
+ m_resource->setCreateLeaseRequest([this](CWpDrmLeaseDeviceV1* r, uint32_t id) {
+ auto RESOURCE = makeShared<CDRMLeaseRequestResource>(makeShared<CWpDrmLeaseRequestV1>(m_resource->client(), m_resource->version(), id));
if UNLIKELY (!RESOURCE) {
- resource->noMemory();
+ m_resource->noMemory();
return;
}
- RESOURCE->self = RESOURCE;
+ RESOURCE->m_self = RESOURCE;
- PROTO::lease->m_vRequests.emplace_back(RESOURCE);
+ PROTO::lease->m_requests.emplace_back(RESOURCE);
LOGM(LOG, "New lease request {}", id);
- RESOURCE->parent = self;
+ RESOURCE->m_parent = m_self;
});
- CFileDescriptor fd{((Aquamarine::CDRMBackend*)PROTO::lease->primaryDevice->backend.get())->getNonMasterFD()};
+ CFileDescriptor fd{((Aquamarine::CDRMBackend*)PROTO::lease->m_primaryDevice->m_backend.get())->getNonMasterFD()};
if (!fd.isValid()) {
LOGM(ERR, "Failed to dup fd in lease");
return;
}
LOGM(LOG, "Sending DRMFD {} to new lease device", fd.get());
- resource->sendDrmFd(fd.get());
+ m_resource->sendDrmFd(fd.get());
- for (auto const& m : PROTO::lease->primaryDevice->offeredOutputs) {
+ for (auto const& m : PROTO::lease->m_primaryDevice->m_offeredOutputs) {
if (m)
sendConnector(m.lock());
}
- resource->sendDone();
+ m_resource->sendDone();
}
bool CDRMLeaseDeviceResource::good() {
- return resource->resource();
+ return m_resource->resource();
}
void CDRMLeaseDeviceResource::sendConnector(PHLMONITOR monitor) {
- if (std::find_if(connectorsSent.begin(), connectorsSent.end(), [monitor](const auto& e) { return e && !e->dead && e->monitor == monitor; }) != connectorsSent.end())
+ if (std::find_if(m_connectorsSent.begin(), m_connectorsSent.end(), [monitor](const auto& e) { return e && !e->m_dead && e->m_monitor == monitor; }) != m_connectorsSent.end())
return;
- auto RESOURCE = makeShared<CDRMLeaseConnectorResource>(makeShared<CWpDrmLeaseConnectorV1>(resource->client(), resource->version(), 0), monitor);
+ auto RESOURCE = makeShared<CDRMLeaseConnectorResource>(makeShared<CWpDrmLeaseConnectorV1>(m_resource->client(), m_resource->version(), 0), monitor);
if UNLIKELY (!RESOURCE) {
- resource->noMemory();
+ m_resource->noMemory();
return;
}
- RESOURCE->parent = self;
- RESOURCE->self = RESOURCE;
+ RESOURCE->m_parent = m_self;
+ RESOURCE->m_self = RESOURCE;
LOGM(LOG, "Sending new connector {}", monitor->m_name);
- connectorsSent.emplace_back(RESOURCE);
- PROTO::lease->m_vConnectors.emplace_back(RESOURCE);
+ m_connectorsSent.emplace_back(RESOURCE);
+ PROTO::lease->m_connectors.emplace_back(RESOURCE);
- resource->sendConnector(RESOURCE->resource.get());
+ m_resource->sendConnector(RESOURCE->m_resource.get());
RESOURCE->sendData();
}
-CDRMLeaseDevice::CDRMLeaseDevice(SP<Aquamarine::CDRMBackend> drmBackend) : backend(drmBackend) {
+CDRMLeaseDevice::CDRMLeaseDevice(SP<Aquamarine::CDRMBackend> drmBackend) : m_backend(drmBackend) {
auto drm = (Aquamarine::CDRMBackend*)drmBackend.get();
CFileDescriptor fd{drm->getNonMasterFD()};
@@ -240,8 +240,8 @@ CDRMLeaseDevice::CDRMLeaseDevice(SP<Aquamarine::CDRMBackend> drmBackend) : backe
return;
}
- success = true;
- name = drm->gpuName;
+ m_success = true;
+ m_name = drm->gpuName;
}
CDRMLeaseProtocol::CDRMLeaseProtocol(const wl_interface* iface, const int& ver, const std::string& name) : IWaylandProtocol(iface, ver, name) {
@@ -251,64 +251,64 @@ CDRMLeaseProtocol::CDRMLeaseProtocol(const wl_interface* iface, const int& ver,
auto drm = ((Aquamarine::CDRMBackend*)b.get())->self.lock();
- primaryDevice = makeShared<CDRMLeaseDevice>(drm);
+ m_primaryDevice = makeShared<CDRMLeaseDevice>(drm);
- if (primaryDevice->success)
+ if (m_primaryDevice->m_success)
break;
}
- if (!primaryDevice || !primaryDevice->success)
+ if (!m_primaryDevice || !m_primaryDevice->m_success)
g_pEventLoopManager->doLater([]() { PROTO::lease.reset(); });
}
void CDRMLeaseProtocol::bindManager(wl_client* client, void* data, uint32_t ver, uint32_t id) {
- const auto RESOURCE = m_vManagers.emplace_back(makeShared<CDRMLeaseDeviceResource>(makeShared<CWpDrmLeaseDeviceV1>(client, ver, id)));
+ const auto RESOURCE = m_managers.emplace_back(makeShared<CDRMLeaseDeviceResource>(makeShared<CWpDrmLeaseDeviceV1>(client, ver, id)));
if UNLIKELY (!RESOURCE->good()) {
wl_client_post_no_memory(client);
- m_vManagers.pop_back();
+ m_managers.pop_back();
return;
}
- RESOURCE->self = RESOURCE;
+ RESOURCE->m_self = RESOURCE;
}
void CDRMLeaseProtocol::destroyResource(CDRMLeaseDeviceResource* resource) {
- std::erase_if(m_vManagers, [resource](const auto& e) { return e.get() == resource; });
+ std::erase_if(m_managers, [resource](const auto& e) { return e.get() == resource; });
}
void CDRMLeaseProtocol::destroyResource(CDRMLeaseConnectorResource* resource) {
- for (const auto& m : m_vManagers) {
- std::erase_if(m->connectorsSent, [resource](const auto& e) { return e.expired() || e->dead || e.get() == resource; });
+ for (const auto& m : m_managers) {
+ std::erase_if(m->m_connectorsSent, [resource](const auto& e) { return e.expired() || e->m_dead || e.get() == resource; });
}
- std::erase_if(m_vConnectors, [resource](const auto& e) { return e.get() == resource; });
+ std::erase_if(m_connectors, [resource](const auto& e) { return e.get() == resource; });
}
void CDRMLeaseProtocol::destroyResource(CDRMLeaseRequestResource* resource) {
- std::erase_if(m_vRequests, [resource](const auto& e) { return e.get() == resource; });
+ std::erase_if(m_requests, [resource](const auto& e) { return e.get() == resource; });
}
void CDRMLeaseProtocol::destroyResource(CDRMLeaseResource* resource) {
- std::erase_if(m_vLeases, [resource](const auto& e) { return e.get() == resource; });
+ std::erase_if(m_leases, [resource](const auto& e) { return e.get() == resource; });
}
void CDRMLeaseProtocol::offer(PHLMONITOR monitor) {
- std::erase_if(primaryDevice->offeredOutputs, [](const auto& e) { return e.expired(); });
- if (std::find(primaryDevice->offeredOutputs.begin(), primaryDevice->offeredOutputs.end(), monitor) != primaryDevice->offeredOutputs.end())
+ std::erase_if(m_primaryDevice->m_offeredOutputs, [](const auto& e) { return e.expired(); });
+ if (std::find(m_primaryDevice->m_offeredOutputs.begin(), m_primaryDevice->m_offeredOutputs.end(), monitor) != m_primaryDevice->m_offeredOutputs.end())
return;
if (monitor->m_output->getBackend()->type() != Aquamarine::AQ_BACKEND_DRM)
return;
- if (monitor->m_output->getBackend() != primaryDevice->backend) {
+ if (monitor->m_output->getBackend() != m_primaryDevice->m_backend) {
LOGM(ERR, "Monitor {} cannot be leased: primaryDevice lease is for a different device", monitor->m_name);
return;
}
- primaryDevice->offeredOutputs.emplace_back(monitor);
+ m_primaryDevice->m_offeredOutputs.emplace_back(monitor);
- for (auto const& m : m_vManagers) {
+ for (auto const& m : m_managers) {
m->sendConnector(monitor);
- m->resource->sendDone();
+ m->m_resource->sendDone();
}
}