[checkmk-commits] Check_MK Git: check_mk: liveproxyd: fixed exception in error message

Module: check_mk Branch: master Commit: 7ba8c587fb473a5db72ef33c0eb2648e5d9724ed URL: http://git.mathias-kettner.de/git/?p=check_mk.git;a=commit;h=7ba8c587fb473a… Author: Mathias Kettner <mk(a)mathias-kettner.de> Date: Wed Oct 9 21:56:19 2013 +0200 liveproxyd: fixed exception in error message --- doc/treasures/liveproxy/liveproxyd | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/doc/treasures/liveproxy/liveproxyd b/doc/treasures/liveproxy/liveproxyd index 11c857c..def77b3 100755 --- a/doc/treasures/liveproxy/liveproxyd +++ b/doc/treasures/liveproxy/liveproxyd @@ -390,7 +390,7 @@ def receive_response(sitename, channel): client = channel.get("client") # None -> client timed out before response! if not client: log("Response from timed-out client arrived lately on channel %s/%d" % - sitename, channel["socket"].fileno()) + (sitename, channel["socket"].fileno())) # We always assume fixed16 as response header! old_response = channel.get("response", "") try: @@ -447,6 +447,9 @@ def receive_response(sitename, channel): del client["channel"] try: + # ACHTUNG: Beim senden an den Client können wir blockieren, wenn + # der Empfänger uns ausbremst. Dürfen wir aber nicht. Wir brauchen + # eine Queue, müssen mit select() warten, usw. client["socket"].send(response) # log("HIRN: An client: [%s]" % response[16:80].replace("\n", "")) client["state"] = "idle"