repl_monitor.c 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102
  1. /** BEGIN COPYRIGHT BLOCK
  2. * This Program is free software; you can redistribute it and/or modify it under
  3. * the terms of the GNU General Public License as published by the Free Software
  4. * Foundation; version 2 of the License.
  5. *
  6. * This Program is distributed in the hope that it will be useful, but WITHOUT
  7. * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
  8. * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
  9. *
  10. * You should have received a copy of the GNU General Public License along with
  11. * this Program; if not, write to the Free Software Foundation, Inc., 59 Temple
  12. * Place, Suite 330, Boston, MA 02111-1307 USA.
  13. *
  14. * In addition, as a special exception, Red Hat, Inc. gives You the additional
  15. * right to link the code of this Program with code not covered under the GNU
  16. * General Public License ("Non-GPL Code") and to distribute linked combinations
  17. * including the two, subject to the limitations in this paragraph. Non-GPL Code
  18. * permitted under this exception must only link to the code of this Program
  19. * through those well defined interfaces identified in the file named EXCEPTION
  20. * found in the source code files (the "Approved Interfaces"). The files of
  21. * Non-GPL Code may instantiate templates or use macros or inline functions from
  22. * the Approved Interfaces without causing the resulting work to be covered by
  23. * the GNU General Public License. Only Red Hat, Inc. may make changes or
  24. * additions to the list of Approved Interfaces. You must obey the GNU General
  25. * Public License in all respects for all of the Program code and other code used
  26. * in conjunction with the Program except the Non-GPL Code covered by this
  27. * exception. If you modify this file, you may extend this exception to your
  28. * version of the file, but you are not obligated to do so. If you do not wish to
  29. * provide this exception without modification, you must delete this exception
  30. * statement from your version and license this file solely under the GPL without
  31. * exception.
  32. *
  33. *
  34. * Copyright (C) 2001 Sun Microsystems, Inc. Used by permission.
  35. * Copyright (C) 2005 Red Hat, Inc.
  36. * All rights reserved.
  37. * END COPYRIGHT BLOCK **/
  38. #ifdef HAVE_CONFIG_H
  39. # include <config.h>
  40. #endif
  41. #include <string.h>
  42. #include "repl.h"
  43. #include "slapi-plugin.h"
  44. #ifdef FOR_40_STYLE_CHANGELOG
  45. /* Forward Declartions */
  46. static int repl_monitor_search (Slapi_PBlock *pb, Slapi_Entry* e, Slapi_Entry* entryAfter, int *returncode, char *returntext, void *arg);
  47. #endif
  48. int
  49. repl_monitor_init()
  50. {
  51. /* The FE DSE *must* be initialised before we get here */
  52. int return_value= LDAP_SUCCESS;
  53. static int initialized = 0;
  54. if (!initialized)
  55. {
  56. #ifdef FOR_40_STYLE_CHANGELOG
  57. /* ONREPL - this is commented until we implement 4.0 style changelog */
  58. slapi_config_register_callback(SLAPI_OPERATION_SEARCH,DSE_FLAG_PREOP,"cn=monitor",LDAP_SCOPE_BASE,"(objectclass=*)",repl_monitor_search,NULL);
  59. #endif
  60. initialized = 1;
  61. }
  62. return return_value;
  63. }
  64. #ifdef FOR_40_STYLE_CHANGELOG
  65. static int
  66. repl_monitor_search(Slapi_PBlock *pb, Slapi_Entry* e, Slapi_Entry* entryAfter, int *returncode, char *returntext, void *arg)
  67. {
  68. const char *sdv = get_server_dataversion();
  69. if ( sdv != NULL )
  70. {
  71. int port;
  72. char buf[BUFSIZ];
  73. struct berval val;
  74. struct berval *vals[2];
  75. vals[0] = &val;
  76. vals[1] = NULL;
  77. port= config_get_port();
  78. if(port==0)
  79. {
  80. port= config_get_secureport();
  81. }
  82. buf[0] = (char)0;
  83. /* ONREPL - how do we publish changenumbers now with multiple changelogs?
  84. sprintf( buf, "%s:%lu %s% lu", get_localhost_DNS(), port, sdv, ldapi_get_last_changenumber());
  85. */
  86. val.bv_val = buf;
  87. val.bv_len = strlen( buf );
  88. slapi_entry_attr_replace( e, attr_dataversion, vals );
  89. }
  90. return SLAPI_DSE_CALLBACK_OK;
  91. }
  92. #endif