Motr
M0
trigger_fop.c
Go to the documentation of this file.
1
/* -*- C -*- */
2
/*
3
* Copyright (c) 2016-2020 Seagate Technology LLC and/or its Affiliates
4
*
5
* Licensed under the Apache License, Version 2.0 (the "License");
6
* you may not use this file except in compliance with the License.
7
* You may obtain a copy of the License at
8
*
9
* http://www.apache.org/licenses/LICENSE-2.0
10
*
11
* Unless required by applicable law or agreed to in writing, software
12
* distributed under the License is distributed on an "AS IS" BASIS,
13
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14
* See the License for the specific language governing permissions and
15
* limitations under the License.
16
*
17
* For any questions about this software or licensing,
18
* please email opensource@seagate.com or cortx-questions@seagate.com.
19
*
20
*/
21
22
23
30
#define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_DIXCM
31
#include "
cm/repreb/trigger_fop.h
"
32
#include "cm/repreb/trigger_fop_xc.h"
33
#include "
cm/repreb/trigger_fom.h
"
34
#include "
dix/cm/trigger_fom.h
"
35
#include "
dix/cm/trigger_fop.h
"
36
#include "
dix/cm/cm.h
"
37
#include "
rpc/item.h
"
38
45
M0_INTERNAL
void
m0_dix_cm_rebalance_trigger_fop_fini
(
void
)
46
{
47
m0_cm_trigger_fop_fini
(&
m0_dix_rebalance_trigger_fopt
);
48
m0_cm_trigger_fop_fini
(&
m0_dix_rebalance_trigger_rep_fopt
);
49
m0_cm_trigger_fop_fini
(&
m0_dix_rebalance_quiesce_fopt
);
50
m0_cm_trigger_fop_fini
(&
m0_dix_rebalance_quiesce_rep_fopt
);
51
m0_cm_trigger_fop_fini
(&
m0_dix_rebalance_status_fopt
);
52
m0_cm_trigger_fop_fini
(&
m0_dix_rebalance_status_rep_fopt
);
53
m0_cm_trigger_fop_fini
(&
m0_dix_rebalance_abort_fopt
);
54
m0_cm_trigger_fop_fini
(&
m0_dix_rebalance_abort_rep_fopt
);
55
}
56
63
M0_INTERNAL
void
m0_dix_cm_rebalance_trigger_fop_init
(
void
)
64
{
65
m0_cm_trigger_fop_init
(&
m0_dix_rebalance_trigger_fopt
,
66
M0_DIX_REBALANCE_TRIGGER_OPCODE
,
67
"dix rebalance trigger"
,
68
trigger_fop_xc,
69
M0_RPC_MUTABO_REQ
,
70
&
dix_rebalance_cmt
,
71
&
m0_dix_trigger_fom_type_ops
);
72
m0_cm_trigger_fop_init
(&
m0_dix_rebalance_trigger_rep_fopt
,
73
M0_DIX_REBALANCE_TRIGGER_REP_OPCODE
,
74
"dix rebalance trigger reply"
,
75
trigger_rep_fop_xc,
76
M0_RPC_ITEM_TYPE_REPLY
,
77
&
dix_rebalance_cmt
,
78
&
m0_dix_trigger_fom_type_ops
);
79
80
m0_cm_trigger_fop_init
(&
m0_dix_rebalance_quiesce_fopt
,
81
M0_DIX_REBALANCE_QUIESCE_OPCODE
,
82
"dix rebalance quiesce trigger"
,
83
trigger_fop_xc,
84
M0_RPC_MUTABO_REQ
,
85
&
dix_rebalance_cmt
,
86
&
m0_dix_trigger_fom_type_ops
);
87
m0_cm_trigger_fop_init
(&
m0_dix_rebalance_quiesce_rep_fopt
,
88
M0_DIX_REBALANCE_QUIESCE_REP_OPCODE
,
89
"dix rebalance quiesce trigger reply"
,
90
trigger_rep_fop_xc,
91
M0_RPC_ITEM_TYPE_REPLY
,
92
&
dix_rebalance_cmt
,
93
&
m0_dix_trigger_fom_type_ops
);
94
95
m0_cm_trigger_fop_init
(&
m0_dix_rebalance_status_fopt
,
96
M0_DIX_REBALANCE_STATUS_OPCODE
,
97
"dix rebalance status"
,
98
trigger_fop_xc,
99
M0_RPC_MUTABO_REQ
,
100
&
dix_rebalance_cmt
,
101
&
m0_dix_trigger_fom_type_ops
);
102
m0_cm_trigger_fop_init
(&
m0_dix_rebalance_status_rep_fopt
,
103
M0_DIX_REBALANCE_STATUS_REP_OPCODE
,
104
"dix rebalance status reply"
,
105
m0_status_rep_fop_xc,
106
M0_RPC_ITEM_TYPE_REPLY
,
107
&
dix_rebalance_cmt
,
108
&
m0_dix_trigger_fom_type_ops
);
109
m0_cm_trigger_fop_init
(&
m0_dix_rebalance_abort_fopt
,
110
M0_DIX_REBALANCE_ABORT_OPCODE
,
111
"dix rebalance abort"
,
112
m0_status_rep_fop_xc,
113
M0_RPC_ITEM_TYPE_REQUEST
,
114
&
dix_rebalance_cmt
,
115
&
m0_dix_trigger_fom_type_ops
);
116
m0_cm_trigger_fop_init
(&
m0_dix_rebalance_abort_rep_fopt
,
117
M0_DIX_REBALANCE_ABORT_REP_OPCODE
,
118
"dix rebalance abort reply"
,
119
m0_status_rep_fop_xc,
120
M0_RPC_ITEM_TYPE_REPLY
,
121
&
dix_rebalance_cmt
,
122
&
m0_dix_trigger_fom_type_ops
);
123
}
124
125
#undef M0_TRACE_SUBSYSTEM
126
129
/*
130
* Local variables:
131
* c-indentation-style: "K&R"
132
* c-basic-offset: 8
133
* tab-width: 8
134
* fill-column: 80
135
* scroll-step: 1
136
* End:
137
*/
138
/*
139
* vim: tabstop=8 shiftwidth=8 noexpandtab textwidth=80 nowrap
140
*/
m0_dix_cm_rebalance_trigger_fop_init
M0_INTERNAL void m0_dix_cm_rebalance_trigger_fop_init(void)
Definition:
trigger_fop.c:63
m0_dix_rebalance_quiesce_fopt
struct m0_fop_type m0_dix_rebalance_quiesce_fopt
Definition:
trigger_fop_common.c:37
dix_rebalance_cmt
M0_EXTERN struct m0_cm_type dix_rebalance_cmt
Definition:
cm.h:174
m0_dix_rebalance_abort_rep_fopt
struct m0_fop_type m0_dix_rebalance_abort_rep_fopt
Definition:
trigger_fop_common.c:42
m0_dix_rebalance_abort_fopt
struct m0_fop_type m0_dix_rebalance_abort_fopt
Definition:
trigger_fop_common.c:41
M0_DIX_REBALANCE_ABORT_REP_OPCODE
Definition:
rpc_opcodes.h:311
trigger_fop.h
trigger_fom.h
trigger_fop.h
m0_dix_trigger_fom_type_ops
const struct m0_fom_type_ops m0_dix_trigger_fom_type_ops
Definition:
trigger_fom.c:55
m0_dix_rebalance_trigger_rep_fopt
struct m0_fop_type m0_dix_rebalance_trigger_rep_fopt
Definition:
trigger_fop_common.c:36
M0_DIX_REBALANCE_TRIGGER_OPCODE
Definition:
rpc_opcodes.h:304
M0_RPC_ITEM_TYPE_REPLY
Definition:
item.h:454
m0_cm_trigger_fop_fini
M0_INTERNAL void m0_cm_trigger_fop_fini(struct m0_fop_type *ft)
Definition:
trigger_fom.c:353
M0_DIX_REBALANCE_TRIGGER_REP_OPCODE
Definition:
rpc_opcodes.h:307
m0_dix_rebalance_quiesce_rep_fopt
struct m0_fop_type m0_dix_rebalance_quiesce_rep_fopt
Definition:
trigger_fop_common.c:38
m0_dix_rebalance_status_fopt
struct m0_fop_type m0_dix_rebalance_status_fopt
Definition:
trigger_fop_common.c:39
trigger_fom.h
item.h
M0_DIX_REBALANCE_QUIESCE_REP_OPCODE
Definition:
rpc_opcodes.h:308
m0_dix_rebalance_trigger_fopt
struct m0_fop_type m0_dix_rebalance_trigger_fopt
Definition:
trigger_fop_common.c:35
M0_RPC_MUTABO_REQ
Definition:
item.h:465
m0_dix_rebalance_status_rep_fopt
struct m0_fop_type m0_dix_rebalance_status_rep_fopt
Definition:
trigger_fop_common.c:40
M0_DIX_REBALANCE_STATUS_OPCODE
Definition:
rpc_opcodes.h:306
cm.h
M0_RPC_ITEM_TYPE_REQUEST
Definition:
item.h:449
m0_cm_trigger_fop_init
M0_INTERNAL void m0_cm_trigger_fop_init(struct m0_fop_type *ft, enum M0_RPC_OPCODES op, const char *name, const struct m0_xcode_type *xt, uint64_t rpc_flags, struct m0_cm_type *cmt, const struct m0_fom_type_ops *ops)
Definition:
trigger_fom.c:358
m0_dix_cm_rebalance_trigger_fop_fini
M0_INTERNAL void m0_dix_cm_rebalance_trigger_fop_fini(void)
Definition:
trigger_fop.c:45
M0_DIX_REBALANCE_STATUS_REP_OPCODE
Definition:
rpc_opcodes.h:309
M0_DIX_REBALANCE_QUIESCE_OPCODE
Definition:
rpc_opcodes.h:305
M0_DIX_REBALANCE_ABORT_OPCODE
Definition:
rpc_opcodes.h:310
dix
cm
rebalance
trigger_fop.c
Generated on Thu Apr 14 2022 14:02:54 for Motr by
1.8.14