Skip to content
Discussion options

You must be logged in to vote

@konikb can you replace verify_concurentcalls to below and retry?

function verify_concurentcalls(name, direction, uuid)
    -- unlimited/bypass cps check
    local max_concurentcalls = get_defined_concurentcalls(name, direction)
    if max_concurentcalls < 0 then
        return -math.huge, -1
    end

    local cckeys = concurentcallskeys(name)
    local replies = rdbconn:transaction({watch=cckeys, cas=true, retry=0}, function(txn)
        txn:multi()
        if direction == INBOUND then
            txn:sadd('realtime:concurentcalls:'..name..':'..NODEID, uuid)
        end
        for i=1, #cckeys do
            txn:scard(cckeys[i])
        end
    end)

    local startpoint = ((direction == 

Replies: 2 comments 1 reply

Comment options

You must be logged in to vote
1 reply
@hnimminh
Comment options

Answer selected by hnimminh
Comment options

You must be logged in to vote
0 replies
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Category
Q&A
Labels
None yet
2 participants