@@ -1096,8 +1096,8 @@ ngx_stream_lua_socket_udp_receive(lua_State *L)
1096
1096
ngx_stream_lua_srv_conf_t * lscf ;
1097
1097
1098
1098
nargs = lua_gettop (L );
1099
- if (nargs != 1 ) {
1100
- return luaL_error (L , "expecting 1 arguments "
1099
+ if (nargs != 1 && nargs != 2 ) {
1100
+ return luaL_error (L , "expecting 1 or 2 arguments "
1101
1101
"(including the object), but got %d" , nargs );
1102
1102
}
1103
1103
@@ -1161,14 +1161,15 @@ ngx_stream_lua_socket_udp_receive(lua_State *L)
1161
1161
1162
1162
if (u -> raw_downstream && !u -> connected ) {
1163
1163
u -> received = c -> buffer -> last - c -> buffer -> pos ;
1164
- c -> buffer -> pos = ngx_copy (ngx_stream_lua_socket_udp_buffer ,
1165
- c -> buffer -> pos , u -> received );
1166
- ngx_stream_lua_socket_udp_handle_success (s , u );
1167
- u -> connected = 1 ;
1168
- rc = NGX_OK ;
1164
+ c -> buffer -> pos =
1165
+ ngx_copy (ngx_stream_lua_socket_udp_buffer , c -> buffer -> pos ,
1166
+ u -> received );
1167
+ ngx_stream_lua_socket_udp_handle_success (s , u );
1168
+ u -> connected = 1 ;
1169
+ rc = NGX_OK ;
1169
1170
1170
1171
} else {
1171
- rc = ngx_stream_lua_socket_udp_read (s , u );
1172
+ rc = ngx_stream_lua_socket_udp_read (s , u );
1172
1173
}
1173
1174
1174
1175
if (rc == NGX_ERROR ) {
@@ -1507,8 +1508,9 @@ ngx_stream_lua_socket_udp_handler(ngx_event_t *ev)
1507
1508
c = ev -> data ;
1508
1509
u = c -> data ;
1509
1510
s = u -> session ;
1511
+ c = s -> connection ;
1510
1512
1511
- ngx_log_debug1 (NGX_LOG_DEBUG_STREAM , s -> connection -> log , 0 ,
1513
+ ngx_log_debug1 (NGX_LOG_DEBUG_STREAM , c -> log , 0 ,
1512
1514
"stream lua udp socket handler, wev %d" , (int ) ev -> write );
1513
1515
1514
1516
u -> read_event_handler (s , u );
0 commit comments