| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/app/services/ci/ |
| H A D | after_requeue_job_service.rb | 5 def execute(processable) argument
6 process_subsequent_jobs(processable)
7 reset_source_bridge(processable)
13 (stage_dependent_jobs(processable) | needs_dependent_jobs(processable))
14 .each do |processable|
15 process(processable)
23 def process(processable) argument
24 Gitlab::OptimisticLocking.retry_lock(processable, name: 'ci_requeue_job') do |processable|
29 def skipped_jobs(processable) argument
34 skipped_jobs(processable).after_stage(processable.stage_idx)
[all …]
|
| H A D | play_manual_stage_service.rb | 12 stage.processables.manual.each do |processable|
13 next unless processable.playable?
15 processable.play(current_user)
17 logger.error(message: 'Unable to play manual action', processable_id: processable.id)
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/app/models/ci/ |
| H A D | build_dependencies.rb | 9 def initialize(processable) argument
10 @processable = processable
40 deps = find_dependencies(processable, deps)
46 def find_dependencies(processable, deps) argument
47 if processable.scheduling_type_dag?
103 next if pipeline == processable.pipeline_id
124 processable.project
128 processable.options[:dependencies]&.empty?
132 scope.before_stage(processable.stage_idx)
143 scope.where(name: processable.options[:dependencies])
[all …]
|
| H A D | processable.rb | 42 before_transition any => :waiting_for_resource do |processable|
43 processable.waiting_for_resource_at = Time.current
47 next unless processable.with_resource_group?
49 processable.resource_group.assign_resource_to(processable)
52 after_transition any => :waiting_for_resource do |processable|
53 processable.run_after_commit do
55 .perform_async(processable.resource_group_id)
60 next unless processable.with_resource_group?
62 processable.resource_group.release_resource_from(processable)
64 processable.run_after_commit do
[all …]
|
| H A D | resource.rb | 8 scope :free, -> { where(processable: nil) }
9 scope :retained, -> { where.not(processable: nil) }
10 scope :retained_by, -> (processable) { where(processable: processable) }
|
| H A D | resource_group.rb | 26 def assign_resource_to(processable) argument
27 resources.free.limit(1).update_all(build_id: processable.id) > 0
30 def release_resource_from(processable) argument
31 resources.retained_by(processable).update_all(build_id: nil) > 0
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/app/services/ci/pipeline_processing/ |
| H A D | atomic_processing_service.rb | 82 def update_processable!(processable) argument
83 status = processable_status(processable)
87 …Gitlab::OptimisticLocking.retry_lock(processable, name: 'atomic_processing_update_processable') do…
95 processable.id, processable.status, processable.lock_version)
99 def processable_status(processable) argument
100 if processable.scheduling_type_dag?
102 @collection.status_for_names(processable.aggregated_needs_names.to_a, dag: true)
105 @collection.status_for_prior_stage_position(processable.stage_idx.to_i)
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/services/ci/create_pipeline_service/ |
| H A D | needs_spec.rb | 208 build_a = processables.find { |processable| processable.name == 'build_a' }
209 test_a = processables.find { |processable| processable.name == 'test_a' }
210 test_b = processables.find { |processable| processable.name == 'test_b' }
211 deploy_a = processables.find { |processable| processable.name == 'deploy_a' }
212 deploy_b = processables.find { |processable| processable.name == 'deploy_b' }
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/app/services/ci/pipeline_processing/atomic_processing_service/ |
| H A D | status_collection.rb | 26 processable = all_statuses_by_id[id]
27 return unless processable
29 processable[:status] = status
30 processable[:lock_version] = lock_version
59 .select { |processable| processable[:status] == 'created' }
60 .map { |processable| processable[:id] }
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/lib/gitlab/ci/pipeline/seed/processable/ |
| H A D | resource_group.rb | 13 def initialize(processable, resource_group_key) argument
14 @processable = processable
21 resource_group = processable.project.resource_groups
36 processable.simple_variables.tap do |variables|
38 if processable.persisted_environment.present?
39 variables.concat(processable.persisted_environment.predefined_variables)
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/lib/gitlab/ci/pipeline/chain/ |
| H A D | ensure_resource_groups.rb | 20 def ensure_resource_group(processable) argument
21 return unless processable.is_a?(::Ci::Processable)
23 key = processable.options.delete(:resource_group_key)
26 .new(processable, key).to_resource
28 processable.resource_group = resource_group
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/app/services/ci/resource_groups/ |
| H A D | assign_resource_from_resource_group_service.rb | 12 resource_group.upcoming_processables.take(free_resources).each do |processable|
13 processable.enqueue_waiting_for_resource
21 resource_group.resources.stale_processables.find_each do |processable|
22 resource_group.release_resource_from(processable)
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/models/ci/ |
| H A D | resource_spec.rb | 22 resource = create(:ci_resource, processable: create(:ci_build))
28 create(:ci_resource, processable: nil)
38 let!(:resource) { create(:ci_resource, processable: build) }
49 let!(:resource) { create(:ci_resource, processable: build, resource_group: resource_group) }
|
| H A D | resource_group_spec.rb | 36 expect(resource_group.resources.first.processable).to be_nil
40 expect(resource_group.resources.first.processable).to eq(build)
54 …let!(:another_resource) { create(:ci_resource, resource_group: resource_group, processable: build)…
74 expect(resource_group.resources.first.processable).to eq(build)
78 expect(resource_group.resources.first.processable).to be_nil
|
| H A D | processable_spec.rb | 25 create(:ci_build_need, build: processable, name: 'test1')
26 create(:ci_build_need, build: processable, name: 'test2')
30 expect(with_aggregated_needs).to contain_exactly(processable)
40 expect(with_aggregated_needs).to contain_exactly(processable)
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/lib/gitlab/ci/pipeline/seed/ |
| H A D | build.rb | 80 processable = initialize_processable
81 … assign_resource_group(processable) unless @pipeline.create_deployment_in_separate_transaction?
82 processable
98 def assign_resource_group(processable) argument
99 processable.resource_group =
100 Seed::Processable::ResourceGroup.new(processable, @resource_group_key)
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/factories/ci/ |
| H A D | processable.rb | 21 after(:build) do |processable, evaluator|
22 processable.resource_group = create(:ci_resource_group, project: processable.project)
|
| H A D | resource.rb | 8 processable factory: :ci_build
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/lib/gitlab/ci/status/processable/ |
| H A D | waiting_for_resource_spec.rb | 9 processable = create(:ci_build, :waiting_for_resource, :resource_group)
10 described_class.new(Gitlab::Ci::Status::Core.new(processable, user))
18 subject {described_class.matches?(processable, user) }
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/lib/gitlab/ci/status/processable/ |
| H A D | waiting_for_resource.rb | 20 def self.matches?(processable, _) argument
21 processable.waiting_for_resource?
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/services/ci/ |
| H A D | play_manual_stage_service_spec.rb | 37 pipeline.processables.each do |processable|
38 expect(processable.user).to eq(current_user)
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/services/ci/pipeline_processing/atomic_processing_service/ |
| H A D | status_collection_spec.rb | 90 expect(collection.processing_processables.map { |processable| processable[:id]} )
|
| /dports/www/moodle310/moodle/backup/util/interfaces/ |
| H A D | processable.class.php | 33 interface processable { interface
|
| /dports/www/moodle311/moodle/backup/util/interfaces/ |
| H A D | processable.class.php | 33 interface processable { interface
|
| /dports/www/moodle39/moodle/backup/util/interfaces/ |
| H A D | processable.class.php | 33 interface processable { interface
|