spacewalk-commits February 2014

spacewalk-commits@lists.fedorahosted.org

10 participants
275 discussions

2 commits - rel-eng/packages schema/spacewalk
by Milan Zazrivec 14 Feb '14

14 Feb '14

rel-eng/packages/spacewalk-schema | 2 - schema/spacewalk/oracle/packages/rhn_channel.pkb | 14 ++++++---- schema/spacewalk/postgres/packages/rhn_channel.pkb | 2 - schema/spacewalk/spacewalk-schema.spec | 5 ++- schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.oracle | 14 ++++++---- schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.postgresql | 2 - 6 files changed, 25 insertions(+), 14 deletions(-) New commits: commit 2ea9624e781168528e6a20c5591ced427ed34c7e Author: Milan Zazrivec <mzazrivec(a)redhat.com> Date: Fri Feb 14 13:46:18 2014 +0100 Automatic commit of package [spacewalk-schema] release [2.1.45-1]. diff --git a/rel-eng/packages/spacewalk-schema b/rel-eng/packages/spacewalk-schema index 50577e7..2c798ba 100644 --- a/rel-eng/packages/spacewalk-schema +++ b/rel-eng/packages/spacewalk-schema @@ -1 +1 @@ -2.1.44-1 schema/spacewalk/ +2.1.45-1 schema/spacewalk/ diff --git a/schema/spacewalk/spacewalk-schema.spec b/schema/spacewalk/spacewalk-schema.spec index 28da1ae..affed7b 100644 --- a/schema/spacewalk/spacewalk-schema.spec +++ b/schema/spacewalk/spacewalk-schema.spec @@ -4,7 +4,7 @@ Name: spacewalk-schema Group: Applications/Internet Summary: Oracle SQL schema for Spacewalk server -Version: 2.1.44 +Version: 2.1.45 Release: 1%{?dist} Source0: %{name}-%{version}.tar.gz @@ -71,6 +71,9 @@ rm -rf $RPM_BUILD_ROOT %{_mandir}/man1/spacewalk-sql* %changelog +* Fri Feb 14 2014 Milan Zazrivec <mzazrivec(a)redhat.com> 2.1.45-1 +- fix ORA-01403: no data found, when unsubscribing a system + * Fri Feb 14 2014 Milan Zazrivec <mzazrivec(a)redhat.com> 2.1.44-1 - rename upgrade scripts to be included in schema upgrade - fix ORA-01403: no data found, during system registration commit f70df3b3bcda93204e0b5d7ab5912cabd62f8ac4 Author: Milan Zazrivec <mzazrivec(a)redhat.com> Date: Fri Feb 14 13:45:35 2014 +0100 fix ORA-01403: no data found, when unsubscribing a system diff --git a/schema/spacewalk/oracle/packages/rhn_channel.pkb b/schema/spacewalk/oracle/packages/rhn_channel.pkb index 4be76a2..4496361 100644 --- a/schema/spacewalk/oracle/packages/rhn_channel.pkb +++ b/schema/spacewalk/oracle/packages/rhn_channel.pkb @@ -526,11 +526,15 @@ IS where c.id = channel_id_in ); - select 1 - into update_lock - from rhnServerNeededCache - where server_id = server_id_in - for update; + begin + select 1 + into update_lock + from rhnServerNeededCache + where server_id = server_id_in + for update; + exception when no_data_found then + null; + end; UPDATE rhnServer SET channels_changed = current_timestamp WHERE id = server_id_in; end if; diff --git a/schema/spacewalk/postgres/packages/rhn_channel.pkb b/schema/spacewalk/postgres/packages/rhn_channel.pkb index 64168d9..98360b9 100644 --- a/schema/spacewalk/postgres/packages/rhn_channel.pkb +++ b/schema/spacewalk/postgres/packages/rhn_channel.pkb @@ -1,4 +1,4 @@ --- oracle equivalent source sha1 78b5b31336bdc942418962b6c374f1a67c95afe2 +-- oracle equivalent source sha1 49755627c92e9950ba24fd313705bb282acdcfba -- -- Copyright (c) 2008--2013 Red Hat, Inc. -- diff --git a/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.oracle b/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.oracle index 477e8b0..3dab16b 100644 --- a/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.oracle +++ b/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.oracle @@ -526,11 +526,15 @@ IS where c.id = channel_id_in ); - select 1 - into update_lock - from rhnServerNeededCache - where server_id = server_id_in - for update; + begin + select 1 + into update_lock + from rhnServerNeededCache + where server_id = server_id_in + for update; + exception when no_data_found then + null; + end; UPDATE rhnServer SET channels_changed = current_timestamp WHERE id = server_id_in; end if; diff --git a/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.postgresql b/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.postgresql index 03422a4..0c3c9b1 100644 --- a/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.postgresql +++ b/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.postgresql @@ -1,4 +1,4 @@ --- oracle equivalent source sha1 8c6ffbfad3684c9957041813f63cfdbd2077d8cf +-- oracle equivalent source sha1 c11143025f1ed0730af16785aee42198b8e477c7 -- -- Copyright (c) 2008--2013 Red Hat, Inc. --

1 0

Changes to 'refs/tags/rhn-client-tools-2.1.15-1'
by mkollar 14 Feb '14

14 Feb '14

Tag 'rhn-client-tools-2.1.15-1' created by Matej Kollar <mkollar(a)redhat.com> at 2014-02-14 12:30 +0000 Tagging package [rhn-client-tools] version [2.1.15-1] in directory [client/rhel/rhn-client-tools/]. Changes since spacewalk-backend-2.1.50-1: Matej Kollar (1): Automatic commit of package [rhn-client-tools] release [2.1.15-1]. --- client/rhel/rhn-client-tools/rhn-client-tools.spec | 6 +++++- rel-eng/packages/rhn-client-tools | 2 +- 2 files changed, 6 insertions(+), 2 deletions(-) ---

1 0

client/rhel rel-eng/packages
by mkollar 14 Feb '14

14 Feb '14

client/rhel/rhn-client-tools/rhn-client-tools.spec | 6 +++++- rel-eng/packages/rhn-client-tools | 2 +- 2 files changed, 6 insertions(+), 2 deletions(-) New commits: commit a0751b8fd19f358dc2ddcac6d815ac77d15d54bb Author: Matej Kollar <mkollar(a)redhat.com> Date: Fri Feb 14 13:30:33 2014 +0100 Automatic commit of package [rhn-client-tools] release [2.1.15-1]. diff --git a/client/rhel/rhn-client-tools/rhn-client-tools.spec b/client/rhel/rhn-client-tools/rhn-client-tools.spec index 7a5293b..5758523 100644 --- a/client/rhel/rhn-client-tools/rhn-client-tools.spec +++ b/client/rhel/rhn-client-tools/rhn-client-tools.spec @@ -4,7 +4,7 @@ Group: System Environment/Base Source0: https://fedorahosted.org/releases/s/p/spacewalk/%{name}-%{version}.tar.gz URL: https://fedorahosted.org/spacewalk Name: rhn-client-tools -Version: 2.1.14 +Version: 2.1.15 Release: 1%{?dist} BuildRoot: %{_tmppath}/%{name}-%{version}-%{release}-root-%(%{__id_u} -n) BuildArch: noarch @@ -360,6 +360,10 @@ make -f Makefile.rhn-client-tools test %endif %changelog +* Fri Feb 14 2014 Matej Kollar <mkollar(a)redhat.com> 2.1.15-1 +- 1061013 - remove unneeded rpm macros file +- 1060742 - new information icon in gnome3 + * Tue Jan 14 2014 Matej Kollar <mkollar(a)redhat.com> 2.1.14-1 - Updating the copyright years info - Update .po and .pot files for rhn-client-tools. diff --git a/rel-eng/packages/rhn-client-tools b/rel-eng/packages/rhn-client-tools index 61f1911..a3d6175 100644 --- a/rel-eng/packages/rhn-client-tools +++ b/rel-eng/packages/rhn-client-tools @@ -1 +1 @@ -2.1.14-1 client/rhel/rhn-client-tools/ +2.1.15-1 client/rhel/rhn-client-tools/

1 0

Changes to 'refs/tags/spacewalk-backend-2.1.50-1'
by mkollar 14 Feb '14

14 Feb '14

Tag 'spacewalk-backend-2.1.50-1' created by Matej Kollar <mkollar(a)redhat.com> at 2014-02-14 12:27 +0000 Tagging package [spacewalk-backend] version [2.1.50-1] in directory [backend/]. Changes since spacewalk-schema-2.1.44-1: Matej Kollar (1): Automatic commit of package [spacewalk-backend] release [2.1.50-1]. --- backend/spacewalk-backend.spec | 5 ++++- rel-eng/packages/spacewalk-backend | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) ---

1 0

backend/spacewalk-backend.spec rel-eng/packages
by mkollar 14 Feb '14

14 Feb '14

backend/spacewalk-backend.spec | 5 ++++- rel-eng/packages/spacewalk-backend | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) New commits: commit 2d4ae440bcd152724d80ee46fa7591320ab16b16 Author: Matej Kollar <mkollar(a)redhat.com> Date: Fri Feb 14 13:27:54 2014 +0100 Automatic commit of package [spacewalk-backend] release [2.1.50-1]. diff --git a/backend/spacewalk-backend.spec b/backend/spacewalk-backend.spec index 46348ae..ba654c8 100644 --- a/backend/spacewalk-backend.spec +++ b/backend/spacewalk-backend.spec @@ -11,7 +11,7 @@ Name: spacewalk-backend Summary: Common programs needed to be installed on the Spacewalk servers/proxies Group: Applications/Internet License: GPLv2 -Version: 2.1.49 +Version: 2.1.50 Release: 1%{?dist} URL: https://fedorahosted.org/spacewalk Source0: https://fedorahosted.org/releases/s/p/spacewalk/%{name}-%{version}.tar.gz @@ -632,6 +632,9 @@ rm -f %{rhnconf}/rhnSecret.py* %{pythonrhnroot}/satellite_tools/exporter/xmlWriter.py* %changelog +* Fri Feb 14 2014 Matej Kollar <mkollar(a)redhat.com> 2.1.50-1 +- query should not end with semicolon in oracle + * Thu Feb 06 2014 Jan Dobes 2.1.49-1 - 1056515 - adapting to different logrotate version in fedora and rhel - 870990 - sw-rm-ch -l when satellite-sync runs. diff --git a/rel-eng/packages/spacewalk-backend b/rel-eng/packages/spacewalk-backend index 544cca2..c110da5 100644 --- a/rel-eng/packages/spacewalk-backend +++ b/rel-eng/packages/spacewalk-backend @@ -1 +1 @@ -2.1.49-1 backend/ +2.1.50-1 backend/

1 0

Changes to 'refs/tags/spacewalk-schema-2.1.44-1'
by Milan Zazrivec 14 Feb '14

14 Feb '14

Tag 'spacewalk-schema-2.1.44-1' created by Milan Zazrivec <mzazrivec(a)redhat.com> at 2014-02-14 12:16 +0000 Tagging package [spacewalk-schema] version [2.1.44-1] in directory [schema/spacewalk/]. Changes since yum-rhn-plugin-2.1.7-1: Milan Zazrivec (3): fix ORA-01403: no data found, during system registration rename upgrade scripts to be included in schema upgrade Automatic commit of package [spacewalk-schema] release [2.1.44-1]. --- rel-eng/packages/spacewalk-schema | 2 schema/spacewalk/oracle/packages/rhn_channel.pkb | 14 schema/spacewalk/postgres/packages/rhn_channel.pkb | 2 schema/spacewalk/spacewalk-schema.spec | 6 schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.oracle | 1255 --------- schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.postgresql | 1278 ---------- schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.oracle | 1259 +++++++++ schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.postgresql | 1278 ++++++++++ 8 files changed, 2553 insertions(+), 2541 deletions(-) ---

1 0

2 commits - rel-eng/packages schema/spacewalk
by Milan Zazrivec 14 Feb '14

14 Feb '14

rel-eng/packages/spacewalk-schema | 2 schema/spacewalk/spacewalk-schema.spec | 6 schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.oracle | 1259 --------- schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.postgresql | 1278 ---------- schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.oracle | 1259 +++++++++ schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.postgresql | 1278 ++++++++++ 6 files changed, 2543 insertions(+), 2539 deletions(-) New commits: commit 3c5f8025fca2f2defaaf06e34cf062a46270e7ad Author: Milan Zazrivec <mzazrivec(a)redhat.com> Date: Fri Feb 14 13:16:59 2014 +0100 Automatic commit of package [spacewalk-schema] release [2.1.44-1]. diff --git a/rel-eng/packages/spacewalk-schema b/rel-eng/packages/spacewalk-schema index 4bb5dd5..50577e7 100644 --- a/rel-eng/packages/spacewalk-schema +++ b/rel-eng/packages/spacewalk-schema @@ -1 +1 @@ -2.1.43-1 schema/spacewalk/ +2.1.44-1 schema/spacewalk/ diff --git a/schema/spacewalk/spacewalk-schema.spec b/schema/spacewalk/spacewalk-schema.spec index 53427f5..28da1ae 100644 --- a/schema/spacewalk/spacewalk-schema.spec +++ b/schema/spacewalk/spacewalk-schema.spec @@ -4,7 +4,7 @@ Name: spacewalk-schema Group: Applications/Internet Summary: Oracle SQL schema for Spacewalk server -Version: 2.1.43 +Version: 2.1.44 Release: 1%{?dist} Source0: %{name}-%{version}.tar.gz @@ -71,6 +71,10 @@ rm -rf $RPM_BUILD_ROOT %{_mandir}/man1/spacewalk-sql* %changelog +* Fri Feb 14 2014 Milan Zazrivec <mzazrivec(a)redhat.com> 2.1.44-1 +- rename upgrade scripts to be included in schema upgrade +- fix ORA-01403: no data found, during system registration + * Wed Feb 12 2014 Milan Zazrivec <mzazrivec(a)redhat.com> 2.1.43-1 - 1063821 - lock rhnServerNeededCache to avoid a db deadlock commit 3bf29925aa57d621c598da898ad4455987852eb6 Author: Milan Zazrivec <mzazrivec(a)redhat.com> Date: Fri Feb 14 13:16:04 2014 +0100 rename upgrade scripts to be included in schema upgrade diff --git a/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.oracle b/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.oracle deleted file mode 100644 index 477e8b0..0000000 --- a/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.oracle +++ /dev/null @@ -1,1259 +0,0 @@ --- --- Copyright (c) 2008--2013 Red Hat, Inc. --- --- This software is licensed to you under the GNU General Public License, --- version 2 (GPLv2). There is NO WARRANTY for this software, express or --- implied, including the implied warranties of MERCHANTABILITY or FITNESS --- FOR A PARTICULAR PURPOSE. You should have received a copy of GPLv2 --- along with this software; if not, see --- http://www.gnu.org/licenses/old-licenses/gpl-2.0.txt. --- --- Red Hat trademarks are not licensed under GPLv2. No permission is --- granted to use or replicate Red Hat trademarks that are incorporated --- in this software or its documentation. --- - -CREATE OR REPLACE -PACKAGE BODY rhn_channel -IS - body_version varchar2(100) := ''; - - -- Cursor that fetches all the possible base channels for a - -- (server_arch_id, release, org_id) combination - cursor base_channel_cursor( - release_in in varchar2, - server_arch_id_in in number, - org_id_in in number - ) return rhnChannel%ROWTYPE is - select distinct c.* - from rhnOrgDistChannelMap odcm, - rhnServerChannelArchCompat scac, - rhnChannel c - where c.parent_channel is null - and c.id = odcm.channel_id - and c.channel_arch_id = odcm.channel_arch_id - and odcm.release = release_in - and odcm.for_org_id = org_id_in - and scac.server_arch_id = server_arch_id_in - and scac.channel_arch_id = c.channel_arch_id; - - procedure obtain_read_lock(channel_family_id_in in number, org_id_in in number) - is - read_lock timestamp with local time zone; - - begin - select created into read_lock - from rhnPrivateChannelFamily - where channel_family_id = channel_family_id_in and org_id = org_id_in - for update; - end obtain_read_lock; - - PROCEDURE subscribe_server(server_id_in IN NUMBER, channel_id_in NUMBER, immediate_in NUMBER := 1, user_id_in in number := null, recalcfamily_in number := 1) - IS - channel_parent_val rhnChannel.parent_channel%TYPE; - parent_subscribed BOOLEAN; - server_has_base_chan BOOLEAN; - server_already_in_chan BOOLEAN; - channel_family_id_val NUMBER; - server_org_id_val NUMBER; - available_subscriptions NUMBER; - available_fve_subs NUMBER; - consenting_user NUMBER; - allowed number := 0; - is_fve CHAR(1) := 'N'; - update_lock number; - BEGIN - if user_id_in is not null then - allowed := rhn_channel.user_role_check(channel_id_in, user_id_in, 'subscribe'); - else - allowed := 1; - end if; - - if allowed = 0 then - rhn_exception.raise_exception('no_subscribe_permissions'); - end if; - - - SELECT parent_channel INTO channel_parent_val FROM rhnChannel WHERE id = channel_id_in; - - IF channel_parent_val IS NOT NULL - THEN - -- child channel; if attempting to cross-subscribe a child to the wrong base, silently ignore - parent_subscribed := FALSE; - - FOR check_subscription IN check_server_subscription(server_id_in, channel_parent_val) - LOOP - parent_subscribed := TRUE; - END LOOP check_subscription; - - IF NOT parent_subscribed - THEN - RETURN; - END IF; - ELSE - -- base channel - server_has_base_chan := FALSE; - FOR base IN server_base_subscriptions(server_id_in) - LOOP - server_has_base_chan := TRUE; - END LOOP base; - - IF server_has_base_chan - THEN - rhn_exception.raise_exception('channel_server_one_base'); - END IF; - END IF; - - FOR check_subscription IN check_server_subscription(server_id_in, channel_id_in) - LOOP - server_already_in_chan := TRUE; - END LOOP check_subscription; - - IF server_already_in_chan - THEN - RETURN; - END IF; - - channel_family_id_val := rhn_channel.family_for_channel(channel_id_in); - IF channel_family_id_val IS NULL - THEN - rhn_exception.raise_exception('channel_subscribe_no_family'); - END IF; - - -- - -- Use the org_id of the server only if the org_id of the channel = NULL. - -- This is required for subscribing to shared channels. - -- - SELECT NVL(org_id, (SELECT org_id FROM rhnServer WHERE id = server_id_in)) - INTO server_org_id_val - FROM rhnChannel - WHERE id = channel_id_in; - - begin - obtain_read_lock(channel_family_id_val, server_org_id_val); - exception - when no_data_found then - rhn_exception.raise_exception('channel_family_no_subscriptions'); - end; - - available_subscriptions := rhn_channel.available_family_subscriptions(channel_family_id_val, server_org_id_val); - available_fve_subs := rhn_channel.available_fve_family_subs(channel_family_id_val, server_org_id_val); - - IF available_subscriptions IS NULL OR - available_subscriptions > 0 or - can_server_consume_virt_channl(server_id_in, channel_family_id_val) = 1 OR - (available_fve_subs > 0 AND can_server_consume_fve(server_id_in) = 1) - THEN - if can_server_consume_virt_channl(server_id_in, channel_family_id_val) = 0 AND available_fve_subs > 0 AND can_server_consume_fve(server_id_in) = 1 THEN - is_fve := 'Y'; - END IF; - insert into rhnServerHistory (id,server_id,summary,details) ( - select rhn_event_id_seq.nextval, - server_id_in, - 'subscribed to channel ' || SUBSTR(c.label, 0, 106), - c.label - from rhnChannel c - where c.id = channel_id_in - ); - - begin - select 1 - into update_lock - from rhnServerNeededCache - where server_id = server_id_in - for update; - exception WHEN no_data_found THEN - null; - end; - - UPDATE rhnServer SET channels_changed = current_timestamp WHERE id = server_id_in; - INSERT INTO rhnServerChannel (server_id, channel_id, is_fve) VALUES (server_id_in, channel_id_in, is_fve); - IF recalcfamily_in > 0 - THEN - rhn_channel.update_family_counts(channel_family_id_val, server_org_id_val); - END IF; - queue_server(server_id_in, immediate_in); - ELSE - rhn_exception.raise_exception('channel_family_no_subscriptions'); - END IF; - - END subscribe_server; - - - - FUNCTION can_convert_to_fve(server_id_in IN NUMBER, channel_family_id_val IN NUMBER) - RETURN NUMBER - IS - CURSOR fve_convertible_entries IS - select 1 from - rhnServerFveCapable cap - where cap.server_id = server_id_in - AND cap.channel_family_id = channel_family_id_val; - BEGIN - FOR entry IN fve_convertible_entries LOOP - return 1; - END LOOP; - RETURN 0; - END can_convert_to_fve; - - - - -- Converts server channel_family to use a flex entitlement - PROCEDURE convert_to_fve(server_id_in IN NUMBER, channel_family_id_val IN NUMBER) - IS - available_fve_subs NUMBER; - server_org_id_val NUMBER; - BEGIN - - -- - -- Use the org_id of the server only if the org_id of the channel = NULL. - -- This is required for subscribing to shared channels. - -- - SELECT org_id - INTO server_org_id_val - FROM rhnServer - WHERE id = server_id_in; - - begin - obtain_read_lock(channel_family_id_val, server_org_id_val); - exception - when no_data_found then - rhn_exception.raise_exception('channel_family_no_subscriptions'); - end; - IF (can_convert_to_fve(server_id_in, channel_family_id_val ) = 0) - THEN - rhn_exception.raise_exception('server_cannot_convert_to_flex'); - END IF; - - available_fve_subs := rhn_channel.available_fve_family_subs(channel_family_id_val, server_org_id_val); - - IF (available_fve_subs > 0) - THEN - - insert into rhnServerHistory (id,server_id,summary,details) ( - select rhn_event_id_seq.nextval, - server_id_in, - 'converted to flex entitlement' || SUBSTR(cf.label, 0, 99), - cf.label - from rhnChannelFamily cf - where cf.id = channel_family_id_val - ); - - UPDATE rhnServerChannel sc set sc.is_fve = 'Y' - where sc.server_id = server_id_in and - sc.channel_id in - (select cfm.channel_id from rhnChannelFamilyMembers cfm - where cfm.CHANNEL_FAMILY_ID = channel_family_id_val); - - rhn_channel.update_family_counts(channel_family_id_val, server_org_id_val); - ELSE - rhn_exception.raise_exception('not_enough_flex_entitlements'); - END IF; - - END convert_to_fve; - - function can_server_consume_virt_channl( - server_id_in in number, - family_id_in in number ) - return number - is - - cursor server_virt_families is - select vi.virtual_system_id, cfvsl.channel_family_id - from - rhnChannelFamilyVirtSubLevel cfvsl, - rhnSGTypeVirtSubLevel sgtvsl, - rhnVirtualInstance vi - where - vi.virtual_system_id = server_id_in - and sgtvsl.virt_sub_level_id = cfvsl.virt_sub_level_id - and cfvsl.channel_family_id = family_id_in - and exists ( - select 1 - from rhnServerEntitlementView sev - where vi.host_system_id = sev.server_id - and sev.server_group_type_id = sgtvsl.server_group_type_id ); - begin - - for server_virt_family in server_virt_families loop - return 1; - end loop; - - return 0; - - end; - - FUNCTION can_server_consume_fve(server_id_in IN NUMBER) - RETURN NUMBER - IS - CURSOR vi_entries IS - SELECT 1 - FROM rhnVirtualInstance vi - WHERE vi.virtual_system_id = server_id_in; - vi_count NUMBER; - - BEGIN - FOR vi_entry IN VI_ENTRIES LOOP - return 1; - END LOOP; - RETURN 0; - END; - - function guess_server_base( - server_id_in in number - ) RETURN number is - cursor server_cursor is - select s.server_arch_id, s.release, s.org_id - from rhnServer s - where s.id = server_id_in; - begin - for s in server_cursor loop - for channel in base_channel_cursor(s.release, - s.server_arch_id, s.org_id) - loop - return channel.id; - end loop base_channel_cursor; - end loop server_cursor; - -- Server not found, or no base channel applies to it - return null; - end; - - -- Private function - function normalize_server_arch(server_arch_in in varchar2) - return varchar2 - deterministic - is - suffix VARCHAR2(128) := '-redhat-linux'; - suffix_len NUMBER := length(suffix); - begin - if server_arch_in is NULL then - return NULL; - end if; - if instr(server_arch_in, '-') > 0 - then - -- Suffix already present - return server_arch_in; - end if; - return server_arch_in || suffix; - end normalize_server_arch; - - -- - -- - -- Raises: - -- server_arch_not_found - -- no_subscribe_permissions - function base_channel_for_release_arch( - release_in in varchar2, - server_arch_in in varchar2, - org_id_in in number := -1, - user_id_in in number := null - ) return number is - server_arch varchar2(256) := normalize_server_arch(server_arch_in); - server_arch_id number; - begin - -- Look up the server arch - begin - select id - into server_arch_id - from rhnServerArch - where label = server_arch; - exception - when no_data_found then - rhn_exception.raise_exception('server_arch_not_found'); - end; - return base_channel_rel_archid(release_in, server_arch_id, - org_id_in, user_id_in); - end base_channel_for_release_arch; - - function base_channel_rel_archid( - release_in in varchar2, - server_arch_id_in in number, - org_id_in in number := -1, - user_id_in in number := null - ) return number is - denied_channel_id number := null; - valid_org_id number := org_id_in; - valid_user_id number := user_id_in; - channel_subscribable number; - begin - if org_id_in = -1 and user_id_in is not null then - -- Get the org id from the user id - begin - select org_id - into valid_org_id - from web_contact - where id = user_id_in; - exception - when no_data_found then - -- User doesn't exist - -- XXX Only list public stuff for now - valid_user_id := null; - valid_org_id := -1; - end; - end if; - - for c in base_channel_cursor(release_in, server_arch_id_in, valid_org_id) - loop - -- This row is a possible match - if valid_user_id is null then - -- User ID not specified, so no user to channel permissions to - -- check - return c.id; - end if; - - -- Check user to channel permissions - select loose_user_role_check(c.id, user_id_in, 'subscribe') - into channel_subscribable - from dual; - - if channel_subscribable = 1 then - return c.id; - end if; - - -- Base channel exists, but is not subscribable; keep trying - denied_channel_id := c.id; - end loop base_channel_fetch; - - if denied_channel_id is not null then - rhn_exception.raise_exception('no_subscribe_permissions'); - end if; - -- No base channel applies - return NULL; - end base_channel_rel_archid; - - PROCEDURE clear_subscriptions(server_id_in IN NUMBER, deleting_server IN NUMBER := 0, - update_family_countsYN IN NUMBER := 1) - IS - cursor server_channels(server_id_in in number) is - select s.org_id, sc.channel_id, cfm.channel_family_id - from rhnServer s, - rhnServerChannel sc, - rhnChannelFamilyMembers cfm - where s.id = server_id_in - and s.id = sc.server_id - and sc.channel_id = cfm.channel_id - order by cfm.channel_family_id; - last_channel_family_id rhnChannelFamilyMembers.channel_family_id%type := -1; - last_channel_org_id rhnServer.org_id%type := -1; - BEGIN - for channel in server_channels(server_id_in) - loop - unsubscribe_server(server_id_in, channel.channel_id, 1, 1, deleting_server, 0); - if update_family_countsYN > 0 - and channel.channel_family_id != last_channel_family_id then - -- update family counts only once - -- after all channels with same family has been fetched - if last_channel_family_id != -1 then - update_family_counts(last_channel_family_id, last_channel_org_id); - end if; - last_channel_family_id := channel.channel_family_id; - last_channel_org_id := channel.org_id; - end if; - end loop channel; - if update_family_countsYN > 0 and last_channel_family_id != -1 then - -- update the last family fetched - update_family_counts(last_channel_family_id, last_channel_org_id); - end if; - END clear_subscriptions; - - PROCEDURE unsubscribe_server(server_id_in IN NUMBER, channel_id_in NUMBER, immediate_in NUMBER := 1, unsubscribe_children_in number := 0, - deleting_server IN NUMBER := 0, - update_family_countsYN IN NUMBER := 1) - IS - channel_family_id_val NUMBER; - server_org_id_val NUMBER; - available_subscriptions NUMBER; - server_already_in_chan BOOLEAN; - update_lock number; - cursor channel_family_is_proxy(channel_family_id_in in number) is - select 1 - from rhnChannelFamily - where id = channel_family_id_in - and label = 'rhn-proxy'; - cursor channel_family_is_satellite(channel_family_id_in in number) is - select 1 - from rhnChannelFamily - where id = channel_family_id_in - and label = 'rhn-satellite'; - -- this is *EXACTLY* like check_server_parent_membership, but if we recurse - -- with the package-level one, we get a "cursor already open", so we need a - -- copy on our call stack instead. GROAN. - cursor local_chk_server_parent_memb ( - server_id_in number, - channel_id_in number ) is - select c.id - from rhnChannel c, - rhnServerChannel sc - where 1=1 - and c.parent_channel = channel_id_in - and c.id = sc.channel_id - and sc.server_id = server_id_in; - BEGIN - FOR child IN local_chk_server_parent_memb(server_id_in, channel_id_in) - LOOP - if unsubscribe_children_in = 1 then - unsubscribe_server(server_id_in => server_id_in, - channel_id_in => child.id, - immediate_in => immediate_in, - unsubscribe_children_in => unsubscribe_children_in, - deleting_server => deleting_server, - update_family_countsYN => update_family_countsYN); - else - rhn_exception.raise_exception('channel_unsubscribe_child_exists'); - end if; - END LOOP child; - - server_already_in_chan := FALSE; - - FOR check_subscription IN check_server_subscription(server_id_in, channel_id_in) - LOOP - server_already_in_chan := TRUE; - END LOOP check_subscription; - - IF NOT server_already_in_chan - THEN - RETURN; - END IF; - - if deleting_server = 0 then - - insert into rhnServerHistory (id,server_id,summary,details) ( - select rhn_event_id_seq.nextval, - server_id_in, - 'unsubscribed from channel ' || SUBSTR(c.label, 0, 106), - c.label - from rhnChannel c - where c.id = channel_id_in - ); - - select 1 - into update_lock - from rhnServerNeededCache - where server_id = server_id_in - for update; - - UPDATE rhnServer SET channels_changed = current_timestamp WHERE id = server_id_in; - end if; - - DELETE FROM rhnServerChannel WHERE server_id = server_id_in AND channel_id = channel_id_in; - - if deleting_server = 0 then - queue_server(server_id_in, immediate_in); - end if; - - channel_family_id_val := rhn_channel.family_for_channel(channel_id_in); - IF channel_family_id_val IS NULL - THEN - rhn_exception.raise_exception('channel_unsubscribe_no_family'); - END IF; - - for ignore in channel_family_is_satellite(channel_family_id_val) loop - delete from rhnSatelliteInfo where server_id = server_id_in; - end loop; - - for ignore in channel_family_is_proxy(channel_family_id_val) loop - delete from rhnProxyInfo where server_id = server_id_in; - end loop; - SELECT org_id INTO server_org_id_val - FROM rhnServer - WHERE id = server_id_in; - - if update_family_countsYN = 1 then - rhn_channel.update_family_counts(channel_family_id_val, server_org_id_val); - end if; - END unsubscribe_server; - - - FUNCTION family_for_channel(channel_id_in IN NUMBER) - RETURN NUMBER - IS - channel_family_id_val NUMBER; - BEGIN - SELECT channel_family_id INTO channel_family_id_val - FROM rhnChannelFamilyMembers - WHERE channel_id = channel_id_in; - - RETURN channel_family_id_val; - EXCEPTION - WHEN NO_DATA_FOUND - THEN - RETURN NULL; - END family_for_channel; - - FUNCTION available_family_subscriptions(channel_family_id_in IN NUMBER, org_id_in IN NUMBER) - RETURN NUMBER - IS - cfp channel_family_perm_cursor%ROWTYPE; - current_members_val NUMBER; - max_members_val NUMBER; - found NUMBER; - BEGIN - IF NOT channel_family_perm_cursor%ISOPEN - THEN - OPEN channel_family_perm_cursor(channel_family_id_in, org_id_in); - END IF; - - FETCH channel_family_perm_cursor INTO cfp; - - WHILE channel_family_perm_cursor%FOUND - LOOP - found := 1; - - current_members_val := cfp.current_members; - max_members_val := cfp.max_members; - - FETCH channel_family_perm_cursor INTO cfp; - END LOOP; - - IF channel_family_perm_cursor%ISOPEN - THEN - CLOSE channel_family_perm_cursor; - END IF; - - -- not found: either the channel fam doesn't have an entry in cfp, or the org doesn't have access to it. - -- either way, there are no available subscriptions - - IF found IS NULL - THEN - RETURN 0; - END IF; - - -- null max members? in that case, pass it on; NULL means infinite - IF max_members_val IS NULL - THEN - RETURN NULL; - END IF; - - -- otherwise, return the delta - RETURN max_members_val - current_members_val; - END available_family_subscriptions; - - FUNCTION available_fve_family_subs(channel_family_id_in IN NUMBER, org_id_in IN NUMBER) - RETURN NUMBER - IS - cfp channel_family_perm_cursor%ROWTYPE; - fve_current_members_val NUMBER; - fve_max_members_val NUMBER; - found NUMBER; - - BEGIN - IF NOT channel_family_perm_cursor%ISOPEN THEN - OPEN channel_family_perm_cursor(channel_family_id_in, org_id_in); - END IF; - - FETCH channel_family_perm_cursor INTO cfp; - - WHILE channel_family_perm_cursor%FOUND LOOP - found := 1; - fve_current_members_val := cfp.fve_current_members; - fve_max_members_val := cfp.fve_max_members; - FETCH channel_family_perm_cursor INTO cfp; - END LOOP; - - IF channel_family_perm_cursor%ISOPEN THEN - CLOSE channel_family_perm_cursor; - END IF; - - IF found IS NULL THEN - RETURN 0; - END IF; - - IF fve_max_members_val IS NULL THEN - RETURN NULL; - END IF; - - RETURN fve_max_members_val - fve_current_members_val; - - END available_fve_family_subs; - - - -- ******************************************************************* - -- FUNCTION: channel_family_current_members - -- Calculates and returns the actual count of systems consuming - -- physical channel subscriptions. - -- Called by: update_family_counts - -- rhn_entitlements.repoll_virt_guest_entitlements - -- ******************************************************************* - function channel_family_current_members(channel_family_id_in IN NUMBER, - org_id_in IN NUMBER) - return number - is - current_members_count number := 0; - begin - select count(distinct server_id) - into current_members_count - from rhnChannelFamilyServerPhysical cfsp - where cfsp.channel_family_id = channel_family_id_in - and cfsp.customer_id = org_id_in; - return current_members_count; - end; - - - function cfam_curr_fve_members( - channel_family_id_in IN NUMBER, - org_id_in IN NUMBER) - return number - is - current_members_count number := 0; - - begin - select count(sc.server_id) - into current_members_count - from rhnServerChannel sc, - rhnChannelFamilyMembers cfm, - rhnServer s - where s.org_id = org_id_in - and s.id = sc.server_id - and cfm.channel_family_id = channel_family_id_in - and cfm.channel_id = sc.channel_id - and exists ( - select 1 - from rhnChannelFamilyServerFve cfsp - where cfsp.CHANNEL_FAMILY_ID = channel_family_id_in - and cfsp.server_id = s.id - ); - - return current_members_count; - end; - PROCEDURE update_family_counts(channel_family_id_in IN NUMBER, - org_id_in IN NUMBER) - IS - BEGIN - update rhnPrivateChannelFamily - set current_members = ( channel_family_current_members(channel_family_id_in, org_id_in)), - fve_current_members = ( cfam_curr_fve_members(channel_family_id_in, org_id_in)) - where org_id = org_id_in - and channel_family_id = channel_family_id_in; - END update_family_counts; - - PROCEDURE update_group_family_counts(group_label_in IN VARCHAR2, - org_id_in IN NUMBER) - IS - BEGIN - FOR i IN ( - SELECT DISTINCT CFM.channel_family_id, SG.org_id - FROM rhnChannelFamilyMembers CFM - JOIN rhnServerChannel SC - ON SC.channel_id = CFM.channel_id - JOIN rhnServerGroupMembers SGM - ON SC.server_id = SGM.server_id - JOIN rhnServerGroup SG - ON SGM.server_group_id = SG.id - JOIN rhnServerGroupType SGT - ON SG.group_type = SGT.id - WHERE SGT.label = group_label_in - AND SG.org_id = org_id_in - AND SGT.is_base = 'Y' - ) LOOP - rhn_channel.update_family_counts(i.channel_family_id, i.org_id); - END LOOP; - END update_group_family_counts; - - FUNCTION available_chan_subscriptions(channel_id_in IN NUMBER, - org_id_in IN NUMBER) - RETURN NUMBER - IS - channel_family_id_val NUMBER; - BEGIN - SELECT channel_family_id INTO channel_family_id_val - FROM rhnChannelFamilyMembers - WHERE channel_id = channel_id_in; - - RETURN rhn_channel.available_family_subscriptions( - channel_family_id_val, org_id_in); - END available_chan_subscriptions; - - FUNCTION available_fve_chan_subs(channel_id_in IN NUMBER, - org_id_in IN NUMBER) - RETURN NUMBER - IS - channel_family_id_val NUMBER; - - BEGIN - SELECT channel_family_id INTO channel_family_id_val - FROM rhnChannelFamilyMembers - WHERE channel_id = channel_id_in; - - RETURN rhn_channel.available_fve_family_subs( channel_family_id_val, org_id_in); - END available_fve_chan_subs; - - procedure unsubscribe_server_from_family(server_id_in in number, - channel_family_id_in in number) - is - begin - delete - from rhnServerChannel rsc - where rsc.server_id = server_id_in - and channel_id in ( - select rcfm.channel_id - from rhnChannelFamilyMembers rcfm - where rcfm.channel_family_id = channel_family_id_in); - end; - - function get_org_id(channel_id_in in number) - return number - is - org_id_out number; - begin - select org_id into org_id_out - from rhnChannel - where id = channel_id_in; - - return org_id_out; - end get_org_id; - - function get_cfam_org_access(cfam_id_in in number, org_id_in in number) - return number - is - cursor families is - select 1 - from rhnOrgChannelFamilyPermissions cfp - where cfp.org_id = org_id_in; - begin - -- the idea: if we get past this query, - -- the user has the role, else catch the exception and return 0 - for family in families loop - return 1; - end loop; - return 0; - end; - - function get_org_access(channel_id_in in number, org_id_in in number) - return number - is - throwaway number; - begin - -- the idea: if we get past this query, - -- the org has access to the channel, else catch the exception and return 0 - select distinct 1 into throwaway - from rhnChannelFamilyMembers CFM, - rhnOrgChannelFamilyPermissions CFP - where cfp.org_id = org_id_in - and CFM.channel_family_id = CFP.channel_family_id - and CFM.channel_id = channel_id_in - and (CFP.max_members > 0 or CFP.max_members is null or CFP.fve_max_members > 0 or CFP.fve_max_members is null or CFP.org_id = 1); - - return 1; - exception - when no_data_found - then - return 0; - end; - - -- check if a user has a given role, or if such a role is inferrable - -- returns NULL if OK, error message otherwise - function user_role_check_debug(channel_id_in in number, - user_id_in in number, - role_in in varchar2) - return varchar2 - is - org_id number; - begin - org_id := rhn_user.get_org_id(user_id_in); - - -- channel might be shared - if role_in = 'subscribe' and - rhn_channel.shared_user_role_check(channel_id_in, user_id_in, role_in) = 1 then - return NULL; - end if; - - if role_in = 'manage' and - NVL(rhn_channel.get_org_id(channel_id_in), -1) <> org_id then - return 'channel_not_owned'; - end if; - - if role_in = 'subscribe' and - rhn_channel.get_org_access(channel_id_in, org_id) = 0 then - return 'channel_not_available'; - end if; - - -- channel admins have all roles - if rhn_user.check_role_implied(user_id_in, 'channel_admin') = 1 then - return NULL; - end if; - - -- the subscribe permission is inferred - -- UNLESS the not_globally_subscribable flag is set - if role_in = 'subscribe' - then - if rhn_channel.org_channel_setting(channel_id_in, - org_id, - 'not_globally_subscribable') = 0 then - return NULL; - end if; - end if; - - -- all other roles (manage right now) are explicitly granted - if rhn_channel.direct_user_role_check(channel_id_in, - user_id_in, role_in) = 1 then - return NULL; - end if; - return 'direct_permission'; - end; - - -- same as above, but with 1/0 output; useful in views, etc - function user_role_check(channel_id_in in number, user_id_in in number, role_in in varchar2) - return number - is - begin - if rhn_channel.user_role_check_debug(channel_id_in, - user_id_in, role_in) is NULL then - return 1; - else - return 0; - end if; - end; - - -- - -- For multiorg phase II, this function simply checks to see if the user's - -- has a trust relationship that includes this channel by id. - -- - function shared_user_role_check(channel_id in number, user_id in number, role in varchar2) - return number - is - n number; - oid number; - begin - oid := rhn_user.get_org_id(user_id); - select 1 into n - from rhnSharedChannelView s - where s.id = channel_id and s.org_trust_id = oid; - return 1; - exception - when no_data_found then - return 0; - end; - - -- same as above, but returns 1 if user_id_in is null - -- This is useful in queries where user_id is not specified - function loose_user_role_check(channel_id_in in number, user_id_in in number, role_in in varchar2) - return number - is - begin - if user_id_in is null then - return 1; - end if; - return user_role_check(channel_id_in, user_id_in, role_in); - end loose_user_role_check; - - -- directly checks the table, no inferred permissions - function direct_user_role_check(channel_id_in in number, user_id_in in number, role_in in varchar2) - return number - is - throwaway number; - begin - -- the idea: if we get past this query, the user has the role, else catch the exception and return 0 - select 1 into throwaway - from rhnChannelPermissionRole CPR, - rhnChannelPermission CP - where CP.user_id = user_id_in - and CP.channel_id = channel_id_in - and CPR.label = role_in - and CP.role_id = CPR.id; - - return 1; - exception - when no_data_found - then - return 0; - end; - - -- check if an org has a certain setting - function org_channel_setting(channel_id_in in number, org_id_in in number, setting_in in varchar2) - return number - is - throwaway number; - begin - -- the idea: if we get past this query, the org has the setting, else catch the exception and return 0 - select 1 into throwaway - from rhnOrgChannelSettingsType OCST, - rhnOrgChannelSettings OCS - where OCS.org_id = org_id_in - and OCS.channel_id = channel_id_in - and OCST.label = setting_in - and OCS.setting_id = OCST.id; - - return 1; - exception - when no_data_found - then - return 0; - end; - - FUNCTION channel_priority(channel_id_in IN number) - RETURN number - IS - channel_name varchar2(256); - priority number; - end_of_life_val timestamp with local time zone; - org_id_val number; - BEGIN - - select name, end_of_life, org_id - into channel_name, end_of_life_val, org_id_val - from rhnChannel - where id = channel_id_in; - - if end_of_life_val is not null then - return -400; - end if; - - if channel_name like 'Red Hat Enterprise Linux%' or channel_name like 'RHEL%' then - priority := 1000; - if channel_name not like '%Beta%' then - priority := priority + 1000; - end if; - - priority := priority + - case - when channel_name like '%v. 5%' then 600 - when channel_name like '%v. 4%' then 500 - when channel_name like '%v. 3%' then 400 - when channel_name like '%v. 2%' then 300 - when channel_name like '%v. 1%' then 200 - else 0 - end; - - priority := priority + - case - when channel_name like 'Red Hat Enterprise Linux (v. 5%' then 60 - when (channel_name like '%AS%' and channel_name not like '%Extras%') then 50 - when (channel_name like '%ES%' and channel_name not like '%Extras%') then 40 - when (channel_name like '%WS%' and channel_name not like '%Extras%') then 30 - when (channel_name like '%Desktop%' and channel_name not like '%Extras%') then 20 - when channel_name like '%Extras%' then 10 - else 0 - end; - - priority := priority + - case - when channel_name like '%)' then 5 - else 0 - end; - - priority := priority + - case - when channel_name like '%32-bit x86%' then 4 - when channel_name like '%64-bit Intel Itanium%' then 3 - when channel_name like '%64-bit AMD64/Intel EM64T%' then 2 - else 0 - end; - elsif channel_name like 'Red Hat Desktop%' then - priority := 900; - - if channel_name not like '%Beta%' then - priority := priority + 50; - end if; - - priority := priority + - case - when channel_name like '%v. 4%' then 40 - when channel_name like '%v. 3%' then 30 - when channel_name like '%v. 2%' then 20 - when channel_name like '%v. 1%' then 10 - else 0 - end; - - priority := priority + - case - when channel_name like '%32-bit x86%' then 4 - when channel_name like '%64-bit Intel Itanium%' then 3 - when channel_name like '%64-bit AMD64/Intel EM64T%' then 2 - else 0 - end; - - elsif org_id_val is not null then - priority := 600; - else - priority := 500; - end if; - - return -priority; - - end channel_priority; - - -- right now this only does the accounting changes; the cascade - -- actually does the rhnServerChannel delete. - procedure delete_server_channels(server_id_in in number) - is - begin - update rhnPrivateChannelFamily - set current_members = current_members -1 - where org_id in ( - select org_id - from rhnServer - where id = server_id_in - ) - and channel_family_id in ( - select rcfm.channel_family_id - from rhnChannelFamilyMembers rcfm, - rhnServerChannel rsc - where rsc.server_id = server_id_in - and rsc.channel_id = rcfm.channel_id - and not exists ( - select 1 - from - rhnChannelFamilyVirtSubLevel cfvsl, - rhnSGTypeVirtSubLevel sgtvsl, - rhnServerEntitlementView sev, - rhnVirtualInstance vi - where - -- system is a virtual instance - vi.virtual_system_id = server_id_in - and vi.host_system_id = sev.server_id - -- system's host has a virt ent - and sev.label in ('virtualization_host', - 'virtualization_host_platform') - and sev.server_group_type_id = - sgtvsl.server_group_type_id - -- the host's virt ent grants a cf virt sub level - and sgtvsl.virt_sub_level_id = cfvsl.virt_sub_level_id - -- the cf is in that virt sub level - and cfvsl.channel_family_id = rcfm.channel_family_id - ) - ); - end; - - -- this could certainly be optimized to do updates if needs be - procedure refresh_newest_package(channel_id_in in number, - caller_in in varchar2 := '(unknown)', - package_name_id_in in number := null) - is - -- procedure refreshes rows for name_id = package_name_id_in or - -- all rows if package_name_id_in is null - begin - delete from rhnChannelNewestPackage - where channel_id = channel_id_in - and (package_name_id_in is null - or name_id = package_name_id_in); - insert into rhnChannelNewestPackage - (channel_id, name_id, evr_id, package_id, package_arch_id) - (select channel_id, - name_id, evr_id, - package_id, package_arch_id - from rhnChannelNewestPackageView - where channel_id = channel_id_in - and (package_name_id_in is null - or name_id = package_name_id_in) - ); - insert into rhnChannelNewestPackageAudit (channel_id, caller) - values (channel_id_in, caller_in); - update rhnChannel - set last_modified = greatest(current_timestamp, last_modified + interval '1' second) - where id = channel_id_in; - end; - - procedure update_channel ( channel_id_in in number, invalidate_ss in number := 0, - date_to_use in timestamp with local time zone := current_timestamp ) - is - - channel_last_modified timestamp with local time zone; - last_modified_value timestamp with local time zone; - - cursor snapshots is - select snapshot_id id - from rhnSnapshotChannel - where channel_id = channel_id_in; - - begin - - select last_modified - into channel_last_modified - from rhnChannel - where id = channel_id_in; - - last_modified_value := date_to_use; - - if last_modified_value <= channel_last_modified then - last_modified_value := last_modified_value + 1/86400; - end if; - - update rhnChannel set last_modified = last_modified_value - where id = channel_id_in; - - if invalidate_ss = 1 then - for snapshot in snapshots loop - update rhnSnapshot - set invalid = lookup_snapshot_invalid_reason('channel_modified') - where id = snapshot.id; - end loop; - end if; - - end update_channel; - - procedure update_channels_by_package ( package_id_in in number, date_to_use in timestamp with local time zone := current_timestamp ) - is - - cursor channels is - select channel_id - from rhnChannelPackage - where package_id = package_id_in - order by channel_id; - - begin - for channel in channels loop - -- we want to invalidate the snapshot assocated with the channel when we - -- do this b/c we know we've added or removed or packages - rhn_channel.update_channel ( channel.channel_id, 1, date_to_use ); - end loop; - end update_channels_by_package; - - - procedure update_channels_by_errata ( errata_id_in number, date_to_use in timestamp with local time zone := current_timestamp ) - is - - cursor channels is - select channel_id - from rhnChannelErrata - where errata_id = errata_id_in - order by channel_id; - - begin - for channel in channels loop - -- we won't invalidate snapshots, b/c just changing the errata associated with - -- a channel shouldn't invalidate snapshots - rhn_channel.update_channel ( channel.channel_id, 0, date_to_use ); - end loop; - end update_channels_by_errata; - - procedure update_needed_cache(channel_id_in in number) - is - -- update of needed cache ican be commited on a per server basis - -- b/c failure of update for a server means nothing for the other servers - begin - -- we intentionaly do a loop here instead of one huge select - -- b/c we want to break update into smaller transaction to unblock other sessions - -- querying rhnServerNeededCache - for server in ( - select sc.server_id as id - from rhnServerChannel sc - where sc.channel_id = channel_id_in - order by id asc - ) loop - rhn_server.update_needed_cache(server.id); - commit; - end loop; - end update_needed_cache; - - procedure set_comps(channel_id_in in number, path_in in varchar2, timestamp_in in varchar2) - is - begin - for row in ( - select relative_filename, last_modified - from rhnChannelComps - where channel_id = channel_id_in - ) loop - if row.relative_filename = path_in - and row.last_modified = to_date(timestamp_in, 'YYYYMMDDHH24MISS') then - return; - end if; - end loop; - delete from rhnChannelComps - where channel_id = channel_id_in; - insert into rhnChannelComps (id, channel_id, relative_filename, last_modified, created, modified) - values (sequence_nextval('rhn_channelcomps_id_seq'), channel_id_in, path_in, to_date(timestamp_in, 'YYYYMMDDHH24MISS'), current_timestamp, current_timestamp); - end set_comps; - -END rhn_channel; -/ -SHOW ERRORS diff --git a/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.postgresql b/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.postgresql deleted file mode 100644 index 03422a4..0000000 --- a/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.postgresql +++ /dev/null @@ -1,1278 +0,0 @@ --- oracle equivalent source sha1 8c6ffbfad3684c9957041813f63cfdbd2077d8cf --- --- Copyright (c) 2008--2013 Red Hat, Inc. --- --- This software is licensed to you under the GNU General Public License, --- version 2 (GPLv2). There is NO WARRANTY for this software, express or --- implied, including the implied warranties of MERCHANTABILITY or FITNESS --- FOR A PARTICULAR PURPOSE. You should have received a copy of GPLv2 --- along with this software; if not, see --- http://www.gnu.org/licenses/old-licenses/gpl-2.0.txt. --- --- Red Hat trademarks are not licensed under GPLv2. No permission is --- granted to use or replicate Red Hat trademarks that are incorporated --- in this software or its documentation. --- --- --- --- - --- create schema rhn_channel; - ---update pg_setting -update pg_settings set setting = 'rhn_channel,' || setting where name = 'search_path'; - - create or replace function obtain_read_lock(channel_family_id_in in numeric, org_id_in in numeric) - returns void as $$ - declare - read_lock timestamptz; - begin - select created into read_lock - from rhnPrivateChannelFamily - where channel_family_id = channel_family_id_in and org_id = org_id_in - for update; - end$$ language plpgsql; - - -- this "emulates" cursor server_base_subscriptions defined in oracle/rhn_channel.pks - create or replace function server_base_subscriptions(server_id_in NUMERIC) - returns boolean as $$ - begin - return exists(SELECT C.id FROM rhnChannel C, rhnServerChannel SC - WHERE C.id = SC.channel_id - AND SC.server_id = server_id_in - AND C.parent_channel IS NULL); - end$$ language plpgsql; - - -- this "emulates" cursor server_base_subscriptions defined in oracle/rhn_channel.pks - create or replace function check_server_subscription(server_id_in NUMERIC, channel_id_in NUMERIC) - returns boolean as $$ - begin - return exists(SELECT channel_id FROM rhnServerChannel WHERE server_id = server_id_in AND channel_id = channel_id_in); - end$$ language plpgsql; - - - CREATE OR REPLACE FUNCTION subscribe_server(server_id_in IN NUMERIC, channel_id_in NUMERIC, immediate_in NUMERIC default 1, user_id_in in numeric default null, recalcfamily_in NUMERIC default 1) returns void - AS $$ - declare - channel_parent_val rhnChannel.parent_channel%TYPE; - parent_subscribed BOOLEAN; - server_has_base_chan BOOLEAN; - server_already_in_chan BOOLEAN; - channel_family_id_val NUMERIC; - server_org_id_val NUMERIC; - available_subscriptions NUMERIC; - available_fve_subs numeric; - consenting_user NUMERIC; - allowed numeric; - is_fve_char char(1) := 'N'; - update_lock numeric; - BEGIN - if user_id_in is not null then - allowed := rhn_channel.user_role_check(channel_id_in, user_id_in, 'subscribe'); - else - allowed := 1; - end if; - - if allowed = 0 then - perform rhn_exception.raise_exception('no_subscribe_permissions'); - end if; - - - SELECT parent_channel INTO channel_parent_val FROM rhnChannel WHERE id = channel_id_in; - - IF channel_parent_val IS NOT NULL - THEN - -- child channel; if attempting to cross-subscribe a child to the wrong base, silently ignore - parent_subscribed := rhn_channel.check_server_subscription(server_id_in, channel_parent_val); - - IF NOT parent_subscribed - THEN - RETURN; - END IF; - ELSE - -- base channel - server_has_base_chan := rhn_channel.server_base_subscriptions(server_id_in); - - IF server_has_base_chan - THEN - perform rhn_exception.raise_exception('channel_server_one_base'); - END IF; - END IF; - - server_already_in_chan := rhn_channel.check_server_subscription(server_id_in, channel_id_in); - - IF server_already_in_chan - THEN - RETURN; - END IF; - - channel_family_id_val := rhn_channel.family_for_channel(channel_id_in); - IF channel_family_id_val IS NULL - THEN - perform rhn_exception.raise_exception('channel_subscribe_no_family'); - END IF; - - -- - -- Use the org_id of the server only if the org_id of the channel = NULL. - -- This is required for subscribing to shared channels. - -- - SELECT COALESCE(org_id, (SELECT org_id FROM rhnServer WHERE id = server_id_in)) - INTO server_org_id_val - FROM rhnChannel - WHERE id = channel_id_in; - - begin - perform rhn_channel.obtain_read_lock(channel_family_id_val, server_org_id_val); - exception - when no_data_found then - perform rhn_exception.raise_exception('channel_family_no_subscriptions'); - end; - - available_subscriptions := rhn_channel.available_family_subscriptions(channel_family_id_val, server_org_id_val); - available_fve_subs := rhn_channel.available_fve_family_subs(channel_family_id_val, server_org_id_val); - - IF available_subscriptions IS NULL OR - available_subscriptions > 0 or - rhn_channel.can_server_consume_virt_channl(server_id_in, channel_family_id_val) = 1 OR - (available_fve_subs > 0 AND rhn_channel.can_server_consume_fve(server_id_in) = 1) - THEN - if rhn_channel.can_server_consume_virt_channl(server_id_in, channel_family_id_val) = 0 AND available_fve_subs > 0 AND rhn_channel.can_server_consume_fve(server_id_in) = 1 THEN - is_fve_char := 'Y'; - end if; - - insert into rhnServerHistory (id,server_id,summary,details) ( - select nextval('rhn_event_id_seq'), - server_id_in, - 'subscribed to channel ' || SUBSTR(c.label, 0, 106), - c.label - from rhnChannel c - where c.id = channel_id_in - ); - - select 1 - into update_lock - from rhnServerNeededCache - where server_id = server_id_in - for update; - - UPDATE rhnServer SET channels_changed = current_timestamp WHERE id = server_id_in; - INSERT INTO rhnServerChannel (server_id, channel_id, is_fve) VALUES (server_id_in, channel_id_in, is_fve_char); - IF recalcfamily_in > 0 - THEN - perform rhn_channel.update_family_counts(channel_family_id_val, server_org_id_val); - END IF; - perform queue_server(server_id_in, immediate_in); - ELSE - perform rhn_exception.raise_exception('channel_family_no_subscriptions'); - END IF; - - END$$ language plpgsql; - - - - create or replace function can_convert_to_fve(server_id_in IN NUMERIC, channel_family_id_val IN NUMERIC) - RETURNS NUMERIC - as $$ - declare - fve_convertible_entries cursor for - select 1 from - rhnServerFveCapable cap - where cap.server_id = server_id_in - AND cap.channel_family_id = channel_family_id_val; - BEGIN - FOR entry IN fve_convertible_entries LOOP - return 1; - END LOOP; - RETURN 0; - END$$ language plpgsql; - - - - -- Converts server channel_family to use a flex entitlement - create or replace function convert_to_fve(server_id_in IN NUMERIC, channel_family_id_val IN NUMERIC) - returns void - as $$ - declare - available_fve_subs NUMERIC; - server_org_id_val NUMERIC; - BEGIN - - -- - -- Use the org_id of the server only if the org_id of the channel = NULL. - -- This is required for subscribing to shared channels. - -- - SELECT org_id - INTO server_org_id_val - FROM rhnServer - WHERE id = server_id_in; - - - perform rhn_channel.obtain_read_lock(channel_family_id_val, server_org_id_val); - if not found then - perform rhn_exception.raise_exception('channel_family_no_subscriptions'); - end if; - IF (rhn_channel.can_convert_to_fve(server_id_in, channel_family_id_val ) = 0) - THEN - perform rhn_exception.raise_exception('server_cannot_convert_to_flex'); - END IF; - - available_fve_subs := rhn_channel.available_fve_family_subs(channel_family_id_val, server_org_id_val); - - IF (available_fve_subs > 0) - THEN - - insert into rhnServerHistory (id,server_id,summary,details) ( - select nextval('rhn_event_id_seq'), - server_id_in, - 'converted to flex entitlement' || SUBSTR(cf.label, 0, 99), - cf.label - from rhnChannelFamily cf - where cf.id = channel_family_id_val - ); - - UPDATE rhnServerChannel sc set is_fve = 'Y' - where sc.server_id = server_id_in and - sc.channel_id in - (select cfm.channel_id from rhnChannelFamilyMembers cfm - where cfm.CHANNEL_FAMILY_ID = channel_family_id_val); - - perform rhn_channel.update_family_counts(channel_family_id_val, server_org_id_val); - ELSE - perform rhn_exception.raise_exception('not_enough_flex_entitlements'); - END IF; - - END$$ language plpgsql; - - create or replace function can_server_consume_virt_channl( - server_id_in in numeric, - family_id_in in numeric ) - returns numeric - as $$ - begin - if exists( - select 1 - from - rhnChannelFamilyVirtSubLevel cfvsl, - rhnSGTypeVirtSubLevel sgtvsl, - rhnVirtualInstance vi - where - vi.virtual_system_id = server_id_in - and sgtvsl.virt_sub_level_id = cfvsl.virt_sub_level_id - and cfvsl.channel_family_id = family_id_in - and exists ( - select 1 - from rhnServerEntitlementView sev - where vi.host_system_id = sev.server_id - and sev.server_group_type_id = sgtvsl.server_group_type_id )) - then - return 1; - else - return 0; - end if; - end$$ language plpgsql; - - create or replace function can_server_consume_fve(server_id_in in numeric) returns numeric - as $$ - declare - vi_entries cursor for - SELECT 1 - FROM rhnVirtualInstance vi - WHERE vi.virtual_system_id = server_id_in; - vi_count numeric; - - begin - FOR vi_entry IN VI_ENTRIES LOOP - return 1; - END LOOP; - RETURN 0; - end$$ language plpgsql; - - create or replace function guess_server_base( - server_id_in in numeric - ) RETURNS numeric as $$ - declare - server_cursor cursor for - select s.server_arch_id, s.release, s.org_id - from rhnServer s - where s.id = server_id_in; - -- Cursor that fetches all the possible base channels for a - -- (server_arch_id, release, org_id) combination - base_channel_cursor cursor( - release_in varchar, - server_arch_id_in numeric, - org_id_in numeric - ) for - select distinct c.* - from rhnOrgDistChannelMap odcm, - rhnServerChannelArchCompat scac, - rhnChannel c - where c.parent_channel is null - and c.id = odcm.channel_id - and c.channel_arch_id = odcm.channel_arch_id - and odcm.release = release_in - and odcm.for_org_id = org_id_in - and scac.server_arch_id = server_arch_id_in - and scac.channel_arch_id = c.channel_arch_id; - - begin - for s in server_cursor loop - for channel in base_channel_cursor(s.release, - s.server_arch_id, s.org_id) - loop - return channel.id; - end loop; - end loop; - -- Server not found, or no base channel applies to it - return null; - end$$ language plpgsql; - - -- Private function - create or replace function normalize_server_arch(server_arch_in in varchar) - returns varchar - as $$ - declare - suffix VARCHAR(128) := '-redhat-linux'; - begin - if server_arch_in is NULL then - return NULL; - end if; - if position('-' IN server_arch_in) > 0 - then - -- Suffix already present - return server_arch_in; - end if; - return server_arch_in || suffix; - end$$ language plpgsql; - - -- - -- Raises: - -- server_arch_not_found - -- no_subscribe_permissions - create or replace function base_channel_for_release_arch( - release_in in varchar, - server_arch_in in varchar, - org_id_in in numeric default -1, - user_id_in in numeric default null - ) returns numeric as $$ - declare - server_arch varchar(256) := rhn_channel.normalize_server_arch(server_arch_in); - server_arch_id numeric; - begin - -- Look up the server arch - select id - into server_arch_id - from rhnServerArch - where label = server_arch; - if not found then - perform rhn_exception.raise_exception('server_arch_not_found'); - end if; - - return rhn_channel.base_channel_rel_archid(release_in, server_arch_id, - org_id_in, user_id_in); - end$$ language plpgsql; - - create or replace function base_channel_rel_archid( - release_in in varchar, - server_arch_id_in in numeric, - org_id_in in numeric default -1, - user_id_in in numeric default null - ) returns numeric as $$ - declare - denied_channel_id numeric := null; - valid_org_id numeric := org_id_in; - valid_user_id numeric := user_id_in; - channel_subscribable numeric; - -- Cursor that fetches all the possible base channels for a - -- (server_arch_id, release, org_id) combination - base_channel_cursor cursor( - release_in varchar, - server_arch_id_in numeric, - org_id_in numeric - ) for - select distinct c.* - from rhnOrgDistChannelMap odcm, - rhnServerChannelArchCompat scac, - rhnChannel c - where c.parent_channel is null - and c.id = odcm.channel_id - and c.channel_arch_id = odcm.channel_arch_id - and odcm.release = release_in - and odcm.for_org_id = org_id_in - and scac.server_arch_id = server_arch_id_in - and scac.channel_arch_id = c.channel_arch_id; - - begin - if org_id_in = -1 and user_id_in is not null then - -- Get the org id from the user id - - select org_id - into valid_org_id - from web_contact - where id = user_id_in; - - if not found then - -- User doesn't exist - -- XXX Only list public stuff for now - valid_user_id := null; - valid_org_id := -1; - end if; - end if; - - for c in base_channel_cursor(release_in, server_arch_id_in, valid_org_id) - loop - -- This row is a possible match - if valid_user_id is null then - -- User ID not specified, so no user to channel permissions to - -- check - return c.id; - end if; - - -- Check user to channel permissions - select rhn_channel.loose_user_role_check(c.id, user_id_in, 'subscribe') - into channel_subscribable; - - if channel_subscribable = 1 then - return c.id; - end if; - - -- Base channel exists, but is not subscribable; keep trying - denied_channel_id := c.id; - end loop; - - if denied_channel_id is not null then - perform rhn_exception.raise_exception('no_subscribe_permissions'); - end if; - -- No base channel applies - return NULL; - end$$ language plpgsql; - - CREATE OR REPLACE FUNCTION clear_subscriptions(server_id_in IN NUMERIC, deleting_server IN NUMERIC default 0, - update_family_countsYN IN NUMERIC default 1 ) returns void - AS $$ - declare - server_channels cursor(server_id_in numeric) for - select s.org_id, sc.channel_id, cfm.channel_family_id - from rhnServer s, - rhnServerChannel sc, - rhnChannelFamilyMembers cfm - where s.id = server_id_in - and s.id = sc.server_id - and sc.channel_id = cfm.channel_id - order by cfm.channel_family_id; - last_channel_family_id rhnChannelFamilyMembers.channel_family_id%type := -1; - last_channel_org_id rhnServer.org_id%type := -1; - BEGIN - for channel in server_channels(server_id_in) - loop - perform rhn_channel.unsubscribe_server(server_id_in, channel.channel_id, 1, 1, deleting_server, 0); - if update_family_countsYN > 0 - and channel.channel_family_id != last_channel_family_id then - -- update family counts only once - -- after all channels with same family has been fetched - if last_channel_family_id != -1 then - perform rhn_channel.update_family_counts(channel.channel_family_id, channel.org_id); - end if; - last_channel_family_id := channel.channel_family_id; - last_channel_org_id := channel.org_id; - end if; - end loop; - if update_family_countsYN > 0 and last_channel_family_id != -1 then - -- update the last family fetched - perform rhn_channel.update_family_counts(last_channel_family_id, last_channel_org_id); - end if; - END$$ language plpgsql; - - CREATE OR REPLACE FUNCTION unsubscribe_server(server_id_in IN NUMERIC, channel_id_in NUMERIC, immediate_in NUMERIC default 1, unsubscribe_children_in numeric default 0, - deleting_server in numeric default 0, - update_family_countsYN in numeric default 1) returns void - AS $$ - declare - channel_family_id_val NUMERIC; - server_org_id_val NUMERIC; - available_subscriptions NUMERIC; - server_already_in_chan BOOLEAN; - update_lock numeric; - channel_family_is_proxy cursor(channel_family_id_in numeric) for - select 1 - from rhnChannelFamily - where id = channel_family_id_in - and label = 'rhn-proxy'; - channel_family_is_satellite cursor(channel_family_id_in numeric) for - select 1 - from rhnChannelFamily - where id = channel_family_id_in - and label = 'rhn-satellite'; - child record; - BEGIN - -- In PostgreSQL recursion with opened cursors is not allowed so we use - -- FOR IN SELECT form which is ok. - FOR child IN select c.id - from rhnChannel c, - rhnServerChannel sc - where 1=1 - and c.parent_channel = channel_id_in - and c.id = sc.channel_id - and sc.server_id = server_id_in - LOOP - if unsubscribe_children_in = 1 then - perform rhn_channel.unsubscribe_server(server_id_in, - child.id, - immediate_in, - unsubscribe_children_in, - deleting_server, - update_family_countsYN); - else - perform rhn_exception.raise_exception('channel_unsubscribe_child_exists'); - end if; - END LOOP; - - server_already_in_chan := rhn_channel.check_server_subscription(server_id_in, channel_id_in); - - IF NOT server_already_in_chan - THEN - RETURN; - END IF; - - if deleting_server = 0 then - - insert into rhnServerHistory (id,server_id,summary,details) ( - select nextval('rhn_event_id_seq'), - server_id_in, - 'unsubscribed from channel ' || SUBSTR(c.label, 0, 106), - c.label - from rhnChannel c - where c.id = channel_id_in - ); - - select 1 - into update_lock - from rhnServerNeededCache - where server_id = server_id_in - for update; - - UPDATE rhnServer SET channels_changed = current_timestamp WHERE id = server_id_in; - end if; - - DELETE FROM rhnServerChannel WHERE server_id = server_id_in AND channel_id = channel_id_in; - - if deleting_server = 0 then - perform queue_server(server_id_in, immediate_in); - end if; - - channel_family_id_val := rhn_channel.family_for_channel(channel_id_in); - IF channel_family_id_val IS NULL - THEN - perform rhn_exception.raise_exception('channel_unsubscribe_no_family'); - END IF; - - for ignore in channel_family_is_satellite(channel_family_id_val) loop - delete from rhnSatelliteInfo where server_id = server_id_in; - end loop; - - for ignore in channel_family_is_proxy(channel_family_id_val) loop - delete from rhnProxyInfo where server_id = server_id_in; - end loop; - SELECT org_id INTO server_org_id_val - FROM rhnServer - WHERE id = server_id_in; - - if update_family_countsYN = 1 then - perform rhn_channel.update_family_counts(channel_family_id_val, server_org_id_val); - end if; - END$$ language plpgsql; - - CREATE OR REPLACE FUNCTION family_for_channel(channel_id_in IN NUMERIC) - RETURNS NUMERIC - AS $$ - declare - channel_family_id_val NUMERIC; - BEGIN - SELECT channel_family_id INTO channel_family_id_val - FROM rhnChannelFamilyMembers - WHERE channel_id = channel_id_in; - - IF NOT FOUND THEN - RETURN NULL; - END IF; - - RETURN channel_family_id_val; - END$$ language plpgsql; - - CREATE OR REPLACE FUNCTION available_family_subscriptions(channel_family_id_in IN NUMERIC, org_id_in IN NUMERIC) - RETURNS NUMERIC - AS $$ - declare - cfp record; - current_members_val NUMERIC; - max_members_val NUMERIC; - found NUMERIC; - BEGIN - for cfp in SELECT * FROM rhnOrgChannelFamilyPermissions - WHERE channel_family_id = channel_family_id_in - AND org_id = org_id_in - LOOP - found := 1; - current_members_val := cfp.current_members; - max_members_val := cfp.max_members; - END LOOP; - - -- not found: either the channel fam doesn't have an entry in cfp, or the org doesn't have access to it. - -- either way, there are no available subscriptions - - IF found IS NULL - THEN - RETURN 0; - END IF; - - -- null max members? in that case, pass it on; NULL means infinite - IF max_members_val IS NULL - THEN - RETURN NULL; - END IF; - - -- otherwise, return the delta - RETURN max_members_val - current_members_val; - END$$ language plpgsql; - - CREATE OR REPLACE FUNCTION available_fve_family_subs(channel_family_id_in IN NUMERIC, org_id_in IN NUMERIC) - RETURNS NUMERIC - AS $$ - declare - cfp record; - fve_current_members_val NUMERIC; - fve_max_members_val NUMERIC; - found NUMERIC; - BEGIN - for cfp in SELECT * FROM rhnOrgChannelFamilyPermissions - WHERE channel_family_id = channel_family_id_in - AND org_id = org_id_in - LOOP - found := 1; - fve_current_members_val := cfp.fve_current_members; - fve_max_members_val := cfp.fve_max_members; - END LOOP; - - -- not found: either the channel fam doesn't have an entry in cfp, or the org doesn't have access to it. - -- either way, there are no available subscriptions - - IF found IS NULL - THEN - RETURN 0; - END IF; - - -- null max members? in that case, pass it on; NULL means infinite - IF fve_max_members_val IS NULL - THEN - RETURN NULL; - END IF; - - -- otherwise, return the delta - RETURN fve_max_members_val - fve_current_members_val; - END$$ language plpgsql; - - -- ******************************************************************* - -- FUNCTION: channel_family_current_members - -- Calculates and returns the actual count of systems consuming - -- physical channel subscriptions. - -- Called by: update_family_counts - -- rhn_entitlements.repoll_virt_guest_entitlements - -- ******************************************************************* - create or replace function channel_family_current_members(channel_family_id_in IN NUMERIC, - org_id_in IN NUMERIC) - returns numeric - as $$ - declare - current_members_count numeric := 0; - begin - select count(distinct server_id) - into current_members_count - from rhnChannelFamilyServerPhysical cfsp - where cfsp.channel_family_id = channel_family_id_in - and cfsp.customer_id = org_id_in; - return current_members_count; - end$$ language plpgsql; - - - create or replace function cfam_curr_fve_members( - channel_family_id_in IN NUMERIC, - org_id_in IN NUMERIC) - returns numeric - as $$ - declare - current_members_count numeric := 0; - - begin - select count(sc.server_id) - into current_members_count - from rhnServerChannel sc, - rhnChannelFamilyMembers cfm, - rhnServer s - where s.org_id = org_id_in - and s.id = sc.server_id - and cfm.channel_family_id = channel_family_id_in - and cfm.channel_id = sc.channel_id - and exists ( - select 1 - from rhnChannelFamilyServerFve cfsp - where cfsp.CHANNEL_FAMILY_ID = channel_family_id_in - and cfsp.server_id = s.id - ); - - return current_members_count; - end$$ language plpgsql; - CREATE OR REPLACE FUNCTION update_family_counts(channel_family_id_in IN NUMERIC, - org_id_in IN NUMERIC) returns void - AS $$ - BEGIN - update rhnPrivateChannelFamily - set current_members = rhn_channel.channel_family_current_members(channel_family_id_in, org_id_in), - fve_current_members = rhn_channel.cfam_curr_fve_members(channel_family_id_in,org_id_in) - where org_id = org_id_in - and channel_family_id = channel_family_id_in; - END$$ language plpgsql; - - create or replace function update_group_family_counts(group_label_in IN VARCHAR, - org_id_in IN NUMERIC) - returns void - as $$ - declare - i record; - BEGIN - FOR i IN ( - SELECT DISTINCT CFM.channel_family_id, SG.org_id - FROM rhnChannelFamilyMembers CFM - JOIN rhnServerChannel SC - ON SC.channel_id = CFM.channel_id - JOIN rhnServerGroupMembers SGM - ON SC.server_id = SGM.server_id - JOIN rhnServerGroup SG - ON SGM.server_group_id = SG.id - JOIN rhnServerGroupType SGT - ON SG.group_type = SGT.id - WHERE SGT.label = group_label_in - AND SG.org_id = org_id_in - AND SGT.is_base = 'Y' - ) LOOP - perform rhn_channel.update_family_counts(i.channel_family_id, i.org_id); - END LOOP; - END$$ language plpgsql; - - CREATE OR REPLACE FUNCTION available_chan_subscriptions(channel_id_in IN NUMERIC, - org_id_in IN NUMERIC) - RETURNS NUMERIC - AS $$ - declare - channel_family_id_val NUMERIC; - BEGIN - SELECT channel_family_id INTO STRICT channel_family_id_val - FROM rhnChannelFamilyMembers - WHERE channel_id = channel_id_in; - - RETURN rhn_channel.available_family_subscriptions( - channel_family_id_val, org_id_in); - END$$ language plpgsql; - - CREATE OR REPLACE FUNCTION available_fve_chan_subs(channel_id_in IN NUMERIC, - org_id_in IN NUMERIC) - RETURNS NUMERIC - AS $$ - declare - channel_family_id_val NUMERIC; - BEGIN - SELECT channel_family_id INTO STRICT channel_family_id_val - FROM rhnChannelFamilyMembers - WHERE channel_id = channel_id_in; - - RETURN rhn_channel.available_fve_family_subs( - channel_family_id_val, org_id_in); - END$$ language plpgsql; - - create or replace function unsubscribe_server_from_family(server_id_in in numeric, - channel_family_id_in in numeric) - returns void - as $$ - begin - delete - from rhnServerChannel rsc - where rsc.server_id = server_id_in - and channel_id in ( - select rcfm.channel_id - from rhnChannelFamilyMembers rcfm - where rcfm.channel_family_id = channel_family_id_in); - end$$ language plpgsql; - - create or replace function get_org_id(channel_id_in in numeric) - returns numeric - as $$ - declare - org_id_out numeric; - begin - select org_id into strict org_id_out - from rhnChannel - where id = channel_id_in; - - return org_id_out; - end$$ language plpgsql; - - create or replace function get_cfam_org_access(cfam_id_in in numeric, org_id_in in numeric) - returns numeric - as $$ - begin - if exists( - select 1 - from rhnOrgChannelFamilyPermissions cfp - where cfp.org_id = org_id_in - ) then - return 1; - else - return 0; - end if; - end$$ language plpgsql; - - create or replace function get_org_access(channel_id_in in numeric, org_id_in in numeric) - returns integer - as $$ - begin - -- the idea: if we get past this query, - -- the org has access to the channel, else not - if exists( - select 1 - from rhnChannelFamilyMembers CFM, - rhnOrgChannelFamilyPermissions CFP - where cfp.org_id = org_id_in - and CFM.channel_family_id = CFP.channel_family_id - and CFM.channel_id = channel_id_in - and (CFP.max_members > 0 or CFP.max_members is null or CFP.fve_max_members > 0 or CFP.fve_max_members is null or CFP.org_id = 1) ) - then - return 1; - else - return 0; - end if; - end$$ language plpgsql; - - -- check if a user has a given role, or if such a role is inferrable - -- returns NULL if OK, error message otherwise - create or replace function user_role_check_debug(channel_id_in in numeric, - user_id_in in numeric, - role_in in varchar) - returns varchar - as $$ - declare - org_id numeric; - begin - org_id := rhn_user.get_org_id(user_id_in); - - -- channel might be shared - if role_in = 'subscribe' and - rhn_channel.shared_user_role_check(channel_id_in, user_id_in, role_in) = 1 then - return NULL; - end if; - - if role_in = 'manage' and - COALESCE(rhn_channel.get_org_id(channel_id_in), -1) <> org_id then - return 'channel_not_owned'; - end if; - - if role_in = 'subscribe' and - rhn_channel.get_org_access(channel_id_in, org_id) = 0 then - return 'channel_not_available'; - end if; - - -- channel admins have all roles - if rhn_user.check_role_implied(user_id_in, 'channel_admin') = 1 then - return NULL; - end if; - - -- the subscribe permission is inferred - -- UNLESS the not_globally_subscribable flag is set - if role_in = 'subscribe' - then - if rhn_channel.org_channel_setting(channel_id_in, - org_id, - 'not_globally_subscribable') = 0 then - return NULL; - end if; - end if; - - -- all other roles (manage right now) are explicitly granted - if rhn_channel.direct_user_role_check(channel_id_in, - user_id_in, role_in) = 1 then - return NULL; - end if; - return 'direct_permission'; - end$$ language plpgsql; - - -- same as above, but with 1/0 output; useful in views, etc - create or replace function user_role_check(channel_id_in in numeric, user_id_in in numeric, role_in in varchar) - returns numeric - as $$ - begin - if rhn_channel.user_role_check_debug(channel_id_in, - user_id_in, role_in) is NULL then - return 1; - else - return 0; - end if; - end$$ language plpgsql; - - -- - -- For multiorg phase II, this function simply checks to see if the user's - -- has a trust relationship that includes this channel by id. - -- - create or replace function shared_user_role_check(channel_id in numeric, user_id in numeric, role in varchar) - returns numeric - as $$ - declare - n numeric; - oid numeric; - begin - oid := rhn_user.get_org_id(user_id); - select 1 into n - from rhnSharedChannelView s - where s.id = channel_id and s.org_trust_id = oid; - - if not found then - return 0; - end if; - - return 1; - end$$ language plpgsql; - - -- same as above, but returns 1 if user_id_in is null - -- This is useful in queries where user_id is not specified - create or replace function loose_user_role_check(channel_id_in in numeric, user_id_in in numeric, role_in in varchar) - returns numeric - as $$ - begin - if user_id_in is null then - return 1; - end if; - return rhn_channel.user_role_check(channel_id_in, user_id_in, role_in); - end$$ language plpgsql; - - -- directly checks the table, no inferred permissions - create or replace function direct_user_role_check(channel_id_in in numeric, user_id_in in numeric, role_in in varchar) - returns numeric - as $$ - declare - throwaway numeric; - begin - -- the idea: if we get past this query, the user has the role, else no - select 1 into throwaway - from rhnChannelPermissionRole CPR, - rhnChannelPermission CP - where CP.user_id = user_id_in - and CP.channel_id = channel_id_in - and CPR.label = role_in - and CP.role_id = CPR.id; - - if not found then - return 0; - end if; - - return 1; - end$$ language plpgsql; - - -- check if an org has a certain setting - create or replace function org_channel_setting(channel_id_in in numeric, org_id_in in numeric, setting_in in varchar) - returns numeric - as $$ - declare - throwaway numeric; - begin - -- the idea: if we get past this query, the org has the setting - select 1 into throwaway - from rhnOrgChannelSettingsType OCST, - rhnOrgChannelSettings OCS - where OCS.org_id = org_id_in - and OCS.channel_id = channel_id_in - and OCST.label = setting_in - and OCS.setting_id = OCST.id; - - if not found then - return 0; - end if; - - return 1; - end$$ language plpgsql; - - CREATE OR REPLACE FUNCTION channel_priority(channel_id_in IN numeric) - RETURNS numeric - AS $$ - declare - channel_name varchar(256); - priority numeric; - end_of_life_val timestamptz; - org_id_val numeric; - BEGIN - - select name, end_of_life, org_id - into channel_name, end_of_life_val, org_id_val - from rhnChannel - where id = channel_id_in; - - if end_of_life_val is not null then - return -400; - end if; - - if channel_name like 'Red Hat Enterprise Linux%' or channel_name like 'RHEL%' then - priority := 1000; - if channel_name not like '%Beta%' then - priority := priority + 1000; - end if; - - priority := priority + - case - when channel_name like '%v. 5%' then 600 - when channel_name like '%v. 4%' then 500 - when channel_name like '%v. 3%' then 400 - when channel_name like '%v. 2%' then 300 - when channel_name like '%v. 1%' then 200 - else 0 - end; - - priority := priority + - case - when channel_name like 'Red Hat Enterprise Linux (v. 5%' then 60 - when (channel_name like '%AS%' and channel_name not like '%Extras%') then 50 - when (channel_name like '%ES%' and channel_name not like '%Extras%') then 40 - when (channel_name like '%WS%' and channel_name not like '%Extras%') then 30 - when (channel_name like '%Desktop%' and channel_name not like '%Extras%') then 20 - when channel_name like '%Extras%' then 10 - else 0 - end; - - priority := priority + - case - when channel_name like '%)' then 5 - else 0 - end; - - priority := priority + - case - when channel_name like '%32-bit x86%' then 4 - when channel_name like '%64-bit Intel Itanium%' then 3 - when channel_name like '%64-bit AMD64/Intel EM64T%' then 2 - else 0 - end; - elsif channel_name like 'Red Hat Desktop%' then - priority := 900; - - if channel_name not like '%Beta%' then - priority := priority + 50; - end if; - - priority := priority + - case - when channel_name like '%v. 4%' then 40 - when channel_name like '%v. 3%' then 30 - when channel_name like '%v. 2%' then 20 - when channel_name like '%v. 1%' then 10 - else 0 - end; - - priority := priority + - case - when channel_name like '%32-bit x86%' then 4 - when channel_name like '%64-bit Intel Itanium%' then 3 - when channel_name like '%64-bit AMD64/Intel EM64T%' then 2 - else 0 - end; - - elsif org_id_val is not null then - priority := 600; - else - priority := 500; - end if; - - return -priority; - - end$$ language plpgsql; - - -- right now this only does the accounting changes; the cascade - -- actually does the rhnServerChannel delete. - create or replace function delete_server_channels(server_id_in in numeric) returns void - as $$ - begin - update rhnPrivateChannelFamily - set current_members = current_members -1 - where org_id in ( - select org_id - from rhnServer - where id = server_id_in - ) - and channel_family_id in ( - select rcfm.channel_family_id - from rhnChannelFamilyMembers rcfm, - rhnServerChannel rsc - where rsc.server_id = server_id_in - and rsc.channel_id = rcfm.channel_id - and not exists ( - select 1 - from - rhnChannelFamilyVirtSubLevel cfvsl, - rhnSGTypeVirtSubLevel sgtvsl, - rhnServerEntitlementView sev, - rhnVirtualInstance vi - where - -- system is a virtual instance - vi.virtual_system_id = server_id_in - and vi.host_system_id = sev.server_id - -- system's host has a virt ent - and sev.label in ('virtualization_host', - 'virtualization_host_platform') - and sev.server_group_type_id = - sgtvsl.server_group_type_id - -- the host's virt ent grants a cf virt sub level - and sgtvsl.virt_sub_level_id = cfvsl.virt_sub_level_id - -- the cf is in that virt sub level - and cfvsl.channel_family_id = rcfm.channel_family_id - ) - ); - end$$ language plpgsql; - - -- this could certainly be optimized to do updates if needs be - create or replace function refresh_newest_package(channel_id_in in numeric, - caller_in in varchar default '(unknown)', - package_name_id_in in numeric default null) - returns void - as $$ - -- procedure refreshes rows for name_id = package_name_id_in or - -- all rows if package_name_id_in is null - begin - delete from rhnChannelNewestPackage - where channel_id = channel_id_in - and (package_name_id_in is null - or name_id = package_name_id_in); - insert into rhnChannelNewestPackage - (channel_id, name_id, evr_id, package_id, package_arch_id) - (select channel_id, - name_id, evr_id, - package_id, package_arch_id - from rhnChannelNewestPackageView - where channel_id = channel_id_in - and (package_name_id_in is null - or name_id = package_name_id_in) - ); - insert into rhnChannelNewestPackageAudit (channel_id, caller) - values (channel_id_in, caller_in); - update rhnChannel - set last_modified = greatest(current_timestamp, - last_modified + interval '1 second') - where id = channel_id_in; - end$$ language plpgsql; - - create or replace function update_channel ( channel_id_in in numeric, invalidate_ss in numeric default 0, - date_to_use in timestamptz default current_timestamp ) returns void - as $$ - declare - channel_last_modified timestamptz; - last_modified_value timestamptz; - - snapshots cursor for - select snapshot_id id - from rhnSnapshotChannel - where channel_id = channel_id_in; - - begin - - select last_modified - into channel_last_modified - from rhnChannel - where id = channel_id_in; - - last_modified_value := date_to_use; - - if last_modified_value <= channel_last_modified then - last_modified_value := last_modified_value + interval '1 second'; - end if; - - update rhnChannel set last_modified = last_modified_value - where id = channel_id_in; - - if invalidate_ss = 1 then - for snapshot in snapshots loop - update rhnSnapshot - set invalid = lookup_snapshot_invalid_reason('channel_modified') - where id = snapshot.id; - end loop; - end if; - - end$$ language plpgsql; - - create or replace function update_channels_by_package ( package_id_in in numeric, date_to_use in timestamptz default current_timestamp ) returns void - as $$ - declare - channels cursor for - select channel_id - from rhnChannelPackage - where package_id = package_id_in - order by channel_id; - - begin - for channel in channels loop - -- we want to invalidate the snapshot assocated with the channel when we - -- do this b/c we know we've added or removed or packages - perform rhn_channel.update_channel ( channel.channel_id, 1, date_to_use ); - end loop; - end$$ language plpgsql; - - - create or replace function update_channels_by_errata ( errata_id_in numeric, date_to_use in timestamptz default current_timestamp ) returns void - as $$ - declare - channels cursor for - select channel_id - from rhnChannelErrata - where errata_id = errata_id_in - order by channel_id; - - begin - for channel in channels loop - -- we won't invalidate snapshots, b/c just changing the errata associated with - -- a channel shouldn't invalidate snapshots - perform rhn_channel.update_channel ( channel.channel_id, 0, date_to_use ); - end loop; - end$$ language plpgsql; - - create or replace function update_needed_cache(channel_id_in in numeric) returns void - as $$ - declare - server record; - begin - -- we intentionaly do a loop here instead of one huge select - -- b/c we want to break update into smaller transaction to unblock other sessions - -- querying rhnServerNeededCache - for server in ( - select sc.server_id as id - from rhnServerChannel sc - where sc.channel_id = channel_id_in - order by id asc - ) loop - perform rhn_server.update_needed_cache(server.id); - end loop; - end$$ language plpgsql; - - create or replace function set_comps(channel_id_in in numeric, path_in in varchar, timestamp_in in varchar) returns void - as $$ - declare - row record; - begin - for row in ( - select relative_filename, last_modified - from rhnChannelComps - where channel_id = channel_id_in - ) loop - if row.relative_filename = path_in - and row.last_modified = to_timestamp(timestamp_in, 'YYYYMMDDHH24MISS') then - return; - end if; - end loop; - delete from rhnChannelComps - where channel_id = channel_id_in; - insert into rhnChannelComps (id, channel_id, relative_filename, last_modified, created, modified) - values (sequence_nextval('rhn_channelcomps_id_seq'), channel_id_in, path_in, to_timestamp(timestamp_in, 'YYYYMMDDHH24MISS'), current_timestamp, current_timestamp); - end$$ language plpgsql; - --- restore the original setting -update pg_settings set setting = overlay( setting placing '' from 1 for (length('rhn_channel')+1) ) where name = 'search_path'; diff --git a/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.oracle b/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.oracle new file mode 100644 index 0000000..477e8b0 --- /dev/null +++ b/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.oracle @@ -0,0 +1,1259 @@ +-- +-- Copyright (c) 2008--2013 Red Hat, Inc. +-- +-- This software is licensed to you under the GNU General Public License, +-- version 2 (GPLv2). There is NO WARRANTY for this software, express or +-- implied, including the implied warranties of MERCHANTABILITY or FITNESS +-- FOR A PARTICULAR PURPOSE. You should have received a copy of GPLv2 +-- along with this software; if not, see +-- http://www.gnu.org/licenses/old-licenses/gpl-2.0.txt. +-- +-- Red Hat trademarks are not licensed under GPLv2. No permission is +-- granted to use or replicate Red Hat trademarks that are incorporated +-- in this software or its documentation. +-- + +CREATE OR REPLACE +PACKAGE BODY rhn_channel +IS + body_version varchar2(100) := ''; + + -- Cursor that fetches all the possible base channels for a + -- (server_arch_id, release, org_id) combination + cursor base_channel_cursor( + release_in in varchar2, + server_arch_id_in in number, + org_id_in in number + ) return rhnChannel%ROWTYPE is + select distinct c.* + from rhnOrgDistChannelMap odcm, + rhnServerChannelArchCompat scac, + rhnChannel c + where c.parent_channel is null + and c.id = odcm.channel_id + and c.channel_arch_id = odcm.channel_arch_id + and odcm.release = release_in + and odcm.for_org_id = org_id_in + and scac.server_arch_id = server_arch_id_in + and scac.channel_arch_id = c.channel_arch_id; + + procedure obtain_read_lock(channel_family_id_in in number, org_id_in in number) + is + read_lock timestamp with local time zone; + + begin + select created into read_lock + from rhnPrivateChannelFamily + where channel_family_id = channel_family_id_in and org_id = org_id_in + for update; + end obtain_read_lock; + + PROCEDURE subscribe_server(server_id_in IN NUMBER, channel_id_in NUMBER, immediate_in NUMBER := 1, user_id_in in number := null, recalcfamily_in number := 1) + IS + channel_parent_val rhnChannel.parent_channel%TYPE; + parent_subscribed BOOLEAN; + server_has_base_chan BOOLEAN; + server_already_in_chan BOOLEAN; + channel_family_id_val NUMBER; + server_org_id_val NUMBER; + available_subscriptions NUMBER; + available_fve_subs NUMBER; + consenting_user NUMBER; + allowed number := 0; + is_fve CHAR(1) := 'N'; + update_lock number; + BEGIN + if user_id_in is not null then + allowed := rhn_channel.user_role_check(channel_id_in, user_id_in, 'subscribe'); + else + allowed := 1; + end if; + + if allowed = 0 then + rhn_exception.raise_exception('no_subscribe_permissions'); + end if; + + + SELECT parent_channel INTO channel_parent_val FROM rhnChannel WHERE id = channel_id_in; + + IF channel_parent_val IS NOT NULL + THEN + -- child channel; if attempting to cross-subscribe a child to the wrong base, silently ignore + parent_subscribed := FALSE; + + FOR check_subscription IN check_server_subscription(server_id_in, channel_parent_val) + LOOP + parent_subscribed := TRUE; + END LOOP check_subscription; + + IF NOT parent_subscribed + THEN + RETURN; + END IF; + ELSE + -- base channel + server_has_base_chan := FALSE; + FOR base IN server_base_subscriptions(server_id_in) + LOOP + server_has_base_chan := TRUE; + END LOOP base; + + IF server_has_base_chan + THEN + rhn_exception.raise_exception('channel_server_one_base'); + END IF; + END IF; + + FOR check_subscription IN check_server_subscription(server_id_in, channel_id_in) + LOOP + server_already_in_chan := TRUE; + END LOOP check_subscription; + + IF server_already_in_chan + THEN + RETURN; + END IF; + + channel_family_id_val := rhn_channel.family_for_channel(channel_id_in); + IF channel_family_id_val IS NULL + THEN + rhn_exception.raise_exception('channel_subscribe_no_family'); + END IF; + + -- + -- Use the org_id of the server only if the org_id of the channel = NULL. + -- This is required for subscribing to shared channels. + -- + SELECT NVL(org_id, (SELECT org_id FROM rhnServer WHERE id = server_id_in)) + INTO server_org_id_val + FROM rhnChannel + WHERE id = channel_id_in; + + begin + obtain_read_lock(channel_family_id_val, server_org_id_val); + exception + when no_data_found then + rhn_exception.raise_exception('channel_family_no_subscriptions'); + end; + + available_subscriptions := rhn_channel.available_family_subscriptions(channel_family_id_val, server_org_id_val); + available_fve_subs := rhn_channel.available_fve_family_subs(channel_family_id_val, server_org_id_val); + + IF available_subscriptions IS NULL OR + available_subscriptions > 0 or + can_server_consume_virt_channl(server_id_in, channel_family_id_val) = 1 OR + (available_fve_subs > 0 AND can_server_consume_fve(server_id_in) = 1) + THEN + if can_server_consume_virt_channl(server_id_in, channel_family_id_val) = 0 AND available_fve_subs > 0 AND can_server_consume_fve(server_id_in) = 1 THEN + is_fve := 'Y'; + END IF; + insert into rhnServerHistory (id,server_id,summary,details) ( + select rhn_event_id_seq.nextval, + server_id_in, + 'subscribed to channel ' || SUBSTR(c.label, 0, 106), + c.label + from rhnChannel c + where c.id = channel_id_in + ); + + begin + select 1 + into update_lock + from rhnServerNeededCache + where server_id = server_id_in + for update; + exception WHEN no_data_found THEN + null; + end; + + UPDATE rhnServer SET channels_changed = current_timestamp WHERE id = server_id_in; + INSERT INTO rhnServerChannel (server_id, channel_id, is_fve) VALUES (server_id_in, channel_id_in, is_fve); + IF recalcfamily_in > 0 + THEN + rhn_channel.update_family_counts(channel_family_id_val, server_org_id_val); + END IF; + queue_server(server_id_in, immediate_in); + ELSE + rhn_exception.raise_exception('channel_family_no_subscriptions'); + END IF; + + END subscribe_server; + + + + FUNCTION can_convert_to_fve(server_id_in IN NUMBER, channel_family_id_val IN NUMBER) + RETURN NUMBER + IS + CURSOR fve_convertible_entries IS + select 1 from + rhnServerFveCapable cap + where cap.server_id = server_id_in + AND cap.channel_family_id = channel_family_id_val; + BEGIN + FOR entry IN fve_convertible_entries LOOP + return 1; + END LOOP; + RETURN 0; + END can_convert_to_fve; + + + + -- Converts server channel_family to use a flex entitlement + PROCEDURE convert_to_fve(server_id_in IN NUMBER, channel_family_id_val IN NUMBER) + IS + available_fve_subs NUMBER; + server_org_id_val NUMBER; + BEGIN + + -- + -- Use the org_id of the server only if the org_id of the channel = NULL. + -- This is required for subscribing to shared channels. + -- + SELECT org_id + INTO server_org_id_val + FROM rhnServer + WHERE id = server_id_in; + + begin + obtain_read_lock(channel_family_id_val, server_org_id_val); + exception + when no_data_found then + rhn_exception.raise_exception('channel_family_no_subscriptions'); + end; + IF (can_convert_to_fve(server_id_in, channel_family_id_val ) = 0) + THEN + rhn_exception.raise_exception('server_cannot_convert_to_flex'); + END IF; + + available_fve_subs := rhn_channel.available_fve_family_subs(channel_family_id_val, server_org_id_val); + + IF (available_fve_subs > 0) + THEN + + insert into rhnServerHistory (id,server_id,summary,details) ( + select rhn_event_id_seq.nextval, + server_id_in, + 'converted to flex entitlement' || SUBSTR(cf.label, 0, 99), + cf.label + from rhnChannelFamily cf + where cf.id = channel_family_id_val + ); + + UPDATE rhnServerChannel sc set sc.is_fve = 'Y' + where sc.server_id = server_id_in and + sc.channel_id in + (select cfm.channel_id from rhnChannelFamilyMembers cfm + where cfm.CHANNEL_FAMILY_ID = channel_family_id_val); + + rhn_channel.update_family_counts(channel_family_id_val, server_org_id_val); + ELSE + rhn_exception.raise_exception('not_enough_flex_entitlements'); + END IF; + + END convert_to_fve; + + function can_server_consume_virt_channl( + server_id_in in number, + family_id_in in number ) + return number + is + + cursor server_virt_families is + select vi.virtual_system_id, cfvsl.channel_family_id + from + rhnChannelFamilyVirtSubLevel cfvsl, + rhnSGTypeVirtSubLevel sgtvsl, + rhnVirtualInstance vi + where + vi.virtual_system_id = server_id_in + and sgtvsl.virt_sub_level_id = cfvsl.virt_sub_level_id + and cfvsl.channel_family_id = family_id_in + and exists ( + select 1 + from rhnServerEntitlementView sev + where vi.host_system_id = sev.server_id + and sev.server_group_type_id = sgtvsl.server_group_type_id ); + begin + + for server_virt_family in server_virt_families loop + return 1; + end loop; + + return 0; + + end; + + FUNCTION can_server_consume_fve(server_id_in IN NUMBER) + RETURN NUMBER + IS + CURSOR vi_entries IS + SELECT 1 + FROM rhnVirtualInstance vi + WHERE vi.virtual_system_id = server_id_in; + vi_count NUMBER; + + BEGIN + FOR vi_entry IN VI_ENTRIES LOOP + return 1; + END LOOP; + RETURN 0; + END; + + function guess_server_base( + server_id_in in number + ) RETURN number is + cursor server_cursor is + select s.server_arch_id, s.release, s.org_id + from rhnServer s + where s.id = server_id_in; + begin + for s in server_cursor loop + for channel in base_channel_cursor(s.release, + s.server_arch_id, s.org_id) + loop + return channel.id; + end loop base_channel_cursor; + end loop server_cursor; + -- Server not found, or no base channel applies to it + return null; + end; + + -- Private function + function normalize_server_arch(server_arch_in in varchar2) + return varchar2 + deterministic + is + suffix VARCHAR2(128) := '-redhat-linux'; + suffix_len NUMBER := length(suffix); + begin + if server_arch_in is NULL then + return NULL; + end if; + if instr(server_arch_in, '-') > 0 + then + -- Suffix already present + return server_arch_in; + end if; + return server_arch_in || suffix; + end normalize_server_arch; + + -- + -- + -- Raises: + -- server_arch_not_found + -- no_subscribe_permissions + function base_channel_for_release_arch( + release_in in varchar2, + server_arch_in in varchar2, + org_id_in in number := -1, + user_id_in in number := null + ) return number is + server_arch varchar2(256) := normalize_server_arch(server_arch_in); + server_arch_id number; + begin + -- Look up the server arch + begin + select id + into server_arch_id + from rhnServerArch + where label = server_arch; + exception + when no_data_found then + rhn_exception.raise_exception('server_arch_not_found'); + end; + return base_channel_rel_archid(release_in, server_arch_id, + org_id_in, user_id_in); + end base_channel_for_release_arch; + + function base_channel_rel_archid( + release_in in varchar2, + server_arch_id_in in number, + org_id_in in number := -1, + user_id_in in number := null + ) return number is + denied_channel_id number := null; + valid_org_id number := org_id_in; + valid_user_id number := user_id_in; + channel_subscribable number; + begin + if org_id_in = -1 and user_id_in is not null then + -- Get the org id from the user id + begin + select org_id + into valid_org_id + from web_contact + where id = user_id_in; + exception + when no_data_found then + -- User doesn't exist + -- XXX Only list public stuff for now + valid_user_id := null; + valid_org_id := -1; + end; + end if; + + for c in base_channel_cursor(release_in, server_arch_id_in, valid_org_id) + loop + -- This row is a possible match + if valid_user_id is null then + -- User ID not specified, so no user to channel permissions to + -- check + return c.id; + end if; + + -- Check user to channel permissions + select loose_user_role_check(c.id, user_id_in, 'subscribe') + into channel_subscribable + from dual; + + if channel_subscribable = 1 then + return c.id; + end if; + + -- Base channel exists, but is not subscribable; keep trying + denied_channel_id := c.id; + end loop base_channel_fetch; + + if denied_channel_id is not null then + rhn_exception.raise_exception('no_subscribe_permissions'); + end if; + -- No base channel applies + return NULL; + end base_channel_rel_archid; + + PROCEDURE clear_subscriptions(server_id_in IN NUMBER, deleting_server IN NUMBER := 0, + update_family_countsYN IN NUMBER := 1) + IS + cursor server_channels(server_id_in in number) is + select s.org_id, sc.channel_id, cfm.channel_family_id + from rhnServer s, + rhnServerChannel sc, + rhnChannelFamilyMembers cfm + where s.id = server_id_in + and s.id = sc.server_id + and sc.channel_id = cfm.channel_id + order by cfm.channel_family_id; + last_channel_family_id rhnChannelFamilyMembers.channel_family_id%type := -1; + last_channel_org_id rhnServer.org_id%type := -1; + BEGIN + for channel in server_channels(server_id_in) + loop + unsubscribe_server(server_id_in, channel.channel_id, 1, 1, deleting_server, 0); + if update_family_countsYN > 0 + and channel.channel_family_id != last_channel_family_id then + -- update family counts only once + -- after all channels with same family has been fetched + if last_channel_family_id != -1 then + update_family_counts(last_channel_family_id, last_channel_org_id); + end if; + last_channel_family_id := channel.channel_family_id; + last_channel_org_id := channel.org_id; + end if; + end loop channel; + if update_family_countsYN > 0 and last_channel_family_id != -1 then + -- update the last family fetched + update_family_counts(last_channel_family_id, last_channel_org_id); + end if; + END clear_subscriptions; + + PROCEDURE unsubscribe_server(server_id_in IN NUMBER, channel_id_in NUMBER, immediate_in NUMBER := 1, unsubscribe_children_in number := 0, + deleting_server IN NUMBER := 0, + update_family_countsYN IN NUMBER := 1) + IS + channel_family_id_val NUMBER; + server_org_id_val NUMBER; + available_subscriptions NUMBER; + server_already_in_chan BOOLEAN; + update_lock number; + cursor channel_family_is_proxy(channel_family_id_in in number) is + select 1 + from rhnChannelFamily + where id = channel_family_id_in + and label = 'rhn-proxy'; + cursor channel_family_is_satellite(channel_family_id_in in number) is + select 1 + from rhnChannelFamily + where id = channel_family_id_in + and label = 'rhn-satellite'; + -- this is *EXACTLY* like check_server_parent_membership, but if we recurse + -- with the package-level one, we get a "cursor already open", so we need a + -- copy on our call stack instead. GROAN. + cursor local_chk_server_parent_memb ( + server_id_in number, + channel_id_in number ) is + select c.id + from rhnChannel c, + rhnServerChannel sc + where 1=1 + and c.parent_channel = channel_id_in + and c.id = sc.channel_id + and sc.server_id = server_id_in; + BEGIN + FOR child IN local_chk_server_parent_memb(server_id_in, channel_id_in) + LOOP + if unsubscribe_children_in = 1 then + unsubscribe_server(server_id_in => server_id_in, + channel_id_in => child.id, + immediate_in => immediate_in, + unsubscribe_children_in => unsubscribe_children_in, + deleting_server => deleting_server, + update_family_countsYN => update_family_countsYN); + else + rhn_exception.raise_exception('channel_unsubscribe_child_exists'); + end if; + END LOOP child; + + server_already_in_chan := FALSE; + + FOR check_subscription IN check_server_subscription(server_id_in, channel_id_in) + LOOP + server_already_in_chan := TRUE; + END LOOP check_subscription; + + IF NOT server_already_in_chan + THEN + RETURN; + END IF; + + if deleting_server = 0 then + + insert into rhnServerHistory (id,server_id,summary,details) ( + select rhn_event_id_seq.nextval, + server_id_in, + 'unsubscribed from channel ' || SUBSTR(c.label, 0, 106), + c.label + from rhnChannel c + where c.id = channel_id_in + ); + + select 1 + into update_lock + from rhnServerNeededCache + where server_id = server_id_in + for update; + + UPDATE rhnServer SET channels_changed = current_timestamp WHERE id = server_id_in; + end if; + + DELETE FROM rhnServerChannel WHERE server_id = server_id_in AND channel_id = channel_id_in; + + if deleting_server = 0 then + queue_server(server_id_in, immediate_in); + end if; + + channel_family_id_val := rhn_channel.family_for_channel(channel_id_in); + IF channel_family_id_val IS NULL + THEN + rhn_exception.raise_exception('channel_unsubscribe_no_family'); + END IF; + + for ignore in channel_family_is_satellite(channel_family_id_val) loop + delete from rhnSatelliteInfo where server_id = server_id_in; + end loop; + + for ignore in channel_family_is_proxy(channel_family_id_val) loop + delete from rhnProxyInfo where server_id = server_id_in; + end loop; + SELECT org_id INTO server_org_id_val + FROM rhnServer + WHERE id = server_id_in; + + if update_family_countsYN = 1 then + rhn_channel.update_family_counts(channel_family_id_val, server_org_id_val); + end if; + END unsubscribe_server; + + + FUNCTION family_for_channel(channel_id_in IN NUMBER) + RETURN NUMBER + IS + channel_family_id_val NUMBER; + BEGIN + SELECT channel_family_id INTO channel_family_id_val + FROM rhnChannelFamilyMembers + WHERE channel_id = channel_id_in; + + RETURN channel_family_id_val; + EXCEPTION + WHEN NO_DATA_FOUND + THEN + RETURN NULL; + END family_for_channel; + + FUNCTION available_family_subscriptions(channel_family_id_in IN NUMBER, org_id_in IN NUMBER) + RETURN NUMBER + IS + cfp channel_family_perm_cursor%ROWTYPE; + current_members_val NUMBER; + max_members_val NUMBER; + found NUMBER; + BEGIN + IF NOT channel_family_perm_cursor%ISOPEN + THEN + OPEN channel_family_perm_cursor(channel_family_id_in, org_id_in); + END IF; + + FETCH channel_family_perm_cursor INTO cfp; + + WHILE channel_family_perm_cursor%FOUND + LOOP + found := 1; + + current_members_val := cfp.current_members; + max_members_val := cfp.max_members; + + FETCH channel_family_perm_cursor INTO cfp; + END LOOP; + + IF channel_family_perm_cursor%ISOPEN + THEN + CLOSE channel_family_perm_cursor; + END IF; + + -- not found: either the channel fam doesn't have an entry in cfp, or the org doesn't have access to it. + -- either way, there are no available subscriptions + + IF found IS NULL + THEN + RETURN 0; + END IF; + + -- null max members? in that case, pass it on; NULL means infinite + IF max_members_val IS NULL + THEN + RETURN NULL; + END IF; + + -- otherwise, return the delta + RETURN max_members_val - current_members_val; + END available_family_subscriptions; + + FUNCTION available_fve_family_subs(channel_family_id_in IN NUMBER, org_id_in IN NUMBER) + RETURN NUMBER + IS + cfp channel_family_perm_cursor%ROWTYPE; + fve_current_members_val NUMBER; + fve_max_members_val NUMBER; + found NUMBER; + + BEGIN + IF NOT channel_family_perm_cursor%ISOPEN THEN + OPEN channel_family_perm_cursor(channel_family_id_in, org_id_in); + END IF; + + FETCH channel_family_perm_cursor INTO cfp; + + WHILE channel_family_perm_cursor%FOUND LOOP + found := 1; + fve_current_members_val := cfp.fve_current_members; + fve_max_members_val := cfp.fve_max_members; + FETCH channel_family_perm_cursor INTO cfp; + END LOOP; + + IF channel_family_perm_cursor%ISOPEN THEN + CLOSE channel_family_perm_cursor; + END IF; + + IF found IS NULL THEN + RETURN 0; + END IF; + + IF fve_max_members_val IS NULL THEN + RETURN NULL; + END IF; + + RETURN fve_max_members_val - fve_current_members_val; + + END available_fve_family_subs; + + + -- ******************************************************************* + -- FUNCTION: channel_family_current_members + -- Calculates and returns the actual count of systems consuming + -- physical channel subscriptions. + -- Called by: update_family_counts + -- rhn_entitlements.repoll_virt_guest_entitlements + -- ******************************************************************* + function channel_family_current_members(channel_family_id_in IN NUMBER, + org_id_in IN NUMBER) + return number + is + current_members_count number := 0; + begin + select count(distinct server_id) + into current_members_count + from rhnChannelFamilyServerPhysical cfsp + where cfsp.channel_family_id = channel_family_id_in + and cfsp.customer_id = org_id_in; + return current_members_count; + end; + + + function cfam_curr_fve_members( + channel_family_id_in IN NUMBER, + org_id_in IN NUMBER) + return number + is + current_members_count number := 0; + + begin + select count(sc.server_id) + into current_members_count + from rhnServerChannel sc, + rhnChannelFamilyMembers cfm, + rhnServer s + where s.org_id = org_id_in + and s.id = sc.server_id + and cfm.channel_family_id = channel_family_id_in + and cfm.channel_id = sc.channel_id + and exists ( + select 1 + from rhnChannelFamilyServerFve cfsp + where cfsp.CHANNEL_FAMILY_ID = channel_family_id_in + and cfsp.server_id = s.id + ); + + return current_members_count; + end; + PROCEDURE update_family_counts(channel_family_id_in IN NUMBER, + org_id_in IN NUMBER) + IS + BEGIN + update rhnPrivateChannelFamily + set current_members = ( channel_family_current_members(channel_family_id_in, org_id_in)), + fve_current_members = ( cfam_curr_fve_members(channel_family_id_in, org_id_in)) + where org_id = org_id_in + and channel_family_id = channel_family_id_in; + END update_family_counts; + + PROCEDURE update_group_family_counts(group_label_in IN VARCHAR2, + org_id_in IN NUMBER) + IS + BEGIN + FOR i IN ( + SELECT DISTINCT CFM.channel_family_id, SG.org_id + FROM rhnChannelFamilyMembers CFM + JOIN rhnServerChannel SC + ON SC.channel_id = CFM.channel_id + JOIN rhnServerGroupMembers SGM + ON SC.server_id = SGM.server_id + JOIN rhnServerGroup SG + ON SGM.server_group_id = SG.id + JOIN rhnServerGroupType SGT + ON SG.group_type = SGT.id + WHERE SGT.label = group_label_in + AND SG.org_id = org_id_in + AND SGT.is_base = 'Y' + ) LOOP + rhn_channel.update_family_counts(i.channel_family_id, i.org_id); + END LOOP; + END update_group_family_counts; + + FUNCTION available_chan_subscriptions(channel_id_in IN NUMBER, + org_id_in IN NUMBER) + RETURN NUMBER + IS + channel_family_id_val NUMBER; + BEGIN + SELECT channel_family_id INTO channel_family_id_val + FROM rhnChannelFamilyMembers + WHERE channel_id = channel_id_in; + + RETURN rhn_channel.available_family_subscriptions( + channel_family_id_val, org_id_in); + END available_chan_subscriptions; + + FUNCTION available_fve_chan_subs(channel_id_in IN NUMBER, + org_id_in IN NUMBER) + RETURN NUMBER + IS + channel_family_id_val NUMBER; + + BEGIN + SELECT channel_family_id INTO channel_family_id_val + FROM rhnChannelFamilyMembers + WHERE channel_id = channel_id_in; + + RETURN rhn_channel.available_fve_family_subs( channel_family_id_val, org_id_in); + END available_fve_chan_subs; + + procedure unsubscribe_server_from_family(server_id_in in number, + channel_family_id_in in number) + is + begin + delete + from rhnServerChannel rsc + where rsc.server_id = server_id_in + and channel_id in ( + select rcfm.channel_id + from rhnChannelFamilyMembers rcfm + where rcfm.channel_family_id = channel_family_id_in); + end; + + function get_org_id(channel_id_in in number) + return number + is + org_id_out number; + begin + select org_id into org_id_out + from rhnChannel + where id = channel_id_in; + + return org_id_out; + end get_org_id; + + function get_cfam_org_access(cfam_id_in in number, org_id_in in number) + return number + is + cursor families is + select 1 + from rhnOrgChannelFamilyPermissions cfp + where cfp.org_id = org_id_in; + begin + -- the idea: if we get past this query, + -- the user has the role, else catch the exception and return 0 + for family in families loop + return 1; + end loop; + return 0; + end; + + function get_org_access(channel_id_in in number, org_id_in in number) + return number + is + throwaway number; + begin + -- the idea: if we get past this query, + -- the org has access to the channel, else catch the exception and return 0 + select distinct 1 into throwaway + from rhnChannelFamilyMembers CFM, + rhnOrgChannelFamilyPermissions CFP + where cfp.org_id = org_id_in + and CFM.channel_family_id = CFP.channel_family_id + and CFM.channel_id = channel_id_in + and (CFP.max_members > 0 or CFP.max_members is null or CFP.fve_max_members > 0 or CFP.fve_max_members is null or CFP.org_id = 1); + + return 1; + exception + when no_data_found + then + return 0; + end; + + -- check if a user has a given role, or if such a role is inferrable + -- returns NULL if OK, error message otherwise + function user_role_check_debug(channel_id_in in number, + user_id_in in number, + role_in in varchar2) + return varchar2 + is + org_id number; + begin + org_id := rhn_user.get_org_id(user_id_in); + + -- channel might be shared + if role_in = 'subscribe' and + rhn_channel.shared_user_role_check(channel_id_in, user_id_in, role_in) = 1 then + return NULL; + end if; + + if role_in = 'manage' and + NVL(rhn_channel.get_org_id(channel_id_in), -1) <> org_id then + return 'channel_not_owned'; + end if; + + if role_in = 'subscribe' and + rhn_channel.get_org_access(channel_id_in, org_id) = 0 then + return 'channel_not_available'; + end if; + + -- channel admins have all roles + if rhn_user.check_role_implied(user_id_in, 'channel_admin') = 1 then + return NULL; + end if; + + -- the subscribe permission is inferred + -- UNLESS the not_globally_subscribable flag is set + if role_in = 'subscribe' + then + if rhn_channel.org_channel_setting(channel_id_in, + org_id, + 'not_globally_subscribable') = 0 then + return NULL; + end if; + end if; + + -- all other roles (manage right now) are explicitly granted + if rhn_channel.direct_user_role_check(channel_id_in, + user_id_in, role_in) = 1 then + return NULL; + end if; + return 'direct_permission'; + end; + + -- same as above, but with 1/0 output; useful in views, etc + function user_role_check(channel_id_in in number, user_id_in in number, role_in in varchar2) + return number + is + begin + if rhn_channel.user_role_check_debug(channel_id_in, + user_id_in, role_in) is NULL then + return 1; + else + return 0; + end if; + end; + + -- + -- For multiorg phase II, this function simply checks to see if the user's + -- has a trust relationship that includes this channel by id. + -- + function shared_user_role_check(channel_id in number, user_id in number, role in varchar2) + return number + is + n number; + oid number; + begin + oid := rhn_user.get_org_id(user_id); + select 1 into n + from rhnSharedChannelView s + where s.id = channel_id and s.org_trust_id = oid; + return 1; + exception + when no_data_found then + return 0; + end; + + -- same as above, but returns 1 if user_id_in is null + -- This is useful in queries where user_id is not specified + function loose_user_role_check(channel_id_in in number, user_id_in in number, role_in in varchar2) + return number + is + begin + if user_id_in is null then + return 1; + end if; + return user_role_check(channel_id_in, user_id_in, role_in); + end loose_user_role_check; + + -- directly checks the table, no inferred permissions + function direct_user_role_check(channel_id_in in number, user_id_in in number, role_in in varchar2) + return number + is + throwaway number; + begin + -- the idea: if we get past this query, the user has the role, else catch the exception and return 0 + select 1 into throwaway + from rhnChannelPermissionRole CPR, + rhnChannelPermission CP + where CP.user_id = user_id_in + and CP.channel_id = channel_id_in + and CPR.label = role_in + and CP.role_id = CPR.id; + + return 1; + exception + when no_data_found + then + return 0; + end; + + -- check if an org has a certain setting + function org_channel_setting(channel_id_in in number, org_id_in in number, setting_in in varchar2) + return number + is + throwaway number; + begin + -- the idea: if we get past this query, the org has the setting, else catch the exception and return 0 + select 1 into throwaway + from rhnOrgChannelSettingsType OCST, + rhnOrgChannelSettings OCS + where OCS.org_id = org_id_in + and OCS.channel_id = channel_id_in + and OCST.label = setting_in + and OCS.setting_id = OCST.id; + + return 1; + exception + when no_data_found + then + return 0; + end; + + FUNCTION channel_priority(channel_id_in IN number) + RETURN number + IS + channel_name varchar2(256); + priority number; + end_of_life_val timestamp with local time zone; + org_id_val number; + BEGIN + + select name, end_of_life, org_id + into channel_name, end_of_life_val, org_id_val + from rhnChannel + where id = channel_id_in; + + if end_of_life_val is not null then + return -400; + end if; + + if channel_name like 'Red Hat Enterprise Linux%' or channel_name like 'RHEL%' then + priority := 1000; + if channel_name not like '%Beta%' then + priority := priority + 1000; + end if; + + priority := priority + + case + when channel_name like '%v. 5%' then 600 + when channel_name like '%v. 4%' then 500 + when channel_name like '%v. 3%' then 400 + when channel_name like '%v. 2%' then 300 + when channel_name like '%v. 1%' then 200 + else 0 + end; + + priority := priority + + case + when channel_name like 'Red Hat Enterprise Linux (v. 5%' then 60 + when (channel_name like '%AS%' and channel_name not like '%Extras%') then 50 + when (channel_name like '%ES%' and channel_name not like '%Extras%') then 40 + when (channel_name like '%WS%' and channel_name not like '%Extras%') then 30 + when (channel_name like '%Desktop%' and channel_name not like '%Extras%') then 20 + when channel_name like '%Extras%' then 10 + else 0 + end; + + priority := priority + + case + when channel_name like '%)' then 5 + else 0 + end; + + priority := priority + + case + when channel_name like '%32-bit x86%' then 4 + when channel_name like '%64-bit Intel Itanium%' then 3 + when channel_name like '%64-bit AMD64/Intel EM64T%' then 2 + else 0 + end; + elsif channel_name like 'Red Hat Desktop%' then + priority := 900; + + if channel_name not like '%Beta%' then + priority := priority + 50; + end if; + + priority := priority + + case + when channel_name like '%v. 4%' then 40 + when channel_name like '%v. 3%' then 30 + when channel_name like '%v. 2%' then 20 + when channel_name like '%v. 1%' then 10 + else 0 + end; + + priority := priority + + case + when channel_name like '%32-bit x86%' then 4 + when channel_name like '%64-bit Intel Itanium%' then 3 + when channel_name like '%64-bit AMD64/Intel EM64T%' then 2 + else 0 + end; + + elsif org_id_val is not null then + priority := 600; + else + priority := 500; + end if; + + return -priority; + + end channel_priority; + + -- right now this only does the accounting changes; the cascade + -- actually does the rhnServerChannel delete. + procedure delete_server_channels(server_id_in in number) + is + begin + update rhnPrivateChannelFamily + set current_members = current_members -1 + where org_id in ( + select org_id + from rhnServer + where id = server_id_in + ) + and channel_family_id in ( + select rcfm.channel_family_id + from rhnChannelFamilyMembers rcfm, + rhnServerChannel rsc + where rsc.server_id = server_id_in + and rsc.channel_id = rcfm.channel_id + and not exists ( + select 1 + from + rhnChannelFamilyVirtSubLevel cfvsl, + rhnSGTypeVirtSubLevel sgtvsl, + rhnServerEntitlementView sev, + rhnVirtualInstance vi + where + -- system is a virtual instance + vi.virtual_system_id = server_id_in + and vi.host_system_id = sev.server_id + -- system's host has a virt ent + and sev.label in ('virtualization_host', + 'virtualization_host_platform') + and sev.server_group_type_id = + sgtvsl.server_group_type_id + -- the host's virt ent grants a cf virt sub level + and sgtvsl.virt_sub_level_id = cfvsl.virt_sub_level_id + -- the cf is in that virt sub level + and cfvsl.channel_family_id = rcfm.channel_family_id + ) + ); + end; + + -- this could certainly be optimized to do updates if needs be + procedure refresh_newest_package(channel_id_in in number, + caller_in in varchar2 := '(unknown)', + package_name_id_in in number := null) + is + -- procedure refreshes rows for name_id = package_name_id_in or + -- all rows if package_name_id_in is null + begin + delete from rhnChannelNewestPackage + where channel_id = channel_id_in + and (package_name_id_in is null + or name_id = package_name_id_in); + insert into rhnChannelNewestPackage + (channel_id, name_id, evr_id, package_id, package_arch_id) + (select channel_id, + name_id, evr_id, + package_id, package_arch_id + from rhnChannelNewestPackageView + where channel_id = channel_id_in + and (package_name_id_in is null + or name_id = package_name_id_in) + ); + insert into rhnChannelNewestPackageAudit (channel_id, caller) + values (channel_id_in, caller_in); + update rhnChannel + set last_modified = greatest(current_timestamp, last_modified + interval '1' second) + where id = channel_id_in; + end; + + procedure update_channel ( channel_id_in in number, invalidate_ss in number := 0, + date_to_use in timestamp with local time zone := current_timestamp ) + is + + channel_last_modified timestamp with local time zone; + last_modified_value timestamp with local time zone; + + cursor snapshots is + select snapshot_id id + from rhnSnapshotChannel + where channel_id = channel_id_in; + + begin + + select last_modified + into channel_last_modified + from rhnChannel + where id = channel_id_in; + + last_modified_value := date_to_use; + + if last_modified_value <= channel_last_modified then + last_modified_value := last_modified_value + 1/86400; + end if; + + update rhnChannel set last_modified = last_modified_value + where id = channel_id_in; + + if invalidate_ss = 1 then + for snapshot in snapshots loop + update rhnSnapshot + set invalid = lookup_snapshot_invalid_reason('channel_modified') + where id = snapshot.id; + end loop; + end if; + + end update_channel; + + procedure update_channels_by_package ( package_id_in in number, date_to_use in timestamp with local time zone := current_timestamp ) + is + + cursor channels is + select channel_id + from rhnChannelPackage + where package_id = package_id_in + order by channel_id; + + begin + for channel in channels loop + -- we want to invalidate the snapshot assocated with the channel when we + -- do this b/c we know we've added or removed or packages + rhn_channel.update_channel ( channel.channel_id, 1, date_to_use ); + end loop; + end update_channels_by_package; + + + procedure update_channels_by_errata ( errata_id_in number, date_to_use in timestamp with local time zone := current_timestamp ) + is + + cursor channels is + select channel_id + from rhnChannelErrata + where errata_id = errata_id_in + order by channel_id; + + begin + for channel in channels loop + -- we won't invalidate snapshots, b/c just changing the errata associated with + -- a channel shouldn't invalidate snapshots + rhn_channel.update_channel ( channel.channel_id, 0, date_to_use ); + end loop; + end update_channels_by_errata; + + procedure update_needed_cache(channel_id_in in number) + is + -- update of needed cache ican be commited on a per server basis + -- b/c failure of update for a server means nothing for the other servers + begin + -- we intentionaly do a loop here instead of one huge select + -- b/c we want to break update into smaller transaction to unblock other sessions + -- querying rhnServerNeededCache + for server in ( + select sc.server_id as id + from rhnServerChannel sc + where sc.channel_id = channel_id_in + order by id asc + ) loop + rhn_server.update_needed_cache(server.id); + commit; + end loop; + end update_needed_cache; + + procedure set_comps(channel_id_in in number, path_in in varchar2, timestamp_in in varchar2) + is + begin + for row in ( + select relative_filename, last_modified + from rhnChannelComps + where channel_id = channel_id_in + ) loop + if row.relative_filename = path_in + and row.last_modified = to_date(timestamp_in, 'YYYYMMDDHH24MISS') then + return; + end if; + end loop; + delete from rhnChannelComps + where channel_id = channel_id_in; + insert into rhnChannelComps (id, channel_id, relative_filename, last_modified, created, modified) + values (sequence_nextval('rhn_channelcomps_id_seq'), channel_id_in, path_in, to_date(timestamp_in, 'YYYYMMDDHH24MISS'), current_timestamp, current_timestamp); + end set_comps; + +END rhn_channel; +/ +SHOW ERRORS diff --git a/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.postgresql b/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.postgresql new file mode 100644 index 0000000..03422a4 --- /dev/null +++ b/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.sql.postgresql @@ -0,0 +1,1278 @@ +-- oracle equivalent source sha1 8c6ffbfad3684c9957041813f63cfdbd2077d8cf +-- +-- Copyright (c) 2008--2013 Red Hat, Inc. +-- +-- This software is licensed to you under the GNU General Public License, +-- version 2 (GPLv2). There is NO WARRANTY for this software, express or +-- implied, including the implied warranties of MERCHANTABILITY or FITNESS +-- FOR A PARTICULAR PURPOSE. You should have received a copy of GPLv2 +-- along with this software; if not, see +-- http://www.gnu.org/licenses/old-licenses/gpl-2.0.txt. +-- +-- Red Hat trademarks are not licensed under GPLv2. No permission is +-- granted to use or replicate Red Hat trademarks that are incorporated +-- in this software or its documentation. +-- +-- +-- +-- + +-- create schema rhn_channel; + +--update pg_setting +update pg_settings set setting = 'rhn_channel,' || setting where name = 'search_path'; + + create or replace function obtain_read_lock(channel_family_id_in in numeric, org_id_in in numeric) + returns void as $$ + declare + read_lock timestamptz; + begin + select created into read_lock + from rhnPrivateChannelFamily + where channel_family_id = channel_family_id_in and org_id = org_id_in + for update; + end$$ language plpgsql; + + -- this "emulates" cursor server_base_subscriptions defined in oracle/rhn_channel.pks + create or replace function server_base_subscriptions(server_id_in NUMERIC) + returns boolean as $$ + begin + return exists(SELECT C.id FROM rhnChannel C, rhnServerChannel SC + WHERE C.id = SC.channel_id + AND SC.server_id = server_id_in + AND C.parent_channel IS NULL); + end$$ language plpgsql; + + -- this "emulates" cursor server_base_subscriptions defined in oracle/rhn_channel.pks + create or replace function check_server_subscription(server_id_in NUMERIC, channel_id_in NUMERIC) + returns boolean as $$ + begin + return exists(SELECT channel_id FROM rhnServerChannel WHERE server_id = server_id_in AND channel_id = channel_id_in); + end$$ language plpgsql; + + + CREATE OR REPLACE FUNCTION subscribe_server(server_id_in IN NUMERIC, channel_id_in NUMERIC, immediate_in NUMERIC default 1, user_id_in in numeric default null, recalcfamily_in NUMERIC default 1) returns void + AS $$ + declare + channel_parent_val rhnChannel.parent_channel%TYPE; + parent_subscribed BOOLEAN; + server_has_base_chan BOOLEAN; + server_already_in_chan BOOLEAN; + channel_family_id_val NUMERIC; + server_org_id_val NUMERIC; + available_subscriptions NUMERIC; + available_fve_subs numeric; + consenting_user NUMERIC; + allowed numeric; + is_fve_char char(1) := 'N'; + update_lock numeric; + BEGIN + if user_id_in is not null then + allowed := rhn_channel.user_role_check(channel_id_in, user_id_in, 'subscribe'); + else + allowed := 1; + end if; + + if allowed = 0 then + perform rhn_exception.raise_exception('no_subscribe_permissions'); + end if; + + + SELECT parent_channel INTO channel_parent_val FROM rhnChannel WHERE id = channel_id_in; + + IF channel_parent_val IS NOT NULL + THEN + -- child channel; if attempting to cross-subscribe a child to the wrong base, silently ignore + parent_subscribed := rhn_channel.check_server_subscription(server_id_in, channel_parent_val); + + IF NOT parent_subscribed + THEN + RETURN; + END IF; + ELSE + -- base channel + server_has_base_chan := rhn_channel.server_base_subscriptions(server_id_in); + + IF server_has_base_chan + THEN + perform rhn_exception.raise_exception('channel_server_one_base'); + END IF; + END IF; + + server_already_in_chan := rhn_channel.check_server_subscription(server_id_in, channel_id_in); + + IF server_already_in_chan + THEN + RETURN; + END IF; + + channel_family_id_val := rhn_channel.family_for_channel(channel_id_in); + IF channel_family_id_val IS NULL + THEN + perform rhn_exception.raise_exception('channel_subscribe_no_family'); + END IF; + + -- + -- Use the org_id of the server only if the org_id of the channel = NULL. + -- This is required for subscribing to shared channels. + -- + SELECT COALESCE(org_id, (SELECT org_id FROM rhnServer WHERE id = server_id_in)) + INTO server_org_id_val + FROM rhnChannel + WHERE id = channel_id_in; + + begin + perform rhn_channel.obtain_read_lock(channel_family_id_val, server_org_id_val); + exception + when no_data_found then + perform rhn_exception.raise_exception('channel_family_no_subscriptions'); + end; + + available_subscriptions := rhn_channel.available_family_subscriptions(channel_family_id_val, server_org_id_val); + available_fve_subs := rhn_channel.available_fve_family_subs(channel_family_id_val, server_org_id_val); + + IF available_subscriptions IS NULL OR + available_subscriptions > 0 or + rhn_channel.can_server_consume_virt_channl(server_id_in, channel_family_id_val) = 1 OR + (available_fve_subs > 0 AND rhn_channel.can_server_consume_fve(server_id_in) = 1) + THEN + if rhn_channel.can_server_consume_virt_channl(server_id_in, channel_family_id_val) = 0 AND available_fve_subs > 0 AND rhn_channel.can_server_consume_fve(server_id_in) = 1 THEN + is_fve_char := 'Y'; + end if; + + insert into rhnServerHistory (id,server_id,summary,details) ( + select nextval('rhn_event_id_seq'), + server_id_in, + 'subscribed to channel ' || SUBSTR(c.label, 0, 106), + c.label + from rhnChannel c + where c.id = channel_id_in + ); + + select 1 + into update_lock + from rhnServerNeededCache + where server_id = server_id_in + for update; + + UPDATE rhnServer SET channels_changed = current_timestamp WHERE id = server_id_in; + INSERT INTO rhnServerChannel (server_id, channel_id, is_fve) VALUES (server_id_in, channel_id_in, is_fve_char); + IF recalcfamily_in > 0 + THEN + perform rhn_channel.update_family_counts(channel_family_id_val, server_org_id_val); + END IF; + perform queue_server(server_id_in, immediate_in); + ELSE + perform rhn_exception.raise_exception('channel_family_no_subscriptions'); + END IF; + + END$$ language plpgsql; + + + + create or replace function can_convert_to_fve(server_id_in IN NUMERIC, channel_family_id_val IN NUMERIC) + RETURNS NUMERIC + as $$ + declare + fve_convertible_entries cursor for + select 1 from + rhnServerFveCapable cap + where cap.server_id = server_id_in + AND cap.channel_family_id = channel_family_id_val; + BEGIN + FOR entry IN fve_convertible_entries LOOP + return 1; + END LOOP; + RETURN 0; + END$$ language plpgsql; + + + + -- Converts server channel_family to use a flex entitlement + create or replace function convert_to_fve(server_id_in IN NUMERIC, channel_family_id_val IN NUMERIC) + returns void + as $$ + declare + available_fve_subs NUMERIC; + server_org_id_val NUMERIC; + BEGIN + + -- + -- Use the org_id of the server only if the org_id of the channel = NULL. + -- This is required for subscribing to shared channels. + -- + SELECT org_id + INTO server_org_id_val + FROM rhnServer + WHERE id = server_id_in; + + + perform rhn_channel.obtain_read_lock(channel_family_id_val, server_org_id_val); + if not found then + perform rhn_exception.raise_exception('channel_family_no_subscriptions'); + end if; + IF (rhn_channel.can_convert_to_fve(server_id_in, channel_family_id_val ) = 0) + THEN + perform rhn_exception.raise_exception('server_cannot_convert_to_flex'); + END IF; + + available_fve_subs := rhn_channel.available_fve_family_subs(channel_family_id_val, server_org_id_val); + + IF (available_fve_subs > 0) + THEN + + insert into rhnServerHistory (id,server_id,summary,details) ( + select nextval('rhn_event_id_seq'), + server_id_in, + 'converted to flex entitlement' || SUBSTR(cf.label, 0, 99), + cf.label + from rhnChannelFamily cf + where cf.id = channel_family_id_val + ); + + UPDATE rhnServerChannel sc set is_fve = 'Y' + where sc.server_id = server_id_in and + sc.channel_id in + (select cfm.channel_id from rhnChannelFamilyMembers cfm + where cfm.CHANNEL_FAMILY_ID = channel_family_id_val); + + perform rhn_channel.update_family_counts(channel_family_id_val, server_org_id_val); + ELSE + perform rhn_exception.raise_exception('not_enough_flex_entitlements'); + END IF; + + END$$ language plpgsql; + + create or replace function can_server_consume_virt_channl( + server_id_in in numeric, + family_id_in in numeric ) + returns numeric + as $$ + begin + if exists( + select 1 + from + rhnChannelFamilyVirtSubLevel cfvsl, + rhnSGTypeVirtSubLevel sgtvsl, + rhnVirtualInstance vi + where + vi.virtual_system_id = server_id_in + and sgtvsl.virt_sub_level_id = cfvsl.virt_sub_level_id + and cfvsl.channel_family_id = family_id_in + and exists ( + select 1 + from rhnServerEntitlementView sev + where vi.host_system_id = sev.server_id + and sev.server_group_type_id = sgtvsl.server_group_type_id )) + then + return 1; + else + return 0; + end if; + end$$ language plpgsql; + + create or replace function can_server_consume_fve(server_id_in in numeric) returns numeric + as $$ + declare + vi_entries cursor for + SELECT 1 + FROM rhnVirtualInstance vi + WHERE vi.virtual_system_id = server_id_in; + vi_count numeric; + + begin + FOR vi_entry IN VI_ENTRIES LOOP + return 1; + END LOOP; + RETURN 0; + end$$ language plpgsql; + + create or replace function guess_server_base( + server_id_in in numeric + ) RETURNS numeric as $$ + declare + server_cursor cursor for + select s.server_arch_id, s.release, s.org_id + from rhnServer s + where s.id = server_id_in; + -- Cursor that fetches all the possible base channels for a + -- (server_arch_id, release, org_id) combination + base_channel_cursor cursor( + release_in varchar, + server_arch_id_in numeric, + org_id_in numeric + ) for + select distinct c.* + from rhnOrgDistChannelMap odcm, + rhnServerChannelArchCompat scac, + rhnChannel c + where c.parent_channel is null + and c.id = odcm.channel_id + and c.channel_arch_id = odcm.channel_arch_id + and odcm.release = release_in + and odcm.for_org_id = org_id_in + and scac.server_arch_id = server_arch_id_in + and scac.channel_arch_id = c.channel_arch_id; + + begin + for s in server_cursor loop + for channel in base_channel_cursor(s.release, + s.server_arch_id, s.org_id) + loop + return channel.id; + end loop; + end loop; + -- Server not found, or no base channel applies to it + return null; + end$$ language plpgsql; + + -- Private function + create or replace function normalize_server_arch(server_arch_in in varchar) + returns varchar + as $$ + declare + suffix VARCHAR(128) := '-redhat-linux'; + begin + if server_arch_in is NULL then + return NULL; + end if; + if position('-' IN server_arch_in) > 0 + then + -- Suffix already present + return server_arch_in; + end if; + return server_arch_in || suffix; + end$$ language plpgsql; + + -- + -- Raises: + -- server_arch_not_found + -- no_subscribe_permissions + create or replace function base_channel_for_release_arch( + release_in in varchar, + server_arch_in in varchar, + org_id_in in numeric default -1, + user_id_in in numeric default null + ) returns numeric as $$ + declare + server_arch varchar(256) := rhn_channel.normalize_server_arch(server_arch_in); + server_arch_id numeric; + begin + -- Look up the server arch + select id + into server_arch_id + from rhnServerArch + where label = server_arch; + if not found then + perform rhn_exception.raise_exception('server_arch_not_found'); + end if; + + return rhn_channel.base_channel_rel_archid(release_in, server_arch_id, + org_id_in, user_id_in); + end$$ language plpgsql; + + create or replace function base_channel_rel_archid( + release_in in varchar, + server_arch_id_in in numeric, + org_id_in in numeric default -1, + user_id_in in numeric default null + ) returns numeric as $$ + declare + denied_channel_id numeric := null; + valid_org_id numeric := org_id_in; + valid_user_id numeric := user_id_in; + channel_subscribable numeric; + -- Cursor that fetches all the possible base channels for a + -- (server_arch_id, release, org_id) combination + base_channel_cursor cursor( + release_in varchar, + server_arch_id_in numeric, + org_id_in numeric + ) for + select distinct c.* + from rhnOrgDistChannelMap odcm, + rhnServerChannelArchCompat scac, + rhnChannel c + where c.parent_channel is null + and c.id = odcm.channel_id + and c.channel_arch_id = odcm.channel_arch_id + and odcm.release = release_in + and odcm.for_org_id = org_id_in + and scac.server_arch_id = server_arch_id_in + and scac.channel_arch_id = c.channel_arch_id; + + begin + if org_id_in = -1 and user_id_in is not null then + -- Get the org id from the user id + + select org_id + into valid_org_id + from web_contact + where id = user_id_in; + + if not found then + -- User doesn't exist + -- XXX Only list public stuff for now + valid_user_id := null; + valid_org_id := -1; + end if; + end if; + + for c in base_channel_cursor(release_in, server_arch_id_in, valid_org_id) + loop + -- This row is a possible match + if valid_user_id is null then + -- User ID not specified, so no user to channel permissions to + -- check + return c.id; + end if; + + -- Check user to channel permissions + select rhn_channel.loose_user_role_check(c.id, user_id_in, 'subscribe') + into channel_subscribable; + + if channel_subscribable = 1 then + return c.id; + end if; + + -- Base channel exists, but is not subscribable; keep trying + denied_channel_id := c.id; + end loop; + + if denied_channel_id is not null then + perform rhn_exception.raise_exception('no_subscribe_permissions'); + end if; + -- No base channel applies + return NULL; + end$$ language plpgsql; + + CREATE OR REPLACE FUNCTION clear_subscriptions(server_id_in IN NUMERIC, deleting_server IN NUMERIC default 0, + update_family_countsYN IN NUMERIC default 1 ) returns void + AS $$ + declare + server_channels cursor(server_id_in numeric) for + select s.org_id, sc.channel_id, cfm.channel_family_id + from rhnServer s, + rhnServerChannel sc, + rhnChannelFamilyMembers cfm + where s.id = server_id_in + and s.id = sc.server_id + and sc.channel_id = cfm.channel_id + order by cfm.channel_family_id; + last_channel_family_id rhnChannelFamilyMembers.channel_family_id%type := -1; + last_channel_org_id rhnServer.org_id%type := -1; + BEGIN + for channel in server_channels(server_id_in) + loop + perform rhn_channel.unsubscribe_server(server_id_in, channel.channel_id, 1, 1, deleting_server, 0); + if update_family_countsYN > 0 + and channel.channel_family_id != last_channel_family_id then + -- update family counts only once + -- after all channels with same family has been fetched + if last_channel_family_id != -1 then + perform rhn_channel.update_family_counts(channel.channel_family_id, channel.org_id); + end if; + last_channel_family_id := channel.channel_family_id; + last_channel_org_id := channel.org_id; + end if; + end loop; + if update_family_countsYN > 0 and last_channel_family_id != -1 then + -- update the last family fetched + perform rhn_channel.update_family_counts(last_channel_family_id, last_channel_org_id); + end if; + END$$ language plpgsql; + + CREATE OR REPLACE FUNCTION unsubscribe_server(server_id_in IN NUMERIC, channel_id_in NUMERIC, immediate_in NUMERIC default 1, unsubscribe_children_in numeric default 0, + deleting_server in numeric default 0, + update_family_countsYN in numeric default 1) returns void + AS $$ + declare + channel_family_id_val NUMERIC; + server_org_id_val NUMERIC; + available_subscriptions NUMERIC; + server_already_in_chan BOOLEAN; + update_lock numeric; + channel_family_is_proxy cursor(channel_family_id_in numeric) for + select 1 + from rhnChannelFamily + where id = channel_family_id_in + and label = 'rhn-proxy'; + channel_family_is_satellite cursor(channel_family_id_in numeric) for + select 1 + from rhnChannelFamily + where id = channel_family_id_in + and label = 'rhn-satellite'; + child record; + BEGIN + -- In PostgreSQL recursion with opened cursors is not allowed so we use + -- FOR IN SELECT form which is ok. + FOR child IN select c.id + from rhnChannel c, + rhnServerChannel sc + where 1=1 + and c.parent_channel = channel_id_in + and c.id = sc.channel_id + and sc.server_id = server_id_in + LOOP + if unsubscribe_children_in = 1 then + perform rhn_channel.unsubscribe_server(server_id_in, + child.id, + immediate_in, + unsubscribe_children_in, + deleting_server, + update_family_countsYN); + else + perform rhn_exception.raise_exception('channel_unsubscribe_child_exists'); + end if; + END LOOP; + + server_already_in_chan := rhn_channel.check_server_subscription(server_id_in, channel_id_in); + + IF NOT server_already_in_chan + THEN + RETURN; + END IF; + + if deleting_server = 0 then + + insert into rhnServerHistory (id,server_id,summary,details) ( + select nextval('rhn_event_id_seq'), + server_id_in, + 'unsubscribed from channel ' || SUBSTR(c.label, 0, 106), + c.label + from rhnChannel c + where c.id = channel_id_in + ); + + select 1 + into update_lock + from rhnServerNeededCache + where server_id = server_id_in + for update; + + UPDATE rhnServer SET channels_changed = current_timestamp WHERE id = server_id_in; + end if; + + DELETE FROM rhnServerChannel WHERE server_id = server_id_in AND channel_id = channel_id_in; + + if deleting_server = 0 then + perform queue_server(server_id_in, immediate_in); + end if; + + channel_family_id_val := rhn_channel.family_for_channel(channel_id_in); + IF channel_family_id_val IS NULL + THEN + perform rhn_exception.raise_exception('channel_unsubscribe_no_family'); + END IF; + + for ignore in channel_family_is_satellite(channel_family_id_val) loop + delete from rhnSatelliteInfo where server_id = server_id_in; + end loop; + + for ignore in channel_family_is_proxy(channel_family_id_val) loop + delete from rhnProxyInfo where server_id = server_id_in; + end loop; + SELECT org_id INTO server_org_id_val + FROM rhnServer + WHERE id = server_id_in; + + if update_family_countsYN = 1 then + perform rhn_channel.update_family_counts(channel_family_id_val, server_org_id_val); + end if; + END$$ language plpgsql; + + CREATE OR REPLACE FUNCTION family_for_channel(channel_id_in IN NUMERIC) + RETURNS NUMERIC + AS $$ + declare + channel_family_id_val NUMERIC; + BEGIN + SELECT channel_family_id INTO channel_family_id_val + FROM rhnChannelFamilyMembers + WHERE channel_id = channel_id_in; + + IF NOT FOUND THEN + RETURN NULL; + END IF; + + RETURN channel_family_id_val; + END$$ language plpgsql; + + CREATE OR REPLACE FUNCTION available_family_subscriptions(channel_family_id_in IN NUMERIC, org_id_in IN NUMERIC) + RETURNS NUMERIC + AS $$ + declare + cfp record; + current_members_val NUMERIC; + max_members_val NUMERIC; + found NUMERIC; + BEGIN + for cfp in SELECT * FROM rhnOrgChannelFamilyPermissions + WHERE channel_family_id = channel_family_id_in + AND org_id = org_id_in + LOOP + found := 1; + current_members_val := cfp.current_members; + max_members_val := cfp.max_members; + END LOOP; + + -- not found: either the channel fam doesn't have an entry in cfp, or the org doesn't have access to it. + -- either way, there are no available subscriptions + + IF found IS NULL + THEN + RETURN 0; + END IF; + + -- null max members? in that case, pass it on; NULL means infinite + IF max_members_val IS NULL + THEN + RETURN NULL; + END IF; + + -- otherwise, return the delta + RETURN max_members_val - current_members_val; + END$$ language plpgsql; + + CREATE OR REPLACE FUNCTION available_fve_family_subs(channel_family_id_in IN NUMERIC, org_id_in IN NUMERIC) + RETURNS NUMERIC + AS $$ + declare + cfp record; + fve_current_members_val NUMERIC; + fve_max_members_val NUMERIC; + found NUMERIC; + BEGIN + for cfp in SELECT * FROM rhnOrgChannelFamilyPermissions + WHERE channel_family_id = channel_family_id_in + AND org_id = org_id_in + LOOP + found := 1; + fve_current_members_val := cfp.fve_current_members; + fve_max_members_val := cfp.fve_max_members; + END LOOP; + + -- not found: either the channel fam doesn't have an entry in cfp, or the org doesn't have access to it. + -- either way, there are no available subscriptions + + IF found IS NULL + THEN + RETURN 0; + END IF; + + -- null max members? in that case, pass it on; NULL means infinite + IF fve_max_members_val IS NULL + THEN + RETURN NULL; + END IF; + + -- otherwise, return the delta + RETURN fve_max_members_val - fve_current_members_val; + END$$ language plpgsql; + + -- ******************************************************************* + -- FUNCTION: channel_family_current_members + -- Calculates and returns the actual count of systems consuming + -- physical channel subscriptions. + -- Called by: update_family_counts + -- rhn_entitlements.repoll_virt_guest_entitlements + -- ******************************************************************* + create or replace function channel_family_current_members(channel_family_id_in IN NUMERIC, + org_id_in IN NUMERIC) + returns numeric + as $$ + declare + current_members_count numeric := 0; + begin + select count(distinct server_id) + into current_members_count + from rhnChannelFamilyServerPhysical cfsp + where cfsp.channel_family_id = channel_family_id_in + and cfsp.customer_id = org_id_in; + return current_members_count; + end$$ language plpgsql; + + + create or replace function cfam_curr_fve_members( + channel_family_id_in IN NUMERIC, + org_id_in IN NUMERIC) + returns numeric + as $$ + declare + current_members_count numeric := 0; + + begin + select count(sc.server_id) + into current_members_count + from rhnServerChannel sc, + rhnChannelFamilyMembers cfm, + rhnServer s + where s.org_id = org_id_in + and s.id = sc.server_id + and cfm.channel_family_id = channel_family_id_in + and cfm.channel_id = sc.channel_id + and exists ( + select 1 + from rhnChannelFamilyServerFve cfsp + where cfsp.CHANNEL_FAMILY_ID = channel_family_id_in + and cfsp.server_id = s.id + ); + + return current_members_count; + end$$ language plpgsql; + CREATE OR REPLACE FUNCTION update_family_counts(channel_family_id_in IN NUMERIC, + org_id_in IN NUMERIC) returns void + AS $$ + BEGIN + update rhnPrivateChannelFamily + set current_members = rhn_channel.channel_family_current_members(channel_family_id_in, org_id_in), + fve_current_members = rhn_channel.cfam_curr_fve_members(channel_family_id_in,org_id_in) + where org_id = org_id_in + and channel_family_id = channel_family_id_in; + END$$ language plpgsql; + + create or replace function update_group_family_counts(group_label_in IN VARCHAR, + org_id_in IN NUMERIC) + returns void + as $$ + declare + i record; + BEGIN + FOR i IN ( + SELECT DISTINCT CFM.channel_family_id, SG.org_id + FROM rhnChannelFamilyMembers CFM + JOIN rhnServerChannel SC + ON SC.channel_id = CFM.channel_id + JOIN rhnServerGroupMembers SGM + ON SC.server_id = SGM.server_id + JOIN rhnServerGroup SG + ON SGM.server_group_id = SG.id + JOIN rhnServerGroupType SGT + ON SG.group_type = SGT.id + WHERE SGT.label = group_label_in + AND SG.org_id = org_id_in + AND SGT.is_base = 'Y' + ) LOOP + perform rhn_channel.update_family_counts(i.channel_family_id, i.org_id); + END LOOP; + END$$ language plpgsql; + + CREATE OR REPLACE FUNCTION available_chan_subscriptions(channel_id_in IN NUMERIC, + org_id_in IN NUMERIC) + RETURNS NUMERIC + AS $$ + declare + channel_family_id_val NUMERIC; + BEGIN + SELECT channel_family_id INTO STRICT channel_family_id_val + FROM rhnChannelFamilyMembers + WHERE channel_id = channel_id_in; + + RETURN rhn_channel.available_family_subscriptions( + channel_family_id_val, org_id_in); + END$$ language plpgsql; + + CREATE OR REPLACE FUNCTION available_fve_chan_subs(channel_id_in IN NUMERIC, + org_id_in IN NUMERIC) + RETURNS NUMERIC + AS $$ + declare + channel_family_id_val NUMERIC; + BEGIN + SELECT channel_family_id INTO STRICT channel_family_id_val + FROM rhnChannelFamilyMembers + WHERE channel_id = channel_id_in; + + RETURN rhn_channel.available_fve_family_subs( + channel_family_id_val, org_id_in); + END$$ language plpgsql; + + create or replace function unsubscribe_server_from_family(server_id_in in numeric, + channel_family_id_in in numeric) + returns void + as $$ + begin + delete + from rhnServerChannel rsc + where rsc.server_id = server_id_in + and channel_id in ( + select rcfm.channel_id + from rhnChannelFamilyMembers rcfm + where rcfm.channel_family_id = channel_family_id_in); + end$$ language plpgsql; + + create or replace function get_org_id(channel_id_in in numeric) + returns numeric + as $$ + declare + org_id_out numeric; + begin + select org_id into strict org_id_out + from rhnChannel + where id = channel_id_in; + + return org_id_out; + end$$ language plpgsql; + + create or replace function get_cfam_org_access(cfam_id_in in numeric, org_id_in in numeric) + returns numeric + as $$ + begin + if exists( + select 1 + from rhnOrgChannelFamilyPermissions cfp + where cfp.org_id = org_id_in + ) then + return 1; + else + return 0; + end if; + end$$ language plpgsql; + + create or replace function get_org_access(channel_id_in in numeric, org_id_in in numeric) + returns integer + as $$ + begin + -- the idea: if we get past this query, + -- the org has access to the channel, else not + if exists( + select 1 + from rhnChannelFamilyMembers CFM, + rhnOrgChannelFamilyPermissions CFP + where cfp.org_id = org_id_in + and CFM.channel_family_id = CFP.channel_family_id + and CFM.channel_id = channel_id_in + and (CFP.max_members > 0 or CFP.max_members is null or CFP.fve_max_members > 0 or CFP.fve_max_members is null or CFP.org_id = 1) ) + then + return 1; + else + return 0; + end if; + end$$ language plpgsql; + + -- check if a user has a given role, or if such a role is inferrable + -- returns NULL if OK, error message otherwise + create or replace function user_role_check_debug(channel_id_in in numeric, + user_id_in in numeric, + role_in in varchar) + returns varchar + as $$ + declare + org_id numeric; + begin + org_id := rhn_user.get_org_id(user_id_in); + + -- channel might be shared + if role_in = 'subscribe' and + rhn_channel.shared_user_role_check(channel_id_in, user_id_in, role_in) = 1 then + return NULL; + end if; + + if role_in = 'manage' and + COALESCE(rhn_channel.get_org_id(channel_id_in), -1) <> org_id then + return 'channel_not_owned'; + end if; + + if role_in = 'subscribe' and + rhn_channel.get_org_access(channel_id_in, org_id) = 0 then + return 'channel_not_available'; + end if; + + -- channel admins have all roles + if rhn_user.check_role_implied(user_id_in, 'channel_admin') = 1 then + return NULL; + end if; + + -- the subscribe permission is inferred + -- UNLESS the not_globally_subscribable flag is set + if role_in = 'subscribe' + then + if rhn_channel.org_channel_setting(channel_id_in, + org_id, + 'not_globally_subscribable') = 0 then + return NULL; + end if; + end if; + + -- all other roles (manage right now) are explicitly granted + if rhn_channel.direct_user_role_check(channel_id_in, + user_id_in, role_in) = 1 then + return NULL; + end if; + return 'direct_permission'; + end$$ language plpgsql; + + -- same as above, but with 1/0 output; useful in views, etc + create or replace function user_role_check(channel_id_in in numeric, user_id_in in numeric, role_in in varchar) + returns numeric + as $$ + begin + if rhn_channel.user_role_check_debug(channel_id_in, + user_id_in, role_in) is NULL then + return 1; + else + return 0; + end if; + end$$ language plpgsql; + + -- + -- For multiorg phase II, this function simply checks to see if the user's + -- has a trust relationship that includes this channel by id. + -- + create or replace function shared_user_role_check(channel_id in numeric, user_id in numeric, role in varchar) + returns numeric + as $$ + declare + n numeric; + oid numeric; + begin + oid := rhn_user.get_org_id(user_id); + select 1 into n + from rhnSharedChannelView s + where s.id = channel_id and s.org_trust_id = oid; + + if not found then + return 0; + end if; + + return 1; + end$$ language plpgsql; + + -- same as above, but returns 1 if user_id_in is null + -- This is useful in queries where user_id is not specified + create or replace function loose_user_role_check(channel_id_in in numeric, user_id_in in numeric, role_in in varchar) + returns numeric + as $$ + begin + if user_id_in is null then + return 1; + end if; + return rhn_channel.user_role_check(channel_id_in, user_id_in, role_in); + end$$ language plpgsql; + + -- directly checks the table, no inferred permissions + create or replace function direct_user_role_check(channel_id_in in numeric, user_id_in in numeric, role_in in varchar) + returns numeric + as $$ + declare + throwaway numeric; + begin + -- the idea: if we get past this query, the user has the role, else no + select 1 into throwaway + from rhnChannelPermissionRole CPR, + rhnChannelPermission CP + where CP.user_id = user_id_in + and CP.channel_id = channel_id_in + and CPR.label = role_in + and CP.role_id = CPR.id; + + if not found then + return 0; + end if; + + return 1; + end$$ language plpgsql; + + -- check if an org has a certain setting + create or replace function org_channel_setting(channel_id_in in numeric, org_id_in in numeric, setting_in in varchar) + returns numeric + as $$ + declare + throwaway numeric; + begin + -- the idea: if we get past this query, the org has the setting + select 1 into throwaway + from rhnOrgChannelSettingsType OCST, + rhnOrgChannelSettings OCS + where OCS.org_id = org_id_in + and OCS.channel_id = channel_id_in + and OCST.label = setting_in + and OCS.setting_id = OCST.id; + + if not found then + return 0; + end if; + + return 1; + end$$ language plpgsql; + + CREATE OR REPLACE FUNCTION channel_priority(channel_id_in IN numeric) + RETURNS numeric + AS $$ + declare + channel_name varchar(256); + priority numeric; + end_of_life_val timestamptz; + org_id_val numeric; + BEGIN + + select name, end_of_life, org_id + into channel_name, end_of_life_val, org_id_val + from rhnChannel + where id = channel_id_in; + + if end_of_life_val is not null then + return -400; + end if; + + if channel_name like 'Red Hat Enterprise Linux%' or channel_name like 'RHEL%' then + priority := 1000; + if channel_name not like '%Beta%' then + priority := priority + 1000; + end if; + + priority := priority + + case + when channel_name like '%v. 5%' then 600 + when channel_name like '%v. 4%' then 500 + when channel_name like '%v. 3%' then 400 + when channel_name like '%v. 2%' then 300 + when channel_name like '%v. 1%' then 200 + else 0 + end; + + priority := priority + + case + when channel_name like 'Red Hat Enterprise Linux (v. 5%' then 60 + when (channel_name like '%AS%' and channel_name not like '%Extras%') then 50 + when (channel_name like '%ES%' and channel_name not like '%Extras%') then 40 + when (channel_name like '%WS%' and channel_name not like '%Extras%') then 30 + when (channel_name like '%Desktop%' and channel_name not like '%Extras%') then 20 + when channel_name like '%Extras%' then 10 + else 0 + end; + + priority := priority + + case + when channel_name like '%)' then 5 + else 0 + end; + + priority := priority + + case + when channel_name like '%32-bit x86%' then 4 + when channel_name like '%64-bit Intel Itanium%' then 3 + when channel_name like '%64-bit AMD64/Intel EM64T%' then 2 + else 0 + end; + elsif channel_name like 'Red Hat Desktop%' then + priority := 900; + + if channel_name not like '%Beta%' then + priority := priority + 50; + end if; + + priority := priority + + case + when channel_name like '%v. 4%' then 40 + when channel_name like '%v. 3%' then 30 + when channel_name like '%v. 2%' then 20 + when channel_name like '%v. 1%' then 10 + else 0 + end; + + priority := priority + + case + when channel_name like '%32-bit x86%' then 4 + when channel_name like '%64-bit Intel Itanium%' then 3 + when channel_name like '%64-bit AMD64/Intel EM64T%' then 2 + else 0 + end; + + elsif org_id_val is not null then + priority := 600; + else + priority := 500; + end if; + + return -priority; + + end$$ language plpgsql; + + -- right now this only does the accounting changes; the cascade + -- actually does the rhnServerChannel delete. + create or replace function delete_server_channels(server_id_in in numeric) returns void + as $$ + begin + update rhnPrivateChannelFamily + set current_members = current_members -1 + where org_id in ( + select org_id + from rhnServer + where id = server_id_in + ) + and channel_family_id in ( + select rcfm.channel_family_id + from rhnChannelFamilyMembers rcfm, + rhnServerChannel rsc + where rsc.server_id = server_id_in + and rsc.channel_id = rcfm.channel_id + and not exists ( + select 1 + from + rhnChannelFamilyVirtSubLevel cfvsl, + rhnSGTypeVirtSubLevel sgtvsl, + rhnServerEntitlementView sev, + rhnVirtualInstance vi + where + -- system is a virtual instance + vi.virtual_system_id = server_id_in + and vi.host_system_id = sev.server_id + -- system's host has a virt ent + and sev.label in ('virtualization_host', + 'virtualization_host_platform') + and sev.server_group_type_id = + sgtvsl.server_group_type_id + -- the host's virt ent grants a cf virt sub level + and sgtvsl.virt_sub_level_id = cfvsl.virt_sub_level_id + -- the cf is in that virt sub level + and cfvsl.channel_family_id = rcfm.channel_family_id + ) + ); + end$$ language plpgsql; + + -- this could certainly be optimized to do updates if needs be + create or replace function refresh_newest_package(channel_id_in in numeric, + caller_in in varchar default '(unknown)', + package_name_id_in in numeric default null) + returns void + as $$ + -- procedure refreshes rows for name_id = package_name_id_in or + -- all rows if package_name_id_in is null + begin + delete from rhnChannelNewestPackage + where channel_id = channel_id_in + and (package_name_id_in is null + or name_id = package_name_id_in); + insert into rhnChannelNewestPackage + (channel_id, name_id, evr_id, package_id, package_arch_id) + (select channel_id, + name_id, evr_id, + package_id, package_arch_id + from rhnChannelNewestPackageView + where channel_id = channel_id_in + and (package_name_id_in is null + or name_id = package_name_id_in) + ); + insert into rhnChannelNewestPackageAudit (channel_id, caller) + values (channel_id_in, caller_in); + update rhnChannel + set last_modified = greatest(current_timestamp, + last_modified + interval '1 second') + where id = channel_id_in; + end$$ language plpgsql; + + create or replace function update_channel ( channel_id_in in numeric, invalidate_ss in numeric default 0, + date_to_use in timestamptz default current_timestamp ) returns void + as $$ + declare + channel_last_modified timestamptz; + last_modified_value timestamptz; + + snapshots cursor for + select snapshot_id id + from rhnSnapshotChannel + where channel_id = channel_id_in; + + begin + + select last_modified + into channel_last_modified + from rhnChannel + where id = channel_id_in; + + last_modified_value := date_to_use; + + if last_modified_value <= channel_last_modified then + last_modified_value := last_modified_value + interval '1 second'; + end if; + + update rhnChannel set last_modified = last_modified_value + where id = channel_id_in; + + if invalidate_ss = 1 then + for snapshot in snapshots loop + update rhnSnapshot + set invalid = lookup_snapshot_invalid_reason('channel_modified') + where id = snapshot.id; + end loop; + end if; + + end$$ language plpgsql; + + create or replace function update_channels_by_package ( package_id_in in numeric, date_to_use in timestamptz default current_timestamp ) returns void + as $$ + declare + channels cursor for + select channel_id + from rhnChannelPackage + where package_id = package_id_in + order by channel_id; + + begin + for channel in channels loop + -- we want to invalidate the snapshot assocated with the channel when we + -- do this b/c we know we've added or removed or packages + perform rhn_channel.update_channel ( channel.channel_id, 1, date_to_use ); + end loop; + end$$ language plpgsql; + + + create or replace function update_channels_by_errata ( errata_id_in numeric, date_to_use in timestamptz default current_timestamp ) returns void + as $$ + declare + channels cursor for + select channel_id + from rhnChannelErrata + where errata_id = errata_id_in + order by channel_id; + + begin + for channel in channels loop + -- we won't invalidate snapshots, b/c just changing the errata associated with + -- a channel shouldn't invalidate snapshots + perform rhn_channel.update_channel ( channel.channel_id, 0, date_to_use ); + end loop; + end$$ language plpgsql; + + create or replace function update_needed_cache(channel_id_in in numeric) returns void + as $$ + declare + server record; + begin + -- we intentionaly do a loop here instead of one huge select + -- b/c we want to break update into smaller transaction to unblock other sessions + -- querying rhnServerNeededCache + for server in ( + select sc.server_id as id + from rhnServerChannel sc + where sc.channel_id = channel_id_in + order by id asc + ) loop + perform rhn_server.update_needed_cache(server.id); + end loop; + end$$ language plpgsql; + + create or replace function set_comps(channel_id_in in numeric, path_in in varchar, timestamp_in in varchar) returns void + as $$ + declare + row record; + begin + for row in ( + select relative_filename, last_modified + from rhnChannelComps + where channel_id = channel_id_in + ) loop + if row.relative_filename = path_in + and row.last_modified = to_timestamp(timestamp_in, 'YYYYMMDDHH24MISS') then + return; + end if; + end loop; + delete from rhnChannelComps + where channel_id = channel_id_in; + insert into rhnChannelComps (id, channel_id, relative_filename, last_modified, created, modified) + values (sequence_nextval('rhn_channelcomps_id_seq'), channel_id_in, path_in, to_timestamp(timestamp_in, 'YYYYMMDDHH24MISS'), current_timestamp, current_timestamp); + end$$ language plpgsql; + +-- restore the original setting +update pg_settings set setting = overlay( setting placing '' from 1 for (length('rhn_channel')+1) ) where name = 'search_path';

1 0

schema/spacewalk
by Milan Zazrivec 14 Feb '14

14 Feb '14

schema/spacewalk/oracle/packages/rhn_channel.pkb | 14 ++++++---- schema/spacewalk/postgres/packages/rhn_channel.pkb | 2 - schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.oracle | 14 ++++++---- schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.postgresql | 2 - 4 files changed, 20 insertions(+), 12 deletions(-) New commits: commit 8d0c918fbfb2ba8007afdc774d74cfaf229e9d70 Author: Milan Zazrivec <mzazrivec(a)redhat.com> Date: Fri Feb 14 13:01:57 2014 +0100 fix ORA-01403: no data found, during system registration diff --git a/schema/spacewalk/oracle/packages/rhn_channel.pkb b/schema/spacewalk/oracle/packages/rhn_channel.pkb index 492f324..4be76a2 100644 --- a/schema/spacewalk/oracle/packages/rhn_channel.pkb +++ b/schema/spacewalk/oracle/packages/rhn_channel.pkb @@ -156,11 +156,15 @@ IS where c.id = channel_id_in ); - select 1 - into update_lock - from rhnServerNeededCache - where server_id = server_id_in - for update; + begin + select 1 + into update_lock + from rhnServerNeededCache + where server_id = server_id_in + for update; + exception WHEN no_data_found THEN + null; + end; UPDATE rhnServer SET channels_changed = current_timestamp WHERE id = server_id_in; INSERT INTO rhnServerChannel (server_id, channel_id, is_fve) VALUES (server_id_in, channel_id_in, is_fve); diff --git a/schema/spacewalk/postgres/packages/rhn_channel.pkb b/schema/spacewalk/postgres/packages/rhn_channel.pkb index 2db8fad..64168d9 100644 --- a/schema/spacewalk/postgres/packages/rhn_channel.pkb +++ b/schema/spacewalk/postgres/packages/rhn_channel.pkb @@ -1,4 +1,4 @@ --- oracle equivalent source sha1 3f65e7873daaa42b5ba247a903dc78d07c505bbc +-- oracle equivalent source sha1 78b5b31336bdc942418962b6c374f1a67c95afe2 -- -- Copyright (c) 2008--2013 Red Hat, Inc. -- diff --git a/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.oracle b/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.oracle index 3b573e5..477e8b0 100644 --- a/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.oracle +++ b/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.oracle @@ -156,11 +156,15 @@ IS where c.id = channel_id_in ); - select 1 - into update_lock - from rhnServerNeededCache - where server_id = server_id_in - for update; + begin + select 1 + into update_lock + from rhnServerNeededCache + where server_id = server_id_in + for update; + exception WHEN no_data_found THEN + null; + end; UPDATE rhnServer SET channels_changed = current_timestamp WHERE id = server_id_in; INSERT INTO rhnServerChannel (server_id, channel_id, is_fve) VALUES (server_id_in, channel_id_in, is_fve); diff --git a/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.postgresql b/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.postgresql index e59c5d4..03422a4 100644 --- a/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.postgresql +++ b/schema/spacewalk/upgrade/spacewalk-schema-2.0-to-spacewalk-schema-2.1/048-rhn_channel.pkb.postgresql @@ -1,4 +1,4 @@ --- oracle equivalent source sha1 7f21173dd16ae3c29c150aa42623feba45894363 +-- oracle equivalent source sha1 8c6ffbfad3684c9957041813f63cfdbd2077d8cf -- -- Copyright (c) 2008--2013 Red Hat, Inc. --

1 0

Changes to 'refs/tags/yum-rhn-plugin-2.1.7-1'
by mkollar 14 Feb '14

14 Feb '14

Tag 'yum-rhn-plugin-2.1.7-1' created by Matej Kollar <mkollar(a)redhat.com> at 2014-02-14 12:04 +0000 Tagging package [yum-rhn-plugin] version [2.1.7-1] in directory [client/rhel/yum-rhn-plugin/]. Changes since rhn-custom-info-5.4.22-1: Matej Kollar (1): Automatic commit of package [yum-rhn-plugin] release [2.1.7-1]. --- client/rhel/yum-rhn-plugin/yum-rhn-plugin.spec | 5 ++++- rel-eng/packages/yum-rhn-plugin | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) ---

1 0

client/rhel rel-eng/packages
by mkollar 14 Feb '14

14 Feb '14

client/rhel/yum-rhn-plugin/yum-rhn-plugin.spec | 5 ++++- rel-eng/packages/yum-rhn-plugin | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) New commits: commit a89e2cb865fa2753ca152d01cc5c5f1369e33b39 Author: Matej Kollar <mkollar(a)redhat.com> Date: Fri Feb 14 13:04:09 2014 +0100 Automatic commit of package [yum-rhn-plugin] release [2.1.7-1]. diff --git a/client/rhel/yum-rhn-plugin/yum-rhn-plugin.spec b/client/rhel/yum-rhn-plugin/yum-rhn-plugin.spec index f879868..efac3be 100644 --- a/client/rhel/yum-rhn-plugin/yum-rhn-plugin.spec +++ b/client/rhel/yum-rhn-plugin/yum-rhn-plugin.spec @@ -1,6 +1,6 @@ Summary: Spacewalk support for yum Name: yum-rhn-plugin -Version: 2.1.6 +Version: 2.1.7 Release: 1%{?dist} License: GPLv2 Group: System Environment/Base @@ -70,6 +70,9 @@ fi %doc LICENSE %changelog +* Fri Feb 14 2014 Matej Kollar <mkollar(a)redhat.com> 2.1.7-1 +- 1043850 - avoid insecure use of /var/tmp + * Tue Jan 14 2014 Matej Kollar <mkollar(a)redhat.com> 2.1.6-1 - Update .po and .pot files for yum-rhn-plugin. diff --git a/rel-eng/packages/yum-rhn-plugin b/rel-eng/packages/yum-rhn-plugin index 132856b..48a5c41 100644 --- a/rel-eng/packages/yum-rhn-plugin +++ b/rel-eng/packages/yum-rhn-plugin @@ -1 +1 @@ -2.1.6-1 client/rhel/yum-rhn-plugin/ +2.1.7-1 client/rhel/yum-rhn-plugin/

1 0

← Newer
1
...
13
14
15
16
17
18
19
...
28
Older →

Jump to page:

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

spacewalk-commits February 2014