Received: from malur.postgresql.org ([217.196.149.56]) by arkaria.postgresql.org with esmtps (TLS1.3:ECDHE_RSA_AES_256_GCM_SHA384:256) (Exim 4.92) (envelope-from ) id 1jY41x-00059i-76 for pgsql-hackers@arkaria.postgresql.org; Mon, 11 May 2020 08:43:21 +0000 Received: from localhost ([127.0.0.1] helo=malur.postgresql.org) by malur.postgresql.org with esmtp (Exim 4.92) (envelope-from ) id 1jY41w-0001o6-4R for pgsql-hackers@arkaria.postgresql.org; Mon, 11 May 2020 08:43:20 +0000 Received: from makus.postgresql.org ([2001:4800:3e1:1::229]) by malur.postgresql.org with esmtps (TLS1.3:ECDHE_RSA_AES_256_GCM_SHA384:256) (Exim 4.92) (envelope-from ) id 1jY41v-0001lQ-Nf for pgsql-hackers@lists.postgresql.org; Mon, 11 May 2020 08:43:19 +0000 Received: from sender4-op-o13.zoho.com ([136.143.188.13]) by makus.postgresql.org with esmtps (TLS1.2:ECDHE_RSA_AES_256_CBC_SHA1:256) (Exim 4.92) (envelope-from ) id 1jY41t-0001Ng-Go for pgsql-hackers@lists.postgresql.org; Mon, 11 May 2020 08:43:18 +0000 ARC-Seal: i=1; a=rsa-sha256; t=1589186594; cv=none; d=zohomail.com; s=zohoarc; b=Ay5wRXmddb0EjQyEBZWs0vMms0Fzu9kq2kRWPcPFOGepI7XqzKo63aAyiExlXui5s1g841sDQce0nd+y9ExlgWINEdQfuleMWnsHtNrqu9F8PdNflN02tp55sWWorCYQ20HC1kyGmEZn/JuW8A+P0fJZhWdkOSGq8myxjWyy4W4= ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=zohomail.com; s=zohoarc; t=1589186594; h=Content-Type:Date:From:MIME-Version:Message-ID:Subject:To; bh=Spp/QJUXS9oksCg/TUp4ECIADTnrJ2uieZ/KiK9vHho=; b=l+mDy+RKgkZoZW+NYfX+iDS1sV4CNs0h8NWtG7aSZSSS3olrT+oFR8kZD1pi3XXyMmcRxgH1LAVIQvW8gyaPr7YY+6r+CmeSkDO4oMAc1DeFn8M1l0jweUmL+jhyL8bq77mlLP5TjPLOUq0je9FZ8d3lJOSpgPZeiXsgDffxjPg= ARC-Authentication-Results: i=1; mx.zohomail.com; dkim=pass header.i=highgo.ca; spf=pass smtp.mailfrom=movead.li@highgo.ca; dmarc=pass header.from= header.from= DKIM-Signature: v=1; a=rsa-sha256; q=dns/txt; c=relaxed/relaxed; t=1589186594; s=zoho; d=highgo.ca; i=movead.li@highgo.ca; h=Date:From:To:Subject:Mime-Version:Message-ID:Content-Type; bh=Spp/QJUXS9oksCg/TUp4ECIADTnrJ2uieZ/KiK9vHho=; b=OUSN+rpOirtZ23+CHfTrORi43S2kshkL5fpPexmHGfQ5BJqVb5FmIGFEtEmNFfu4 ZbF18jqrOhY9x5K/paIUE/21KVgI9zP5RQ9ySoL0jpcQ9cQ0NGdVCseqlMWUgqGdnFr p1cEIkkFFn/nky9B4oStFelzcoRx6lkiT6Wx85Pk= Received: from lchch (124.133.18.218 [124.133.18.218]) by mx.zohomail.com with SMTPS id 1589186592627270.19299732835805; Mon, 11 May 2020 01:43:12 -0700 (PDT) Date: Mon, 11 May 2020 16:43:11 +0800 From: "movead.li@highgo.ca" To: pgsql-hackers Subject: A patch for get origin from commit_ts. X-Priority: 3 X-GUID: F6B2A322-1D31-4F5F-9E4D-83D3E252F931 X-Has-Attach: yes X-Mailer: Foxmail 7.2.14.410[cn] Mime-Version: 1.0 Message-ID: <2020051116430836450630@highgo.ca> Content-Type: multipart/mixed; boundary="----=_001_NextPart158418273311_=----" X-Zoho-Virus-Status: 2 X-ZohoMailClient: External List-Id: List-Help: List-Subscribe: List-Post: List-Owner: List-Archive: Precedence: bulk This is a multi-part message in MIME format. ------=_001_NextPart158418273311_=---- Content-Type: multipart/alternative; boundary="----=_002_NextPart002437405858_=----" ------=_002_NextPart002437405858_=---- Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: base64 SGVsbG8gaGFja2VycywNCg0KSSBhbSByZXNlYXJjaGluZyBhYm91dCAnb3JpZ2luJyBpbiBQb3N0 Z3JlU1FMLCBtYWlubHkgaXQgdXNlZCBpbiBsb2dpY2FsDQpkZWNvZGluZyB0byBmaWx0ZXIgdHJh bnNhY3Rpb24gZnJvbSBub24tbG9jYWwgc291cmNlLiBJIG5vdGljZSB0aGF0IHRoZQ0KJ29yaWdp bicgaXMgc3RvcmVkIGluIGNvbW1pdF90cyBzbyB0aGF0IEkgdGhpbmsgd2UgYXJlIHBvc3NpYmxl IHRvIGdldCAnb3JpZ2luJw0Kb2YgYSB0cmFuc2FjdGlvbiBmcm9tIGNvbW1pdF90cy4NCg0KQnV0 IEkgY2FuIG5vdCBmb25kIGFueSBjb2RlIHRvIGdldCAnb3JpZ2luJyBmcm9tIGNvbW1pdF90cywg anVzdCBsaWtlIGl0IGlzDQpwcm9kdWNpbmcgZGF0YSB3aGljaCBub2JvZHkgY2FyZXMgYWJvdXQu IENhbiBJIGtub3cgd2hhdCdzIHRoZSBwdXJwb3NlDQpvZiB0aGUgJ29yaWdpbicgaW4gY29tbWl0 X3RzPyBEbyB5b3UgdGhpbmsgd2Ugc2hvdWxkIGFkZCBzb21lIHN1cHBvcnQNCnRvIHRoZSBjYXJl bGVzcyBkYXRhPw0KDQpGb3IgZXhhbXBsZSwgSSBhZGQgYSBmdW5jdGlvbiB0byBnZXQgJ29yaWdp bicgZnJvbSBjb21taXRfdHM6DQo9PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09 PT0NCnBvc3RncmVzPSMgc2VsZWN0IHBnX3hhY3RfY29tbWl0X29yaWdpbignNDkwJyk7DQogcGdf eGFjdF9jb21taXRfb3JpZ2luIA0KLS0tLS0tLS0tLS0tLS0tLS0tLS0tLS0NCiB0ZXN0X29yaWdp bg0KKDEgcm93KQ0KDQpwb3N0Z3Jlcz0jIHNlbGVjdCBwZ194YWN0X2NvbW1pdF9vcmlnaW4oJzQ5 MScpOw0KIHBnX3hhY3RfY29tbWl0X29yaWdpbiANCi0tLS0tLS0tLS0tLS0tLS0tLS0tLS0tDQog dGVzdF9vcmlnaW4xDQooMSByb3cpDQoNCnBvc3RncmVzPSMNCj09PT09PT09PT09PT09PT09PT09 PT09PT09PT09PT09PT09PT09PQ0KDQoNCg0KDQpSZWdhcmRzLA0KSGlnaGdvIFNvZnR3YXJlIChD YW5hZGEvQ2hpbmEvUGFraXN0YW4pIA0KVVJMIDogd3d3LmhpZ2hnby5jYSANCkVNQUlMOiBtYWls dG86bW92ZWFkKGRvdClsaShhdCloaWdoZ28oZG90KWNhDQo= ------=_002_NextPart002437405858_=---- Content-Type: text/html; charset="us-ascii" Content-Transfer-Encoding: quoted-printable =0A
Hello hackers,

I am researching about 'origin' in PostgreSQL, mainly it used= in logical
decoding to filter transaction from non-local source= .. I notice that the
'origin' is stored in commit_ts so that I th= ink we are possible to get 'origin'
of a transaction from commit= _ts.

But I can not fond any code to get 'origin' = from commit_ts, just like it is
producing data which nobody care= s about. Can I know what's the purpose
of the 'origin' in commit= _ts? Do you think we should add some support
to the careless dat= a?

For example, I add a function to get 'origin' = from commit_ts:
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D
postgres= =3D# select pg_xact_commit_origin('490');
 pg_xact_commit_o= rigin 
-----------------------
 test_origin<= /div>
(1 row)

postgres=3D# select pg_xact_com= mit_origin('491');
 pg_xact_commit_origin 
-= ----------------------
 test_origin1
(1 row)

postgres=3D#
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D

=0A
=
=0A
Regards,
Highgo Software (Canada/China/Pakistan)
UR= L : www.highgo.ca
EMAIL: mailto:movead(dot)li(at)highgo(dot)ca
=0A ------=_002_NextPart002437405858_=------ ------=_001_NextPart158418273311_=---- Content-Type: application/octet-stream; name="get_origin_from_commit_ts.patch" Content-Transfer-Encoding: base64 Content-Disposition: attachment; filename="get_origin_from_commit_ts.patch" ZGlmZiAtLWdpdCBhL3NyYy9iYWNrZW5kL2FjY2Vzcy90cmFuc2FtL2NvbW1pdF90cy5jIGIvc3Jj L2JhY2tlbmQvYWNjZXNzL3RyYW5zYW0vY29tbWl0X3RzLmMKaW5kZXggNjMwZGY2NzJjYy4uODVl MDNlZmU0ZSAxMDA2NDQKLS0tIGEvc3JjL2JhY2tlbmQvYWNjZXNzL3RyYW5zYW0vY29tbWl0X3Rz LmMKKysrIGIvc3JjL2JhY2tlbmQvYWNjZXNzL3RyYW5zYW0vY29tbWl0X3RzLmMKQEAgLTQxNiw2 ICs0MTYsMjkgQEAgcGdfeGFjdF9jb21taXRfdGltZXN0YW1wKFBHX0ZVTkNUSU9OX0FSR1MpCiAJ UEdfUkVUVVJOX1RJTUVTVEFNUFRaKHRzKTsKIH0KIAorLyoKKyAqIFNRTC1jYWxsYWJsZSB3cmFw cGVyIHRvIG9idGFpbiBjb21taXQgb3JpZ2luIG9mIGEgdHJhbnNhY3Rpb24KKyAqLworRGF0dW0K K3BnX3hhY3RfY29tbWl0X29yaWdpbihQR19GVU5DVElPTl9BUkdTKQoreworCVRyYW5zYWN0aW9u SWQgCXhpZCA9IFBHX0dFVEFSR19VSU5UMzIoMCk7CisJUmVwT3JpZ2luSWQJCW5vZGVpZDsKKwlU aW1lc3RhbXBUeiAJdHM7CisJYm9vbAkJCWZvdW5kOworCWNoYXIJICAgCQkqcm9uYW1lID0gTlVM TDsKKworCWZvdW5kID0gVHJhbnNhY3Rpb25JZEdldENvbW1pdFRzRGF0YSh4aWQsICZ0cywgJm5v ZGVpZCk7CisKKwlpZiAoIWZvdW5kIHx8IChJbnZhbGlkUmVwT3JpZ2luSWQgPT0gbm9kZWlkKSkK KwkJUEdfUkVUVVJOX05VTEwoKTsKKworCXJlcGxvcmlnaW5fYnlfb2lkKG5vZGVpZCwgZmFsc2Us ICZyb25hbWUpOworCisJUEdfUkVUVVJOX1RFWFRfUChjc3RyaW5nX3RvX3RleHQocm9uYW1lKSk7 Cit9CisKKwogCiBEYXR1bQogcGdfbGFzdF9jb21taXR0ZWRfeGFjdChQR19GVU5DVElPTl9BUkdT KQpkaWZmIC0tZ2l0IGEvc3JjL2luY2x1ZGUvY2F0YWxvZy9wZ19wcm9jLmRhdCBiL3NyYy9pbmNs dWRlL2NhdGFsb2cvcGdfcHJvYy5kYXQKaW5kZXggNGJjZTNhZDhkZS4uNWU2N2FjZTMyZCAxMDA2 NDQKLS0tIGEvc3JjL2luY2x1ZGUvY2F0YWxvZy9wZ19wcm9jLmRhdAorKysgYi9zcmMvaW5jbHVk ZS9jYXRhbG9nL3BnX3Byb2MuZGF0CkBAIC01OTQ1LDYgKzU5NDUsMTIgQEAKICAgcHJvcmV0dHlw ZSA9PiAndGltZXN0YW1wdHonLCBwcm9hcmd0eXBlcyA9PiAneGlkJywKICAgcHJvc3JjID0+ICdw Z194YWN0X2NvbW1pdF90aW1lc3RhbXAnIH0sCiAKK3sgb2lkID0+ICczNDM1JywgZGVzY3IgPT4g J2dldCBjb21taXQgb3JpZ2luIG9mIGEgdHJhbnNhY3Rpb24nLAorICBwcm9uYW1lID0+ICdwZ194 YWN0X2NvbW1pdF9vcmlnaW4nLCBwcm92b2xhdGlsZSA9PiAndicsCisgIHByb3JldHR5cGUgPT4g J3RleHQnLCBwcm9hcmd0eXBlcyA9PiAneGlkJywKKyAgcHJvc3JjID0+ICdwZ194YWN0X2NvbW1p dF9vcmlnaW4nIH0sCisKKwogeyBvaWQgPT4gJzM1ODMnLAogICBkZXNjciA9PiAnZ2V0IHRyYW5z YWN0aW9uIElkIGFuZCBjb21taXQgdGltZXN0YW1wIG9mIGxhdGVzdCB0cmFuc2FjdGlvbiBjb21t aXQnLAogICBwcm9uYW1lID0+ICdwZ19sYXN0X2NvbW1pdHRlZF94YWN0JywgcHJvdm9sYXRpbGUg PT4gJ3YnLAo= ------=_001_NextPart158418273311_=------