Package com.sleepycat.je.txn

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

823
824
825
826
827
828
829
830
831
832
833
                        foundDbImpl =  mapLN.getDatabase();
                    }
                    break;
    } catch (DeadlockException DE) {
        idCursor.close();
        locker.operationEnd(false);
        locker = new BasicLocker(envImpl);
        if (lockTimeout != -1) {
      locker.setLockTimeout(lockTimeout);
        }
        idCursor = new CursorImpl(idDatabase, locker);
View Full Code Here
834
835
836
837
838
839
840
841
842
843
844
                    idCursor.setAllowEviction(allowEviction);
        continue;
    } finally {
        idCursor.releaseBIN();
        idCursor.close();
        locker.operationEnd(true);
    }
      }

            /*
             * Set the debugging name in the databaseImpl, but only after
View Full Code Here
959
960
961
962
963
964
965
966
967
968
969
    if (cursor != null) {
        cursor.releaseBINs();
        cursor.close();
    }
    if (locker != null) {
        locker.operationEnd();
    }
      }
  }

  return ret;
View Full Code Here
1018
1019
1020
1021
1022
1023
1024
1025
1026
1027
1028
            if (cursor != null) {
                cursor.releaseBINs();
                cursor.close();
            }
            if (locker != null) {
                locker.operationEnd();
            }
        }
    }
   
    /**
 
View Full Code Here
1062
1063
1064
1065
1066
1067
1068
1069
1070
1071
1072
            if (cursor != null) {
                cursor.close();
            }

            if (locker != null) {
                locker.operationEnd();
            }
        }
    }

    /**
 
View Full Code Here
287
288
289
290
291
292
293
294
295
296
297
        } finally {
            if (cursor != null) {
                cursor.close();
            }
            if (locker != null) {
                locker.operationEnd(commitStatus);
            }
        }
    }

    /**
 
View Full Code Here
338
339
340
341
342
343
344
345
346
347
348
                (envHandle, txn, isTransactional());
            commitStatus = deleteInternal(locker, key);
            return commitStatus;
        } finally {
            if (locker != null) {
                locker.operationEnd(commitStatus);
            }
        }
    }

    /**
 
View Full Code Here
527
528
529
530
531
532
533
534
535
536
537
        } finally {
            if (cursor != null) {
                cursor.close();
            }
            if (locker != null) {
                locker.operationEnd(commitStatus);
            }
        }
    }

    /**
 
View Full Code Here
631
632
633
634
635
636
637
638
639
640
641
            operationOk = true;
            return count;
        } finally {
            if (locker != null) {
                locker.operationEnd(operationOk);
            }
            if (triggerLock) {
                releaseTriggerListReadLock();
            }
        }
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
                        LN ln = lns[i][j];
                        retrieveDuplicateLN(key, ln);
                    }
                }
            } finally {
                txn.operationEnd();
            }
        } catch (Throwable t) {
            t.printStackTrace();
            throw t;
        }
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.