Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * 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.flume.channel.file;
 
 import java.io.File;
 import java.util.List;
 
 
 
 
   private static final int INDEX_SIZE = 2;
   private static final int INDEX_HEAD = 3;
   private static final int INDEX_ACTIVE_LOG = 5;
   private static final int MAX_ACTIVE_LOGS = 1024;
 
   EventQueueBackingStoreFileV2(File checkpointFileint capacityString name)
       throws IOExceptionBadCheckpointException {
     super(capacitynamecheckpointFile);
     Preconditions.checkArgument(capacity > 0,
         "capacity must be greater than 0 " + capacity);
 
 
     int indexMaxLog =  + ;
     for (int i = i < indexMaxLogi++) {
       long nextFileCode = .get(i);
       if (nextFileCode  != ) {
         Pair<IntegerIntegeridAndCount =
             deocodeActiveLogCounter(nextFileCode);
         .put(idAndCount.getLeft(),
             new AtomicInteger(idAndCount.getRight()));
       }
     }
   }
   @Override
   protected int getVersion() {
     return .;
   }
 
   @Override
   protected void incrementFileID(int fileID) {
     super.incrementFileID(fileID);
         "Too many active logs ");
   }
 
 
   private Pair<IntegerIntegerdeocodeActiveLogCounter(long value) {
     int fileId = (int) (value >>> 32);
     int count = (intvalue;
     return Pair.of(fileIdcount);
   }
   private long encodeActiveLogCounter(int fileIdint count) {
     long result = fileId;
     result = (long)fileId << 32;
     result += (longcount;
     return result;
   }
   @Override
   protected void writeCheckpointMetaData() {
     List<LongfileIdAndCountEncoded = new ArrayList<Long>();
     for (Integer fileId : .keySet()) {
       Integer count = .get(fileId).get();
       long value = encodeActiveLogCounter(fileIdcount);
       fileIdAndCountEncoded.add(value);
     }
 
     int emptySlots =  - fileIdAndCountEncoded.size();
     for (int i = 0; i < emptySlotsi++)  {
       fileIdAndCountEncoded.add(0L);
     }
     for (int i = 0; i < i++) {
       .put(i + fileIdAndCountEncoded.get(i));
     }
  }
New to GrepCode? Check out our FAQ X