@@ -101,11 +101,10 @@ _EOC_
101101_EOC_
102102 } else {
103103 $new_http_server_config .= <<_EOC_ ;
104- sock:send('trigger dgram req')
104+ sock:send('trigger dgram req')
105105_EOC_
106106 }
107107
108-
109108 if (defined $block -> abort) {
110109 my $timeout = Test::Nginx::Util::parse_time($block -> timeout)
111110 // Test::Nginx::Util::timeout();
@@ -123,13 +122,13 @@ _EOC_
123122 || defined $block -> dgram_response
124123 || defined $block -> dgram_response_like)
125124 {
126- $new_http_server_config .= <<_EOC_ ;
127- local data, err = sock:receive()
128- if not data then
129- sock:close()
130- ngx.say("receive stream response error: ", err)
131- return
132- end
125+ $new_http_server_config .= <<_EOC_ ;
126+ local data, err = sock:receive()
127+ if not data then
128+ sock:close()
129+ ngx.say("receive stream response error: ", err)
130+ return
131+ end
133132_EOC_
134133 if (defined $block -> log_dgram_response) {
135134 $new_http_server_config .= <<_EOC_ ;
@@ -168,22 +167,22 @@ _EOC_
168167 }
169168
170169 $new_http_server_config .= <<_EOC_ ;
171- sock:send('trigger_dgram_req2')
170+ sock:send('trigger_dgram_req2')
172171_EOC_
173172
174173 if (defined $block -> response_body
175174 || defined $block -> response_body_like
176175 || defined $block -> dgram_response
177176 || defined $block -> dgram_response_like)
178177 {
179- $new_http_server_config .= <<_EOC_ ;
180- local data, err = sock:receive()
181- if not data then
182- sock:close()
183- ngx.say("receive stream response error: ", err)
184- return
185- end
186- ngx.print(data)
178+ $new_http_server_config .= <<_EOC_ ;
179+ local data, err = sock:receive()
180+ if not data then
181+ sock:close()
182+ ngx.say("receive stream response error: ", err)
183+ return
184+ end
185+ ngx.print(data)
187186_EOC_
188187 }
189188 }
@@ -201,24 +200,24 @@ _EOC_
201200 if (defined $dgram_req3 ) {
202201 my $file = gen_data_file($dgram_req3 );
203202 $new_http_server_config .= <<_EOC_ ;
204- local f = assert(io.open('$file ', 'r'))
205- local data = assert(f:read("*a"))
206- assert(f:close())
207- local bytes, err = sock:send(data)
208- if not bytes then
209- ngx.say("send stream request error: ", err)
210- return
211- end
203+ local f = assert(io.open('$file ', 'r'))
204+ local data = assert(f:read("*a"))
205+ assert(f:close())
206+ local bytes, err = sock:send(data)
207+ if not bytes then
208+ ngx.say("send stream request error: ", err)
209+ return
210+ end
212211_EOC_
213212 }
214213
215214 $new_http_server_config .= <<_EOC_ ;
216- sock:send('trigger_dgram_req3')
217- local data, err = sock:receive()
218- if not data then
219- ngx.say("receive stream response error: ", err)
220- return
221- end
215+ sock:send('trigger_dgram_req3')
216+ local data, err = sock:receive()
217+ if not data then
218+ ngx.say("receive stream response error: ", err)
219+ return
220+ end
222221_EOC_
223222
224223 if (defined $block -> response_body
@@ -227,13 +226,13 @@ _EOC_
227226 || defined $block -> dgram_response_like)
228227 {
229228 $new_http_server_config .= <<_EOC_ ;
230- local data, err = sock:receive()
231- if not data then
232- sock:close()
233- ngx.say("receive stream response error: ", err)
234- return
235- end
236- ngx.print(data)
229+ local data, err = sock:receive()
230+ if not data then
231+ sock:close()
232+ ngx.say("receive stream response error: ", err)
233+ return
234+ end
235+ ngx.print(data)
237236_EOC_
238237 }
239238 }
0 commit comments