backup/EWF
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Use socket .._noexception functions in websocket networking.

Browse Source
This commit is contained in:
Jocelyn FIAT
2016-10-13 21:55:53 +02:00
parent b84f4838f5
commit 1e4203111f
1 changed files with 23 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
library/server/wsf/connector/standalone_websocket/websocket/web_socket.e
View File

@@ -255,31 +255,33 @@ feature -- Response!
else else
l_header_message.append_code (n.as_natural_32) l_header_message.append_code (n.as_natural_32)
end end
socket.put_string (l_header_message) socket.put_string_8_noexception (l_header_message)
if not socket.was_error then
l_chunk_size := 16_384 -- 16K TODO: see if we should make it customizable. l_chunk_size := 16_384 -- 16K TODO: see if we should make it customizable.
if l_message_count < l_chunk_size then if l_message_count < l_chunk_size then
socket.put_string (a_message) socket.put_string_8_noexception (a_message)
else else
from from
i := 0 i := 0
until until
l_chunk_size = 0 l_chunk_size = 0 or socket.was_error
loop loop
debug ("ws")
print ("Sending chunk " + (i + 1).out + " -> " + (i + l_chunk_size).out +" / " + l_message_count.out + "%N")
end
l_chunk := a_message.substring (i + 1, l_message_count.min (i + l_chunk_size))
socket.put_string_8_noexception (l_chunk)
if l_chunk.count < l_chunk_size then
l_chunk_size := 0
end
i := i + l_chunk_size
end
debug ("ws") debug ("ws")
print ("Sending chunk " + (i + 1).out + " -> " + (i + l_chunk_size).out +" / " + l_message_count.out + "%N") print ("Sending chunk done%N")
end end
l_chunk := a_message.substring (i + 1, l_message_count.min (i + l_chunk_size))
socket.put_string (l_chunk)
if l_chunk.count < l_chunk_size then
l_chunk_size := 0
end
i := i + l_chunk_size
end
debug ("ws")
print ("Sending chunk done%N")
end end
end end
else else
-- FIXME: what should be done on rescue? -- FIXME: what should be done on rescue?
end end