Revision 4afb2001
Added by Marc Dequènes over 13 years ago
- ID 4afb2001a4b374e656585a1bccdc629d94d74ad9
| lib/cyborghood/cyborg/protocol.rb | ||
|---|---|---|
|
end
|
||
|
end
|
||
|
|
||
|
# TODO: what is the peer close a thread i have opened ?
|
||
|
# send error to all actions ?
|
||
|
def receive_notify_thread_closed(message)
|
||
|
message.conv_thread.close(false)
|
||
|
end
|
||
|
|
||
|
def receive_notify_event(message)
|
||
|
# TODO
|
||
|
end
|
||
|
|
||
|
def receive_reply_ack(message)
|
||
|
# TODO
|
||
|
end
|
||
| ... | ... | |
|
recv_message.create_reply("ERROR ACTION", { :error => error }).send
|
||
|
end
|
||
|
|
||
|
def send_notify_thread_closed(conv_thread)
|
||
|
conv_thread.new_message("NOTIFY THREAD CLOSED").send
|
||
|
end
|
||
|
|
||
|
def send_notify_event(conv_thread, event_name, event_info)
|
||
|
conv_thread.new_message.create_reply("NOTIFY EVENT", { :name => event_name, :info => event_info }).send
|
||
|
end
|
||
|
|
||
|
def send_reply_ack(recv_message)
|
||
|
recv_message.create_reply("REPLY ACK").send
|
||
|
end
|
||
Also available in: Unified diff
[evol] preliminary work for NOTIFY: closed thread are handled but close too early in most situations yet (need request/reply tracking)