2 * Copyright (c) 2013 Cisco Systems, Inc. and others. All rights reserved.
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
8 package org.opendaylight.protocol.bgp.rib.impl;
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;
23 import java.net.SocketAddress;
25 import org.opendaylight.protocol.bgp.parser.BGPMessage;
26 import org.opendaylight.protocol.bgp.parser.BGPSessionListener;
27 import org.opendaylight.protocol.bgp.parser.message.BGPOpenMessage;
30 * Mock of the BGP speakers session.
32 public class SpeakerSessionMock extends BGPSessionImpl {
34 private final BGPSessionListener client;
36 SpeakerSessionMock(final BGPSessionListener listener, final BGPSessionListener client) {
37 super(new HashedWheelTimer(), listener, new Channel() {
40 public <T> Attribute<T> attr(final AttributeKey<T> key) {
41 // TODO Auto-generated method stub
46 public ChannelFuture bind(final SocketAddress localAddress) {
47 // TODO Auto-generated method stub
52 public ChannelFuture connect(final SocketAddress remoteAddress) {
53 // TODO Auto-generated method stub
58 public ChannelFuture connect(final SocketAddress remoteAddress,
59 final SocketAddress localAddress) {
60 // TODO Auto-generated method stub
65 public ChannelFuture disconnect() {
66 // TODO Auto-generated method stub
71 public ChannelFuture close() {
72 // TODO Auto-generated method stub
77 public ChannelFuture deregister() {
78 // TODO Auto-generated method stub
83 public ChannelFuture bind(final SocketAddress localAddress,
84 final ChannelPromise promise) {
85 // TODO Auto-generated method stub
90 public ChannelFuture connect(final SocketAddress remoteAddress,
91 final ChannelPromise promise) {
92 // TODO Auto-generated method stub
97 public ChannelFuture connect(final SocketAddress remoteAddress,
98 final SocketAddress localAddress, final ChannelPromise promise) {
99 // TODO Auto-generated method stub
104 public ChannelFuture disconnect(final ChannelPromise promise) {
105 // TODO Auto-generated method stub
110 public ChannelFuture close(final ChannelPromise promise) {
111 // TODO Auto-generated method stub
116 public ChannelFuture deregister(final ChannelPromise promise) {
117 // TODO Auto-generated method stub
122 public ChannelFuture write(final Object msg) {
123 // TODO Auto-generated method stub
128 public ChannelFuture write(final Object msg, final ChannelPromise promise) {
129 // TODO Auto-generated method stub
134 public ChannelFuture writeAndFlush(final Object msg,
135 final ChannelPromise promise) {
136 // TODO Auto-generated method stub
141 public ChannelFuture writeAndFlush(final Object msg) {
142 // TODO Auto-generated method stub
147 public ChannelPipeline pipeline() {
148 // TODO Auto-generated method stub
153 public ByteBufAllocator alloc() {
154 // TODO Auto-generated method stub
159 public ChannelPromise newPromise() {
160 // TODO Auto-generated method stub
165 public ChannelProgressivePromise newProgressivePromise() {
166 // TODO Auto-generated method stub
171 public ChannelFuture newSucceededFuture() {
172 // TODO Auto-generated method stub
177 public ChannelFuture newFailedFuture(final Throwable cause) {
178 // TODO Auto-generated method stub
183 public ChannelPromise voidPromise() {
184 // TODO Auto-generated method stub
189 public int compareTo(final Channel o) {
190 // TODO Auto-generated method stub
195 public EventLoop eventLoop() {
196 // TODO Auto-generated method stub
201 public Channel parent() {
202 // TODO Auto-generated method stub
207 public ChannelConfig config() {
208 // TODO Auto-generated method stub
213 public boolean isOpen() {
214 // TODO Auto-generated method stub
219 public boolean isRegistered() {
220 // TODO Auto-generated method stub
225 public boolean isActive() {
226 // TODO Auto-generated method stub
231 public ChannelMetadata metadata() {
232 // TODO Auto-generated method stub
237 public SocketAddress localAddress() {
238 // TODO Auto-generated method stub
243 public SocketAddress remoteAddress() {
244 // TODO Auto-generated method stub
249 public ChannelFuture closeFuture() {
250 // TODO Auto-generated method stub
255 public boolean isWritable() {
256 // TODO Auto-generated method stub
261 public Channel flush() {
262 // TODO Auto-generated method stub
267 public Channel read() {
268 // TODO Auto-generated method stub
273 public Unsafe unsafe() {
274 // TODO Auto-generated method stub
278 }, (short)3, new BGPOpenMessage(null, (short)5, null, null));
279 this.client = client;
283 public void sendMessage(final BGPMessage msg) {
284 this.lastMessageSentAt = System.nanoTime();
285 this.client.onMessage(this, msg);