summaryrefslogtreecommitdiff
path: root/lib/gitlab/ci/trace
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/gitlab/ci/trace
parent4eb67ccff350d181e60e4666e459a364cd36b064 (diff)
downloadgitlab-ce-9d6fe7bfdf9ff3f68ee73baa0e3d0aa7df13c351.tar.gz
Refactoring ci_job_trace to ci_build_trace
Diffstat (limited to 'lib/gitlab/ci/trace')
-rw-r--r--lib/gitlab/ci/trace/chunked_io.rb22
1 files changed, 11 insertions, 11 deletions
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