Module: Baykit::BayServer::Common::Multiplexer

Included in:
Agent::Multiplexer::MultiplexerBase
Defined in:
lib/baykit/bayserver/common/multiplexer.rb

Overview

interface

Instance Method Summary collapse

Instance Method Details

#add_rudder_state(rd, st) ⇒ Object

Raises:

  • (NotImplementedError) 


8
9
10
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 8

def add_rudder_state(rd, st)
  raise NotImplementedError.new
end

#cancel_read(st) ⇒ Object

Raises:

  • (NotImplementedError) 


48
49
50
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 48

def cancel_read(st)
  raise NotImplementedError.new
end

#cancel_write(st) ⇒ Object

Raises:

  • (NotImplementedError) 


52
53
54
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 52

def cancel_write(st)
  raise NotImplementedError.new
end

#close_rudder(st) ⇒ Object

Raises:

  • (NotImplementedError) 


84
85
86
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 84

def close_rudder(st)
  raise NotImplementedError.new
end

#consume_oldest_unit(st) ⇒ Object

Raises:

  • (NotImplementedError) 


80
81
82
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 80

def consume_oldest_unit(st)
  raise NotImplementedError.new
end

#get_rudder_state(rd) ⇒ Object

Raises:

  • (NotImplementedError) 


16
17
18
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 16

def get_rudder_state(rd)
  raise NotImplementedError.new
end

#get_transporter(rd) ⇒ Object

Raises:

  • (NotImplementedError) 


20
21
22
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 20

def get_transporter(rd)
  raise NotImplementedError.new
end

#is_busy ⇒ Object

Raises:

  • (NotImplementedError) 


88
89
90
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 88

def is_busy
  raise NotImplementedError.new
end

#is_non_blocking ⇒ Object

Raises:

  • (NotImplementedError) 


72
73
74
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 72

def is_non_blocking()
  raise NotImplementedError.new
end

#next_accept(st) ⇒ Object

Raises:

  • (NotImplementedError) 


56
57
58
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 56

def next_accept(st)
  raise NotImplementedError.new
end

#next_read(st) ⇒ Object

Raises:

  • (NotImplementedError) 


60
61
62
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 60

def next_read(st)
  raise NotImplementedError.new
end

#next_write(st) ⇒ Object

Raises:

  • (NotImplementedError) 


64
65
66
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 64

def next_write(st)
  raise NotImplementedError.new
end

#on_busy ⇒ Object

Raises:

  • (NotImplementedError) 


92
93
94
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 92

def on_busy
  raise NotImplementedError.new
end

#on_free ⇒ Object

Raises:

  • (NotImplementedError) 


96
97
98
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 96

def on_free
  raise NotImplementedError.new
end

#remove_rudder_state(rd) ⇒ Object

Raises:

  • (NotImplementedError) 


12
13
14
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 12

def remove_rudder_state(rd)
  raise NotImplementedError.new
end

#req_accept(rd) ⇒ Object

Raises:

  • (NotImplementedError) 


24
25
26
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 24

def req_accept(rd)
  raise NotImplementedError.new
end

#req_close(rd) ⇒ Object 



44
45
46
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 44

def req_close(rd)

end

#req_connect(rd, adr) ⇒ Object

Raises:

  • (NotImplementedError) 


28
29
30
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 28

def req_connect(rd, adr)
  raise NotImplementedError.new
end

#req_end(rd) ⇒ Object

Raises:

  • (NotImplementedError) 


40
41
42
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 40

def req_end(rd)
  raise NotImplementedError.new
end

#req_read(rd) ⇒ Object

Raises:

  • (NotImplementedError) 


32
33
34
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 32

def req_read(rd)
  raise NotImplementedError.new
end

#req_write(rd, buf, adr, tag, &lis) ⇒ Object

Raises:

  • (NotImplementedError) 


36
37
38
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 36

def req_write(rd, buf, adr, tag, &lis)
  raise NotImplementedError.new
end

#shutdown ⇒ Object

Raises:

  • (NotImplementedError) 


68
69
70
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 68

def shutdown()
  raise NotImplementedError.new
end

#use_async_api ⇒ Object

Raises:

  • (NotImplementedError) 


76
77
78
 
# File 'lib/baykit/bayserver/common/multiplexer.rb', line 76

def use_async_api()
  raise NotImplementedError.new
end