Package com.google.nigori.client

Examples of com.google.nigori.client.NigoriDatastore.unregister()

119
120
121
122
123
124
125
126
127
128
129
        for (IndexValue iv : testCases) {
          final Index index = iv.index;
          assertNull("Still there after deletion " + i, nigori.get(index));
        }
      } finally {
        assertTrue("Not unregistered", nigori.unregister());
      }
    }
  }

  @Test
View Full Code Here
144
145
146
147
148
149
150
151
152
153
154
        assertThat(revisions, hasItem(b));
      } finally {
        nigori.delete(index, NULL_DELETE_TOKEN);
      }
    } finally {
      assertTrue("Not unregistered", nigori.unregister());
    }
  }

  @Test
  public void getIndices() throws IOException, NigoriCryptographyException, UnauthorisedException {
View Full Code Here
169
170
171
172
173
174
175
176
177
178
179
      } finally {
        nigori.delete(indexa, NULL_DELETE_TOKEN);
        nigori.delete(indexb, NULL_DELETE_TOKEN);
      }
    } finally {
      assertTrue("Not unregistered", nigori.unregister());
    }
  }

  // @Test //TODO(drt24) Do we want to enforce revisions being immutable? Migori doesn't really need
  // this due to the way revisions are generated.
View Full Code Here
186
187
188
189
190
191
192
193
194
      final Revision revision = new Revision("rev");
      assertTrue("Not put", nigori.put(index, revision, Util.int2bin(0)));
      assertFalse("Could replace revision value", nigori.put(index, revision, Util.int2bin(1)));
      nigori.delete(index, NULL_DELETE_TOKEN);
    } finally {
      assertTrue("Not unregistered", nigori.unregister());
    }
  }
}
View Full Code Here
106
107
108
109
110
111
112
113
114
115
116
                  assertArrayEquals("Got different" + i, value, nigori.getRevision(index, revision));
                  assertTrue("Not deleted " + i, nigori.delete(index, NULL_DELETE_TOKEN));
                  assertNull("Still there after deletion " + i, nigori.get(index));
                }
              } finally {
                assertTrue(nigori.unregister());
              }
            }
            succeeded = true;
          } catch (Throwable e) {
            exceptionList.add(e);
View Full Code Here
181
182
183
184
185
186
187
188
189
190
191
      }
      startThenJoinThreads(threads);

      ifFailedPrintFailures(failed, exceptionList);
    } finally {
      assertTrue(nigori.unregister());
    }
  }

  // TODO(drt24) once we have versioning then test that concurrent execution on the same keys works.
}
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.