Skip to content

Commit

Permalink
styling
Browse files Browse the repository at this point in the history
  • Loading branch information
alonbg committed Aug 23, 2016
1 parent 9f65bb9 commit f1b827d
Showing 1 changed file with 38 additions and 39 deletions.
77 changes: 38 additions & 39 deletions lib/Test/Nginx/Socket/Lua/Dgram.pm
Original file line number Diff line number Diff line change
Expand Up @@ -101,11 +101,10 @@ _EOC_
_EOC_
} else {
$new_http_server_config .= <<_EOC_;
sock:send('trigger dgram req')
sock:send('trigger dgram req')
_EOC_
}


if (defined $block->abort) {
my $timeout = Test::Nginx::Util::parse_time($block->timeout)
// Test::Nginx::Util::timeout();
Expand All @@ -123,13 +122,13 @@ _EOC_
|| defined $block->dgram_response
|| defined $block->dgram_response_like)
{
$new_http_server_config .= <<_EOC_;
local data, err = sock:receive()
if not data then
sock:close()
ngx.say("receive stream response error: ", err)
return
end
$new_http_server_config .= <<_EOC_;
local data, err = sock:receive()
if not data then
sock:close()
ngx.say("receive stream response error: ", err)
return
end
_EOC_
if (defined $block->log_dgram_response) {
$new_http_server_config .= <<_EOC_;
Expand Down Expand Up @@ -168,22 +167,22 @@ _EOC_
}

$new_http_server_config .= <<_EOC_;
sock:send('trigger_dgram_req2')
sock:send('trigger_dgram_req2')
_EOC_

if (defined $block->response_body
|| defined $block->response_body_like
|| defined $block->dgram_response
|| defined $block->dgram_response_like)
{
$new_http_server_config .= <<_EOC_;
local data, err = sock:receive()
if not data then
sock:close()
ngx.say("receive stream response error: ", err)
return
end
ngx.print(data)
$new_http_server_config .= <<_EOC_;
local data, err = sock:receive()
if not data then
sock:close()
ngx.say("receive stream response error: ", err)
return
end
ngx.print(data)
_EOC_
}
}
Expand All @@ -201,24 +200,24 @@ _EOC_
if (defined $dgram_req3) {
my $file = gen_data_file($dgram_req3);
$new_http_server_config .= <<_EOC_;
local f = assert(io.open('$file', 'r'))
local data = assert(f:read("*a"))
assert(f:close())
local bytes, err = sock:send(data)
if not bytes then
ngx.say("send stream request error: ", err)
return
end
local f = assert(io.open('$file', 'r'))
local data = assert(f:read("*a"))
assert(f:close())
local bytes, err = sock:send(data)
if not bytes then
ngx.say("send stream request error: ", err)
return
end
_EOC_
}

$new_http_server_config .= <<_EOC_;
sock:send('trigger_dgram_req3')
local data, err = sock:receive()
if not data then
ngx.say("receive stream response error: ", err)
return
end
sock:send('trigger_dgram_req3')
local data, err = sock:receive()
if not data then
ngx.say("receive stream response error: ", err)
return
end
_EOC_

if (defined $block->response_body
Expand All @@ -227,13 +226,13 @@ _EOC_
|| defined $block->dgram_response_like)
{
$new_http_server_config .= <<_EOC_;
local data, err = sock:receive()
if not data then
sock:close()
ngx.say("receive stream response error: ", err)
return
end
ngx.print(data)
local data, err = sock:receive()
if not data then
sock:close()
ngx.say("receive stream response error: ", err)
return
end
ngx.print(data)
_EOC_
}
}
Expand Down

0 comments on commit f1b827d

Please sign in to comment.