1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20 package org.apache.mina.transport.socket.apr;
21
22 import java.net.InetSocketAddress;
23
24 import org.apache.mina.core.RuntimeIoException;
25 import org.apache.mina.core.buffer.IoBuffer;
26 import org.apache.mina.core.service.DefaultTransportMetadata;
27 import org.apache.mina.core.service.IoProcessor;
28 import org.apache.mina.core.service.IoService;
29 import org.apache.mina.core.service.TransportMetadata;
30 import org.apache.mina.core.session.IoSession;
31 import org.apache.mina.transport.socket.AbstractDatagramSessionConfig;
32 import org.apache.mina.transport.socket.DatagramSessionConfig;
33 import org.apache.tomcat.jni.Socket;
34
35
36
37
38
39
40
41
42 class AprDatagramSession extends AprSession {
43
44 static final TransportMetadata METADATA =
45 new DefaultTransportMetadata(
46 "apr", "datagram", true, false,
47 InetSocketAddress.class,
48 DatagramSessionConfig.class, IoBuffer.class);
49
50 private final DatagramSessionConfig config = new SessionConfigImpl();
51
52
53
54
55
56
57 AprDatagramSession(
58 IoService service, IoProcessor<AprSession> processor,
59 long descriptor, InetSocketAddress remoteAddress) throws Exception {
60 super(service, processor, descriptor, remoteAddress);
61 this.config.setAll(service.getSessionConfig());
62 }
63
64
65
66
67 public DatagramSessionConfig getConfig() {
68 return config;
69 }
70
71
72
73
74 public TransportMetadata getTransportMetadata() {
75 return METADATA;
76 }
77
78
79
80
81
82 private class SessionConfigImpl extends AbstractDatagramSessionConfig {
83
84
85
86 public boolean isReuseAddress() {
87 try {
88 return Socket.optGet(getDescriptor(), Socket.APR_SO_REUSEADDR) == 1;
89 } catch (Exception e) {
90 throw new RuntimeIoException("Failed to get SO_REUSEADDR.", e);
91 }
92 }
93
94
95
96
97 public void setReuseAddress(boolean on) {
98 Socket.optSet(getDescriptor(), Socket.APR_SO_REUSEADDR, on ? 1 : 0);
99 }
100
101
102
103
104 public int getTrafficClass() {
105 return 0;
106 }
107
108
109
110
111 public void setTrafficClass(int tc) {
112 }
113
114
115
116
117 public int getSendBufferSize() {
118 try {
119 return Socket.optGet(getDescriptor(), Socket.APR_SO_SNDBUF);
120 } catch (Exception e) {
121 throw new RuntimeException("APR Exception", e);
122 }
123 }
124
125
126
127
128 public void setSendBufferSize(int size) {
129 Socket.optSet(getDescriptor(), Socket.APR_SO_SNDBUF, size);
130 }
131
132
133
134
135 public int getReceiveBufferSize() {
136 try {
137 return Socket.optGet(getDescriptor(), Socket.APR_SO_RCVBUF);
138 } catch (Exception e) {
139 throw new RuntimeException("APR Exception", e);
140 }
141 }
142
143
144
145
146 public void setReceiveBufferSize(int size) {
147 Socket.optSet(getDescriptor(), Socket.APR_SO_RCVBUF, size);
148 }
149
150
151
152
153 public boolean isBroadcast() {
154 return false;
155 }
156
157
158
159
160 public void setBroadcast(boolean broadcast) {
161 }
162 }
163 }