Commit 1a78483b authored by Grzegorz Bizon's avatar Grzegorz Bizon

Merge branch 'gitaly-diff-mandatory' into 'master'

Make all Gitaly diff flags mandatory

Closes gitaly#528 and gitaly#222

See merge request gitlab-org/gitlab-ce!20424
parents c17e9a63 b012abee
...@@ -42,12 +42,10 @@ module Gitlab ...@@ -42,12 +42,10 @@ module Gitlab
return if @overflow return if @overflow
return if @iterator.nil? return if @iterator.nil?
Gitlab::GitalyClient.migrate(:commit_raw_diffs) do |is_enabled| if @iterator.is_a?(Gitlab::GitalyClient::DiffStitcher)
if is_enabled && @iterator.is_a?(Gitlab::GitalyClient::DiffStitcher)
each_gitaly_patch(&block) each_gitaly_patch(&block)
else else
each_rugged_patch(&block) each_serialized_patch(&block)
end
end end
@populated = true @populated = true
...@@ -118,7 +116,7 @@ module Gitlab ...@@ -118,7 +116,7 @@ module Gitlab
end end
end end
def each_rugged_patch def each_serialized_patch
i = @array.length i = @array.length
@iterator.each do |raw| @iterator.each do |raw|
......
...@@ -555,13 +555,7 @@ module Gitlab ...@@ -555,13 +555,7 @@ module Gitlab
# diff options. The +options+ hash can also include :break_rewrites to # diff options. The +options+ hash can also include :break_rewrites to
# split larger rewrites into delete/add pairs. # split larger rewrites into delete/add pairs.
def diff(from, to, options = {}, *paths) def diff(from, to, options = {}, *paths)
iterator = gitaly_migrate(:diff_between) do |is_enabled| iterator = gitaly_commit_client.diff(from, to, options.merge(paths: paths))
if is_enabled
gitaly_commit_client.diff(from, to, options.merge(paths: paths))
else
diff_patches(from, to, options, *paths)
end
end
Gitlab::Git::DiffCollection.new(iterator, options) Gitlab::Git::DiffCollection.new(iterator, options)
end end
......
...@@ -91,16 +91,12 @@ module Gitlab ...@@ -91,16 +91,12 @@ module Gitlab
end end
def send_git_diff(repository, diff_refs) def send_git_diff(repository, diff_refs)
params = if Gitlab::GitalyClient.feature_enabled?(:workhorse_send_git_diff, status: Gitlab::GitalyClient::MigrationStatus::OPT_OUT) params = {
{
'GitalyServer' => gitaly_server_hash(repository), 'GitalyServer' => gitaly_server_hash(repository),
'RawDiffRequest' => Gitaly::RawDiffRequest.new( 'RawDiffRequest' => Gitaly::RawDiffRequest.new(
gitaly_diff_or_patch_hash(repository, diff_refs) gitaly_diff_or_patch_hash(repository, diff_refs)
).to_json ).to_json
} }
else
workhorse_diff_or_patch_hash(repository, diff_refs)
end
[ [
SEND_DATA_HEADER, SEND_DATA_HEADER,
......
...@@ -143,7 +143,6 @@ describe Gitlab::Workhorse do ...@@ -143,7 +143,6 @@ describe Gitlab::Workhorse do
let(:diff_refs) { double(base_sha: "base", head_sha: "head") } let(:diff_refs) { double(base_sha: "base", head_sha: "head") }
subject { described_class.send_git_diff(repository, diff_refs) } subject { described_class.send_git_diff(repository, diff_refs) }
context 'when Gitaly workhorse_send_git_diff feature is enabled' do
it 'sets the header correctly' do it 'sets the header correctly' do
key, command, params = decode_workhorse_header(subject) key, command, params = decode_workhorse_header(subject)
...@@ -163,17 +162,6 @@ describe Gitlab::Workhorse do ...@@ -163,17 +162,6 @@ describe Gitlab::Workhorse do
end end
end end
context 'when Gitaly workhorse_send_git_diff feature is disabled', :disable_gitaly do
it 'sets the header correctly' do
key, command, params = decode_workhorse_header(subject)
expect(key).to eq("Gitlab-Workhorse-Send-Data")
expect(command).to eq("git-diff")
expect(params).to eq("RepoPath" => repository.path_to_repo, "ShaFrom" => "base", "ShaTo" => "head")
end
end
end
describe ".secret" do describe ".secret" do
subject { described_class.secret } subject { described_class.secret }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment