diff --git a/reactor-core/src/blockHoundTest/java/reactor/core/scheduler/ReactorBlockHoundIntegrationSPITest.java b/reactor-core/src/blockHoundTest/java/reactor/core/scheduler/ReactorBlockHoundIntegrationSPITest.java index f9d373f3e7..f294936e78 100644 --- a/reactor-core/src/blockHoundTest/java/reactor/core/scheduler/ReactorBlockHoundIntegrationSPITest.java +++ b/reactor-core/src/blockHoundTest/java/reactor/core/scheduler/ReactorBlockHoundIntegrationSPITest.java @@ -1,3 +1,19 @@ +/* + * Copyright (c) 2019-2021 VMware Inc. or its affiliates, All Rights Reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + package reactor.core.scheduler; import java.util.ServiceLoader; diff --git a/reactor-core/src/jcstress/java/reactor/core/publisher/MonoDelayStressTest.java b/reactor-core/src/jcstress/java/reactor/core/publisher/MonoDelayStressTest.java index 025946f124..704a3c62df 100644 --- a/reactor-core/src/jcstress/java/reactor/core/publisher/MonoDelayStressTest.java +++ b/reactor-core/src/jcstress/java/reactor/core/publisher/MonoDelayStressTest.java @@ -1,3 +1,19 @@ +/* + * Copyright (c) 2021 VMware Inc. or its affiliates, All Rights Reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + package reactor.core.publisher; import org.openjdk.jcstress.annotations.Actor; diff --git a/reactor-core/src/jcstress/java/reactor/core/publisher/MonoInnerProducerBaseStressTest.java b/reactor-core/src/jcstress/java/reactor/core/publisher/MonoInnerProducerBaseStressTest.java index f890872d94..0cf9ff847d 100644 --- a/reactor-core/src/jcstress/java/reactor/core/publisher/MonoInnerProducerBaseStressTest.java +++ b/reactor-core/src/jcstress/java/reactor/core/publisher/MonoInnerProducerBaseStressTest.java @@ -1,3 +1,19 @@ +/* + * Copyright (c) 2021 VMware Inc. or its affiliates, All Rights Reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + package reactor.core.publisher; import org.openjdk.jcstress.annotations.Actor; diff --git a/reactor-core/src/main/java/reactor/core/publisher/FluxErrorSupplied.java b/reactor-core/src/main/java/reactor/core/publisher/FluxErrorSupplied.java index 43c8dadcd6..b3fb42df21 100644 --- a/reactor-core/src/main/java/reactor/core/publisher/FluxErrorSupplied.java +++ b/reactor-core/src/main/java/reactor/core/publisher/FluxErrorSupplied.java @@ -14,22 +14,6 @@ * limitations under the License. */ -/* - * Copyright (c) 2011-2021 VMware Inc. or its affiliates, All Rights Reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * https://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - package reactor.core.publisher; import java.util.Objects; diff --git a/reactor-core/src/main/java/reactor/core/publisher/FluxIndexFuseable.java b/reactor-core/src/main/java/reactor/core/publisher/FluxIndexFuseable.java index 9b45a39343..56b34d048b 100644 --- a/reactor-core/src/main/java/reactor/core/publisher/FluxIndexFuseable.java +++ b/reactor-core/src/main/java/reactor/core/publisher/FluxIndexFuseable.java @@ -14,22 +14,6 @@ * limitations under the License. */ -/* - * Copyright (c) 2011-2021 VMware Inc. or its affiliates, All Rights Reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * https://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - package reactor.core.publisher; import java.util.Objects; diff --git a/reactor-core/src/main/java/reactor/core/publisher/FluxLiftFuseable.java b/reactor-core/src/main/java/reactor/core/publisher/FluxLiftFuseable.java index c4d6523922..c04bded1fe 100644 --- a/reactor-core/src/main/java/reactor/core/publisher/FluxLiftFuseable.java +++ b/reactor-core/src/main/java/reactor/core/publisher/FluxLiftFuseable.java @@ -14,21 +14,6 @@ * limitations under the License. */ -/* - * Copyright (c) 2011-2021 VMware Inc. or its affiliates, All Rights Reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * https://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ package reactor.core.publisher; import java.util.Objects; diff --git a/reactor-core/src/main/java/reactor/core/publisher/MonoErrorSupplied.java b/reactor-core/src/main/java/reactor/core/publisher/MonoErrorSupplied.java index 4595b6e304..f02f96477f 100644 --- a/reactor-core/src/main/java/reactor/core/publisher/MonoErrorSupplied.java +++ b/reactor-core/src/main/java/reactor/core/publisher/MonoErrorSupplied.java @@ -14,21 +14,6 @@ * limitations under the License. */ -/* - * Copyright (c) 2011-2021 VMware Inc. or its affiliates, All Rights Reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * https://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ package reactor.core.publisher; import java.time.Duration; diff --git a/reactor-core/src/main/java/reactor/core/scheduler/DelegatingScheduledExecutorService.java b/reactor-core/src/main/java/reactor/core/scheduler/DelegatingScheduledExecutorService.java index 4ad8bee64a..a36787def4 100644 --- a/reactor-core/src/main/java/reactor/core/scheduler/DelegatingScheduledExecutorService.java +++ b/reactor-core/src/main/java/reactor/core/scheduler/DelegatingScheduledExecutorService.java @@ -1,3 +1,19 @@ +/* + * Copyright (c) 2020-2021 VMware Inc. or its affiliates, All Rights Reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + package reactor.core.scheduler; import java.util.Collection; diff --git a/reactor-core/src/main/java/reactor/core/scheduler/EmptyCompositeDisposable.java b/reactor-core/src/main/java/reactor/core/scheduler/EmptyCompositeDisposable.java index fbb6a85f86..28b9c6870f 100644 --- a/reactor-core/src/main/java/reactor/core/scheduler/EmptyCompositeDisposable.java +++ b/reactor-core/src/main/java/reactor/core/scheduler/EmptyCompositeDisposable.java @@ -1,3 +1,19 @@ +/* + * Copyright (c) 2017-2021 VMware Inc. or its affiliates, All Rights Reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + package reactor.core.scheduler; import reactor.core.Disposable; diff --git a/reactor-core/src/main/java/reactor/util/concurrent/MpscLinkedQueue.java b/reactor-core/src/main/java/reactor/util/concurrent/MpscLinkedQueue.java index 90cb44f3cd..f3c322e155 100644 --- a/reactor-core/src/main/java/reactor/util/concurrent/MpscLinkedQueue.java +++ b/reactor-core/src/main/java/reactor/util/concurrent/MpscLinkedQueue.java @@ -14,10 +14,6 @@ * limitations under the License. */ -/* - * The code was inspired by the similarly named JCTools class: - * https://github.com/JCTools/JCTools/blob/master/jctools-core/src/main/java/org/jctools/queues/atomic - */ package reactor.util.concurrent; import java.util.AbstractQueue; @@ -28,6 +24,10 @@ import reactor.util.annotation.Nullable; +/* + * The code was inspired by the similarly named JCTools class: + * https://github.com/JCTools/JCTools/blob/master/jctools-core/src/main/java/org/jctools/queues/atomic + */ /** * A multi-producer single consumer unbounded queue. * @param the contained value type diff --git a/reactor-core/src/tckTest/java/reactor/core/publisher/tck/FluxSwitchOnFirstVerification.java b/reactor-core/src/tckTest/java/reactor/core/publisher/tck/FluxSwitchOnFirstVerification.java index b3a709fcc1..cd8cfafa1b 100644 --- a/reactor-core/src/tckTest/java/reactor/core/publisher/tck/FluxSwitchOnFirstVerification.java +++ b/reactor-core/src/tckTest/java/reactor/core/publisher/tck/FluxSwitchOnFirstVerification.java @@ -1,3 +1,19 @@ +/* + * Copyright (c) 2018-2021 VMware Inc. or its affiliates, All Rights Reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + package reactor.core.publisher.tck; import org.reactivestreams.Publisher; diff --git a/reactor-core/src/test/java/reactor/core/publisher/MonoSingleMonoTest.java b/reactor-core/src/test/java/reactor/core/publisher/MonoSingleMonoTest.java index 6459d2f17e..fe91ccd743 100644 --- a/reactor-core/src/test/java/reactor/core/publisher/MonoSingleMonoTest.java +++ b/reactor-core/src/test/java/reactor/core/publisher/MonoSingleMonoTest.java @@ -1,3 +1,19 @@ +/* + * Copyright (c) 2017-2021 VMware Inc. or its affiliates, All Rights Reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + package reactor.core.publisher; import java.util.NoSuchElementException; diff --git a/reactor-core/src/test/java/reactor/util/concurrent/MpscLinkedQueueTest.java b/reactor-core/src/test/java/reactor/util/concurrent/MpscLinkedQueueTest.java index 984501f49e..2889a4beeb 100644 --- a/reactor-core/src/test/java/reactor/util/concurrent/MpscLinkedQueueTest.java +++ b/reactor-core/src/test/java/reactor/util/concurrent/MpscLinkedQueueTest.java @@ -1,3 +1,19 @@ +/* + * Copyright (c) 2018-2021 VMware Inc. or its affiliates, All Rights Reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + package reactor.util.concurrent; import java.util.concurrent.atomic.AtomicInteger; diff --git a/reactor-core/src/test/java/reactor/util/concurrent/SpscArrayQueueTest.java b/reactor-core/src/test/java/reactor/util/concurrent/SpscArrayQueueTest.java index 096d07a904..bc8bfcc231 100644 --- a/reactor-core/src/test/java/reactor/util/concurrent/SpscArrayQueueTest.java +++ b/reactor-core/src/test/java/reactor/util/concurrent/SpscArrayQueueTest.java @@ -1,3 +1,19 @@ +/* + * Copyright (c) 2018-2021 VMware Inc. or its affiliates, All Rights Reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + package reactor.util.concurrent; import java.util.Arrays; diff --git a/reactor-core/src/withMicrometerTest/java/reactor/core/scheduler/SchedulersMetricsTest.java b/reactor-core/src/withMicrometerTest/java/reactor/core/scheduler/SchedulersMetricsTest.java index 031e79e9d8..9320699015 100644 --- a/reactor-core/src/withMicrometerTest/java/reactor/core/scheduler/SchedulersMetricsTest.java +++ b/reactor-core/src/withMicrometerTest/java/reactor/core/scheduler/SchedulersMetricsTest.java @@ -1,3 +1,19 @@ +/* + * Copyright (c) 2018-2021 VMware Inc. or its affiliates, All Rights Reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + package reactor.core.scheduler; import java.util.concurrent.Executors;