Tests L2 ACL creation and read.
Equivalent to the following vppctl commands:
*
*
{@code
* vppctl classify table mask l2 src
* vppctl classify session acl-hit-next deny opaque-index 0 table-index 0 match l2 src 01:02:03:04:05:06
* vppctl set int input acl intfc local0 l2-table 0
* vppctl sh class table verbose
* }
*
*/
public class L2AclTest {
private static final int LOCAL0_IFACE_ID = 0;
private static ClassifyAddDelTable createClassifyTable() {
ClassifyAddDelTable request = new ClassifyAddDelTable();
request.isAdd = 1;
request.tableIndex = ~0; // default
request.nbuckets = 2;
request.memorySize = 2 << 20;
request.nextTableIndex = ~0; // default
request.missNextIndex = ~0; // default
request.skipNVectors = 0;
request.matchNVectors = 1;
request.mask =
new byte[] {0x00, 0x00, 0x00, 0x00, 0x00, 0x00, (byte) 0xff, (byte) 0xff, (byte) 0xff, (byte) 0xff,
(byte) 0xff, (byte) 0xff, 0x00, 0x00, 0x00, 0x00};
return request;
}
private static ClassifyTableInfo createClassifyTableInfoRequest(final int tableId) {
ClassifyTableInfo request = new ClassifyTableInfo();
request.tableId = tableId;
return request;
}
private static ClassifyAddDelSession createClassifySession(final int tableIndex) {
ClassifyAddDelSession request = new ClassifyAddDelSession();
request.isAdd = 1;
request.tableIndex = tableIndex;
request.hitNextIndex = 0; // deny
request.opaqueIndex = 0;
request.advance = 0; // default
// match 01:02:03:04:05:06 mac address
request.match =
new byte[] {0x00, 0x00, 0x00, 0x00, 0x00, 0x00, (byte) 0x01, (byte) 0x02, (byte) 0x03, (byte) 0x04,
(byte) 0x05, (byte) 0x06, 0x00, 0x00, 0x00, 0x00};
return request;
}
private static ClassifySessionDump createClassifySessionDumpRequest(final int newTableIndex) {
ClassifySessionDump request = new ClassifySessionDump();
request.tableId = newTableIndex;
return request;
}
private static InputAclSetInterface aclSetInterface() {
InputAclSetInterface request = new InputAclSetInterface();
request.isAdd = 1;
request.swIfIndex = LOCAL0_IFACE_ID;
request.ip4TableIndex = ~0; // skip
request.ip6TableIndex = ~0; // skip
request.l2TableIndex = 0;
return request;
}
private static ClassifyTableByInterface createClassifyTableByInterfaceRequest() {
ClassifyTableByInterface request = new ClassifyTableByInterface();
request.swIfIndex = LOCAL0_IFACE_ID;
return request;
}
private static void print(ClassifyAddDelTableReply reply) {
System.out.printf("ClassifyAddDelTableReply: context=%d, "
+ "newTableIndex=%d, skipNVectors=%d, matchNVectors=%d\n",
reply.context, reply.newTableIndex, reply.skipNVectors, reply.matchNVectors);
}
private static void print(ClassifyTableIdsReply reply) {
System.out.printf("ClassifyTableIdsReply: context=%d, count=%d, ids.length=%d\n",
reply.context, reply.count, reply.ids.length);
Arrays.stream(reply.ids).forEach(System.out::println);
}
private static void print(final ClassifyTableInfoReply reply) {
final StringBuilder builder = new StringBuilder("ClassifyTableInfoReply:\n");
builder.append("context: ").append(reply.context).append('\n');
builder.append("tableId: ").append(reply.tableId).append('\n');
builder.append("nbuckets: ").append(reply.nbuckets).append('\n');
builder.append("matchNVectors: ").append(reply.matchNVectors).append('\n');
builder.append("skipNVectors: ").append(reply.skipNVectors).append('\n');
builder.append("activeSessions: ").append(reply.activeSessions).append('\n');
builder.append("nextTableIndex: ").append(reply.nextTableIndex).append('\n');
builder.append("missNextIndex: ").append(reply.missNextIndex).append('\n');
builder.append("maskLength: ").append(reply.maskLength).append('\n');
builder.append("mask: ").append(DatatypeConverter.printHexBinary(reply.mask)).append('\n');
System.out.println(builder.toString());
}
private static void print(ClassifyAddDelSessionReply reply) {
System.out.printf("ClassifyAddDelSessionReply: context=%d\n",
reply.context);
}
private static void print(final ClassifySessionDetailsReplyDump reply) {
if (reply.classifySessionDetails == null) {
System.out.println("ClassifySessionDetailsReplyDump: classifySessionDetails == NULL");
}
for (final ClassifySessionDetails details : reply.classifySessionDetails) {
final StringBuilder builder = new StringBuilder("ClassifySessionDetails:\n");
builder.append("context: ").append(details.context).append('\n');
builder.append("tableId: ").append(details.tableId).append('\n');
builder.append("hitNextIndex: ").append(details.hitNextIndex).append('\n');
builder.append("advance: ").append(details.advance).append('\n');
builder.append("opaqueIndex: ").append(details.opaqueIndex).append('\n');
builder.append("matchLength: ").append(details.matchLength).append('\n');
builder.append("match: ").append(DatatypeConverter.printHexBinary(details.match)).append('\n');
System.out.println(builder.toString());
}
}
private static void print(final InputAclSetInterfaceReply reply) {
System.out.printf("InputAclSetInterfaceReply: context=%d\n", reply.context);
}
private static void print(final ClassifyTableByInterfaceReply reply) {
System.out.printf("ClassifyAddDelTableReply: context=%d, swIfIndex=%d, l2TableId=%d, ip4TableId=%d,"
+ "ip6TableId=%d\n", reply.context, reply.swIfIndex, reply.l2TableId, reply.ip4TableId, reply.ip6TableId);
}
private static void testL2Acl() throws Exception {
System.out.println("Testing L2 ACLs using Java callback API");
final JVppRegistry registry = new JVppRegistryImpl("L2AclTest");
final JVpp jvpp = new JVppCoreImpl();
final FutureJVppCoreFacade jvppFacade = new FutureJVppCoreFacade(registry, jvpp);
System.out.println("Successfully connected to VPP");
Thread.sleep(1000);
final ClassifyAddDelTableReply classifyAddDelTableReply =
jvppFacade.classifyAddDelTable(createClassifyTable()).toCompletableFuture().get();
print(classifyAddDelTableReply);
final ClassifyTableIdsReply classifyTableIdsReply =
jvppFacade.classifyTableIds(new ClassifyTableIds()).toCompletableFuture().get();
print(classifyTableIdsReply);
final ClassifyTableInfoReply classifyTableInfoReply =
jvppFacade.classifyTableInfo(createClassifyTableInfoRequest(classifyAddDelTableReply.newTableIndex))
.toCompletableFuture().get();
print(classifyTableInfoReply);
final ClassifyAddDelSessionReply classifyAddDelSessionReply =
jvppFacade.classifyAddDelSession(createClassifySession(classifyAddDelTableReply.newTableIndex))
.toCompletableFuture().get();
print(classifyAddDelSessionReply);
final ClassifySessionDetailsReplyDump classifySessionDetailsReplyDump =
jvppFacade.classifySessionDump(createClassifySessionDumpRequest(classifyAddDelTableReply.newTableIndex))
.toCompletableFuture().get();
print(classifySessionDetailsReplyDump);
final InputAclSetInterfaceReply inputAclSetInterfaceReply =
jvppFacade.inputAclSetInterface(aclSetInterface()).toCompletableFuture().get();
print(inputAclSetInterfaceReply);
final ClassifyTableByInterfaceReply classifyTableByInterfaceReply =
jvppFacade.classifyTableByInterface(createClassifyTableByInterfaceRequest()).toCompletableFuture().get();
print(classifyTableByInterfaceReply);
System.out.println("Disconnecting...");
registry.close();
Thread.sleep(1000);
}
public static void main(String[] args) throws Exception {
testL2Acl();
}
}