summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorShinya Maeda <shinya@gitlab.com>2018-04-26 15:06:04 +0900
committerShinya Maeda <shinya@gitlab.com>2018-04-26 15:06:04 +0900
commit9d6fe7bfdf9ff3f68ee73baa0e3d0aa7df13c351 (patch)
tree575021ca2d2a2775ee6fe74bd2a323735afa9f22 /lib
parent4eb67ccff350d181e60e4666e459a364cd36b064 (diff)
downloadgitlab-ce-9d6fe7bfdf9ff3f68ee73baa0e3d0aa7df13c351.tar.gz
Refactoring ci_job_trace to ci_build_trace
Diffstat (limited to 'lib')
-rw-r--r--lib/gitlab/ci/trace.rb12
-rw-r--r--lib/gitlab/ci/trace/chunked_io.rb22
-rw-r--r--lib/tasks/migrate/add_limits_mysql.rake4
3 files changed, 19 insertions, 19 deletions
diff --git a/lib/gitlab/ci/trace.rb b/lib/gitlab/ci/trace.rb
index 79838cabdb5..65c8b9118c6 100644
--- a/lib/gitlab/ci/trace.rb
+++ b/lib/gitlab/ci/trace.rb
@@ -54,14 +54,14 @@ module Gitlab
end
def exist?
- trace_artifact&.exists? || job.chunks.any? || current_path.present? || old_trace.present?
+ trace_artifact&.exists? || job.trace_chunks.any? || current_path.present? || old_trace.present?
end
def read
stream = Gitlab::Ci::Trace::Stream.new do
if trace_artifact
trace_artifact.open
- elsif job.chunks.any?
+ elsif job.trace_chunks.any?
Gitlab::Ci::Trace::ChunkedIO.new(job)
elsif current_path
File.open(current_path, "rb")
@@ -100,7 +100,7 @@ module Gitlab
FileUtils.rm(trace_path, force: true)
end
- job.chunks.destroy_all
+ job.trace_chunks.destroy_all
job.erase_old_trace!
end
@@ -108,7 +108,7 @@ module Gitlab
raise ArchiveError, 'Already archived' if trace_artifact
raise ArchiveError, 'Job is not finished yet' unless job.complete?
- if job.chunks.any?
+ if job.trace_chunks.any?
Gitlab::Ci::Trace::ChunkedIO.new(job) do |stream|
archive_stream!(stream)
stream.destroy!
@@ -130,7 +130,7 @@ module Gitlab
def archive_stream!(stream)
clone_file!(stream, JobArtifactUploader.workhorse_upload_path) do |clone_path|
- create_job_trace!(job, clone_path)
+ create_build_trace!(job, clone_path)
end
end
@@ -146,7 +146,7 @@ module Gitlab
end
end
- def create_job_trace!(job, path)
+ def create_build_trace!(job, path)
File.open(path) do |stream|
job.create_job_artifacts_trace!(
project: job.project,
diff --git a/lib/gitlab/ci/trace/chunked_io.rb b/lib/gitlab/ci/trace/chunked_io.rb
index 6b4a9f61961..877be08b219 100644
--- a/lib/gitlab/ci/trace/chunked_io.rb
+++ b/lib/gitlab/ci/trace/chunked_io.rb
@@ -5,18 +5,18 @@ module Gitlab
module Ci
class Trace
class ChunkedIO
- CHUNK_SIZE = ::Ci::JobTraceChunk::CHUNK_SIZE
+ CHUNK_SIZE = ::Ci::BuildTraceChunk::CHUNK_SIZE
FailedToGetChunkError = Class.new(StandardError)
- attr_reader :job
+ attr_reader :build
attr_reader :tell, :size
attr_reader :chunk, :chunk_range
alias_method :pos, :tell
- def initialize(job, &block)
- @job = job
+ def initialize(build, &block)
+ @build = build
@chunks_cache = []
@tell = 0
@size = calculate_size
@@ -140,7 +140,7 @@ module Gitlab
@size = offset
# remove all next chunks
- job_chunks.where('chunk_index > ?', chunk_index).destroy_all
+ trace_chunks.where('chunk_index > ?', chunk_index).destroy_all
# truncate current chunk
current_chunk.truncate(chunk_offset) if chunk_offset != 0
@@ -157,7 +157,7 @@ module Gitlab
end
def destroy!
- job_chunks.destroy_all
+ trace_chunks.destroy_all
@tell = @size = 0
ensure
invalidate_chunk_cache
@@ -206,23 +206,23 @@ module Gitlab
end
def current_chunk
- @chunks_cache[chunk_index] ||= job_chunks.find_by(chunk_index: chunk_index)
+ @chunks_cache[chunk_index] ||= trace_chunks.find_by(chunk_index: chunk_index)
end
def build_chunk
- @chunks_cache[chunk_index] = ::Ci::JobTraceChunk.new(job: job, chunk_index: chunk_index)
+ @chunks_cache[chunk_index] = ::Ci::BuildTraceChunk.new(build: build, chunk_index: chunk_index)
end
def ensure_chunk
current_chunk || build_chunk
end
- def job_chunks
- ::Ci::JobTraceChunk.where(job: job)
+ def trace_chunks
+ ::Ci::BuildTraceChunk.where(build: build)
end
def calculate_size
- job_chunks.order(chunk_index: :desc).first.try(&:end_offset).to_i
+ trace_chunks.order(chunk_index: :desc).first.try(&:end_offset).to_i
end
end
end
diff --git a/lib/tasks/migrate/add_limits_mysql.rake b/lib/tasks/migrate/add_limits_mysql.rake
index 3cdcdcdf874..c6204f89de4 100644
--- a/lib/tasks/migrate/add_limits_mysql.rake
+++ b/lib/tasks/migrate/add_limits_mysql.rake
@@ -1,7 +1,7 @@
require Rails.root.join('db/migrate/limits_to_mysql')
require Rails.root.join('db/migrate/markdown_cache_limits_to_mysql')
require Rails.root.join('db/migrate/merge_request_diff_file_limits_to_mysql')
-require Rails.root.join('db/migrate/limits_ci_job_trace_chunks_raw_data_for_mysql')
+require Rails.root.join('db/migrate/limits_ci_build_trace_chunks_raw_data_for_mysql')
desc "GitLab | Add limits to strings in mysql database"
task add_limits_mysql: :environment do
@@ -9,5 +9,5 @@ task add_limits_mysql: :environment do
LimitsToMysql.new.up
MarkdownCacheLimitsToMysql.new.up
MergeRequestDiffFileLimitsToMysql.new.up
- LimitsCiJobTraceChunksRawDataForMysql.new.up
+ LimitsCiBuildTraceChunksRawDataForMysql.new.up
end