Examples of freenet.support.api.Bucket.free()

freenet.support.api.Bucket.free()
Free the bucket, if supported. Note that you must call free() even if you haven't used the Bucket (haven't called getOutputStream()) for some kinds of Bucket's, as they may have allocated space (e.g. created a temporary file).

          if(keepLastData) {
            if(lastRequestData != null)
              lastRequestData.free();
            lastRequestData = data;
          } else
            data.free();
        } else {
          lastCompressionCodec = -1;
          lastWasMetadata = false;
          lastRequestData = null;
        }

View Full Code Here

      a.cancel(context);
    if(storeChecker != null)
      // Remove from the store checker queue.
      storeChecker.unregister(context, storeChecker.getPriorityClass());
    if(data != null)
        data.free();
  }


  /** Set of interested USKCallbacks. Note that we don't actually
   * send them any information - they are essentially placeholders,
   * an alternative to a refcount. This could be replaced with a

View Full Code Here

      } catch (IOException e) {
        // Bucket error?
        SingleFileFetcher.this.onFailure(new FetchException(FetchExceptionMode.BUCKET_ERROR, e), false, context);
        return;
      } finally {
        finalData.free();
      }
    }
    
    @Override
    public void onFailure(FetchException e, ClientGetState state, ClientContext context) {

View Full Code Here

            Bucket metaBucket = m.toBucket(bf);
            Metadata m1 = Metadata.construct(metaBucket);
            Bucket copyBucket = m1.toBucket(bf);
            assertTrue(BucketTools.equalBuckets(metaBucket, copyBucket));
            metaBucket.free();
            copyBucket.free();
            return new TestSplitfile(data, m1, originalDataBlocks, originalCheckBlocks, dataKeys, checkKeys, 
                    cryptoKey, cryptoAlgorithm, null, null, persistent);
        }


        /**

View Full Code Here

            Bucket metaBucket = m.toBucket(bf);
            Metadata m1 = Metadata.construct(metaBucket);
            Bucket copyBucket = m1.toBucket(bf);
            assertTrue(BucketTools.equalBuckets(metaBucket, copyBucket));
            metaBucket.free();
            copyBucket.free();
            return new TestSplitfile(data, m1, originalDataBlocks, originalCheckBlocks, dataKeys, checkKeys, 
                    cryptoKey, cryptoAlgorithm, segmentDataBlockCount, segmentCheckBlockCount, persistent);
        }
        
        public CHKBlock encodeDataBlock(int i) throws CHKEncodeException {

View Full Code Here

            Bucket out = bf.makeBucket(-1);
            OutputStream os = out.getOutputStream();
            g.writeTo(os, null);
            os.close();
            assertTrue(BucketTools.equalBuckets(originalData, out));
            out.free();
        }


        public NodeCHK getCHK(int block) {
            if(block < dataBlocks.length)
                return dataKeys[block].getNodeCHK();

View Full Code Here

                    new URI("http://127.0.0.1:8888/freenet:USK@ZupQjDFZSc3I4orBpl1iTEAPZKo2733RxCUbZ2Q7iH0,EO8Tuf8SP3lnDjQdAPdCM2ve2RaUEN8m-hod3tQ5oQE,AQACAAE/jFreesite/19/Style/"), null, null, null);
        } finally {
            Closer.close(inputStream);
            Closer.close(outputStream);
            inputBucket.free();
            outputBucket.free();
        }
    }
}

View Full Code Here

    synchronized(this) {
      runningInserters.remove(data);
    }
    if(logMINOR)
      Logger.minor(this, "Successfully inserted healing block: "+sbi.getURINoEncode()+" for "+data+" ("+sbi.token+ ')');
    data.free();
  }


  @Override
  public void onFailure(InsertException e, ClientPutState state, ClientContext context) {
    SingleBlockInserter sbi = (SingleBlockInserter)state;

View Full Code Here

    synchronized(this) {
      runningInserters.remove(data);
    }
    if(logMINOR)
      Logger.minor(this, "Failed to insert healing block: "+sbi.getURINoEncode()+" : "+e+" for "+data+" ("+sbi.token+ ')', e);
    data.free();
  }


  @Override
  public void onEncode(BaseClientKey usk, ClientPutState state, ClientContext context) {
    // Ignore

View Full Code Here

            maybeNextMainJarVersion = -1;
            maybeNextMainJarData = null;
          }
        }
        if (toFree != null)
          toFree.free();
      }
    }
  }
  
  /** Use this lock when deploying an update of any kind which will require us to restart. If the

View Full Code Here

0 1 2 3 4

TOP

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.