Package org.eclipse.jgit.storage.dht

Examples of org.eclipse.jgit.storage.dht.DhtException

120
121
122
123
124
125
126
127
128
129
130
      MemTable.Cell cell = table.get(row, colMeta.name());
      if (cell != null) {
        try {
          out.put(chunk, ChunkMeta.parseFrom(cell.getValue()));
        } catch (InvalidProtocolBufferException err) {
          callback.onFailure(new DhtException(MessageFormat.format(
              DhtText.get().invalidChunkMeta, chunk), err));
          return;
        }
      }
    }
View Full Code Here
73
74
75
76
77
78
79
80
        name.asBytes(), //
        colId.name(), //
        null, //
        key.asBytes());
    if (!ok)
      throw new DhtException(MessageFormat.format(
          DhtText.get().repositoryAlreadyExists, name.asString()));
  }
View Full Code Here
85
86
87
88
89
90
91
92
        name.asBytes(),
        colId.name(),
        key.asBytes(),
        null);
    if (!ok)
      throw new DhtException(MessageFormat.format(
          DhtText.get().repositoryAlreadyExists, name.asString()));
  }
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
          chunks.add(new ObjectInfo(
              chunkKey,
              cell.getTimestamp(),
              GitStore.ObjectInfo.parseFrom(cell.getValue())));
        } catch (InvalidProtocolBufferException badCell) {
          callback.onFailure(new DhtException(MessageFormat.format(
              DhtText.get().invalidObjectInfo, objId, chunkKey),
              badCell));
          return;
        }
      }
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
    for (MemTable.Cell cell : table.scanFamily(repository.asBytes(), colRef)) {
      RefKey ref = RefKey.fromBytes(colRef.suffix(cell.getName()));
      try {
        out.put(ref, RefData.parseFrom(cell.getValue()));
      } catch (InvalidProtocolBufferException badCell) {
        throw new DhtException(MessageFormat.format(
            DhtText.get().invalidRefData, ref), badCell);
      }
    }
    return out;
  }
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
    List<CachedPackInfo> out = new ArrayList<CachedPackInfo>(4);
    for (MemTable.Cell cell : table.scanFamily(repo.asBytes(), colCachedPack)) {
      try {
        out.add(CachedPackInfo.parseFrom(cell.getValue()));
      } catch (InvalidProtocolBufferException e) {
        throw new DhtException(MessageFormat.format(
            DhtText.get().invalidCachedPackInfo, repo,
            CachedPackKey.fromBytes(cell.getName())), e);
      }
    }
    return out;
View Full Code Here
TOP

Related Classes of org.eclipse.jgit.storage.dht.DhtException

  • org.eclipse.jgit.storage.cassandra.CassandraDatabase
  • org.eclipse.jgit.storage.cassandra.CsBuffer
  • org.eclipse.jgit.storage.cassandra.CsChunkTable
  • org.eclipse.jgit.storage.cassandra.CsObjectIndexTable
  • org.eclipse.jgit.storage.cassandra.CsRefTable
  • org.eclipse.jgit.storage.cassandra.CsRepositoryIndexTable
  • org.eclipse.jgit.storage.dht.spi.memory.MemChunkTable
  • org.eclipse.jgit.storage.dht.spi.memory.MemObjectIndexTable
  • org.eclipse.jgit.storage.dht.spi.memory.MemRefTable
  • org.eclipse.jgit.storage.dht.spi.memory.MemRepositoryIndexTable
    • 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.