Package net.spy.memcached.ops

Examples of net.spy.memcached.ops.Operation

51
52
53
54
55
56
57
58
59
60
61
    super(sa, c, bufSize, rq, wq, iq, opQueueMaxBlockTimeNs, waitForAuth, dt);
  }

  @Override
  protected void optimize() {
    Operation firstOp = writeQ.peek();
    if (firstOp instanceof GetOperation) {
      optimizeGets();
    } else if (firstOp instanceof CASOperation) {
      optimizeSets();
    }
View Full Code Here
267
268
269
270
271
272
273
274
275
276
277
                 int exp, T value, Transcoder<T> tc) {
    CachedData co=tc.encode(value);
    final CountDownLatch latch=new CountDownLatch(1);
    final OperationFuture<Boolean> rv=new OperationFuture<Boolean>(latch,
        operationTimeout);
    Operation op=opFact.store(storeType, key, co.getFlags(),
        exp, co.getData(), new OperationCallback() {
          public void receivedStatus(OperationStatus val) {
            rv.set(val.isSuccess());
          }
          public void complete() {
View Full Code Here
292
293
294
295
296
297
298
299
300
301
302
      T value, Transcoder<T> tc) {
    CachedData co=tc.encode(value);
    final CountDownLatch latch=new CountDownLatch(1);
    final OperationFuture<Boolean> rv=new OperationFuture<Boolean>(latch,
        operationTimeout);
    Operation op=opFact.cat(catType, cas, key, co.getData(),
        new OperationCallback() {
      public void receivedStatus(OperationStatus val) {
        rv.set(val.isSuccess());
      }
      public void complete() {
View Full Code Here
372
373
374
375
376
377
378
379
380
381
382
      Transcoder<T> tc) {
    CachedData co=tc.encode(value);
    final CountDownLatch latch=new CountDownLatch(1);
    final OperationFuture<CASResponse> rv=new OperationFuture<CASResponse>(
        latch, operationTimeout);
    Operation op=opFact.cas(key, casId, co.getFlags(),
        co.getData(), new OperationCallback() {
          public void receivedStatus(OperationStatus val) {
            if(val instanceof CASOperationStatus) {
              rv.set(((CASOperationStatus)val).getCASResponse());
            } else if(val instanceof CancelledOperationStatus) {
View Full Code Here
639
640
641
642
643
644
645
646
647
648
649
    final CountDownLatch latch=new CountDownLatch(1);
    final OperationFuture<T> rv=new OperationFuture<T>(latch,
      operationTimeout);

    Operation op=opFact.get(key,
        new GetOperation.Callback() {
      private T val=null;
      public void receivedStatus(OperationStatus status) {
        rv.set(val);
      }
View Full Code Here
682
683
684
685
686
687
688
689
690
691
692
    final CountDownLatch latch=new CountDownLatch(1);
    final OperationFuture<CASValue<T>> rv=
      new OperationFuture<CASValue<T>>(latch, operationTimeout);

    Operation op=opFact.gets(key,
        new GetsOperation.Callback() {
      private CASValue<T> val=null;
      public void receivedStatus(OperationStatus status) {
        rv.set(val);
      }
View Full Code Here
853
854
855
856
857
858
859
860
861
862
863
    final Map<MemcachedNode, Operation> mops=
      new HashMap<MemcachedNode, Operation>();

    for(Map.Entry<MemcachedNode, Collection<String>> me
        : chunks.entrySet()) {
      Operation op=opFact.get(me.getValue(), cb);
      mops.put(me.getKey(), op);
      ops.add(op);
    }
    assert mops.size() == chunks.size();
    checkState();
View Full Code Here
1190
1191
1192
1193
1194
1195
1196
1197
1198
1199
1200
1201
1202
1203
1204
1205
1206
1207
1208
1209
1210
1211
1212
1213
1214
1215
1216
1217
1218
1219
1220
1221
1222
1223
1224
1225
1226
1227
1228
1229
1230
1231
1232
1233
    final ConcurrentLinkedQueue<Operation> ops=
      new ConcurrentLinkedQueue<Operation>();
    CountDownLatch blatch = broadcastOp(new BroadcastOpFactory(){
      public Operation newOp(final MemcachedNode n,
          final CountDownLatch latch) {
        Operation op=opFact.flush(delay, new OperationCallback(){
          public void receivedStatus(OperationStatus s) {
            flushResult.set(s.isSuccess());
          }
          public void complete() {
            latch.countDown();
          }});
        ops.add(op);
        return op;
      }});
    return new OperationFuture<Boolean>(blatch, flushResult,
        operationTimeout) {
      @Override
      public boolean cancel(boolean ign) {
        boolean rv=false;
        for(Operation op : ops) {
          op.cancel();
          rv |= op.getState() == OperationState.WRITING;
        }
        return rv;
      }
      @Override
      public boolean isCancelled() {
        boolean rv=false;
        for(Operation op : ops) {
          rv |= op.isCancelled();
        }
        return rv;
      }
      @Override
      public boolean isDone() {
        boolean rv=true;
        for(Operation op : ops) {
          rv &= op.getState() == OperationState.COMPLETE;
        }
        return rv || isCancelled();
      }
    };
  }
View Full Code Here
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
  /* (non-Javadoc)
   * @see net.spy.memcached.MemcachedNode#setupResend()
   */
  public final void setupResend() {
    // First, reset the current write op.
    Operation op=getCurrentWriteOp();
    if(op != null) {
      op.getBuffer().reset();
    }
    // Now cancel all the pending read operations.  Might be better to
    // to requeue them.
    while(hasReadOp()) {
      op=removeCurrentReadOp();
      getLogger().warn("Discarding partially completed op: %s", op);
      op.cancel();
    }

    getWbuf().clear();
    getRbuf().clear();
    toWrite=0;
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
107
  private boolean preparePending() {
    // Copy the input queue into the write queue.
    copyInputQueue();

    // Now check the ops
    Operation nextOp=getCurrentWriteOp();
    while(nextOp != null && nextOp.isCancelled()) {
      getLogger().info("Removing cancelled operation: %s", nextOp);
      removeCurrentWriteOp();
      nextOp=getCurrentWriteOp();
    }
    return nextOp != null;
View Full Code Here
TOP

Related Classes of net.spy.memcached.ops.Operation

  • com.couchbase.client.CouchbaseClient
  • com.couchbase.client.CouchbaseConnection
  • com.couchbase.client.TapClient
  • com.englishtown.vertx.clients.EtCouchbaseClient
  • net.spy.memcached.auth.AuthThread
  • net.spy.memcached.MemcachedClient
  • net.spy.memcached.MemcachedConnection
  • net.spy.memcached.protocol.binary.BinaryMemcachedNodeImpl
  • net.spy.memcached.protocol.TCPMemcachedNodeImpl
  • net.spy.memcached.TapClient
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.