/*
* Copyright (c) 2018 FRINX s.r.o., and others. All rights reserved.
*
* This program and the accompanying materials are made available under the
* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
package org.opendaylight.netconf.nettyutil.handler;
import static org.junit.Assert.assertEquals;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import java.nio.charset.Charset;
import java.util.LinkedList;
import java.util.List;
import org.junit.Before;
import org.junit.Test;
public class NetconfEOMAggregatorTest {
private static final String COMM_1 = "\n"
+ "\n"
+ "\n"
+ "\n"
+ "rootsuperuser\n"
+ "fredadmin\n"
+ "barneyadmin\n"
+ "\n"
+ "\n"
+ "\n"
+ "]]>]]>"
+ "\n"
+ "\n"
+ "\n"
+ "\n"
+ "rootsuperuser\n"
+ "fredadmin\n"
+ "barneyadmin\n"
+ "joeuser\n"
+ "\n"
+ "\n"
+ "\n"
+ "]]>]]>";
private static final String COMM_1_M_1 = "\n"
+ "\n"
+ "\n"
+ "\n"
+ "rootsuperuser\n"
+ "fredadmin\n"
+ "barneyadmin\n"
+ "\n"
+ "\n"
+ "\n";
private static final String COMM_1_M_2 = "\n"
+ "\n"
+ "\n"
+ "\n"
+ "rootsuperuser\n"
+ "fredadmin\n"
+ "barneyadmin\n"
+ "joeuser\n"
+ "\n"
+ "\n"
+ "\n";
private static final String COMM_2 = "\n"
+ "\n"
+ "\n"
+ "\n"
+ "porsche\n"
+ "ford\n"
+ "\n"
+ "\n"
+ "\n"
+ "]]>]]>";
private static final String COMM_2_M_1 = "\n"
+ "\n"
+ "\n"
+ "\n"
+ "porsche\n"
+ "ford\n"
+ "\n"
+ "\n"
+ "\n";
private static final String COMM_3_S_1 = "\n"
+ "\n"
+ "\n"
+ "\n"
+ "rootsuperuser\n"
+ "fredadmin\n"
+ "barneyadmin\n"
+ "\n"
+ "\n"
+ "\n"
+ "]]>]]>";
private static final String COMM_3_S_2 = "\n"
+ "\n"
+ "\n"
+ "\n";
private static final String COMM_3_S_3 = "porsche\n"
+ "ford\n"
+ "\n"
+ "\n"
+ "\n"
+ "]]>]]>";
private static final String COMM_3_M_1 = "\n"
+ "\n"
+ "\n"
+ "\n"
+ "rootsuperuser\n"
+ "fredadmin\n"
+ "barneyadmin\n"
+ "\n"
+ "\n"
+ "\n";
private static final String COMM_3_M_2 = "\n"
+ "\n"
+ "\n"
+ "\n"
+ "porsche\n"
+ "ford\n"
+ "\n"
+ "\n"
+ "\n";
private static NetconfEOMAggregator aggregator;
@Before
public void setUp() throws Exception {
aggregator = new NetconfEOMAggregator();
}
@Test
public void testDecodeMessagesReadAtOnce() {
final ByteBuf in = Unpooled.copiedBuffer(COMM_1.getBytes());
final List