858
858
859
859
-- Debugging {{{
860
860
861
- --[[
862
861
local function prepared_object_digest (prepared_object )
863
862
local json = require (' json' )
864
863
local digest = {
@@ -883,29 +882,30 @@ local function prepared_object_digest(prepared_object)
883
882
return json .encode (digest )
884
883
end
885
884
886
- local function print_open_set(open_set)
885
+ local function open_set_tostring (open_set , name )
886
+ local res = (' \n ==== %s ====\n ' ):format (name )
887
887
for _ , item in ipairs (open_set ) do
888
888
if item .prepared_object ~= nil then
889
889
local digest = prepared_object_digest (item .prepared_object )
890
- print('prepared_object : ' .. digest)
890
+ res = res .. ' \n prepared_object : ' .. digest
891
891
elseif item .prepared_object_list ~= nil then
892
- print('prepared_object_list:')
892
+ res = res .. ' \n prepared_object_list: '
893
893
for _ , prepared_object in ipairs (item .prepared_object_list ) do
894
894
local digest = prepared_object_digest (prepared_object )
895
- print(' ' .. digest)
895
+ res = res .. ' \n ' .. digest
896
896
end
897
897
elseif item .squash_marker ~= nil then
898
898
if item .fetch_id ~= nil then
899
- print('squash marker: ' .. tostring(item.fetch_id) )
899
+ res = res .. ' \n squash marker: ' .. tostring (item .fetch_id )
900
900
else
901
- print('squash marker')
901
+ res = res .. ' \n squash marker'
902
902
end
903
903
else
904
- print('unknown open_set item')
904
+ res = res .. ' \n unknown open_set item'
905
905
end
906
906
end
907
+ return res
907
908
end
908
- ]] --
909
909
910
910
-- }}}
911
911
@@ -980,14 +980,9 @@ function bfs_executor.execute(schema, query_ast, variables, operation_name, opts
980
980
table.insert (open_set , 1 , {squash_marker = true })
981
981
982
982
while true do
983
- --[[
984
- print('')
985
- print('==== cache only open set ====')
986
- print_open_set(cache_only_open_set)
987
- print('')
988
- print('==== open set ====')
989
- print_open_set(open_set)
990
- ]] --
983
+ utils .debug (open_set_tostring , cache_only_open_set ,
984
+ ' cache only open set' )
985
+ utils .debug (open_set_tostring , open_set , ' open set' )
991
986
992
987
local item
993
988
local is_item_cache_only = next (cache_only_open_set ) ~= nil
@@ -997,11 +992,7 @@ function bfs_executor.execute(schema, query_ast, variables, operation_name, opts
997
992
item = table.remove (open_set , 1 )
998
993
end
999
994
1000
- --[[
1001
- print('')
1002
- print('==== item (before) ====')
1003
- print_open_set({item})
1004
- ]] --
995
+ utils .debug (open_set_tostring , {item }, ' item (before)' )
1005
996
1006
997
if item == nil then break end
1007
998
if item .prepared_object ~= nil then
@@ -1035,11 +1026,7 @@ function bfs_executor.execute(schema, query_ast, variables, operation_name, opts
1035
1026
assert (false , ' unknown open_set item format' )
1036
1027
end
1037
1028
1038
- --[[
1039
- print('')
1040
- print('==== item (after) ====')
1041
- print_open_set({item})
1042
- ]] --
1029
+ utils .debug (open_set_tostring , {item }, ' item (after)' )
1043
1030
end
1044
1031
1045
1032
-- XXX: support several parallel graphql instances (use
0 commit comments