http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/hll/Varint.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/hll/Varint.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/hll/Varint.java deleted file mode 100755 index da370ce..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/hll/Varint.java +++ /dev/null @@ -1,238 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.hll; - -/** - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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. - */ - - -import java.io.DataInput; -import java.io.DataOutput; -import java.io.IOException; - - -/** - * <p> - * Encodes signed and unsigned values using a common variable-length scheme, found for example in - * <a href="http://code.google.com/apis/protocolbuffers/docs/encoding.html";> Google's Protocol - * Buffers</a>. It uses fewer bytes to encode smaller values, but will use slightly more bytes to - * encode large values. - * </p> - * <p/> - * <p> - * Signed values are further encoded using so-called zig-zag encoding in order to make them - * "compatible" with variable-length encoding. - * </p> - */ -public final class Varint { - - private Varint() {} - - /** - * Encodes a value using the variable-length encoding from - * <a href="http://code.google.com/apis/protocolbuffers/docs/encoding.html";> Google Protocol - * Buffers</a>. It uses zig-zag encoding to efficiently encode signed values. If values are known - * to be nonnegative, {@link #writeUnsignedVarLong(long, DataOutput)} should be used. - * - * @param value value to encode - * @param out to write bytes to - * @throws IOException if {@link DataOutput} throws {@link IOException} - */ - public static void writeSignedVarLong(long value, DataOutput out) throws IOException { - // Great trick from http://code.google.com/apis/protocolbuffers/docs/encoding.html#types - writeUnsignedVarLong((value << 1) ^ (value >> 63), out); - } - - /** - * Encodes a value using the variable-length encoding from - * <a href="http://code.google.com/apis/protocolbuffers/docs/encoding.html";> Google Protocol - * Buffers</a>. Zig-zag is not used, so input must not be negative. If values can be negative, use - * {@link #writeSignedVarLong(long, DataOutput)} instead. This method treats negative input as - * like a large unsigned value. - * - * @param value value to encode - * @param out to write bytes to - * @throws IOException if {@link DataOutput} throws {@link IOException} - */ - public static void writeUnsignedVarLong(long value, DataOutput out) throws IOException { - while ((value & 0xFFFFFFFFFFFFFF80L) != 0L) { - out.writeByte(((int) value & 0x7F) | 0x80); - value >>>= 7; - } - out.writeByte((int) value & 0x7F); - } - - /** - * @see #writeSignedVarLong(long, DataOutput) - */ - public static void writeSignedVarInt(int value, DataOutput out) throws IOException { - // Great trick from http://code.google.com/apis/protocolbuffers/docs/encoding.html#types - writeUnsignedVarInt((value << 1) ^ (value >> 31), out); - } - - /** - * @see #writeUnsignedVarLong(long, DataOutput) - */ - public static void writeUnsignedVarInt(int value, DataOutput out) throws IOException { - while ((value & 0xFFFFFF80) != 0L) { - out.writeByte((value & 0x7F) | 0x80); - value >>>= 7; - } - out.writeByte(value & 0x7F); - } - - public static byte[] writeSignedVarInt(int value) { - // Great trick from http://code.google.com/apis/protocolbuffers/docs/encoding.html#types - return writeUnsignedVarInt((value << 1) ^ (value >> 31)); - } - - /** - * @see #writeUnsignedVarLong(long, DataOutput) - * <p/> - * This one does not use streams and is much faster. Makes a single object each time, and - * that object is a primitive array. - */ - public static byte[] writeUnsignedVarInt(int value) { - byte[] byteArrayList = new byte[10]; - int i = 0; - while ((value & 0xFFFFFF80) != 0L) { - byteArrayList[i++] = ((byte) ((value & 0x7F) | 0x80)); - value >>>= 7; - } - byteArrayList[i] = ((byte) (value & 0x7F)); - byte[] out = new byte[i + 1]; - for (; i >= 0; i--) { - out[i] = byteArrayList[i]; - } - return out; - } - - /** - * @param in to read bytes from - * @return decode value - * @throws IOException if {@link DataInput} throws {@link IOException} - * @throws IllegalArgumentException if variable-length value does not terminate after 9 bytes have - * been read - * @see #writeSignedVarLong(long, DataOutput) - */ - public static long readSignedVarLong(DataInput in) throws IOException { - long raw = readUnsignedVarLong(in); - // This undoes the trick in writeSignedVarLong() - long temp = (((raw << 63) >> 63) ^ raw) >> 1; - // This extra step lets us deal with the largest signed values by treating - // negative results from read unsigned methods as like unsigned values - // Must re-flip the top bit if the original read value had it set. - return temp ^ (raw & (1L << 63)); - } - - /** - * @param in to read bytes from - * @return decode value - * @throws IOException if {@link DataInput} throws {@link IOException} - * @throws IllegalArgumentException if variable-length value does not terminate after 9 bytes have - * been read - * @see #writeUnsignedVarLong(long, DataOutput) - */ - public static long readUnsignedVarLong(DataInput in) throws IOException { - long value = 0L; - int i = 0; - long b; - while (((b = in.readByte()) & 0x80L) != 0) { - value |= (b & 0x7F) << i; - i += 7; - if (i > 63) { - throw new IllegalArgumentException("Variable length quantity is too long"); - } - } - return value | (b << i); - } - - /** - * @throws IllegalArgumentException if variable-length value does not terminate after 5 bytes have - * been read - * @throws IOException if {@link DataInput} throws {@link IOException} - * @see #readSignedVarLong(DataInput) - */ - public static int readSignedVarInt(DataInput in) throws IOException { - int raw = readUnsignedVarInt(in); - // This undoes the trick in writeSignedVarInt() - int temp = (((raw << 31) >> 31) ^ raw) >> 1; - // This extra step lets us deal with the largest signed values by treating - // negative results from read unsigned methods as like unsigned values. - // Must re-flip the top bit if the original read value had it set. - return temp ^ (raw & (1 << 31)); - } - - /** - * @throws IllegalArgumentException if variable-length value does not terminate after 5 bytes have - * been read - * @throws IOException if {@link DataInput} throws {@link IOException} - * @see #readUnsignedVarLong(DataInput) - */ - public static int readUnsignedVarInt(DataInput in) throws IOException { - int value = 0; - int i = 0; - int b; - while (((b = in.readByte()) & 0x80) != 0) { - value |= (b & 0x7F) << i; - i += 7; - if (i > 35) { - throw new IllegalArgumentException("Variable length quantity is too long"); - } - } - return value | (b << i); - } - - public static int readSignedVarInt(byte[] bytes) { - int raw = readUnsignedVarInt(bytes); - // This undoes the trick in writeSignedVarInt() - int temp = (((raw << 31) >> 31) ^ raw) >> 1; - // This extra step lets us deal with the largest signed values by treating - // negative results from read unsigned methods as like unsigned values. - // Must re-flip the top bit if the original read value had it set. - return temp ^ (raw & (1 << 31)); - } - - public static int readUnsignedVarInt(byte[] bytes) { - int value = 0; - int i = 0; - byte rb = Byte.MIN_VALUE; - for (byte b : bytes) { - rb = b; - if ((b & 0x80) == 0) { - break; - } - value |= (b & 0x7f) << i; - i += 7; - if (i > 35) { - throw new IllegalArgumentException("Variable length quantity is too long"); - } - } - return value | (rb << i); - } - -}
http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LIndexExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LIndexExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LIndexExecutor.java deleted file mode 100755 index c80a505..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LIndexExecutor.java +++ /dev/null @@ -1,118 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import java.util.List; - -import org.apache.geode.cache.Region; -import org.apache.geode.cache.query.Query; -import org.apache.geode.cache.query.SelectResults; -import org.apache.geode.cache.query.Struct; -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.Coder; -import org.apache.geode.redis.internal.Command; -import org.apache.geode.redis.internal.ExecutionHandlerContext; -import org.apache.geode.redis.internal.RedisConstants.ArityDef; -import org.apache.geode.redis.internal.RedisDataType; -import org.apache.geode.redis.internal.executor.ListQuery; - -public class LIndexExecutor extends ListExecutor { - - private final String ERROR_NOT_NUMERIC = "The index provided is not numeric"; - - @Override - public void executeCommand(Command command, ExecutionHandlerContext context) { - List<byte[]> commandElems = command.getProcessedCommand(); - - if (commandElems.size() < 3) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ArityDef.LINDEX)); - return; - } - - ByteArrayWrapper key = command.getKey(); - byte[] indexArray = commandElems.get(2); - - checkDataType(key, RedisDataType.REDIS_LIST, context); - Region<Integer, ByteArrayWrapper> keyRegion = getRegion(context, key); - - if (keyRegion == null) { - command.setResponse(Coder.getNilResponse(context.getByteBufAllocator())); - return; - } - - int listSize = keyRegion.size() - LIST_EMPTY_SIZE; - - Integer redisIndex; - - try { - redisIndex = Coder.bytesToInt(indexArray); - } catch (NumberFormatException e) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ERROR_NOT_NUMERIC)); - return; - } - - /* - * Now the fun part, converting the redis index into our index. The redis index is 0 based but - * negative values count from the tail - */ - - if (redisIndex < 0) - // Since the redisIndex is negative here, this will reset it to be a standard 0 based index - redisIndex = listSize + redisIndex; - - /* - * If the index is still less than 0 that means the index has shot off back past the beginning, - * which means the index isn't real and a nil is returned - */ - if (redisIndex < 0) { - command.setResponse(Coder.getNilResponse(context.getByteBufAllocator())); - return; - } - - /* - * Now we must get that element from the region - */ - Struct entry; - try { - entry = getEntryAtIndex(context, key, redisIndex); - } catch (Exception e) { - throw new RuntimeException(e); - } - if (entry == null) { - command.setResponse(Coder.getNilResponse(context.getByteBufAllocator())); - return; - } - - Object[] entryArray = entry.getFieldValues(); - ByteArrayWrapper valueWrapper = (ByteArrayWrapper) entryArray[1]; - command.setResponse( - Coder.getBulkStringResponse(context.getByteBufAllocator(), valueWrapper.toBytes())); - } - - private Struct getEntryAtIndex(ExecutionHandlerContext context, ByteArrayWrapper key, int index) - throws Exception { - - Query query = getQuery(key, ListQuery.LINDEX, context); - - Object[] params = {Integer.valueOf(index + 1)}; - - SelectResults<?> results = (SelectResults<?>) query.execute(params); - - if (results == null || results.size() == 0 || results.size() <= index) - return null; - else - return (Struct) results.asList().get(index); - } -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LInsertExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LInsertExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LInsertExecutor.java deleted file mode 100755 index ac9f653..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LInsertExecutor.java +++ /dev/null @@ -1,28 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import org.apache.geode.redis.internal.Command; -import org.apache.geode.redis.internal.Coder; -import org.apache.geode.redis.internal.ExecutionHandlerContext; - -public class LInsertExecutor extends ListExecutor { - - @Override - public void executeCommand(Command command, ExecutionHandlerContext context) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), - "Unfortunately GemFireRedis server does not support LINSERT")); - } -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LLenExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LLenExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LLenExecutor.java deleted file mode 100755 index f9e685f..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LLenExecutor.java +++ /dev/null @@ -1,56 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import java.util.List; - -import org.apache.geode.cache.Region; -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.Command; -import org.apache.geode.redis.internal.ExecutionHandlerContext; -import org.apache.geode.redis.internal.RedisDataType; -import org.apache.geode.redis.internal.Coder; -import org.apache.geode.redis.internal.RedisConstants.ArityDef; - -public class LLenExecutor extends ListExecutor { - - private final int NOT_EXISTS = 0; - - @Override - public void executeCommand(Command command, ExecutionHandlerContext context) { - List<byte[]> commandElems = command.getProcessedCommand(); - - if (commandElems.size() < 2) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ArityDef.LLEN)); - return; - } - - ByteArrayWrapper key = command.getKey(); - - int listSize = 0; - - checkDataType(key, RedisDataType.REDIS_LIST, context); - Region<Integer, ByteArrayWrapper> keyRegion = getRegion(context, key); - - if (keyRegion == null) { - command.setResponse(Coder.getIntegerResponse(context.getByteBufAllocator(), NOT_EXISTS)); - return; - } - - listSize = keyRegion.size() - LIST_EMPTY_SIZE; - - command.setResponse(Coder.getIntegerResponse(context.getByteBufAllocator(), listSize)); - } -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LPopExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LPopExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LPopExecutor.java deleted file mode 100755 index 40736c8..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LPopExecutor.java +++ /dev/null @@ -1,32 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import org.apache.geode.redis.internal.RedisConstants.ArityDef; - - -public class LPopExecutor extends PopExecutor { - - @Override - protected ListDirection popType() { - return ListDirection.LEFT; - } - - @Override - public String getArgsError() { - return ArityDef.LPOP; - } - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LPushExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LPushExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LPushExecutor.java deleted file mode 100755 index 6624a61..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LPushExecutor.java +++ /dev/null @@ -1,32 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import org.apache.geode.redis.internal.RedisConstants.ArityDef; - - -public class LPushExecutor extends PushExecutor { - - @Override - protected ListDirection pushType() { - return ListDirection.LEFT; - } - - @Override - public String getArgsError() { - return ArityDef.LPUSH; - } - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LPushXExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LPushXExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LPushXExecutor.java deleted file mode 100755 index dc84896..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LPushXExecutor.java +++ /dev/null @@ -1,32 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import org.apache.geode.redis.internal.RedisConstants.ArityDef; - - -public class LPushXExecutor extends PushXExecutor { - - @Override - protected ListDirection pushType() { - return ListDirection.LEFT; - } - - @Override - public String getArgsError() { - return ArityDef.LPUSHX; - } - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LRangeExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LRangeExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LRangeExecutor.java deleted file mode 100755 index fc36408..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LRangeExecutor.java +++ /dev/null @@ -1,113 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import java.util.List; - -import org.apache.geode.cache.Region; -import org.apache.geode.cache.query.Query; -import org.apache.geode.cache.query.SelectResults; -import org.apache.geode.cache.query.Struct; -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.Coder; -import org.apache.geode.redis.internal.Command; -import org.apache.geode.redis.internal.ExecutionHandlerContext; -import org.apache.geode.redis.internal.RedisConstants.ArityDef; -import org.apache.geode.redis.internal.RedisDataType; -import org.apache.geode.redis.internal.executor.ListQuery; - -public class LRangeExecutor extends ListExecutor { - - private final String ERROR_NOT_NUMERIC = "The index provided is not numeric"; - - @Override - public void executeCommand(Command command, ExecutionHandlerContext context) { - List<byte[]> commandElems = command.getProcessedCommand(); - - if (commandElems.size() < 4) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ArityDef.LRANGE)); - return; - } - - ByteArrayWrapper key = command.getKey(); - byte[] startArray = commandElems.get(2); - byte[] stopArray = commandElems.get(3); - - int redisStart; - int redisStop; - - - checkDataType(key, RedisDataType.REDIS_LIST, context); - Region<Integer, ByteArrayWrapper> keyRegion = getRegion(context, key); - - if (keyRegion == null) { - command.setResponse(Coder.getEmptyArrayResponse(context.getByteBufAllocator())); - return; - } - - int listSize = keyRegion.size() - LIST_EMPTY_SIZE; - if (listSize == 0) { - command.setResponse(Coder.getEmptyArrayResponse(context.getByteBufAllocator())); - return; - } - - try { - redisStart = Coder.bytesToInt(startArray); - redisStop = Coder.bytesToInt(stopArray); - } catch (NumberFormatException e) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ERROR_NOT_NUMERIC)); - return; - } - - - redisStart = getBoundedStartIndex(redisStart, listSize); - redisStop = getBoundedEndIndex(redisStop, listSize); - if (redisStart > redisStop) { - command.setResponse(Coder.getEmptyArrayResponse(context.getByteBufAllocator())); - return; - } - redisStart = Math.min(redisStart, listSize - 1); - redisStop = Math.min(redisStop, listSize - 1); - - - List<Struct> range; - try { - range = getRange(context, key, redisStart, redisStop, keyRegion); - } catch (Exception e) { - throw new RuntimeException(e); - } - - if (range == null) - command.setResponse(Coder.getEmptyArrayResponse(context.getByteBufAllocator())); - else - command.setResponse( - Coder.getBulkStringArrayResponseOfValues(context.getByteBufAllocator(), range)); - } - - private List<Struct> getRange(ExecutionHandlerContext context, ByteArrayWrapper key, int start, - int stop, Region r) throws Exception { - - Query query = getQuery(key, ListQuery.LRANGE, context); - - Object[] params = {Integer.valueOf(stop + 1)}; - SelectResults<Struct> results = (SelectResults<Struct>) query.execute(params); - int size = results.size(); - if (results == null || size <= start) { - return null; - } - - return results.asList().subList(start, size); - } -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LRemExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LRemExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LRemExecutor.java deleted file mode 100755 index be0793e..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LRemExecutor.java +++ /dev/null @@ -1,115 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import java.util.List; - -import org.apache.geode.cache.Region; -import org.apache.geode.cache.query.Query; -import org.apache.geode.cache.query.SelectResults; -import org.apache.geode.cache.query.Struct; -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.Coder; -import org.apache.geode.redis.internal.Command; -import org.apache.geode.redis.internal.ExecutionHandlerContext; -import org.apache.geode.redis.internal.RedisDataType; -import org.apache.geode.redis.internal.RedisConstants.ArityDef; -import org.apache.geode.redis.internal.executor.ListQuery; - -public class LRemExecutor extends ListExecutor { - - private final String ERROR_NOT_NUMERIC = "The count provided is not numeric"; - - private final int NOT_EXISTS = 0; - - @Override - public void executeCommand(Command command, ExecutionHandlerContext context) { - List<byte[]> commandElems = command.getProcessedCommand(); - - if (commandElems.size() < 4) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ArityDef.LREM)); - return; - } - - ByteArrayWrapper key = command.getKey(); - byte[] countArray = commandElems.get(2); - byte[] value = commandElems.get(3); - - int count; - - - checkDataType(key, RedisDataType.REDIS_LIST, context); - Region<Integer, ByteArrayWrapper> keyRegion = getRegion(context, key); - - if (keyRegion == null) { - command.setResponse(Coder.getIntegerResponse(context.getByteBufAllocator(), NOT_EXISTS)); - return; - } - - try { - count = Coder.bytesToInt(countArray); - } catch (NumberFormatException e) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ERROR_NOT_NUMERIC)); - return; - } - - List<Struct> removeList; - try { - removeList = getRemoveList(context, key, new ByteArrayWrapper(value), count); - } catch (Exception e) { - throw new RuntimeException(e); - } - - int numRemoved = 0; - - if (removeList == null) { - command.setResponse(Coder.getIntegerResponse(context.getByteBufAllocator(), numRemoved)); - return; - } - - for (Struct entry : removeList) { - Integer removeKey = (Integer) entry.getFieldValues()[0]; - Object oldVal = keyRegion.remove(removeKey); - if (oldVal != null) - numRemoved++; - } - command.setResponse(Coder.getIntegerResponse(context.getByteBufAllocator(), numRemoved)); - } - - private List<Struct> getRemoveList(ExecutionHandlerContext context, ByteArrayWrapper key, - ByteArrayWrapper value, int count) throws Exception { - Object[] params; - Query query; - if (count > 0) { - query = getQuery(key, ListQuery.LREMG, context); - params = new Object[] {value, Integer.valueOf(count)}; - } else if (count < 0) { - query = getQuery(key, ListQuery.LREML, context); - params = new Object[] {value, Integer.valueOf(-count)}; - } else { - query = getQuery(key, ListQuery.LREME, context); - params = new Object[] {value}; - } - - - SelectResults<Struct> results = (SelectResults<Struct>) query.execute(params); - - if (results == null || results.isEmpty()) { - return null; - } - - return results.asList(); - } -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LSetExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LSetExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LSetExecutor.java deleted file mode 100755 index 0a53041..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LSetExecutor.java +++ /dev/null @@ -1,108 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import java.util.List; - -import org.apache.geode.cache.Region; -import org.apache.geode.cache.query.Query; -import org.apache.geode.cache.query.SelectResults; -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.Coder; -import org.apache.geode.redis.internal.Command; -import org.apache.geode.redis.internal.ExecutionHandlerContext; -import org.apache.geode.redis.internal.RedisDataType; -import org.apache.geode.redis.internal.RedisConstants.ArityDef; -import org.apache.geode.redis.internal.executor.ListQuery; - -public class LSetExecutor extends ListExecutor { - - private final String ERROR_NOT_NUMERIC = "The index provided is not numeric"; - - private final String ERROR_INDEX = - "The index provided is not within range of this list or the key does not exist"; - - private final String SUCCESS = "OK"; - - @Override - public void executeCommand(Command command, ExecutionHandlerContext context) { - List<byte[]> commandElems = command.getProcessedCommand(); - - if (commandElems.size() < 4) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ArityDef.LSET)); - return; - } - - ByteArrayWrapper key = command.getKey(); - byte[] indexArray = commandElems.get(2); - byte[] value = commandElems.get(3); - - int index; - - - checkDataType(key, RedisDataType.REDIS_LIST, context); - Region<Integer, ByteArrayWrapper> keyRegion = getRegion(context, key); - - if (keyRegion == null) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ERROR_INDEX)); - return; - } - - try { - index = Coder.bytesToInt(indexArray); - } catch (NumberFormatException e) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ERROR_NOT_NUMERIC)); - return; - } - - int listSize = keyRegion.size() - LIST_EMPTY_SIZE; - if (index < 0) - index += listSize; - if (index < 0 || index > listSize) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ERROR_INDEX)); - return; - } - - Integer indexKey; - try { - indexKey = getIndexKey(context, key, index); - } catch (Exception e) { - throw new RuntimeException(e); - } - if (indexKey == null) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ERROR_INDEX)); - return; - } - if (index == listSize) - indexKey++; - keyRegion.put(indexKey, new ByteArrayWrapper(value)); - command.setResponse(Coder.getSimpleStringResponse(context.getByteBufAllocator(), SUCCESS)); - } - - private Integer getIndexKey(ExecutionHandlerContext context, ByteArrayWrapper key, int index) - throws Exception { - Query query = getQuery(key, ListQuery.LSET, context); - - Object[] params = {Integer.valueOf(index + 1)}; - - SelectResults<Integer> results = (SelectResults<Integer>) query.execute(params); - int size = results.size(); - if (results == null || size == 0) { - return null; - } - - return results.asList().get(size - 1); - } -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LTrimExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LTrimExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LTrimExecutor.java deleted file mode 100755 index de5804f..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/LTrimExecutor.java +++ /dev/null @@ -1,123 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import java.util.List; - -import org.apache.geode.cache.Region; -import org.apache.geode.cache.query.Query; -import org.apache.geode.cache.query.SelectResults; -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.Coder; -import org.apache.geode.redis.internal.Command; -import org.apache.geode.redis.internal.ExecutionHandlerContext; -import org.apache.geode.redis.internal.RedisDataType; -import org.apache.geode.redis.internal.RedisConstants.ArityDef; -import org.apache.geode.redis.internal.executor.ListQuery; - -public class LTrimExecutor extends ListExecutor { - - private final String ERROR_KEY_NOT_EXISTS = "The key does not exists on this server"; - - private final String ERROR_NOT_NUMERIC = "The index provided is not numeric"; - - private final String SUCCESS = "OK"; - - @Override - public void executeCommand(Command command, ExecutionHandlerContext context) { - List<byte[]> commandElems = command.getProcessedCommand(); - - if (commandElems.size() < 4) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ArityDef.LTRIM)); - return; - } - - ByteArrayWrapper key = command.getKey(); - byte[] startArray = commandElems.get(2); - byte[] stopArray = commandElems.get(3); - - int redisStart; - int redisStop; - - - checkDataType(key, RedisDataType.REDIS_LIST, context); - Region keyRegion = getRegion(context, key); - - if (keyRegion == null) { - command - .setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ERROR_KEY_NOT_EXISTS)); - return; - } - - int listSize = keyRegion.size() - LIST_EMPTY_SIZE; - if (listSize == 0) { - command.setResponse(Coder.getSimpleStringResponse(context.getByteBufAllocator(), SUCCESS)); - return; - } - - try { - redisStart = Coder.bytesToInt(startArray); - redisStop = Coder.bytesToInt(stopArray); - } catch (NumberFormatException e) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ERROR_NOT_NUMERIC)); - return; - } - - redisStart = getBoundedStartIndex(redisStart, listSize); - redisStop = getBoundedEndIndex(redisStop, listSize); - redisStart = Math.min(redisStart, listSize - 1); - redisStop = Math.min(redisStop, listSize - 1); - - if (redisStart == 0 && redisStop == listSize - 1) { - command.setResponse(Coder.getSimpleStringResponse(context.getByteBufAllocator(), SUCCESS)); - return; - } else if (redisStart == 0 && redisStop < redisStart) { - context.getRegionProvider().removeKey(key, RedisDataType.REDIS_LIST); - command.setResponse(Coder.getSimpleStringResponse(context.getByteBufAllocator(), SUCCESS)); - return; - } - - List<Integer> keepList; - try { - keepList = getRange(context, key, redisStart, redisStop, keyRegion); - } catch (Exception e) { - throw new RuntimeException(e); - } - - for (Object keyElement : keyRegion.keySet()) { - if (!keepList.contains(keyElement) && keyElement instanceof Integer) - keyRegion.remove(keyElement); - } - - // Reset indexes in meta data region - keyRegion.put("head", keepList.get(0)); - keyRegion.put("tail", keepList.get(keepList.size() - 1)); - command.setResponse(Coder.getSimpleStringResponse(context.getByteBufAllocator(), SUCCESS)); - } - - private List<Integer> getRange(ExecutionHandlerContext context, ByteArrayWrapper key, int start, - int stop, Region r) throws Exception { - Query query = getQuery(key, ListQuery.LTRIM, context); - - Object[] params = {Integer.valueOf(stop + 1)}; - - SelectResults<Integer> results = (SelectResults<Integer>) query.execute(params); - if (results == null || results.size() <= start) { - return null; - } - - return results.asList().subList(start, results.size()); - } -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/ListExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/ListExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/ListExecutor.java deleted file mode 100755 index ab80a36..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/ListExecutor.java +++ /dev/null @@ -1,141 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import java.util.List; - -import org.apache.geode.cache.Region; -import org.apache.geode.cache.query.QueryService; -import org.apache.geode.internal.cache.GemFireCacheImpl; -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.ExecutionHandlerContext; -import org.apache.geode.redis.internal.RedisDataType; -import org.apache.geode.redis.internal.executor.AbstractExecutor; - - -public abstract class ListExecutor extends AbstractExecutor { - - protected static final int LIST_EMPTY_SIZE = 2; - - protected static enum ListDirection { - LEFT, RIGHT - }; - - protected final static QueryService getQueryService() { - return GemFireCacheImpl.getInstance().getQueryService(); - } - - @SuppressWarnings("unchecked") - @Override - protected Region<Integer, ByteArrayWrapper> getOrCreateRegion(ExecutionHandlerContext context, - ByteArrayWrapper key, RedisDataType type) { - return (Region<Integer, ByteArrayWrapper>) context.getRegionProvider().getOrCreateRegion(key, - type, context); - } - - @SuppressWarnings("unchecked") - protected Region<Integer, ByteArrayWrapper> getRegion(ExecutionHandlerContext context, - ByteArrayWrapper key) { - return (Region<Integer, ByteArrayWrapper>) context.getRegionProvider().getRegion(key); - } - - /** - * Helper method to be used by the push commands to push elements onto a list. Because our current - * setup requires non trivial code to push elements in to a Region, I wanted all the push code to - * reside in one place. - * - * @param key Name of the list - * @param commandElems Pieces of the command, this is where the elements that need to be pushed - * live - * @param startIndex The index to start with in the commandElems list, inclusive - * @param endIndex The index to end with in the commandElems list, exclusive - * @param keyRegion Region of list - * @param pushType ListDirection.LEFT || ListDirection.RIGHT - * @param context Context of this push - */ - protected void pushElements(ByteArrayWrapper key, List<byte[]> commandElems, int startIndex, - int endIndex, Region keyRegion, ListDirection pushType, ExecutionHandlerContext context) { - - String indexKey = pushType == ListDirection.LEFT ? "head" : "tail"; - String oppositeKey = pushType == ListDirection.RIGHT ? "head" : "tail"; - Integer index = (Integer) keyRegion.get(indexKey); - Integer opp = (Integer) keyRegion.get(oppositeKey); - if (index != opp) - index += pushType == ListDirection.LEFT ? -1 : 1; // Subtract index if left push, add if right - // push - - /** - * Multi push command - * - * For every element that needs to be added - */ - - for (int i = startIndex; i < endIndex; i++) { - byte[] value = commandElems.get(i); - ByteArrayWrapper wrapper = new ByteArrayWrapper(value); - - /** - * - * First, use the start index to attempt to insert the value into the Region - * - */ - - Object oldValue; - do { - oldValue = keyRegion.putIfAbsent(index, wrapper); - if (oldValue != null) { - index += pushType == ListDirection.LEFT ? -1 : 1; // Subtract index if left push, add if - // right push - } - } while (oldValue != null); - - /** - * - * Next, update the index in the meta data region. Keep trying to replace the existing index - * unless the index is further out than previously inserted, that's ok. Example below: - * - * ********************** LPUSH/LPUSH *************************** Push occurring at the same - * time, further index update first | This push | | | | V V [-4] [-3] [-2] [-1] [0] [1] [2] - * - * In this case, -4 would already exist in the meta data region, therefore we do not try to - * put -3 in the meta data region because a further index is already there. - * *************************************************************** - * - * Another example - * - * ********************** LPUSH/LPOP ***************************** This push | Simultaneous - * LPOP, meta data head index already updated to -2 | | | | V V [-4] [X] [-2] [-1] [0] [1] [2] - * - * In this case, -2 would already exist in the meta data region, but we need to make sure the - * element at -4 is visible to all other threads so we will attempt to change the index to -4 - * as long as it is greater than -4 - * *************************************************************** - * - */ - - boolean indexSet = false; - do { - Integer existingIndex = (Integer) keyRegion.get(indexKey); - if ((pushType == ListDirection.RIGHT && existingIndex < index) - || (pushType == ListDirection.LEFT && existingIndex > index)) - indexSet = keyRegion.replace(indexKey, existingIndex, index); - else - break; - } while (!indexSet); - - } - } - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/PopExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/PopExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/PopExecutor.java deleted file mode 100755 index d5c6e01..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/PopExecutor.java +++ /dev/null @@ -1,134 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import java.util.List; - -import org.apache.geode.cache.Region; - -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.Coder; -import org.apache.geode.redis.internal.Command; -import org.apache.geode.redis.internal.ExecutionHandlerContext; -import org.apache.geode.redis.internal.Extendable; -import org.apache.geode.redis.internal.RedisDataType; - -public abstract class PopExecutor extends ListExecutor implements Extendable { - - @Override - public void executeCommand(Command command, ExecutionHandlerContext context) { - List<byte[]> commandElems = command.getProcessedCommand(); - - if (commandElems.size() < 2) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), getArgsError())); - return; - } - - ByteArrayWrapper key = command.getKey(); - - checkDataType(key, RedisDataType.REDIS_LIST, context); - Region keyRegion = getRegion(context, key); - - if (keyRegion == null || keyRegion.size() == LIST_EMPTY_SIZE) { - command.setResponse(Coder.getNilResponse(context.getByteBufAllocator())); - return; - } - - String indexKey = popType() == ListDirection.LEFT ? "head" : "tail"; - String oppositeKey = popType() == ListDirection.RIGHT ? "head" : "tail"; - Integer index = 0; - int originalIndex = index; - int incr = popType() == ListDirection.LEFT ? 1 : -1; - ByteArrayWrapper valueWrapper = null; - - /** - * - * First attempt to hop over an index by moving the index down one in the meta data region. The - * desired index to remove is held within the field index - * - */ - - boolean indexChanged = false; - do { - index = (Integer) keyRegion.get(indexKey); - Integer opp = (Integer) keyRegion.get(oppositeKey); - if (index.equals(opp)) - break; - indexChanged = keyRegion.replace(indexKey, index, index + incr); - } while (!indexChanged); - - /** - * - * Now attempt to remove the value of the index. We must do a get to ensure a returned value and - * then call remove with the value to ensure no one else has removed it first. Otherwise, try - * other indexes - * - */ - - boolean removed = false; - int i = 0; - do { - valueWrapper = (ByteArrayWrapper) keyRegion.get(index); - if (valueWrapper != null) - removed = keyRegion.remove(index, valueWrapper); - - /** - * - * If remove has passed, our job is done and we can break and stop looking for a value - * - */ - - if (removed) - break; - - /** - * - * If the index has not been removed, we need to look at other indexes. Two cases exist: - * - * ************************** FIRST MISS *********************************** Push occurring at - * the same time, further index update first | This is location of miss | | | | V V [-4] [X] - * [-2] [-1] [0] [1] [2] <-- Direction of index update If this is the first miss, the index is - * re obtained from the meta region and that index is trying. However, if the index in the - * meta data region is not further out, that index is not used and moves on to the second case - * ************************************************************************** - * - * ************************* SUBSEQUENT MISSES ****************************** Push occurring - * at the same time, further index update first | This is location of miss | | | | V V [-4] - * [X] [-2] [-1] [0] [1] [2] Direction of index update --> If this is not the first miss then - * we move down to the other end of the list which means the next not empty index will be - * attempted to be removed - * ************************************************************************** - * - * If it is the case that the list is empty, it will exit this loop - * - */ - - index += incr; - Integer metaIndex = (Integer) keyRegion.get(indexKey); - if (i < 1 && (popType() == ListDirection.LEFT && metaIndex < originalIndex - || popType() == ListDirection.RIGHT && metaIndex > originalIndex)) - index = metaIndex; - i++; - } while (!removed && keyRegion.size() != LIST_EMPTY_SIZE); - if (valueWrapper != null) - command.setResponse( - Coder.getBulkStringResponse(context.getByteBufAllocator(), valueWrapper.toBytes())); - else - command.setResponse(Coder.getNilResponse(context.getByteBufAllocator())); - } - - protected abstract ListDirection popType(); - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/PushExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/PushExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/PushExecutor.java deleted file mode 100755 index b6017a5..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/PushExecutor.java +++ /dev/null @@ -1,54 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import java.util.List; -import java.util.concurrent.atomic.AtomicInteger; - -import org.apache.geode.cache.Region; -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.Command; -import org.apache.geode.redis.internal.ExecutionHandlerContext; -import org.apache.geode.redis.internal.Extendable; -import org.apache.geode.redis.internal.RedisDataType; -import org.apache.geode.redis.internal.Coder; - -public abstract class PushExecutor extends PushXExecutor implements Extendable { - - private final int START_VALUES_INDEX = 2; - static volatile AtomicInteger puts = new AtomicInteger(0); - - @Override - public void executeCommand(Command command, ExecutionHandlerContext context) { - List<byte[]> commandElems = command.getProcessedCommand(); - - if (commandElems.size() < 3) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), getArgsError())); - return; - } - - ByteArrayWrapper key = command.getKey(); - - Region<Integer, ByteArrayWrapper> keyRegion = - getOrCreateRegion(context, key, RedisDataType.REDIS_LIST); - pushElements(key, commandElems, START_VALUES_INDEX, commandElems.size(), keyRegion, pushType(), - context); - int listSize = keyRegion.size() - LIST_EMPTY_SIZE; - command.setResponse(Coder.getIntegerResponse(context.getByteBufAllocator(), listSize)); - } - - protected abstract ListDirection pushType(); - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/PushXExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/PushXExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/PushXExecutor.java deleted file mode 100755 index 3123f92..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/PushXExecutor.java +++ /dev/null @@ -1,57 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import java.util.List; - -import org.apache.geode.cache.Region; -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.Coder; -import org.apache.geode.redis.internal.Command; -import org.apache.geode.redis.internal.ExecutionHandlerContext; -import org.apache.geode.redis.internal.Extendable; -import org.apache.geode.redis.internal.RedisDataType; - -public abstract class PushXExecutor extends ListExecutor implements Extendable { - - private final int NOT_EXISTS = 0; - - @Override - public void executeCommand(Command command, ExecutionHandlerContext context) { - List<byte[]> commandElems = command.getProcessedCommand(); - - if (commandElems.size() < 3) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), getArgsError())); - return; - } - - ByteArrayWrapper key = command.getKey(); - - Region<Integer, ByteArrayWrapper> keyRegion = getRegion(context, key); - if (keyRegion == null) { - command.setResponse(Coder.getIntegerResponse(context.getByteBufAllocator(), NOT_EXISTS)); - return; - } - checkDataType(key, RedisDataType.REDIS_LIST, context); - pushElements(key, commandElems, 2, 3, keyRegion, pushType(), context); - - int listSize = keyRegion.size() - LIST_EMPTY_SIZE; - - command.setResponse(Coder.getIntegerResponse(context.getByteBufAllocator(), listSize)); - } - - protected abstract ListDirection pushType(); - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/RPopExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/RPopExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/RPopExecutor.java deleted file mode 100755 index 3d25ae6..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/RPopExecutor.java +++ /dev/null @@ -1,32 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import org.apache.geode.redis.internal.RedisConstants.ArityDef; - - -public class RPopExecutor extends PopExecutor { - - @Override - protected ListDirection popType() { - return ListDirection.RIGHT; - } - - @Override - public String getArgsError() { - return ArityDef.RPOP; - } - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/RPushExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/RPushExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/RPushExecutor.java deleted file mode 100755 index 04f6bfd..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/RPushExecutor.java +++ /dev/null @@ -1,32 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import org.apache.geode.redis.internal.RedisConstants.ArityDef; - - -public class RPushExecutor extends PushExecutor { - - @Override - protected ListDirection pushType() { - return ListDirection.RIGHT; - } - - @Override - public String getArgsError() { - return ArityDef.RPUSH; - } - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/RPushXExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/RPushXExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/RPushXExecutor.java deleted file mode 100755 index 8d1a007..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/list/RPushXExecutor.java +++ /dev/null @@ -1,32 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.list; - -import org.apache.geode.redis.internal.RedisConstants.ArityDef; - - -public class RPushXExecutor extends PushXExecutor { - - @Override - protected ListDirection pushType() { - return ListDirection.RIGHT; - } - - @Override - public String getArgsError() { - return ArityDef.RPUSHX; - } - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SAddExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SAddExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SAddExecutor.java deleted file mode 100755 index 2226a55..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SAddExecutor.java +++ /dev/null @@ -1,60 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.set; - -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -import org.apache.geode.cache.Region; -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.Coder; -import org.apache.geode.redis.internal.Command; -import org.apache.geode.redis.internal.ExecutionHandlerContext; -import org.apache.geode.redis.internal.RedisConstants.ArityDef; -import org.apache.geode.redis.internal.RedisDataType; - -public class SAddExecutor extends SetExecutor { - - @Override - public void executeCommand(Command command, ExecutionHandlerContext context) { - List<byte[]> commandElems = command.getProcessedCommand(); - - if (commandElems.size() < 3) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ArityDef.SADD)); - return; - } - - ByteArrayWrapper key = command.getKey(); - @SuppressWarnings("unchecked") - Region<ByteArrayWrapper, Boolean> keyRegion = (Region<ByteArrayWrapper, Boolean>) context - .getRegionProvider().getOrCreateRegion(key, RedisDataType.REDIS_SET, context); - - if (commandElems.size() >= 4) { - Map<ByteArrayWrapper, Boolean> entries = new HashMap<ByteArrayWrapper, Boolean>(); - for (int i = 2; i < commandElems.size(); i++) - entries.put(new ByteArrayWrapper(commandElems.get(i)), true); - - keyRegion.putAll(entries); - command.setResponse(Coder.getIntegerResponse(context.getByteBufAllocator(), entries.size())); - } else { - Object v = keyRegion.put(new ByteArrayWrapper(commandElems.get(2)), true); - command - .setResponse(Coder.getIntegerResponse(context.getByteBufAllocator(), v == null ? 1 : 0)); - } - - } - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SCardExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SCardExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SCardExecutor.java deleted file mode 100755 index c1d3a4c..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SCardExecutor.java +++ /dev/null @@ -1,54 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.set; - -import java.util.List; - -import org.apache.geode.cache.Region; -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.Command; -import org.apache.geode.redis.internal.ExecutionHandlerContext; -import org.apache.geode.redis.internal.RedisConstants.ArityDef; -import org.apache.geode.redis.internal.RedisDataType; -import org.apache.geode.redis.internal.Coder; - -public class SCardExecutor extends SetExecutor { - - private final int NOT_EXISTS = 0; - - @SuppressWarnings("unchecked") - @Override - public void executeCommand(Command command, ExecutionHandlerContext context) { - List<byte[]> commandElems = command.getProcessedCommand(); - - if (commandElems.size() < 2) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ArityDef.SCARD)); - return; - } - - ByteArrayWrapper key = command.getKey(); - checkDataType(key, RedisDataType.REDIS_SET, context); - Region<ByteArrayWrapper, Boolean> keyRegion = - (Region<ByteArrayWrapper, Boolean>) context.getRegionProvider().getRegion(key); - - if (keyRegion == null) { - command.setResponse(Coder.getIntegerResponse(context.getByteBufAllocator(), NOT_EXISTS)); - return; - } - - command.setResponse(Coder.getIntegerResponse(context.getByteBufAllocator(), keyRegion.size())); - } - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SDiffExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SDiffExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SDiffExecutor.java deleted file mode 100755 index ef61a93..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SDiffExecutor.java +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.set; - -import java.util.List; -import java.util.Set; - -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.RedisConstants.ArityDef; - -public class SDiffExecutor extends SetOpExecutor { - - @Override - protected boolean isStorage() { - return false; - } - - @Override - protected Set<ByteArrayWrapper> setOp(Set<ByteArrayWrapper> firstSet, - List<Set<ByteArrayWrapper>> setList) { - if (firstSet == null) - return null; - for (Set<ByteArrayWrapper> set : setList) - firstSet.removeAll(set); - return firstSet; - } - - @Override - public String getArgsError() { - return ArityDef.SDIFF; - } - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SDiffStoreExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SDiffStoreExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SDiffStoreExecutor.java deleted file mode 100755 index 63064da..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SDiffStoreExecutor.java +++ /dev/null @@ -1,31 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.set; - -import org.apache.geode.redis.internal.RedisConstants.ArityDef; - - -public class SDiffStoreExecutor extends SDiffExecutor { - - @Override - protected boolean isStorage() { - return true; - } - - @Override - public String getArgsError() { - return ArityDef.SDIFFSTORE; - } -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SInterExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SInterExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SInterExecutor.java deleted file mode 100755 index e51fa2c..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SInterExecutor.java +++ /dev/null @@ -1,48 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.set; - -import java.util.List; -import java.util.Set; - -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.RedisConstants.ArityDef; - -public class SInterExecutor extends SetOpExecutor { - - @Override - protected boolean isStorage() { - return false; - } - - @Override - protected Set<ByteArrayWrapper> setOp(Set<ByteArrayWrapper> firstSet, - List<Set<ByteArrayWrapper>> setList) { - if (firstSet == null) - return null; - for (Set<ByteArrayWrapper> set : setList) { - if (set == null || set.isEmpty()) - return null; - firstSet.retainAll(set); - } - return firstSet; - } - - @Override - public String getArgsError() { - return ArityDef.SINTER; - } - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SInterStoreExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SInterStoreExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SInterStoreExecutor.java deleted file mode 100755 index bef36ff..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SInterStoreExecutor.java +++ /dev/null @@ -1,32 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.set; - -import org.apache.geode.redis.internal.RedisConstants.ArityDef; - - -public class SInterStoreExecutor extends SInterExecutor { - - @Override - protected boolean isStorage() { - return true; - } - - @Override - public String getArgsError() { - return ArityDef.SINTERSTORE; - } - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SIsMemberExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SIsMemberExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SIsMemberExecutor.java deleted file mode 100755 index 62ff597..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SIsMemberExecutor.java +++ /dev/null @@ -1,62 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.set; - -import java.util.List; - -import org.apache.geode.cache.Region; -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.Command; -import org.apache.geode.redis.internal.ExecutionHandlerContext; -import org.apache.geode.redis.internal.RedisConstants.ArityDef; -import org.apache.geode.redis.internal.RedisDataType; -import org.apache.geode.redis.internal.Coder; - -public class SIsMemberExecutor extends SetExecutor { - - private final int EXISTS = 1; - - private final int NOT_EXISTS = 0; - - @Override - public void executeCommand(Command command, ExecutionHandlerContext context) { - List<byte[]> commandElems = command.getProcessedCommand(); - - if (commandElems.size() < 3) { - command - .setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ArityDef.SISMEMBER)); - return; - } - - ByteArrayWrapper key = command.getKey(); - ByteArrayWrapper member = new ByteArrayWrapper(commandElems.get(2)); - - checkDataType(key, RedisDataType.REDIS_SET, context); - @SuppressWarnings("unchecked") - Region<ByteArrayWrapper, Boolean> keyRegion = - (Region<ByteArrayWrapper, Boolean>) context.getRegionProvider().getRegion(key); - - if (keyRegion == null) { - command.setResponse(Coder.getIntegerResponse(context.getByteBufAllocator(), NOT_EXISTS)); - return; - } - - if (keyRegion.containsKey(member)) - command.setResponse(Coder.getIntegerResponse(context.getByteBufAllocator(), EXISTS)); - else - command.setResponse(Coder.getIntegerResponse(context.getByteBufAllocator(), NOT_EXISTS)); - } - -} http://git-wip-us.apache.org/repos/asf/geode/blob/c6dbc6d4/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SMembersExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SMembersExecutor.java b/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SMembersExecutor.java deleted file mode 100755 index dc94897..0000000 --- a/geode-core/src/main/java/org/apache/geode/redis/internal/executor/set/SMembersExecutor.java +++ /dev/null @@ -1,55 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more contributor license - * agreements. See the NOTICE file distributed with this work for additional information regarding - * copyright ownership. The ASF licenses this file to You 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.apache.geode.redis.internal.executor.set; - -import java.util.HashSet; -import java.util.List; -import java.util.Set; - -import org.apache.geode.cache.Region; -import org.apache.geode.redis.internal.ByteArrayWrapper; -import org.apache.geode.redis.internal.Coder; -import org.apache.geode.redis.internal.Command; -import org.apache.geode.redis.internal.ExecutionHandlerContext; -import org.apache.geode.redis.internal.RedisConstants.ArityDef; -import org.apache.geode.redis.internal.RedisDataType; - -public class SMembersExecutor extends SetExecutor { - - @Override - public void executeCommand(Command command, ExecutionHandlerContext context) { - List<byte[]> commandElems = command.getProcessedCommand(); - - if (commandElems.size() < 2) { - command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ArityDef.SMEMBERS)); - return; - } - - ByteArrayWrapper key = command.getKey(); - checkDataType(key, RedisDataType.REDIS_SET, context); - @SuppressWarnings("unchecked") - Region<ByteArrayWrapper, Boolean> keyRegion = - (Region<ByteArrayWrapper, Boolean>) context.getRegionProvider().getRegion(key); - - if (keyRegion == null) { - command.setResponse(Coder.getEmptyArrayResponse(context.getByteBufAllocator())); - return; - } - - Set<ByteArrayWrapper> members = new HashSet(keyRegion.keySet()); // Emulate copy on read - - command.setResponse(Coder.getBulkStringArrayResponse(context.getByteBufAllocator(), members)); - } -}
