Merge "Add target to missing .gitignore"
[aaf/authz.git] / cadi / core / src / test / java / org / onap / aaf / cadi / test / util / JU_Pool.java
1 /*******************************************************************************
2  * * org.onap.aaf
3  * * ===========================================================================
4  * * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
5  * * ===========================================================================
6  * * Licensed under the Apache License, Version 2.0 (the "License");
7  * * you may not use this file except in compliance with the License.
8  * * You may obtain a copy of the License at
9  * * 
10  *  *      http://www.apache.org/licenses/LICENSE-2.0
11  * * 
12  *  * Unless required by applicable law or agreed to in writing, software
13  * * distributed under the License is distributed on an "AS IS" BASIS,
14  * * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15  * * See the License for the specific language governing permissions and
16  * * limitations under the License.
17  * * ============LICENSE_END====================================================
18  * *
19  * *
20  ******************************************************************************/
21 package org.onap.aaf.cadi.test.util;
22
23 import static org.junit.Assert.*;
24
25 import java.util.ArrayList;
26 import java.util.List;
27
28 import static org.hamcrest.CoreMatchers.*;
29 import org.junit.*;
30 import org.onap.aaf.cadi.CadiException;
31 import org.onap.aaf.cadi.util.Pool;
32 import org.onap.aaf.cadi.util.Pool.*;
33
34 public class JU_Pool {
35
36         private StringBuilder sb = new StringBuilder();
37
38         private class IntegerCreator implements Creator<Integer> {
39                 private int current = 0;
40                 @Override public Integer create() { return current++; } 
41                 @Override public void destroy(Integer t) { t = 0; } 
42                 @Override public boolean isValid(Integer t) { return (t & 0x1) == 0; } 
43                 @Override public void reuse(Integer t) { }
44         }
45
46         private class CustomLogger implements Log {
47                 @Override
48                 public void log(Object ... o) {
49                         for (Object item : o) {
50                                 sb.append(item.toString());
51                         }
52                 }
53         }
54
55         @Test
56         public void getTest() throws CadiException {
57                 Pool<Integer> intPool = new Pool<Integer>(new IntegerCreator());
58
59                 List<Pooled<Integer>> gotten = new ArrayList<Pooled<Integer>>();
60                 for (int i = 0; i < 10; i++) {
61                         gotten.add(intPool.get());
62                         assertThat(gotten.get(i).content, is(i));
63                 }
64
65                 gotten.get(9).done();
66                 gotten.set(9, intPool.get());
67                 assertThat(gotten.get(9).content, is(9));
68
69                 for (int i = 0; i < 10; i++) {
70                         gotten.get(i).done();
71                 }
72
73                 for (int i = 0; i < 10; i++) {
74                         gotten.set(i, intPool.get());
75                         if (i < 5) {
76                                 assertThat(gotten.get(i).content, is(i));
77                         } else {
78                                 assertThat(gotten.get(i).content, is(i + 5));
79                         }
80                 }
81
82                 for (int i = 0; i < 10; i++) {
83                         gotten.get(i).toss();
84                         // Coverage calls
85                         gotten.get(i).toss();
86                         gotten.get(i).done();
87
88                         // only set some objects to null -> this is for the finalize coverage test
89                         if (i < 5) {
90                                 gotten.set(i, null);
91                         }
92                 }
93
94                 // Coverage of finalize()
95                 System.gc();
96         }
97
98         @Test
99         public void bulkTest() throws CadiException {
100                 Pool<Integer> intPool = new Pool<Integer>(new IntegerCreator());
101
102                 intPool.prime(10);
103                 // Remove all of the invalid items (in this case, odd numbers)
104                 assertFalse(intPool.validate());
105
106                 // Make sure we got them all
107                 assertTrue(intPool.validate());
108
109                 // Get an item from the pool
110                 Pooled<Integer> gotten = intPool.get();
111                 assertThat(gotten.content, is(0));
112
113                 // finalize that item, then check the next one to make sure we actually purged the odd numbers
114                 gotten = intPool.get();
115                 assertThat(gotten.content, is(2));
116
117                 intPool.drain();
118
119         }
120
121
122         @Test
123         public void setMaxTest() {
124                 Pool<Integer> intPool = new Pool<Integer>(new IntegerCreator());
125                 intPool.setMaxRange(10);
126                 assertThat(intPool.getMaxRange(), is(10));
127                 intPool.setMaxRange(-10);
128                 assertThat(intPool.getMaxRange(), is(0));
129         }
130
131         @Test
132         public void loggingTest() {
133                 Pool<Integer> intPool = new Pool<Integer>(new IntegerCreator());
134
135                 // Log to Log.NULL for coverage
136                 intPool.log("Test log output");
137
138                 intPool.setLogger(new CustomLogger());
139                 intPool.log("Test log output");
140
141                 assertThat(sb.toString(), is("Test log output"));
142         }
143
144 }