0

2 つのサーバー間にプロキシ クライアントがあります。メインサーバー S1 はインターネット上にあります。プロキシ クライアントと 2 番目のサーバー S2 は、同じイントラネット内にあります。S2からのデータを「そのまま」S1に転送する役割を担う次のコード(簡単にするために一部を省略)があります。

fsctimeout = 0.01

function send_data(sock, data, i, l)
    local p,err,q = sock:send(data, i, l)
    if(err == "timeout" and q ~= l) then
        fsctimeout = fsctimeout * 2
        sock:settimeout(fsctimeout)
        send_data(sock, data, q + 1, l)
        fsctimeout = fsctimeout / 2
        sock:settimeout(fsctimeout)
    end
end

while not e do

rect, _, st = socket.select({csc, fsc}, nil, .01) --csc is S1, fsc is S2 sockets.

    if(rect[fsc] ~= nil and csc ~= nil) then
        local data, err, part = fsc:receive(8192)
        if(data ~= nil) then
            send_data(csc, data, 1, data:len())
            totalBytesFromFP = totalBytesFromFP + data:len()
        end
        if(part ~= nil) then
            send_data(csc, part, 1, part:len())
            totalBytesFromFP = totalBytesFromFP + part:len()
        end
    end
 end

send_data送信がタイムアウトした場合、ソケットのタイムアウトを 2 倍にして再試行するように関数を作成しました。send_dataしかし、現在では、プログラムがデータの送信に成功せずに関数内でスタックすることがあります。ここで何ができますか?(1MB のファイルを送信しようとしてテストしていますが、少量のデータの場合、この問題は発生していないようです。)

4

1 に答える 1

0

「タイムアウト」エラーが発生した後に初めてタイムアウトを変更しますが、デフォルトsendではブロックされているため、タイムアウトは発生しません(タイムアウトすることはありません)。

csc:settimeout(fsctimeout)ループの前に追加するだけです。

于 2013-05-10T15:40:42.207 に答える