"img" is not a valid locale
Extracted source (around line #343):
341
342
343
344
345
346
|
def enforce_available_locales!(locale)
if locale != false && config.enforce_available_locales
raise I18n::InvalidLocale.new(locale) if !locale_available?(locale)
end
end
|
Extracted source (around line #15):
13
14
15
16
17
18
|
# Sets the current locale pseudo-globally, i.e. in the Thread.current hash.
def locale=(locale)
I18n.enforce_available_locales!(locale)
@locale = locale && locale.to_sym
end
|
Extracted source (around line #268):
266
267
268
269
270
271
|
if value
config = I18n.config.respond_to?(:original_config) ? I18n.config.original_config : I18n.config
config.locale = value
end
super(default_locale)
|
Extracted source (around line #21):
19
20
21
22
23
24
|
def locale=(value)
@lookup_context.locale = value
end
end
|
Extracted source (around line #60):
58
59
60
61
62
63
|
def #{method}=(value)
config.#{method} = (value)
end
DELEGATORS
end
|
Extracted source (around line #26):
24
25
26
27
28
29
|
def set_locale
I18n.locale = params[:locale] || I18n.default_locale
@current_locale = I18n.locale
@ptypes = Ptype.where(public: true).order("ord asc")
|
Extracted source (around line #426):
424
425
426
427
428
429
|
lambda do |target, value, &block|
target, block, method, *arguments = expand(target, value, block)
target.send(method, *arguments, &block)
end
end
|
Extracted source (around line #198):
196
197
198
199
200
201
|
unless halted
result_lambda = -> { user_callback.call target, value }
env.halted = halted_lambda.call(target, result_lambda)
if env.halted
|
Extracted source (around line #34):
32
33
34
35
36
37
|
included do
define_callbacks :process_action,
terminator: ->(controller, result_lambda) { result_lambda.call; controller.performed? },
skip_after_callbacks_if_terminated: true
end
|
Extracted source (around line #199):
197
198
199
200
201
202
|
unless halted
result_lambda = -> { user_callback.call target, value }
env.halted = halted_lambda.call(target, result_lambda)
if env.halted
target.send :halted_callback_hook, filter
|
Extracted source (around line #513):
511
512
513
514
515
516
|
def invoke_before(arg)
@before.each { |b| b.call(arg) }
end
def invoke_after(arg)
|
Extracted source (around line #513):
511
512
513
514
515
516
|
def invoke_before(arg)
@before.each { |b| b.call(arg) }
end
def invoke_after(arg)
|
Extracted source (around line #513):
511
512
513
514
515
516
|
def invoke_before(arg)
@before.each { |b| b.call(arg) }
end
def invoke_after(arg)
|
Extracted source (around line #131):
129
130
131
132
133
134
|
# Common case: no 'around' callbacks defined
if next_sequence.final?
next_sequence.invoke_before(env)
env.value = !env.halted && (!block_given? || yield)
next_sequence.invoke_after(env)
env.value
|
Extracted source (around line #41):
39
40
41
42
43
44
|
# <tt>process_action</tt> callbacks around the normal behavior.
def process_action(*args)
run_callbacks(:process_action) do
super
end
end
|
Extracted source (around line #22):
20
21
22
23
24
25
|
private
def process_action(*args)
super
rescue Exception => exception
request.env["action_dispatch.show_detailed_exceptions"] ||= show_detailed_exceptions?
rescue_with_handler(exception) || raise
|
Extracted source (around line #34):
32
33
34
35
36
37
|
ActiveSupport::Notifications.instrument("process_action.action_controller", raw_payload) do |payload|
begin
result = super
payload[:status] = response.status
result
ensure
|
Extracted source (around line #168):
166
167
168
169
170
171
|
def instrument(name, payload = {})
if notifier.listening?(name)
instrumenter.instrument(name, payload) { yield payload if block_given? }
else
yield payload if block_given?
end
|
Extracted source (around line #23):
21
22
23
24
25
26
|
listeners_state = start name, payload
begin
yield payload
rescue Exception => e
payload[:exception] = [e.class.name, e.message]
payload[:exception_object] = e
|
Extracted source (around line #168):
166
167
168
169
170
171
|
def instrument(name, payload = {})
if notifier.listening?(name)
instrumenter.instrument(name, payload) { yield payload if block_given? }
else
yield payload if block_given?
end
|
Extracted source (around line #32):
30
31
32
33
34
35
|
ActiveSupport::Notifications.instrument("start_processing.action_controller", raw_payload.dup)
ActiveSupport::Notifications.instrument("process_action.action_controller", raw_payload) do |payload|
begin
result = super
payload[:status] = response.status
|
Extracted source (around line #256):
254
255
256
257
258
259
|
request.filtered_parameters.merge! wrapped_filtered_hash
end
super
end
private
|
Extracted source (around line #24):
22
23
24
25
26
27
|
# and it won't be cleaned up by the method below.
ActiveRecord::LogSubscriber.reset_runtime
super
end
def cleanup_view_runtime
|
Extracted source (around line #134):
132
133
134
135
136
137
|
@_response_body = nil
process_action(action_name, *args)
end
# Delegates to the class' ::controller_path
|
Extracted source (around line #32):
30
31
32
33
34
35
|
def process(*) #:nodoc:
old_config, I18n.config = I18n.config, I18nProxy.new(I18n.config, lookup_context)
super
ensure
I18n.config = old_config
end
|
Extracted source (around line #191):
189
190
191
192
193
194
|
set_request!(request)
set_response!(response)
process(name)
request.commit_flash
to_a
end
|
Extracted source (around line #252):
250
251
252
253
254
255
|
middleware_stack.build(name) { |env| new.dispatch(name, req, res) }.call req.env
else
new.dispatch(name, req, res)
end
end
end
|
Extracted source (around line #52):
50
51
52
53
54
55
|
def dispatch(controller, action, req, res)
controller.dispatch(action, req, res)
end
end
|
Extracted source (around line #34):
32
33
34
35
36
37
|
controller = controller req
res = controller.make_response! req
dispatch(controller, params[:action], req, res)
rescue ActionController::RoutingError
if @raise_on_name_error
raise
|
Extracted source (around line #52):
50
51
52
53
54
55
|
req.path_parameters = set_params.merge parameters
status, headers, body = route.app.serve(req)
if "pass" == headers["X-Cascade"]
req.script_name = script_name
|
Extracted source (around line #35):
33
34
35
36
37
38
|
def serve(req)
find_routes(req).each do |match, parameters, route|
set_params = req.path_parameters
path_info = req.path_info
script_name = req.script_name
|
Extracted source (around line #35):
33
34
35
36
37
38
|
def serve(req)
find_routes(req).each do |match, parameters, route|
set_params = req.path_parameters
path_info = req.path_info
script_name = req.script_name
|
Extracted source (around line #840):
838
839
840
841
842
843
|
req = make_request(env)
req.path_info = Journey::Router::Utils.normalize_path(req.path_info)
@router.serve(req)
end
def recognize_path(path, environment = {})
|
Extracted source (around line #36):
34
35
36
37
38
39
|
result = catch(:warden) do
env['warden'].on_request
@app.call(env)
end
result ||= {}
|
Extracted source (around line #34):
32
33
34
35
36
37
|
env['warden'] = Proxy.new(env, self)
result = catch(:warden) do
env['warden'].on_request
@app.call(env)
end
|
Extracted source (around line #34):
32
33
34
35
36
37
|
env['warden'] = Proxy.new(env, self)
result = catch(:warden) do
env['warden'].on_request
@app.call(env)
end
|
Extracted source (around line #15):
13
14
15
16
17
18
|
def call(env)
env[RACK_TEMPFILES] ||= []
status, headers, body = @app.call(env)
body_proxy = BodyProxy.new(body) do
env[RACK_TEMPFILES].each(&:close!) unless env[RACK_TEMPFILES].nil?
end
|
Extracted source (around line #27):
25
26
27
28
29
30
|
def call(env)
status, headers, body = @app.call(env)
if etag_status?(status) && etag_body?(body) && !skip_caching?(headers)
original_body = body
|
Extracted source (around line #27):
25
26
27
28
29
30
|
case env[REQUEST_METHOD]
when "GET", "HEAD"
status, headers, body = @app.call(env)
headers = Utils::HeaderHash[headers]
if status == 200 && fresh?(env, headers)
status = 304
|
Extracted source (around line #12):
10
11
12
13
14
15
|
def call(env)
status, headers, body = @app.call(env)
if env[REQUEST_METHOD] == HEAD
[
|
Extracted source (around line #18):
16
17
18
19
20
21
|
def call(env)
request = ActionDispatch::Request.new env
_, headers, _ = response = @app.call(env)
return response unless html_response?(headers)
return response if policy_present?(headers)
|
Extracted source (around line #266):
264
265
266
267
268
269
|
req = make_request env
prepare_session(req)
status, headers, body = app.call(req.env)
res = Rack::Response::Raw.new status, headers
commit_session(req, res)
[status, headers, body]
|
Extracted source (around line #260):
258
259
260
261
262
263
|
def call(env)
context(env)
end
def context(env, app = @app)
|
Extracted source (around line #670):
668
669
670
671
672
673
|
request = ActionDispatch::Request.new env
status, headers, body = @app.call(env)
if request.have_cookie_jar?
cookie_jar = request.cookie_jar
|
Extracted source (around line #28):
26
27
28
29
30
31
|
result = run_callbacks :call do
begin
@app.call(env)
rescue => error
end
end
|
Extracted source (around line #98):
96
97
98
99
100
101
|
if callbacks.empty?
yield if block_given?
else
env = Filters::Environment.new(self, false, nil)
next_sequence = callbacks.compile
|
Extracted source (around line #26):
24
25
26
27
28
29
|
def call(env)
error = nil
result = run_callbacks :call do
begin
@app.call(env)
rescue => error
|
Extracted source (around line #61):
59
60
61
62
63
64
|
def call(env)
request = ActionDispatch::Request.new env
_, headers, body = response = @app.call(env)
if headers["X-Cascade"] == "pass"
body.close if body.respond_to?(:close)
|
Extracted source (around line #33):
31
32
33
34
35
36
|
def call(env)
request = ActionDispatch::Request.new env
@app.call(env)
rescue Exception => exception
if request.show_exceptions?
render_exception(request, exception)
|
Extracted source (around line #38):
36
37
38
39
40
41
|
instrumenter.start "request.action_dispatch", request: request
logger.info { started_request_message(request) }
status, headers, body = @app.call(env)
body = ::Rack::BodyProxy.new(body) { finish(request) }
[status, headers, body]
rescue Exception
|
Extracted source (around line #26):
24
25
26
27
28
29
|
if logger.respond_to?(:tagged)
logger.tagged(compute_tags(request)) { call_app(request, env) }
else
call_app(request, env)
end
|
Extracted source (around line #71):
69
70
71
72
73
74
|
def tagged(*tags)
formatter.tagged(*tags) { yield self }
end
def flush
|
Extracted source (around line #28):
26
27
28
29
30
31
|
def tagged(*tags)
new_tags = push_tags(*tags)
yield self
ensure
pop_tags(new_tags.size)
end
|
Extracted source (around line #71):
69
70
71
72
73
74
|
def tagged(*tags)
formatter.tagged(*tags) { yield self }
end
def flush
|
Extracted source (around line #26):
24
25
26
27
28
29
|
if logger.respond_to?(:tagged)
logger.tagged(compute_tags(request)) { call_app(request, env) }
else
call_app(request, env)
end
|
Extracted source (around line #81):
79
80
81
82
83
84
|
req = ActionDispatch::Request.new env
req.remote_ip = GetIp.new(req, check_ip, proxies)
@app.call(req.env)
end
# The GetIp class exists as a way to defer processing of the request data
|
Extracted source (around line #19):
17
18
19
20
21
22
|
RequestStore.begin!
response = @app.call(env)
returned = response << Rack::BodyProxy.new(response.pop) do
RequestStore.end!
|
Extracted source (around line #27):
25
26
27
28
29
30
|
req = ActionDispatch::Request.new env
req.request_id = make_request_id(req.x_request_id)
@app.call(env).tap { |_status, headers, _body| headers[X_REQUEST_ID] = req.request_id }
end
private
|
Extracted source (around line #24):
22
23
24
25
26
27
|
end
@app.call(env)
end
def method_override(env)
|
Extracted source (around line #22):
20
21
22
23
24
25
|
def call(env)
start_time = Utils.clock_time
status, headers, body = @app.call(env)
headers = Utils::HeaderHash[headers]
request_time = Utils.clock_time - start_time
|
Extracted source (around line #29):
27
28
29
30
31
32
|
def call(env)
LocalCacheRegistry.set_cache_for(local_cache_key, LocalStore.new)
response = @app.call(env)
response[2] = ::Rack::BodyProxy.new(response[2]) do
LocalCacheRegistry.set_cache_for(local_cache_key, nil)
end
|
Extracted source (around line #24):
22
23
24
25
26
27
|
return rack_response unless rack_response === true
end
@app.call(env)
end
private
|
Extracted source (around line #14):
12
13
14
15
16
17
|
state = @executor.run!
begin
response = @app.call(env)
returned = response << ::Rack::BodyProxy.new(response.pop) { state.complete! }
ensure
state.complete! unless returned
|
Extracted source (around line #127):
125
126
127
128
129
130
|
end
@app.call(req.env)
end
end
end
|
Extracted source (around line #110):
108
109
110
111
112
113
|
def call(env)
status, headers, body = @app.call(env)
if body.respond_to?(:to_path)
case type = variation(env)
when 'X-Accel-Redirect'
|
Extracted source (around line #524):
522
523
524
525
526
527
|
def call(env)
req = build_request env
app.call req.env
end
# Defines additional Rack env configuration that is added on each call.
|
Extracted source (around line #190):
188
189
190
191
192
193
|
def method_missing(name, *args, &block)
if instance.respond_to?(name)
instance.public_send(name, *args, &block)
else
super
end
|
Extracted source (around line #190):
188
189
190
191
192
193
|
def method_missing(name, *args, &block)
if instance.respond_to?(name)
instance.public_send(name, *args, &block)
else
super
end
|
Extracted source (around line #545):
543
544
545
546
547
548
|
# in 3 easy steps: read request, call app, write app response
def process_client(client)
status, headers, body = @app.call(env = @request.read(client))
if 100 == status.to_i
client.write(Unicorn::Const::EXPECT_100_RESPONSE)
|
Extracted source (around line #623):
621
622
623
624
625
626
|
ready.each do |sock|
if client = sock.kgio_tryaccept
process_client(client)
nr += 1
alive.chmod(m = 0 == m ? 1 : 0)
end
|
Extracted source (around line #621):
619
620
621
622
623
624
|
alive.chmod(m = 0 == m ? 1 : 0)
ready.each do |sock|
if client = sock.kgio_tryaccept
process_client(client)
nr += 1
|
Extracted source (around line #621):
619
620
621
622
623
624
|
alive.chmod(m = 0 == m ? 1 : 0)
ready.each do |sock|
if client = sock.kgio_tryaccept
process_client(client)
nr += 1
|
Extracted source (around line #509):
507
508
509
510
511
512
|
WORKERS[fork {
after_fork_internal
worker_loop(worker)
}] = worker
end
end
|
Extracted source (around line #507):
505
506
507
508
509
510
|
worker = Worker.new(worker_nr, Unicorn::TmpIO.new)
before_fork.call(self, worker)
WORKERS[fork {
after_fork_internal
worker_loop(worker)
}] = worker
|
Extracted source (around line #507):
505
506
507
508
509
510
|
worker = Worker.new(worker_nr, Unicorn::TmpIO.new)
before_fork.call(self, worker)
WORKERS[fork {
after_fork_internal
worker_loop(worker)
}] = worker
|
Extracted source (around line #9):
7
8
9
10
11
12
|
def each(&block)
ensure_iteration_allowed
super
end
def step(n = 1, &block)
|
Extracted source (around line #9):
7
8
9
10
11
12
|
def each(&block)
ensure_iteration_allowed
super
end
def step(n = 1, &block)
|
Extracted source (around line #503):
501
502
503
504
505
506
|
def spawn_missing_workers
(0...worker_processes).each do |worker_nr|
WORKERS.values.include?(worker_nr) and next
worker = Worker.new(worker_nr, Unicorn::TmpIO.new)
before_fork.call(self, worker)
|
Extracted source (around line #516):
514
515
516
517
518
519
|
def maintain_worker_count
(off = WORKERS.size - worker_processes) == 0 and return
off < 0 and return spawn_missing_workers
WORKERS.dup.each_pair { |wpid,w|
w.nr >= worker_processes and kill_worker(:QUIT, wpid) rescue nil
}
|
Extracted source (around line #166):
164
165
166
167
168
169
|
self.master_pid = $$
build_app! if preload_app
maintain_worker_count
self
end
|
Extracted source (around line #30):
28
29
30
31
32
33
|
# :stopdoc:
def self.run(app, options = {})
Unicorn::HttpServer.new(app, options).start.join
end
# This returns a lambda to pass in as the app, this does not "build" the
|
Extracted source (around line #208):
206
207
208
|
Unicorn::Launcher.daemonize!(options)
end
Unicorn.run(app, options)
|
Extracted source (around line #23):
21
22
23
24
25
26
|
if Gem.respond_to?(:activate_bin_path)
load Gem.activate_bin_path('unicorn', 'unicorn_rails', version)
else
gem "unicorn", version
load Gem.bin_path("unicorn", "unicorn_rails", version)
|
Extracted source (around line #23):
21
22
23
24
25
26
|
if Gem.respond_to?(:activate_bin_path)
load Gem.activate_bin_path('unicorn', 'unicorn_rails', version)
else
gem "unicorn", version
load Gem.bin_path("unicorn", "unicorn_rails", version)
|
Extracted source (around line #24):
22
23
24
25
|
eval content, binding, $0, start_line
else
eval content, binding, $0
end
|
Extracted source (around line #24):
22
23
24
25
|
eval content, binding, $0, start_line
else
eval content, binding, $0
end
|
Rails.root: /var/www/admin/www/tavfoods/current
Request
Parameters:
{"locale"=>"img", "url"=>"3299e4e542592495425924954259", "format"=>"jpg"}
cart: #<Cart:0x000055f43a21f5f0 @items=[], @deliver=0, @coupon=0, @coupon_val="", @push=0>
HTTP_ACCEPT: "*/*"
HTTP_VERSION: "HTTP/1.0"
HTTP_X_FORWARDED_FOR: "54.163.62.42"
ORIGINAL_SCRIPT_NAME: ""
REMOTE_ADDR: "127.0.0.1"
SERVER_NAME: "tavfoods.ru"
SERVER_PROTOCOL: "HTTP/1.0"
Response
Headers:
None