1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
/** BEGIN COPYRIGHT BLOCK
* Copyright (C) 2001 Sun Microsystems, Inc. Used by permission.
* Copyright (C) 2005 Red Hat, Inc.
* All rights reserved.
*
* License: GPL (version 3 or any later version).
* See LICENSE for details.
* END COPYRIGHT BLOCK **/
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif
/* supplier_operation_extension.c - replication extension to the Operation object
*/
#include "repl5.h"
/* ***** Supplier side ***** */
/* supplier operation extension constructor */
void *
supplier_operation_extension_constructor(void *object __attribute__((unused)), void *parent __attribute__((unused)))
{
supplier_operation_extension *ext = (supplier_operation_extension *)slapi_ch_calloc(1, sizeof(supplier_operation_extension));
if (ext == NULL) {
slapi_log_err(SLAPI_LOG_PLUGIN, repl_plugin_name, "unable to create replication supplier operation extension - out of memory\n");
} else {
ext->prevent_recursive_call = 0;
}
return ext;
}
/* supplier operation extension destructor */
void
supplier_operation_extension_destructor(void *ext, void *object __attribute__((unused)), void *parent __attribute__((unused)))
{
if (ext) {
supplier_operation_extension *supext = (supplier_operation_extension *)ext;
if (supext->operation_parameters)
operation_parameters_free(&(supext->operation_parameters));
if (supext->repl_gen)
slapi_ch_free((void **)&supext->repl_gen);
slapi_ch_free((void **)&ext);
}
}
/* ***** Consumer side ***** */
/* consumer operation extension constructor */
void *
consumer_operation_extension_constructor(void *object, void *parent)
{
consumer_operation_extension *ext = (consumer_operation_extension *)slapi_ch_calloc(1, sizeof(consumer_operation_extension));
if (ext == NULL) {
slapi_log_err(SLAPI_LOG_PLUGIN, repl_plugin_name, "unable to create replication consumer operation extension - out of memory\n");
}
if (object != NULL && parent != NULL) {
consumer_connection_extension *connext;
connext = (consumer_connection_extension *)repl_con_get_ext(REPL_CON_EXT_CONN, parent);
if (NULL != connext) {
/* We copy the Connection Replicated Session flag to the Replicated Operation flag */
if (connext->isreplicationsession) {
operation_set_flag((Slapi_Operation *)object, OP_FLAG_REPLICATED);
}
}
} else {
/* (parent==NULL) for internal operations */
PR_ASSERT(object != NULL);
}
return ext;
}
/* consumer operation extension destructor */
void
consumer_operation_extension_destructor(void *ext, void *object __attribute__((unused)), void *parent __attribute__((unused)))
{
if (NULL != ext) {
consumer_operation_extension *opext = (consumer_operation_extension *)ext;
if (NULL != opext->search_referrals) {
/* free them - search_referrals is currently unused, but
free them using the obverse of the allocation method */
opext->search_referrals = NULL;
}
slapi_ch_free((void **)&ext);
}
}
|
