Searched refs:syncPolicy (Results 1 – 10 of 10) sorted by relevance
169 public long commit(SyncPolicy syncPolicy, in commit() argument180 if (syncPolicy == SyncPolicy.SYNC) { in commit()182 } else if (syncPolicy == SyncPolicy.NO_SYNC) { in commit()184 } else if (syncPolicy == SyncPolicy.WRITE_NO_SYNC) { in commit()188 ("Unknown sync policy: " + syncPolicy); in commit()
399 final SyncPolicy syncPolicy, in updateCommitStats() argument422 if (syncPolicy == SyncPolicy.SYNC) { in updateCommitStats()424 } else if (syncPolicy == SyncPolicy.NO_SYNC) { in updateCommitStats()426 } else if (syncPolicy == SyncPolicy.WRITE_NO_SYNC) { in updateCommitStats()430 ("Unknown sync policy: " + syncPolicy); in updateCommitStats()629 SyncPolicy syncPolicy) { in logReplay() argument639 syncPolicy + in logReplay()
121 inline SyncPolicy syncPolicy() const { return _syncPolicy; } in syncPolicy() function
193 public native void setDefaultSyncPolicy(NormSyncPolicy syncPolicy); in setDefaultSyncPolicy() argument
311 void SetSyncPolicy(SyncPolicy syncPolicy) in SetSyncPolicy() argument312 {sync_policy = syncPolicy;} in SetSyncPolicy()
539 void ReceiverSetDefaultSyncPolicy(NormSenderNode::SyncPolicy syncPolicy) in ReceiverSetDefaultSyncPolicy() argument540 {default_sync_policy = syncPolicy;} in ReceiverSetDefaultSyncPolicy()
619 NormSyncPolicy syncPolicy);
666 (JNIEnv *env, jobject obj, jobject syncPolicy) { in PKGNAME()671 policy = (NormSyncPolicy)env->CallIntMethod(syncPolicy, in PKGNAME()
402 public long commit(SyncPolicy syncPolicy, in commit() argument407 return replayTxn.commit(syncPolicy, replayContext, masterNodeId); in commit()
2204 NormSyncPolicy syncPolicy) in NormSetDefaultSyncPolicy() argument2207 if (session) session->ReceiverSetDefaultSyncPolicy((NormSenderNode::SyncPolicy)syncPolicy); in NormSetDefaultSyncPolicy()