@@ -128,7 +128,7 @@ static int ngx_http_lua_socket_tcp_conn_op_resume_retval_handler(
128
128
ngx_http_request_t * r , ngx_http_lua_socket_tcp_upstream_t * u , lua_State * L );
129
129
static int ngx_http_lua_socket_tcp_upstream_destroy (lua_State * L );
130
130
static int ngx_http_lua_socket_downstream_destroy (lua_State * L );
131
- static ngx_int_t ngx_http_lua_socket_push_input_data (ngx_http_request_t * r ,
131
+ static void ngx_http_lua_socket_push_input_data (ngx_http_request_t * r ,
132
132
ngx_http_lua_ctx_t * ctx , ngx_http_lua_socket_tcp_upstream_t * u ,
133
133
lua_State * L );
134
134
static ngx_int_t ngx_http_lua_socket_add_pending_data (ngx_http_request_t * r ,
@@ -3200,12 +3200,7 @@ ngx_http_lua_socket_tcp_receive_retval_handler(ngx_http_request_t *r,
3200
3200
dd ("u->bufs_in: %p" , u -> bufs_in );
3201
3201
3202
3202
if (u -> bufs_in ) {
3203
- rc = ngx_http_lua_socket_push_input_data (r , ctx , u , L );
3204
- if (rc == NGX_ERROR ) {
3205
- lua_pushnil (L );
3206
- lua_pushliteral (L , "no memory" );
3207
- return 2 ;
3208
- }
3203
+ ngx_http_lua_socket_push_input_data (r , ctx , u , L );
3209
3204
3210
3205
(void ) ngx_http_lua_socket_read_error_retval_handler (r , u , L );
3211
3206
@@ -3219,12 +3214,7 @@ ngx_http_lua_socket_tcp_receive_retval_handler(ngx_http_request_t *r,
3219
3214
return n + 1 ;
3220
3215
}
3221
3216
3222
- rc = ngx_http_lua_socket_push_input_data (r , ctx , u , L );
3223
- if (rc == NGX_ERROR ) {
3224
- lua_pushnil (L );
3225
- lua_pushliteral (L , "no memory" );
3226
- return 2 ;
3227
- }
3217
+ ngx_http_lua_socket_push_input_data (r , ctx , u , L );
3228
3218
3229
3219
return 1 ;
3230
3220
}
@@ -5908,7 +5898,7 @@ ngx_http_lua_socket_downstream_destroy(lua_State *L)
5908
5898
}
5909
5899
5910
5900
5911
- static ngx_int_t
5901
+ static void
5912
5902
ngx_http_lua_socket_push_input_data (ngx_http_request_t * r ,
5913
5903
ngx_http_lua_ctx_t * ctx , ngx_http_lua_socket_tcp_upstream_t * u ,
5914
5904
lua_State * L )
@@ -5980,8 +5970,6 @@ ngx_http_lua_socket_push_input_data(ngx_http_request_t *r,
5980
5970
u -> buf_in -> buf -> last = u -> buffer .pos ;
5981
5971
u -> buf_in -> buf -> pos = u -> buffer .pos ;
5982
5972
}
5983
-
5984
- return NGX_OK ;
5985
5973
}
5986
5974
5987
5975
0 commit comments