File tree Expand file tree Collapse file tree 3 files changed +18
-8
lines changed
main/java/org/opensearch/search/sandboxing/resourcetype
test/java/org/opensearch/search/sandboxing/cancellation Expand file tree Collapse file tree 3 files changed +18
-8
lines changed Original file line number Diff line number Diff line change @@ -15,4 +15,13 @@ public class CpuTimeResourceType extends SandboxResourceType {
15
15
public long getResourceUsage (Task task ) {
16
16
return task .getTotalResourceStats ().getCpuTimeInNanos ();
17
17
}
18
+ @ Override
19
+ public boolean equals (Object obj ) {
20
+ return obj instanceof CpuTimeResourceType ;
21
+ }
22
+
23
+ @ Override
24
+ public int hashCode () {
25
+ return "CPU" .hashCode ();
26
+ }
18
27
}
Original file line number Diff line number Diff line change @@ -15,4 +15,13 @@ public class JvmMemoryResourceType extends SandboxResourceType {
15
15
public long getResourceUsage (Task task ) {
16
16
return task .getTotalResourceStats ().getMemoryInBytes ();
17
17
}
18
+ @ Override
19
+ public boolean equals (Object obj ) {
20
+ return obj instanceof JvmMemoryResourceType ;
21
+ }
22
+
23
+ @ Override
24
+ public int hashCode () {
25
+ return "JVM" .hashCode ();
26
+ }
18
27
}
Original file line number Diff line number Diff line change 13
13
import org .opensearch .core .tasks .resourcetracker .ResourceStats ;
14
14
import org .opensearch .core .tasks .resourcetracker .ResourceStatsType ;
15
15
import org .opensearch .core .tasks .resourcetracker .ResourceUsageMetric ;
16
- import org .opensearch .core .tasks .resourcetracker .TaskResourceUsage ;
17
- import org .opensearch .tasks .CancellableTask ;
18
16
import org .opensearch .tasks .Task ;
19
- import org .opensearch .test .OpenSearchTestCase ;
20
17
21
18
import java .util .ArrayList ;
22
19
import java .util .Collections ;
23
20
import java .util .List ;
24
- import java .util .concurrent .atomic .AtomicBoolean ;
25
21
26
- import static org .mockito .ArgumentMatchers .anyString ;
27
- import static org .mockito .Mockito .doAnswer ;
28
- import static org .mockito .Mockito .mock ;
29
- import static org .mockito .Mockito .when ;
30
22
import static org .opensearch .test .OpenSearchTestCase .randomLong ;
31
23
import static org .opensearch .test .OpenSearchTestCase .randomLongBetween ;
32
24
You can’t perform that action at this time.
0 commit comments