1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
|
# =XMPP4R - XMPP Library for Ruby
# License:: Ruby's license (see the LICENSE file) or GNU GPL, at your option.
# Website::http://xmpp4r.github.io
module Jabber
module Bytestreams
##
# Implementation of IBB at the target side
class IBBTarget < IBB
# You may read the block-size after accept
attr_reader :block_size
def initialize(stream, session_id, initiator_jid, target_jid)
# Target and Initiator are swapped here, because we're the target
super(stream, session_id, target_jid, initiator_jid)
@accept_ready = Semaphore::new
end
def accept_wait
@accept_ready.wait
end
##
# Wait for the initiator side to start
# the stream.
def accept
connect_sem = Semaphore.new
@stream.add_iq_callback(200, self) { |iq|
open = iq.first_element('open')
if iq.type == :set and iq.from == @peer_jid and iq.to == @my_jid and open and open.attributes['sid'] == @session_id
@stream.delete_iq_callback(self)
activate
@block_size = (open.attributes['block-size'] || 4096).to_i
reply = iq.answer(false)
reply.type = :result
@stream.send(reply)
connect_sem.run
true
else
false
end
}
@accept_ready.run
connect_sem.wait
true
end
end
end
end
|
