Skip to content

Commit 14f4f03

Browse files
committed
engine/schema: use PostConstruct in FirewallRulesDaoImpl
1 parent a7f9756 commit 14f4f03

1 file changed

Lines changed: 14 additions & 13 deletions

File tree

engine/schema/src/main/java/com/cloud/network/dao/FirewallRulesDaoImpl.java

Lines changed: 14 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818

1919
import java.util.List;
2020

21+
import javax.annotation.PostConstruct;
2122
import javax.inject.Inject;
2223

2324
import org.springframework.stereotype.Component;
@@ -47,8 +48,8 @@ public class FirewallRulesDaoImpl extends GenericDaoBase<FirewallRuleVO, Long> i
4748
protected final SearchBuilder<FirewallRuleVO> AllFieldsSearch;
4849
protected final SearchBuilder<FirewallRuleVO> NotRevokedSearch;
4950
protected final SearchBuilder<FirewallRuleVO> ReleaseSearch;
50-
protected SearchBuilder<FirewallRuleVO> VmSearch;
51-
protected SearchBuilder<FirewallRuleVO> FirewallByPortsAndNetwork;
51+
protected final SearchBuilder<FirewallRuleVO> VmSearch = createSearchBuilder();;
52+
protected final SearchBuilder<FirewallRuleVO> FirewallByPortsAndNetwork;
5253
protected final SearchBuilder<FirewallRuleVO> SystemRuleSearch;
5354
protected final GenericSearchBuilder<FirewallRuleVO, Long> RulesByIpCount;
5455
protected final SearchBuilder<FirewallRuleVO> RoutingFirewallRulesSearch;
@@ -121,6 +122,17 @@ protected FirewallRulesDaoImpl() {
121122
RoutingFirewallRulesSearch.done();
122123
}
123124

125+
@PostConstruct
126+
public void init() {
127+
SearchBuilder<IPAddressVO> IpSearch = _ipDao.createSearchBuilder();
128+
IpSearch.and("associatedWithVmId", IpSearch.entity().getAssociatedWithVmId(), SearchCriteria.Op.EQ);
129+
IpSearch.and("oneToOneNat", IpSearch.entity().isOneToOneNat(), SearchCriteria.Op.NNULL);
130+
131+
VmSearch.and("purpose", VmSearch.entity().getPurpose(), Op.EQ);
132+
VmSearch.join("ipSearch", IpSearch, VmSearch.entity().getSourceIpAddressId(), IpSearch.entity().getId(), JoinBuilder.JoinType.INNER);
133+
VmSearch.done();
134+
}
135+
124136
@Override
125137
public List<FirewallRuleVO> listSystemRules() {
126138
SearchCriteria<FirewallRuleVO> sc = SystemRuleSearch.create();
@@ -216,17 +228,6 @@ public boolean revoke(FirewallRuleVO rule) {
216228

217229
@Override
218230
public List<FirewallRuleVO> listStaticNatByVmId(long vmId) {
219-
if (VmSearch == null) {
220-
SearchBuilder<IPAddressVO> IpSearch = _ipDao.createSearchBuilder();
221-
IpSearch.and("associatedWithVmId", IpSearch.entity().getAssociatedWithVmId(), SearchCriteria.Op.EQ);
222-
IpSearch.and("oneToOneNat", IpSearch.entity().isOneToOneNat(), SearchCriteria.Op.NNULL);
223-
224-
VmSearch = createSearchBuilder();
225-
VmSearch.and("purpose", VmSearch.entity().getPurpose(), Op.EQ);
226-
VmSearch.join("ipSearch", IpSearch, VmSearch.entity().getSourceIpAddressId(), IpSearch.entity().getId(), JoinBuilder.JoinType.INNER);
227-
VmSearch.done();
228-
}
229-
230231
SearchCriteria<FirewallRuleVO> sc = VmSearch.create();
231232
sc.setParameters("purpose", Purpose.StaticNat);
232233
sc.setJoinParameters("ipSearch", "associatedWithVmId", vmId);

0 commit comments

Comments
 (0)