clearlinux/uwsgi
2
0
Fork 0
mirror of https://github.com/clearlinux/uwsgi.git synced 2026-06-16 02:15:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

lua_plugin: no switch in 1st yield; async_id_get()

Browse Source 
If coroutine and async, do not switch until first yield of coroutine;
uwsgi.async_id_get() to get 'wsgi_req->async_id' in my app;
This commit is contained in:
Hleran
2015-07-31 01:03:40 +03:00
parent a0dc7fdcf9
commit f3bc21cf2b
1 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/lua/lua_plugin.c
+12 -1
View File
@@ -669,6 +669,15 @@ static int uwsgi_lua_input(lua_State *L) {
return 0;
}
static int uwsgi_api_async_id_get(lua_State *L) {
struct wsgi_request *wsgi_req = current_wsgi_req();
lua_pushnumber(L, wsgi_req->async_id);
return 1;
}
static const luaL_Reg uwsgi_api[] = {
{"log", uwsgi_api_log},
{"connection_fd", uwsgi_api_req_fd},
@@ -698,6 +707,7 @@ static const luaL_Reg uwsgi_api[] = {
{"async_sleep", uwsgi_api_async_sleep},
{"async_connect", uwsgi_api_async_connect},
{"async_id_get", uwsgi_api_async_id_get},
{"is_connected", uwsgi_api_is_connected},
{"close", uwsgi_api_close},
{"wait_fd_read", uwsgi_api_wait_fd_read},
@@ -856,6 +866,7 @@ static int uwsgi_lua_request(struct wsgi_request *wsgi_req) {
// wrong async_status status!
return -1;
}
async_coroutine:
while (lua_pcall(L, 0, 1, 0) == 0) {
if (lua_isstring(L, -1)) {
http = lua_tolstring(L, -1, &slen);
@@ -967,7 +978,7 @@ static int uwsgi_lua_request(struct wsgi_request *wsgi_req) {
if (lua_type(L, -1) == LUA_TFUNCTION) {
if (uwsgi.async > 0) {
return UWSGI_AGAIN;
goto async_coroutine;
}
while ( lua_pcall(L, 0, 1, 0) == 0) {