diff options
| author | davc0n <dconti.dev@gmail.com> | 2025-05-04 00:13:29 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-05-04 00:13:29 +0200 |
| commit | adbae0f74d951e06c575bad3c81a944027dfe413 (patch) | |
| tree | 4ae313af18629596c7e98518c7c1d2c10bc260a3 /src/protocols/DRMLease.cpp | |
| parent | 46ac115bd19ee3aff5c816033de0b1d55a74e33f (diff) | |
protocols: refactor class member vars (a-m) (#10265)
Diffstat (limited to 'src/protocols/DRMLease.cpp')
| -rw-r--r-- | src/protocols/DRMLease.cpp | 202 |
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(); } } |
