/* * Copyright 2018 Anton Tananaev (anton@traccar.org) * Copyright 2018 Andrey Kunitsyn (andrey@traccar.org) * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.traccar.helper; import java.nio.charset.StandardCharsets; import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBufUtil; import io.netty.buffer.Unpooled; public final class BufferUtil { private BufferUtil() { } public static int indexOf(String needle, ByteBuf haystack) { ByteBuf needleBuffer = Unpooled.wrappedBuffer(needle.getBytes(StandardCharsets.US_ASCII)); try { return ByteBufUtil.indexOf(needleBuffer, haystack); } finally { needleBuffer.release(); } } public static int indexOf(String needle, ByteBuf haystack, int startIndex, int endIndex) { ByteBuf wrappedHaystack = Unpooled.wrappedBuffer(haystack); wrappedHaystack.readerIndex(startIndex - haystack.readerIndex()); wrappedHaystack.writerIndex(endIndex - haystack.readerIndex()); int result = indexOf(needle, wrappedHaystack); return result < 0 ? result : haystack.readerIndex() + result; } }