skynet.call请求被挂起的问题

[hankzzh]

A,B两个服务，在A执行

skynet.fork(function()
        skynet.call(B, "func1")
end)
skynet.fork(function()
        local now = skynet.time()                                                                                                                                                                                                            
        while true do                                                                                                                                                                                                                        
                if skynet.time() > now + 3 then                                                                                                                                                                                              
                        skynet.exit()                                                                                                                                                                                                        
                        break                                                                                                                                                                                                                
                end                                                                                                                                                                                                                          
        end 
end)
B服务func1的处理函数
function B.func1()
        skynet.call(A, "func2")
end

可以看到B服务被挂起，A服务器在exit退出的时候没有返回func2请求（func2函数可以是空函数）

这种情况正常吗？还是skynet本身在exit的时候没有处理C代码中的msg？
可否退出的时候对存储在c代码中的msg做flush处理？

这个bug今年1月份修复了，我用的23年6月的分支，结案，叨扰大家了

[cloudwu]

skynet.exit 退出时的处理逻辑见 https://github.com/cloudwu/skynet/blob/master/lualib/skynet.lua#L647

[hankzzh]

我理解中skynet.call一定会有返回，但是我上面的测试代码可以稳定复现skynet.call永久被挂起。
skynet.lua中exit函数只是处理了被lua代码dispatch后的call请求，c代码中没有被skynet_mq_pop出来的消息是否没有处理

[hankzzh]

服务被其他服务call的逻辑应该是
1.skynet_mq_push，插入被call的消息
2.skynet_context_dispatchall中调用skynet_mq_pop弹出消息，等待skynet.lua处理
3.skynet.lua的raw_dispatch_message函数，将被call的co存入session_coroutine_id
4.skynet.exit,清理未结束的session_coroutine_id

上面的测试代码使用lua卡死cpu处理，在第二步之前调用了skynet.exit。
c中skynet_server.c的{ "EXIT", cmd_exit }指令并未处理第一步被压入队列中的消息

[huahua132]

static void
drop_message(struct skynet_message *msg, void *ud) {
	struct drop_t *d = ud;
	skynet_free(msg->data);
	uint32_t source = d->handle;
	assert(source);
	// report error to the message source
	skynet_send(NULL, source, msg->source, PTYPE_ERROR, msg->session, NULL, 0);
}

服务退出时，未处理的消息会上报ERROR消息给来源方。

[hankzzh]

drop_message没有被调用，c没有机会dispatch。测试可以稳定复现挂起

[huahua132]

正常应该不会永远挂起才对

[hankzzh]

是的，call必须有返回是基础逻辑。所以没有返回才是问题

[huahua132]

local skynet = require "skynet"
local service = require "skynet.service"

local function serverA()
	local skynet = require "skynet.manager"
	local skynet_util = require "skynet-fly.utils.skynet_util"

	local CMD = {}

	function CMD.hello()
		skynet.error("hello")
	end


	skynet.fork(function()
		skynet.error("A call B begin")
		skynet.call('.B', 'lua', 'hello')
		skynet.error("A call B end")
	end)

	skynet.fork(function()
		local now = skynet.time()
		while true do
			if skynet.time() > now + 3 then
				skynet.exit()
				break
			end
		end
	end)

	skynet_util.lua_dispatch(CMD)
	skynet.register('.A')
end

local function serverB()
	local skynet = require "skynet.manager"
	local skynet_util = require "skynet-fly.utils.skynet_util"

	local CMD = {}

	function CMD.hello()
		skynet.error("B call A begin")
		skynet.call('.A', 'lua', 'hello')
		skynet.error("B call A end")
	end

	skynet_util.lua_dispatch(CMD)
	skynet.register('.B')
end

skynet.start(function()
	service.new("B", serverB)
	service.new("A", serverA)
end)

[:00000002][20240704 15:40:35 45]LAUNCH snlua bootstrap
[:00000003][20240704 15:40:35 46]LAUNCH snlua launcher
[:00000004][20240704 15:40:35 46]LAUNCH snlua cdummy
[:00000005][20240704 15:40:35 46]LAUNCH harbor 0 4
[:00000006][20240704 15:40:35 47]LAUNCH snlua datacenterd
[:00000007][20240704 15:40:35 47]LAUNCH snlua service_mgr
[:00000008][20240704 15:40:35 47]LAUNCH snlua service_provider
[:00000009][20240704 15:40:35 47]LAUNCH snlua service_cell ltls_holder
[:0000000a][20240704 15:40:35 48]LAUNCH snlua main
[:0000000b][20240704 15:40:35 48]LAUNCH snlua service_cell B
[:0000000c][20240704 15:40:35 48]LAUNCH snlua service_cell A
[:0000000c][20240704 15:40:35 49]A call B begin
[:0000000b][20240704 15:40:35 49]B call A begin
[:00000002][20240704 15:40:35 49]KILL self
[:0000000c][20240704 15:40:38 49]KILL self
[:0000000b][20240704 15:40:38 49]lua call [c to :b : 2 msgsz = 0] error : ../../skynet/lualib/skynet.lua:987: ../../skynet/lualib/skynet.lua:452: ../../skynet/lualib/skynet.lua:719: call failed
stack traceback:
        [C]: in function 'error'
        ../../skynet/lualib/skynet.lua:719: in upvalue 'yield_call'
        ../../skynet/lualib/skynet.lua:736: in function 'skynet.manager.call'
        ./main.lua:43: in local 'f'
        ../../lualib/skynet-fly/utils/skynet_util.lua:39: in upvalue 'f'
        ../../skynet/lualib/skynet.lua:402: in function <../../skynet/lualib/skynet.lua:374>
stack traceback:
        [C]: in function 'assert'
        ../../skynet/lualib/skynet.lua:987: in function 'skynet.manager.dispatch_message'

按照你的描述复写程序，被没有出现skynet.call永久被挂起

[hankzzh]

我这里确实可以稳定复现，麻烦用timeout包起来试一下

 skynet.timeout(100*3, function()
	skynet.fork(function()
		skynet.error("A call B begin")
		skynet.call('.B', 'lua', 'hello')
		skynet.error("A call B end")
	end)

	skynet.fork(function()
		local now = skynet.time()
		while true do
			if skynet.time() > now + 3 then
				skynet.exit()
				break
			end
		end
	end)
end)

[huahua132]

你可以用这样的方式包裹一下代码，不然格式难看，建议学一下markdown

[huahua132]

包裹了也没出

[hankzzh]

我的测试结果，我的包裹层有call前和call后的日志，B->A没有回调。等有空用skynet-fly和你的代码测试一下

161336.65 :00000012 DBG [gsp1:webworker:1@6=>(game1:.A)] begin #?> {"sz":6}
161336.65 :00000074 TRC [game1:A:0<=gsp1:webworker:1@6] handle_command#begin #?> {"args":"ps-6"}
161336.65 :00000074 TRC [game1:A:0=>gsp1:webworker:1@6] reply_command#begin #?> {"args":[]}
161336.65 :00000074 DBG [game1:A:0@1->(.:.B)] send_command#call#hello #?> {"args":[]}
161336.65 :00000075 TRC [game1:B:0<=game1:A:0@1] handle_command#hello #?> {"args":[]}
161336.65 :00000075 DBG [game1:B:0@1->(.:.A)] send_command#call#hello #?> {"args":[]}
161339.66 :00000074 SYS [(.:00000074)] system #?> KILL self

[hankzzh]

这个bug今年1月份修复了，我用的23年6月的分支，结案，叨扰大家了