From patchwork Sat May 11 11:01:34 2024 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Michael Opdenacker X-Patchwork-Id: 43476 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from aws-us-west-2-korg-lkml-1.web.codeaurora.org (localhost.localdomain [127.0.0.1]) by smtp.lore.kernel.org (Postfix) with ESMTP id DC9FBC04FFE for ; Sat, 11 May 2024 11:03:35 +0000 (UTC) Received: from relay5-d.mail.gandi.net (relay5-d.mail.gandi.net [217.70.183.197]) by mx.groups.io with SMTP id smtpd.web10.12295.1715425408532638315 for ; Sat, 11 May 2024 04:03:28 -0700 Authentication-Results: mx.groups.io; dkim=pass header.i=@bootlin.com header.s=gm1 header.b=BdBKFnRH; spf=pass (domain: bootlin.com, ip: 217.70.183.197, mailfrom: michael.opdenacker@bootlin.com) Received: by mail.gandi.net (Postfix) with ESMTPSA id F05561C0003; Sat, 11 May 2024 11:03:25 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=bootlin.com; s=gm1; t=1715425406; h=from:from:reply-to:subject:subject:date:date:message-id:message-id: to:to:cc:cc:mime-version:mime-version: content-transfer-encoding:content-transfer-encoding: in-reply-to:in-reply-to:references:references; bh=7Dfgnmk9gbHmBxnBQB09hJFpWDSttG5SMEP+1UNsnXk=; b=BdBKFnRHi7TNLyFhITHyyFoqJsUiaTKmaqa7sSsY5yI5GNboaU17Th8McqhAShHE7Pc/UD 7eArwp01DfgW7lIe2t3dhRuHWqNA378F3pgp1TjZ80+2TEqevMl++LOgrbSWsooXZM+DPU R4fYotjeAT1QbHMHX9nlvvUPwIHus/fk84vLrvmKZKU0I0rkhBT2cGggFttvMMGKw3VPV0 4lryzYOmcOVlb21E4D0VDfCsGRuJ7Guxs938m0bKTl3BH/WjKQrV/2UPB8840KMtehqd+k wHMs9cI4piUBvNwScZZwLjuU3YlMBTGmQwBpXw82tjMgAD4HJCzsx4/xvOlk/Q== From: michael.opdenacker@bootlin.com To: bitbake-devel@lists.openembedded.org Cc: Michael Opdenacker , Joshua Watt , Tim Orling , Thomas Petazzoni Subject: [PATCH v7 7/8] prserv: import simplification Date: Sat, 11 May 2024 16:31:34 +0530 Message-Id: <20240511110135.1887578-8-michael.opdenacker@bootlin.com> X-Mailer: git-send-email 2.34.1 In-Reply-To: <20240511110135.1887578-1-michael.opdenacker@bootlin.com> References: <20240511110135.1887578-1-michael.opdenacker@bootlin.com> MIME-Version: 1.0 X-GND-Sasl: michael.opdenacker@bootlin.com List-Id: X-Webhook-Received: from li982-79.members.linode.com [45.33.32.79] by aws-us-west-2-korg-lkml-1.web.codeaurora.org with HTTPS for ; Sat, 11 May 2024 11:03:35 -0000 X-Groupsio-URL: https://lists.openembedded.org/g/bitbake-devel/message/16206 From: Michael Opdenacker Simplify the importone() hook: - to make it independent from the "history" mode which is client specific. - remove the "history" parameter - we want all values to be imported for binary reproducibility purposes. - using the store_value() function (which warrants you don't save the same value twice and doesn't write when you're using a read-only server) is enough. Signed-off-by: Michael Opdenacker Cc: Joshua Watt Cc: Tim Orling Cc: Thomas Petazzoni --- lib/prserv/client.py | 4 +-- lib/prserv/db.py | 64 +++----------------------------------------- lib/prserv/serv.py | 3 +-- 3 files changed, 6 insertions(+), 65 deletions(-) diff --git a/lib/prserv/client.py b/lib/prserv/client.py index 565c6f3872..9f5794c433 100644 --- a/lib/prserv/client.py +++ b/lib/prserv/client.py @@ -42,9 +42,9 @@ class PRAsyncClient(bb.asyncrpc.AsyncClient): if response: return response["value"] - async def importone(self, version, pkgarch, checksum, value, history=False): + async def importone(self, version, pkgarch, checksum, value): response = await self.invoke( - {"import-one": {"version": version, "pkgarch": pkgarch, "checksum": checksum, "value": value, "history": history}} + {"import-one": {"version": version, "pkgarch": pkgarch, "checksum": checksum, "value": value}} ) if response: return response["value"] diff --git a/lib/prserv/db.py b/lib/prserv/db.py index 88ed8e2125..2da493ddf5 100644 --- a/lib/prserv/db.py +++ b/lib/prserv/db.py @@ -192,67 +192,9 @@ class PRTable(object): self.store_value(version, pkgarch, checksum, value) return value - def _import_hist(self, version, pkgarch, checksum, value): - if self.read_only: - return None - - val = None - with closing(self.conn.cursor()) as cursor: - data = cursor.execute("SELECT value FROM %s WHERE version=? AND pkgarch=? AND checksum=?;" % self.table, - (version, pkgarch, checksum)) - row = data.fetchone() - if row is not None: - val=row[0] - else: - #no value found, try to insert - try: - cursor.execute("INSERT INTO %s VALUES (?, ?, ?, ?);" % (self.table), - (version, pkgarch, checksum, value)) - except sqlite3.IntegrityError as exc: - logger.error(str(exc)) - - self.conn.commit() - - data = cursor.execute("SELECT value FROM %s WHERE version=? AND pkgarch=? AND checksum=?;" % self.table, - (version, pkgarch, checksum)) - row = data.fetchone() - if row is not None: - val = row[0] - return val - - def _import_no_hist(self, version, pkgarch, checksum, value): - if self.read_only: - return None - - with closing(self.conn.cursor()) as cursor: - try: - #try to insert - cursor.execute("INSERT INTO %s VALUES (?, ?, ?, ?);" % (self.table), - (version, pkgarch, checksum, value)) - except sqlite3.IntegrityError as exc: - #already have the record, try to update - try: - cursor.execute("UPDATE %s SET value=? WHERE version=? AND pkgarch=? AND checksum=? AND value=?;" % self.table, - (version, pkgarch, checksum, value)) - row=data.fetchone() - if row is not None: - return row[0] - else: - return None - - def importone(self, version, pkgarch, checksum, value, history=False): - if history: - return self._import_hist(version, pkgarch, checksum, value) - else: - return self._import_no_hist(version, pkgarch, checksum, value) + def importone(self, version, pkgarch, checksum, value): + self.store_value(version, pkgarch, checksum, value) + return value def export(self, version, pkgarch, checksum, colinfo, history=False): metainfo = {} diff --git a/lib/prserv/serv.py b/lib/prserv/serv.py index 3992056f88..e175886308 100644 --- a/lib/prserv/serv.py +++ b/lib/prserv/serv.py @@ -179,9 +179,8 @@ class PRServerClient(bb.asyncrpc.AsyncServerConnection): pkgarch = request["pkgarch"] checksum = request["checksum"] value = request["value"] - history = request["history"] - value = self.server.table.importone(version, pkgarch, checksum, value, history) + value = self.server.table.importone(version, pkgarch, checksum, value) if value is not None: response = {"value": value}