1 24 25 package org.continuent.sequoia.controller.virtualdatabase.protocol; 26 27 import org.continuent.sequoia.common.xml.DatabasesXmlTags; 28 29 37 public class MessageTimeouts 38 { 39 40 private long defaultTimeout; 41 42 43 private static final int DEFAULT_TIMEOUT_VALUE = -1; 44 private long backendStatusTimeout = DEFAULT_TIMEOUT_VALUE; 45 private long backendTransferTimeout = DEFAULT_TIMEOUT_VALUE; 46 private long cacheInvalidateTimeout = DEFAULT_TIMEOUT_VALUE; 47 private long commitTimeout = DEFAULT_TIMEOUT_VALUE; 48 private long controllerNameTimeout = DEFAULT_TIMEOUT_VALUE; 49 private long copyLogEntryTimeout = DEFAULT_TIMEOUT_VALUE; 50 private long disableBackendTimeout = DEFAULT_TIMEOUT_VALUE; 51 private long enableBackendTimeout = DEFAULT_TIMEOUT_VALUE; 52 private long execReadRequestTimeout = DEFAULT_TIMEOUT_VALUE; 53 private long execReadStoredProcedureTimeout = DEFAULT_TIMEOUT_VALUE; 54 private long execWriteRequestTimeout = DEFAULT_TIMEOUT_VALUE; 55 private long execWriteRequestWithKeysTimeout = DEFAULT_TIMEOUT_VALUE; 56 private long execWriteStoredProcedureTimeout = DEFAULT_TIMEOUT_VALUE; 57 private long initiateDumpCopyTimeout = DEFAULT_TIMEOUT_VALUE; 58 private long notifyCompletionTimeout = DEFAULT_TIMEOUT_VALUE; 59 private long releaseSavepointTimeout = DEFAULT_TIMEOUT_VALUE; 60 private long replicateLogEntriesTimeout = DEFAULT_TIMEOUT_VALUE; 61 private long rollbackTimeout = DEFAULT_TIMEOUT_VALUE; 62 private long rollbackToSavepointTimeout = DEFAULT_TIMEOUT_VALUE; 63 private long setCheckpointTimeout = DEFAULT_TIMEOUT_VALUE; 64 private long setSavepointTimeout = DEFAULT_TIMEOUT_VALUE; 65 private long unlogCommitTimeout = DEFAULT_TIMEOUT_VALUE; 66 private long unlogRequestTimeout = DEFAULT_TIMEOUT_VALUE; 67 private long unlogRollbackTimeout = DEFAULT_TIMEOUT_VALUE; 68 private long virtualDatabaseConfigurationTimeout = DEFAULT_TIMEOUT_VALUE; 69 70 75 public MessageTimeouts(long defaultTimeout) 76 { 77 this.defaultTimeout = defaultTimeout; 78 } 79 80 88 public static long getMinTimeout(long timeout1, long timeout2) 89 { 90 if (timeout1 == timeout2) 91 return timeout1; 92 if (timeout1 == 0) 93 return timeout2; 94 if (timeout2 == 0) 95 return timeout1; 96 if (timeout1 < timeout2) 97 return timeout1; 98 else 99 return timeout2; 100 } 101 102 107 public long getBackendStatusTimeout() 108 { 109 if (backendStatusTimeout == DEFAULT_TIMEOUT_VALUE) 110 return defaultTimeout; 111 return backendStatusTimeout; 112 } 113 114 119 public void setBackendStatusTimeout(long backendStatusTimeout) 120 { 121 this.backendStatusTimeout = backendStatusTimeout; 122 } 123 124 129 public long getBackendTransferTimeout() 130 { 131 if (backendTransferTimeout == DEFAULT_TIMEOUT_VALUE) 132 return defaultTimeout; 133 return backendTransferTimeout; 134 } 135 136 141 public void setBackendTransferTimeout(long backendTransferTimeout) 142 { 143 this.backendTransferTimeout = backendTransferTimeout; 144 } 145 146 151 public long getCacheInvalidateTimeout() 152 { 153 if (cacheInvalidateTimeout == DEFAULT_TIMEOUT_VALUE) 154 return defaultTimeout; 155 return cacheInvalidateTimeout; 156 } 157 158 163 public void setCacheInvalidateTimeout(long cacheInvalidateTimeout) 164 { 165 this.cacheInvalidateTimeout = cacheInvalidateTimeout; 166 } 167 168 173 public long getCommitTimeout() 174 { 175 if (commitTimeout == DEFAULT_TIMEOUT_VALUE) 176 return defaultTimeout; 177 return commitTimeout; 178 } 179 180 185 public void setCommitTimeout(long commitTimeout) 186 { 187 this.commitTimeout = commitTimeout; 188 } 189 190 195 public long getControllerNameTimeout() 196 { 197 if (controllerNameTimeout == DEFAULT_TIMEOUT_VALUE) 198 return defaultTimeout; 199 return controllerNameTimeout; 200 } 201 202 207 public void setControllerNameTimeout(long controllerNameTimeout) 208 { 209 this.controllerNameTimeout = controllerNameTimeout; 210 } 211 212 217 public long getCopyLogEntryTimeout() 218 { 219 if (copyLogEntryTimeout == DEFAULT_TIMEOUT_VALUE) 220 return defaultTimeout; 221 return copyLogEntryTimeout; 222 } 223 224 229 public void setCopyLogEntryTimeout(long copyLogEntryTimeout) 230 { 231 this.copyLogEntryTimeout = copyLogEntryTimeout; 232 } 233 234 239 public long getDefaultTimeout() 240 { 241 return defaultTimeout; 242 } 243 244 249 public void setDefaultTimeout(long defaultTimeout) 250 { 251 this.defaultTimeout = defaultTimeout; 252 } 253 254 259 public long getDisableBackendTimeout() 260 { 261 if (disableBackendTimeout == DEFAULT_TIMEOUT_VALUE) 262 return defaultTimeout; 263 return disableBackendTimeout; 264 } 265 266 271 public void setDisableBackendTimeout(long disableBackendTimeout) 272 { 273 this.disableBackendTimeout = disableBackendTimeout; 274 } 275 276 281 public long getEnableBackendTimeout() 282 { 283 if (enableBackendTimeout == DEFAULT_TIMEOUT_VALUE) 284 return defaultTimeout; 285 return enableBackendTimeout; 286 } 287 288 293 public void setEnableBackendTimeout(long enableBackendTimeout) 294 { 295 this.enableBackendTimeout = enableBackendTimeout; 296 } 297 298 303 public long getExecReadRequestTimeout() 304 { 305 if (execReadRequestTimeout == DEFAULT_TIMEOUT_VALUE) 306 return defaultTimeout; 307 return execReadRequestTimeout; 308 } 309 310 315 public void setExecReadRequestTimeout(long execReadRequestTimeout) 316 { 317 this.execReadRequestTimeout = execReadRequestTimeout; 318 } 319 320 325 public long getExecReadStoredProcedureTimeout() 326 { 327 if (execReadStoredProcedureTimeout == DEFAULT_TIMEOUT_VALUE) 328 return defaultTimeout; 329 return execReadStoredProcedureTimeout; 330 } 331 332 338 public void setExecReadStoredProcedureTimeout( 339 long execReadStoredProcedureTimeout) 340 { 341 this.execReadStoredProcedureTimeout = execReadStoredProcedureTimeout; 342 } 343 344 349 public long getExecWriteRequestTimeout() 350 { 351 if (execWriteRequestTimeout == DEFAULT_TIMEOUT_VALUE) 352 return defaultTimeout; 353 return execWriteRequestTimeout; 354 } 355 356 361 public long getExecWriteRequestWithKeysTimeout() 362 { 363 if (execWriteRequestWithKeysTimeout == DEFAULT_TIMEOUT_VALUE) 364 return defaultTimeout; 365 return execWriteRequestWithKeysTimeout; 366 } 367 368 374 public void setExecWriteRequestWithKeysTimeout( 375 long execWriteRequestWithKeysTimeout) 376 { 377 this.execWriteRequestWithKeysTimeout = execWriteRequestWithKeysTimeout; 378 } 379 380 385 public void setExecWriteRequestTimeout(long execWriteRequestTimeout) 386 { 387 this.execWriteRequestTimeout = execWriteRequestTimeout; 388 } 389 390 395 public long getExecWriteStoredProcedureTimeout() 396 { 397 if (execWriteStoredProcedureTimeout == DEFAULT_TIMEOUT_VALUE) 398 return defaultTimeout; 399 return execWriteStoredProcedureTimeout; 400 } 401 402 408 public void setExecWriteStoredProcedureTimeout( 409 long execWriteStoredProcedureTimeout) 410 { 411 this.execWriteStoredProcedureTimeout = execWriteStoredProcedureTimeout; 412 } 413 414 419 public long getInitiateDumpCopyTimeout() 420 { 421 if (initiateDumpCopyTimeout == DEFAULT_TIMEOUT_VALUE) 422 return defaultTimeout; 423 return initiateDumpCopyTimeout; 424 } 425 426 431 public void setInitiateDumpCopyTimeout(long initiateDumpCopyTimeout) 432 { 433 this.initiateDumpCopyTimeout = initiateDumpCopyTimeout; 434 } 435 436 441 public long getNotifyCompletionTimeout() 442 { 443 if (notifyCompletionTimeout == DEFAULT_TIMEOUT_VALUE) 444 return defaultTimeout; 445 return notifyCompletionTimeout; 446 } 447 448 453 public void setNotifyCompletionTimeout(long notifyCompletionTimeout) 454 { 455 this.notifyCompletionTimeout = notifyCompletionTimeout; 456 } 457 458 463 public long getReleaseSavepointTimeout() 464 { 465 if (releaseSavepointTimeout == DEFAULT_TIMEOUT_VALUE) 466 return defaultTimeout; 467 return releaseSavepointTimeout; 468 } 469 470 475 public void setReleaseSavepointTimeout(long releaseSavepointTimeout) 476 { 477 this.releaseSavepointTimeout = releaseSavepointTimeout; 478 } 479 480 485 public long getReplicateLogEntriesTimeout() 486 { 487 if (replicateLogEntriesTimeout == DEFAULT_TIMEOUT_VALUE) 488 return defaultTimeout; 489 return replicateLogEntriesTimeout; 490 } 491 492 497 public void setReplicateLogEntriesTimeout(long replicateLogEntriesTimeout) 498 { 499 this.replicateLogEntriesTimeout = replicateLogEntriesTimeout; 500 } 501 502 507 public long getRollbackTimeout() 508 { 509 if (rollbackTimeout == DEFAULT_TIMEOUT_VALUE) 510 return defaultTimeout; 511 return rollbackTimeout; 512 } 513 514 519 public void setRollbackTimeout(long rollbackTimeout) 520 { 521 this.rollbackTimeout = rollbackTimeout; 522 } 523 524 529 public long getRollbackToSavepointTimeout() 530 { 531 if (rollbackToSavepointTimeout == DEFAULT_TIMEOUT_VALUE) 532 return defaultTimeout; 533 return rollbackToSavepointTimeout; 534 } 535 536 541 public void setRollbackToSavepointTimeout(long rollbackToSavepointTimeout) 542 { 543 this.rollbackToSavepointTimeout = rollbackToSavepointTimeout; 544 } 545 546 551 public long getSetCheckpointTimeout() 552 { 553 if (setCheckpointTimeout == DEFAULT_TIMEOUT_VALUE) 554 return defaultTimeout; 555 return setCheckpointTimeout; 556 } 557 558 563 public void setSetCheckpointTimeout(long setCheckpointTimeout) 564 { 565 this.setCheckpointTimeout = setCheckpointTimeout; 566 } 567 568 573 public long getSetSavepointTimeout() 574 { 575 if (setSavepointTimeout == DEFAULT_TIMEOUT_VALUE) 576 return defaultTimeout; 577 return setSavepointTimeout; 578 } 579 580 585 public void setSetSavepointTimeout(long setSavepointTimeout) 586 { 587 this.setSavepointTimeout = setSavepointTimeout; 588 } 589 590 595 public long getUnlogCommitTimeout() 596 { 597 if (unlogCommitTimeout == DEFAULT_TIMEOUT_VALUE) 598 return defaultTimeout; 599 return unlogCommitTimeout; 600 } 601 602 607 public void setUnlogCommitTimeout(long unlogCommitTimeout) 608 { 609 this.unlogCommitTimeout = unlogCommitTimeout; 610 } 611 612 617 public long getUnlogRequestTimeout() 618 { 619 if (unlogRequestTimeout == DEFAULT_TIMEOUT_VALUE) 620 return defaultTimeout; 621 return unlogRequestTimeout; 622 } 623 624 629 public void setUnlogRequestTimeout(long unlogRequestTimeout) 630 { 631 this.unlogRequestTimeout = unlogRequestTimeout; 632 } 633 634 639 public long getUnlogRollbackTimeout() 640 { 641 if (unlogRollbackTimeout == DEFAULT_TIMEOUT_VALUE) 642 return defaultTimeout; 643 return unlogRollbackTimeout; 644 } 645 646 651 public void setUnlogRollbackTimeout(long unlogRollbackTimeout) 652 { 653 this.unlogRollbackTimeout = unlogRollbackTimeout; 654 } 655 656 661 public long getVirtualDatabaseConfigurationTimeout() 662 { 663 if (virtualDatabaseConfigurationTimeout == DEFAULT_TIMEOUT_VALUE) 664 return defaultTimeout; 665 return virtualDatabaseConfigurationTimeout; 666 } 667 668 674 public void setVirtualDatabaseConfigurationTimeout( 675 long virtualDatabaseConfigurationTimeout) 676 { 677 this.virtualDatabaseConfigurationTimeout = virtualDatabaseConfigurationTimeout; 678 } 679 680 687 public void generateXml(StringBuffer sb) 688 { 689 sb.append("<" + DatabasesXmlTags.ELT_MessageTimeouts + " "); 690 691 if (backendStatusTimeout != defaultTimeout) 692 sb.append(" " + DatabasesXmlTags.ATT_backendStatusTimeout + " = \"" 693 + backendStatusTimeout + "\""); 694 if (backendTransferTimeout != defaultTimeout) 695 sb.append(" " + DatabasesXmlTags.ATT_backendTransferTimeout + " = \"" 696 + backendTransferTimeout + "\""); 697 if (cacheInvalidateTimeout != defaultTimeout) 698 sb.append(" " + DatabasesXmlTags.ATT_cacheInvalidateTimeout + " = \"" 699 + cacheInvalidateTimeout + "\""); 700 if (commitTimeout != defaultTimeout) 701 sb.append(" " + DatabasesXmlTags.ATT_commitTimeout + " = \"" 702 + commitTimeout + "\""); 703 if (controllerNameTimeout != defaultTimeout) 704 sb.append(" " + DatabasesXmlTags.ATT_controllerNameTimeout + " = \"" 705 + controllerNameTimeout + "\""); 706 if (copyLogEntryTimeout != defaultTimeout) 707 sb.append(" " + DatabasesXmlTags.ATT_copyLogEntryTimeout + " = \"" 708 + copyLogEntryTimeout + "\""); 709 if (disableBackendTimeout != defaultTimeout) 710 sb.append(" " + DatabasesXmlTags.ATT_disableBackendTimeout + " = \"" 711 + disableBackendTimeout + "\""); 712 if (enableBackendTimeout != defaultTimeout) 713 sb.append(" " + DatabasesXmlTags.ATT_enableBackendTimeout + " = \"" 714 + enableBackendTimeout + "\""); 715 if (execReadRequestTimeout != defaultTimeout) 716 sb.append(" " + DatabasesXmlTags.ATT_execReadRequestTimeout + " = \"" 717 + execReadRequestTimeout + "\""); 718 if (execReadStoredProcedureTimeout != defaultTimeout) 719 sb.append(" " + DatabasesXmlTags.ATT_execReadStoredProcedureTimeout 720 + " = \"" + execReadStoredProcedureTimeout + "\""); 721 if (execWriteRequestTimeout != defaultTimeout) 722 sb.append(" " + DatabasesXmlTags.ATT_execWriteRequestTimeout + " = \"" 723 + execWriteRequestTimeout + "\""); 724 if (execWriteRequestWithKeysTimeout != defaultTimeout) 725 sb.append(" " + DatabasesXmlTags.ATT_execWriteRequestWithKeysTimeout 726 + " = \"" + execWriteRequestWithKeysTimeout + "\""); 727 if (execWriteStoredProcedureTimeout != defaultTimeout) 728 sb.append(" " + DatabasesXmlTags.ATT_execWriteStoredProcedureTimeout 729 + " = \"" + execWriteStoredProcedureTimeout + "\""); 730 if (initiateDumpCopyTimeout != defaultTimeout) 731 sb.append(" " + DatabasesXmlTags.ATT_initiateDumpCopyTimeout + " = \"" 732 + initiateDumpCopyTimeout + "\""); 733 if (notifyCompletionTimeout != defaultTimeout) 734 sb.append(" " + DatabasesXmlTags.ATT_notifyCompletionTimeout + " = \"" 735 + notifyCompletionTimeout + "\""); 736 if (releaseSavepointTimeout != defaultTimeout) 737 sb.append(" " + DatabasesXmlTags.ATT_releaseSavepointTimeout + " = \"" 738 + releaseSavepointTimeout + "\""); 739 if (replicateLogEntriesTimeout != defaultTimeout) 740 sb.append(" " + DatabasesXmlTags.ATT_replicateLogEntriesTimeout + " = \"" 741 + replicateLogEntriesTimeout + "\""); 742 if (rollbackTimeout != defaultTimeout) 743 sb.append(" " + DatabasesXmlTags.ATT_rollbackTimeout + " = \"" 744 + rollbackTimeout + "\""); 745 if (rollbackToSavepointTimeout != defaultTimeout) 746 sb.append(" " + DatabasesXmlTags.ATT_rollbackToSavepointTimeout + " = \"" 747 + rollbackToSavepointTimeout + "\""); 748 if (setCheckpointTimeout != defaultTimeout) 749 sb.append(" " + DatabasesXmlTags.ATT_setCheckpointTimeout + " = \"" 750 + setCheckpointTimeout + "\""); 751 if (setSavepointTimeout != defaultTimeout) 752 sb.append(" " + DatabasesXmlTags.ATT_setSavepointTimeout + " = \"" 753 + setSavepointTimeout + "\""); 754 if (unlogCommitTimeout != defaultTimeout) 755 sb.append(" " + DatabasesXmlTags.ATT_unlogCommitTimeout + " = \"" 756 + unlogCommitTimeout + "\""); 757 if (unlogRequestTimeout != defaultTimeout) 758 sb.append(" " + DatabasesXmlTags.ATT_unlogRequestTimeout + " = \"" 759 + unlogRequestTimeout + "\""); 760 if (unlogRollbackTimeout != defaultTimeout) 761 sb.append(" " + DatabasesXmlTags.ATT_unlogRollbackTimeout + " = \"" 762 + unlogRollbackTimeout + "\""); 763 if (virtualDatabaseConfigurationTimeout != defaultTimeout) 764 sb.append(" " + DatabasesXmlTags.ATT_virtualDatabaseConfigurationTimeout 765 + " = \"" + virtualDatabaseConfigurationTimeout + "\""); 766 767 sb.append("/>"); 768 } 769 770 } 771 | Popular Tags |