From 6e1ef5af508d13061bdf1ab4892d6881ccdbdfda Mon Sep 17 00:00:00 2001
From: ewhauser <ewhauser@gmail.com>
Date: Thu, 28 Apr 2011 14:39:08 -0400
Subject: [PATCH] adding bit commands to ShardedJedisPipeline

---
 .../clients/jedis/ShardedJedisPipeline.java   | 28 +++++++++++++++++--
 1 file changed, 26 insertions(+), 2 deletions(-)

diff --git a/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java b/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java
index ad57c0f..544ce73 100644
--- a/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java
+++ b/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java
@@ -1,11 +1,11 @@
 package redis.clients.jedis;
 
+import redis.clients.jedis.BinaryClient.LIST_POSITION;
+
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 
-import redis.clients.jedis.BinaryClient.LIST_POSITION;
-
 public abstract class ShardedJedisPipeline {
     private BinaryShardedJedis jedis;
     private List<FutureResult> results = new ArrayList<FutureResult>();
@@ -425,6 +425,30 @@ public abstract class ShardedJedisPipeline {
         results.add(new FutureResult(c));
     }
 
+    protected void getbit(String key, long offset) {
+        Client c = jedis.getShard(key).getClient();
+        c.getbit(key, offset);
+        results.add(new FutureResult(c));
+    }
+
+    public void setbit(String key, long offset, boolean value) {
+        Client c = jedis.getShard(key).getClient();
+        c.setbit(key, offset, value);
+        results.add(new FutureResult(c));
+    }
+
+    public void setrange(String key, long offset, String value) {
+        Client c = jedis.getShard(key).getClient();
+        c.setrange(key, offset, value);
+        results.add(new FutureResult(c));
+    }
+
+    public void getrange(String key, long startOffset, long endOffset) {
+        Client c = jedis.getShard(key).getClient();
+        c.getrange(key, startOffset, endOffset);
+        results.add(new FutureResult(c));
+    }
+
     public List<Object> getResults() {
         List<Object> r = new ArrayList<Object>();
         for (FutureResult fr : results) {