Module: Vertx::TCPSupport

Included in:
HttpClient
Defined in:
lib/vertx/tcp_support.rb

Overview

Mixin module that provides all the common TCP params that can be set.

Author:

Instance Method Summary collapse

Instance Method Details

#receive_buffer_size=(val) ⇒ Object

Set the TCP receive buffer size.

Parameters:

  • val. (FixNum)

    The size in bytes.

Returns:

  • A reference to self so invocations can be chained



43
44
45
46
# File 'lib/vertx/tcp_support.rb', line 43

def receive_buffer_size=(val)
  @j_del.setReceiveBufferSize(val)
  self
end

#reuse_address(val = nil) ⇒ Object

Set or get TCP reuse address for fluent API



85
86
87
88
89
90
91
92
# File 'lib/vertx/tcp_support.rb', line 85

def reuse_address(val = nil)
  if val
    @j_del.setReuseAddress(val)
    self
  else
    @j_del.isReuseAddress
  end
end

#reuse_address=(val) ⇒ Object

Set the TCP reuse address setting.

Parameters:

  • val. (Boolean)

    If true, then TCP reuse address will be enabled.

Returns:

  • A reference to self so invocations can be chained



79
80
81
82
# File 'lib/vertx/tcp_support.rb', line 79

def reuse_address=(val)
  @j_del.setReuseAddress(val)
  self
end

#send_buffer_size(val = nil) ⇒ Object

Set or get send buffer size for fluent API



31
32
33
34
35
36
37
38
# File 'lib/vertx/tcp_support.rb', line 31

def send_buffer_size(val = nil)
  if val
    @j_del.setSendBufferSize(val)
    self
  else
    @j_del.getSendBufferSize
  end
end

#send_buffer_size=(val) ⇒ Object

Set the TCP send buffer size.

Parameters:

  • val. (FixNum)

    The size in bytes.

Returns:

  • A reference to self so invocations can be chained



25
26
27
28
# File 'lib/vertx/tcp_support.rb', line 25

def send_buffer_size=(val)
  @j_del.setSendBufferSize(val)
  self
end

#send_receive_size(val = nil) ⇒ Object

Set or get send buffer size for fluent API



49
50
51
52
53
54
55
56
# File 'lib/vertx/tcp_support.rb', line 49

def send_receive_size(val = nil)
  if val
    @j_del.setReceiveBufferSize(val)
    self
  else
    @j_del.getReceiveBufferSize
  end
end

#so_linger(val = nil) ⇒ Object

Set or get TCP so linger for fluent API



103
104
105
106
107
108
109
110
# File 'lib/vertx/tcp_support.rb', line 103

def so_linger(val = nil)
  if val
    @j_del.setSoLinger(val)
    self
  else
    @j_del.getSoLinger
  end
end

#so_linger=(val) ⇒ Object

Set the TCP so linger setting.

Parameters:

  • val. (FixNum)

    Set TCP soLinger

Returns:

  • A reference to self so invocations can be chained



97
98
99
100
# File 'lib/vertx/tcp_support.rb', line 97

def so_linger=(val)
  @j_del.setSoLinger(val)
  self
end

#tcp_keep_alive(val = nil) ⇒ Object

Set or get TCP keep alive for fluent API



67
68
69
70
71
72
73
74
# File 'lib/vertx/tcp_support.rb', line 67

def tcp_keep_alive(val = nil)
  if val
    @j_del.setTCPKeepAlive(val)
    self
  else
    @j_del.getTCPKeepAlive
  end
end

#tcp_keep_alive=(val) ⇒ Object

Set the TCP keep alive setting.

Parameters:

  • val. (Boolean)

    If true, then TCP keep alive will be enabled.

Returns:

  • A reference to self so invocations can be chained



61
62
63
64
# File 'lib/vertx/tcp_support.rb', line 61

def tcp_keep_alive=(val)
  @j_del.setTCPKeepAlive(val)
  self
end

#traffic_class(val = nil) ⇒ Object

Set or get TCP traffic class for fluent API



121
122
123
124
125
126
127
128
# File 'lib/vertx/tcp_support.rb', line 121

def traffic_class(val = nil)
  if val
    @j_del.setTrafficClass(val)
    self
  else
    @j_del.getTrafficClass
  end
end

#traffic_class=(val) ⇒ Object

Set the TCP traffic class setting.

Parameters:

  • val. (FixNum)

    The TCP traffic class setting.

Returns:

  • A reference to self so invocations can be chained



115
116
117
118
# File 'lib/vertx/tcp_support.rb', line 115

def traffic_class=(val)
  @j_del.setTrafficClass(val)
  self
end

#use_pooled_buffers(val = nil) ⇒ Object

Set or get use_pooled_buffers for fluent API



139
140
141
142
143
144
145
146
# File 'lib/vertx/tcp_support.rb', line 139

def use_pooled_buffers(val = nil)
  if val
    @j_del.setUsePooledBuffers(val)
    self
  else
    @j_del.isUsePooledBuffers
  end
end

#use_pooled_buffers=(val) ⇒ Object

Set to use pooled buffers

Parameters:

  • val. (Boolean)

Returns:

  • A reference to self so invocations can be chained



133
134
135
136
# File 'lib/vertx/tcp_support.rb', line 133

def use_pooled_buffers=(val)
  @j_del.setUsedPooledBuffers(val)
  self
end