Home Explore Help
Register Sign In
Apq
/
389-ds-base
mirror of https://github.com/389ds/389-ds-base.git
1
0
Fork 0
Files Issues 0 Wiki
Tree: 759b9fe22e
Branches Tags
389-ds-base
/
ldap
/
servers
/
plugins
/
replication
/
windows_prot_private.h

windows_prot_private.h 2.3 KB
History Raw

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970 
  1. /** BEGIN COPYRIGHT BLOCK
    2. 

  2.  * Copyright (C) 2001 Sun Microsystems, Inc. Used by permission.
    3. 

  3.  * Copyright (C) 2005 Red Hat, Inc.
    4. 

  4.  * All rights reserved.
    5. 

  5.  * END COPYRIGHT BLOCK **/
    6. 

  6. 

  7. #include "repl5_prot_private.h"
    8. 

  8.  
    9. 

  9. #ifndef _WINDOWS_PROT_PRIVATE_H_
    10. 

  10. #define _WINDOWS_PROT_PRIVATE_H_
    11. 

  11. 

  12. #define ACQUIRE_SUCCESS 101
    13. 

  13. #define ACQUIRE_REPLICA_BUSY 102
    14. 

  14. #define ACQUIRE_FATAL_ERROR 103
    15. 

  15. #define ACQUIRE_CONSUMER_WAS_UPTODATE 104
    16. 

  16. #define ACQUIRE_TRANSIENT_ERROR 105
    17. 

  17. 

  18. typedef struct windows_private_repl_protocol
    19. 

  19. {
    20. 

  20. 	void (*delete)(struct windows_private_repl_protocol **);
    21. 

  21. 	void (*run)(struct windows_private_repl_protocol *);
    22. 

  22. 	int (*stop)(struct windows_private_repl_protocol *);
    23. 

  23. 	int (*status)(struct windows_private_repl_protocol *);
    24. 

  24. 	void (*notify_update)(struct windows_private_repl_protocol *);
    25. 

  25. 	void (*notify_agmt_changed)(struct windows_private_repl_protocol *);
    26. 

  26.         void (*notify_window_opened)(struct windows_private_repl_protocol *);
    27. 

  27.         void (*notify_window_closed)(struct windows_private_repl_protocol *);
    28. 

  28. 	void (*update_now)(struct windows_private_repl_protocol *);
    29. 

  29. 	PRLock *lock;
    30. 

  30. 	PRCondVar *cvar;
    31. 

  31. 	int stopped;
    32. 

  32. 	int terminate;
    33. 

  33. 	PRUint32 eventbits;
    34. 

  34. 	Repl_Connection *conn;
    35. 

  35. 	int last_acquire_response_code;
    36. 

  36. 	Repl_Agmt *agmt;
    37. 

  37. 	Object *replica_object;
    38. 

  38. 	void *private;
    39. 

  39.     PRBool replica_acquired;
    40. 

  40. } Windows_Private_Repl_Protocol;
    41. 

  41. 

  42. /*
    43. 

  43. extern Windows_Private_Repl_Protocol *Windows_Inc_Protocol_new();
    44. 

  44. extern Windows_Private_Repl_Protocol *Windows_Tot_Protocol_new();
    45. 

  45. */
    46. 

  46. 

  47. #define PROTOCOL_TERMINATION_NORMAL 301
    48. 

  48. #define PROTOCOL_TERMINATION_ABNORMAL 302
    49. 

  49. #define PROTOCOL_TERMINATION_NEEDS_TOTAL_UPDATE 303
    50. 

  50. 

  51. #define RESUME_DO_TOTAL_UPDATE 401
    52. 

  52. #define RESUME_DO_INCREMENTAL_UPDATE 402
    53. 

  53. #define RESUME_TERMINATE 403
    54. 

  54. #define RESUME_SUSPEND 404
    55. 

  55. 

  56. /* Backoff timer settings for reconnect */
    57. 

  57. #define PROTOCOL_BACKOFF_MINIMUM 3 /* 3 seconds */
    58. 

  58. #define PROTOCOL_BACKOFF_MAXIMUM (60 * 5) /* 5 minutes */
    59. 

  59. /* Backoff timer settings for replica busy reconnect */
    60. 

  60. #define PROTOCOL_BUSY_BACKOFF_MINIMUM PROTOCOL_BACKOFF_MINIMUM
    61. 

  61. #define PROTOCOL_BUSY_BACKOFF_MAXIMUM PROTOCOL_BUSY_BACKOFF_MINIMUM
    62. 

  62. 

  63. /* protocol related functions */
    64. 

  64. 

  65. CSN *get_current_csn(Slapi_DN *replarea_sdn);
    66. 

  66. char* protocol_response2string (int response);
    67. 

  67. 

  68. void windows_dirsync_inc_run(Private_Repl_Protocol *prp);
    69. 

  69. 

  70. #endif /* _REPL5_PROT_PRIVATE_H_ */
    71.