Package com.sleepycat.je.txn

Examples of com.sleepycat.je.txn.Locker.operationEnd()

1002
1003
1004
1005
1006
1007
1008
1009
1010
1011
1012
            if (cursor != null) {
                cursor.releaseBINs();
                cursor.close();
            }
            if (locker != null) {
                locker.operationEnd();
            }

            int newMemorySize = fileSummaryMap.size() *
                MemoryBudget.UTILIZATION_PROFILE_ENTRY;
            MemoryBudget mb = env.getMemoryBudget();
View Full Code Here
1087
1088
1089
1090
1091
1092
1093
1094
1095
1096
1097
            fileSummaryDb = db;
            operationOk = true;
            return true;
        } finally {
            if (autoTxn != null) {
                autoTxn.operationEnd(operationOk);
            }
        }
    }

    /**
 
View Full Code Here
1129
1130
1131
1132
1133
1134
1135
1136
1137
1138
1139
        } finally {
            if (cursor != null) {
                cursor.close();
            }
            if (locker != null) {
                locker.operationEnd();
            }
        }
    }

    /**
 
View Full Code Here
1200
1201
1202
1203
1204
1205
1206
1207
1208
1209
1210
        } finally {
            if (cursor != null) {
                cursor.close();
            }
            if (locker != null) {
                locker.operationEnd();
            }
        }

        return ok;
    }
View Full Code Here
164
165
166
167
168
169
170
171
172
173
174
        } finally {
            if (cursor != null) {
                cursor.close();
            }
            if (locker != null) {
                locker.operationEnd(status);
            }
        }

        /*
         * cacheLast is initialized such that the cache will be considered
View Full Code Here
306
307
308
309
310
311
312
313
314
315
316
            } finally {
                if (cursor != null) {
                    cursor.close();
                }
                if (locker != null) {
                    locker.operationEnd(status);
                }
            }

            /* The cache now contains the range: [cacheValue, storedValue) */
            cacheValue = storedValue - adjust;
View Full Code Here
218
219
220
221
222
223
224
225
226
227
228
            if (nameCursor != null) {
                nameCursor.close();
            }

            if (autoTxn != null) {
                autoTxn.operationEnd(operationOk);
            }
        }

        return newDb;
    }
View Full Code Here
267
268
269
270
271
272
273
274
275
276
277
      mapLN = (MapLN)
          cursor.getCurrentLNAlreadyLatched(LockType.WRITE);
                        assert mapLN != null; /* Should be locked. */
        } catch (DeadlockException DE) {
      cursor.close();
      locker.operationEnd(false);
      locker = createLocker(envImpl);
      cursor = new CursorImpl(idDatabase, locker);
      continue;
        } finally {
      cursor.releaseBINs();
View Full Code Here
287
288
289
290
291
292
293
294
295
296
297
            } finally {
                if (cursor != null) {
                    cursor.close();
                }

                locker.operationEnd(operationOk);
            }
        }
    }

    private static class RewriteMapLN implements WithRootLatched {
View Full Code Here
502
503
504
505
506
507
508
509
510
511
512
                    if (idCursor != null) {
                        idCursor.close();
                    }

                    if (autoTxn != null) {
                        autoTxn.operationEnd(operationOk);
                    }
                }
                result.nameLN.setId(newDb.getId());

                /* If required, count the number of records in the database. */
 
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.