BUG-58: refactor to take advantage of netty
[bgpcep.git] / pcep / impl / src / test / java / org / opendaylight / protocol / pcep / impl / ServerSessionMock.java
1 /*
2  * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
3  *
4  * This program and the accompanying materials are made available under the
5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6  * and is available at http://www.eclipse.org/legal/epl-v10.html
7  */
8 package org.opendaylight.protocol.pcep.impl;
9
10 import io.netty.buffer.ByteBufAllocator;
11 import io.netty.channel.Channel;
12 import io.netty.channel.ChannelConfig;
13 import io.netty.channel.ChannelFuture;
14 import io.netty.channel.ChannelMetadata;
15 import io.netty.channel.ChannelPipeline;
16 import io.netty.channel.ChannelProgressivePromise;
17 import io.netty.channel.ChannelPromise;
18 import io.netty.channel.EventLoop;
19 import io.netty.util.Attribute;
20 import io.netty.util.AttributeKey;
21 import io.netty.util.HashedWheelTimer;
22
23 import java.net.SocketAddress;
24
25 import org.opendaylight.protocol.pcep.PCEPCloseTermination;
26 import org.opendaylight.protocol.pcep.PCEPMessage;
27 import org.opendaylight.protocol.pcep.PCEPSessionListener;
28 import org.opendaylight.protocol.pcep.object.PCEPCloseObject.Reason;
29 import org.opendaylight.protocol.pcep.object.PCEPOpenObject;
30
31 public class ServerSessionMock extends PCEPSessionImpl {
32
33         private final MockPCE client;
34
35         public ServerSessionMock(final PCEPSessionListener listener, final PCEPSessionListener client) {
36                 super(new HashedWheelTimer(), listener, 5, new Channel() {
37
38                         @Override
39                         public int compareTo(final Channel arg0) {
40                                 // TODO Auto-generated method stub
41                                 return 0;
42                         }
43
44                         @Override
45                         public ChannelPromise voidPromise() {
46                                 // TODO Auto-generated method stub
47                                 return null;
48                         }
49
50                         @Override
51                         public ChannelPipeline pipeline() {
52                                 // TODO Auto-generated method stub
53                                 return null;
54                         }
55
56                         @Override
57                         public ChannelFuture newSucceededFuture() {
58                                 // TODO Auto-generated method stub
59                                 return null;
60                         }
61
62                         @Override
63                         public ChannelPromise newPromise() {
64                                 // TODO Auto-generated method stub
65                                 return null;
66                         }
67
68                         @Override
69                         public ChannelProgressivePromise newProgressivePromise() {
70                                 // TODO Auto-generated method stub
71                                 return null;
72                         }
73
74                         @Override
75                         public ChannelFuture newFailedFuture(final Throwable cause) {
76                                 // TODO Auto-generated method stub
77                                 return null;
78                         }
79
80                         @Override
81                         public ByteBufAllocator alloc() {
82                                 // TODO Auto-generated method stub
83                                 return null;
84                         }
85
86                         @Override
87                         public ChannelFuture writeAndFlush(final Object msg, final ChannelPromise promise) {
88                                 // TODO Auto-generated method stub
89                                 return null;
90                         }
91
92                         @Override
93                         public ChannelFuture writeAndFlush(final Object msg) {
94                                 // TODO Auto-generated method stub
95                                 return null;
96                         }
97
98                         @Override
99                         public ChannelFuture write(final Object msg, final ChannelPromise promise) {
100                                 // TODO Auto-generated method stub
101                                 return null;
102                         }
103
104                         @Override
105                         public ChannelFuture write(final Object msg) {
106                                 // TODO Auto-generated method stub
107                                 return null;
108                         }
109
110                         @Override
111                         public ChannelFuture disconnect(final ChannelPromise promise) {
112                                 // TODO Auto-generated method stub
113                                 return null;
114                         }
115
116                         @Override
117                         public ChannelFuture disconnect() {
118                                 // TODO Auto-generated method stub
119                                 return null;
120                         }
121
122                         @Override
123                         public ChannelFuture deregister(final ChannelPromise promise) {
124                                 // TODO Auto-generated method stub
125                                 return null;
126                         }
127
128                         @Override
129                         public ChannelFuture deregister() {
130                                 // TODO Auto-generated method stub
131                                 return null;
132                         }
133
134                         @Override
135                         public ChannelFuture connect(final SocketAddress remoteAddress,
136                                         final SocketAddress localAddress, final ChannelPromise promise) {
137                                 // TODO Auto-generated method stub
138                                 return null;
139                         }
140
141                         @Override
142                         public ChannelFuture connect(final SocketAddress remoteAddress,
143                                         final ChannelPromise promise) {
144                                 // TODO Auto-generated method stub
145                                 return null;
146                         }
147
148                         @Override
149                         public ChannelFuture connect(final SocketAddress remoteAddress,
150                                         final SocketAddress localAddress) {
151                                 // TODO Auto-generated method stub
152                                 return null;
153                         }
154
155                         @Override
156                         public ChannelFuture connect(final SocketAddress remoteAddress) {
157                                 // TODO Auto-generated method stub
158                                 return null;
159                         }
160
161                         @Override
162                         public ChannelFuture close(final ChannelPromise promise) {
163                                 // TODO Auto-generated method stub
164                                 return null;
165                         }
166
167                         @Override
168                         public ChannelFuture close() {
169                                 // TODO Auto-generated method stub
170                                 return null;
171                         }
172
173                         @Override
174                         public ChannelFuture bind(final SocketAddress localAddress, final ChannelPromise promise) {
175                                 // TODO Auto-generated method stub
176                                 return null;
177                         }
178
179                         @Override
180                         public ChannelFuture bind(final SocketAddress localAddress) {
181                                 // TODO Auto-generated method stub
182                                 return null;
183                         }
184
185                         @Override
186                         public <T> Attribute<T> attr(final AttributeKey<T> key) {
187                                 // TODO Auto-generated method stub
188                                 return null;
189                         }
190
191                         @Override
192                         public Unsafe unsafe() {
193                                 // TODO Auto-generated method stub
194                                 return null;
195                         }
196
197                         @Override
198                         public SocketAddress remoteAddress() {
199                                 // TODO Auto-generated method stub
200                                 return null;
201                         }
202
203                         @Override
204                         public Channel read() {
205                                 // TODO Auto-generated method stub
206                                 return null;
207                         }
208
209                         @Override
210                         public Channel parent() {
211                                 // TODO Auto-generated method stub
212                                 return null;
213                         }
214
215                         @Override
216                         public ChannelMetadata metadata() {
217                                 // TODO Auto-generated method stub
218                                 return null;
219                         }
220
221                         @Override
222                         public SocketAddress localAddress() {
223                                 // TODO Auto-generated method stub
224                                 return null;
225                         }
226
227                         @Override
228                         public boolean isWritable() {
229                                 // TODO Auto-generated method stub
230                                 return false;
231                         }
232
233                         @Override
234                         public boolean isRegistered() {
235                                 // TODO Auto-generated method stub
236                                 return false;
237                         }
238
239                         @Override
240                         public boolean isOpen() {
241                                 // TODO Auto-generated method stub
242                                 return false;
243                         }
244
245                         @Override
246                         public boolean isActive() {
247                                 // TODO Auto-generated method stub
248                                 return false;
249                         }
250
251                         @Override
252                         public Channel flush() {
253                                 // TODO Auto-generated method stub
254                                 return null;
255                         }
256
257                         @Override
258                         public EventLoop eventLoop() {
259                                 // TODO Auto-generated method stub
260                                 return null;
261                         }
262
263                         @Override
264                         public ChannelConfig config() {
265                                 // TODO Auto-generated method stub
266                                 return null;
267                         }
268
269                         @Override
270                         public ChannelFuture closeFuture() {
271                                 // TODO Auto-generated method stub
272                                 return null;
273                         }
274                 }, new PCEPOpenObject(4, 9, 2), new PCEPOpenObject(4, 9, 2));
275                 this.client = (MockPCE) client;
276         }
277
278         @Override
279         public void sendMessage(final PCEPMessage msg) {
280                 this.lastMessageSentAt = System.nanoTime();
281                 this.client.onMessage(this, msg);
282         }
283
284         @Override
285         public void close() {
286                 this.client.onSessionTerminated(this, new PCEPCloseTermination(Reason.UNKNOWN));
287         }
288 }