13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
# File 'lib/content_server/content_receiver.rb', line 13
def run
Socket.tcp_server_loop(@port) do |sock, client_addrinfo|
while size_of_data = sock.read(4)
size_of_data = size_of_data.unpack("l")[0]
Log.debug2("Size of data: %s", size_of_data)
data = sock.read(size_of_data)
unmarshaled_data = Marshal.load(data)
@queue.push unmarshaled_data
Log.debug2("Socket closed? %s.", sock.closed?)
break if sock.closed?
Log.debug2('Waiting on sock.read')
end
Log.debug2('Exited, socket closed or read returned nil.')
end
end
|