Adding license headers to the hbase-consensus module Summary: The hbase-consensus classes were missing apache license headers. I am adding them.
Total files : 234 Licensed files : 232 Remaining two files : 1. IllegalArgument.java (Auto generated) 2. rmap.json (data for test cases) java -jar apache-rat-0.11.jar --exclude ./test/resources/org/apache/hadoop/hbase/consensus/rmap/rmap.json --dir ./ Test Plan: build and also run the rat tool Reviewers: eclark, fantasist, reddragon Differential Revision: https://reviews.facebook.net/D30687 Signed-off-by: Elliott Clark <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/8e7a91a3 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8e7a91a3 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8e7a91a3 Branch: refs/heads/HBASE-12259 Commit: 8e7a91a36ea388e4be0b5a5cbbd6b3645829e9e9 Parents: 15570dd Author: Rishit Shroff <[email protected]> Authored: Tue Dec 23 12:18:54 2014 -0800 Committer: Elliott Clark <[email protected]> Committed: Fri Dec 26 11:11:22 2014 -0800 ---------------------------------------------------------------------- .../client/NoLeaderForRegionException.java | 20 ++++++++++++++++++++ .../hbase/consensus/client/FetchTask.java | 20 ++++++++++++++++++++ .../hbase/consensus/client/QuorumClient.java | 20 ++++++++++++++++++++ .../consensus/client/QuorumLoadTestClient.java | 20 ++++++++++++++++++++ .../client/QuorumThriftClientAgent.java | 20 ++++++++++++++++++++ .../consensus/client/QuorumThriftClientCLI.java | 20 ++++++++++++++++++++ .../CommitQueueOverloadedException.java | 20 ++++++++++++++++++++ .../exceptions/LeaderNotReadyException.java | 20 ++++++++++++++++++++ .../exceptions/NewLeaderException.java | 20 ++++++++++++++++++++ .../exceptions/NotEnoughMemoryException.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/fsm/Conditional.java | 20 ++++++++++++++++++++ .../consensus/fsm/ConstitutentFSMService.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/fsm/Event.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/fsm/EventType.java | 20 ++++++++++++++++++++ .../fsm/FSMLargeOpsExecutorService.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/fsm/FSMMetrics.java | 20 ++++++++++++++++++++ .../hbase/consensus/fsm/FiniteStateMachine.java | 20 ++++++++++++++++++++ .../consensus/fsm/FiniteStateMachineIf.java | 20 ++++++++++++++++++++ .../fsm/FiniteStateMachineService.java | 20 ++++++++++++++++++++ .../fsm/FiniteStateMachineServiceImpl.java | 20 ++++++++++++++++++++ .../hbase/consensus/fsm/MutableContext.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/fsm/OnEvent.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/fsm/State.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/fsm/StateType.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/fsm/Transition.java | 20 ++++++++++++++++++++ .../hbase/consensus/fsm/TransitionType.java | 20 ++++++++++++++++++++ .../hbase/consensus/fsm/Unconditional.java | 20 ++++++++++++++++++++ .../apache/hadoop/hbase/consensus/fsm/Util.java | 20 ++++++++++++++++++++ .../hbase/consensus/log/CachedFileChannel.java | 20 ++++++++++++++++++++ .../log/CommitLogManagerInterface.java | 20 ++++++++++++++++++++ .../hbase/consensus/log/InMemoryLogManager.java | 20 ++++++++++++++++++++ .../consensus/log/LogFetchPlanCreator.java | 20 ++++++++++++++++++++ .../consensus/log/LogFileInfoIterator.java | 20 ++++++++++++++++++++ .../hbase/consensus/log/LogFileInterface.java | 20 ++++++++++++++++++++ .../hbase/consensus/log/LogFileViewer.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/log/LogReader.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/log/LogWriter.java | 20 ++++++++++++++++++++ .../hbase/consensus/log/RandomAccessLog.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/log/ReadOnlyLog.java | 20 ++++++++++++++++++++ .../hbase/consensus/log/RemoteLogFetcher.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/log/SeedLogFile.java | 20 ++++++++++++++++++++ .../consensus/log/TransactionLogCreator.java | 20 ++++++++++++++++++++ .../consensus/log/TransactionLogManager.java | 20 ++++++++++++++++++++ .../consensus/metrics/ConsensusMetrics.java | 20 ++++++++++++++++++++ .../hbase/consensus/metrics/PeerMetrics.java | 20 ++++++++++++++++++++ .../hbase/consensus/protocol/ConsensusHost.java | 20 ++++++++++++++++++++ .../protocol/DataStoreCommitEvent.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/protocol/EditId.java | 20 ++++++++++++++++++++ .../hbase/consensus/protocol/Payload.java | 20 ++++++++++++++++++++ .../consensus/quorum/AbstractPeerManager.java | 20 ++++++++++++++++++++ .../hbase/consensus/quorum/AggregateTimer.java | 20 ++++++++++++++++++++ .../quorum/AppendConsensusSession.java | 20 ++++++++++++++++++++ .../quorum/AppendConsensusSessionInterface.java | 20 ++++++++++++++++++++ .../quorum/AppendResponseCallBack.java | 20 ++++++++++++++++++++ .../consensus/quorum/ConsensusSession.java | 20 ++++++++++++++++++++ .../consensus/quorum/ConstituentTimer.java | 20 ++++++++++++++++++++ .../quorum/HeartbeatTimeoutCallback.java | 20 ++++++++++++++++++++ .../consensus/quorum/ImmutableRaftContext.java | 20 ++++++++++++++++++++ .../quorum/JointAppendConsensusSession.java | 20 ++++++++++++++++++++ .../quorum/JointConsensusPeerManager.java | 20 ++++++++++++++++++++ .../quorum/JointVoteConsensusSession.java | 20 ++++++++++++++++++++ .../consensus/quorum/MutableRaftContext.java | 20 ++++++++++++++++++++ .../consensus/quorum/PeerManagerInterface.java | 20 ++++++++++++++++++++ .../quorum/ProgressTimeoutCallback.java | 20 ++++++++++++++++++++ .../hbase/consensus/quorum/QuorumInfo.java | 20 ++++++++++++++++++++ .../quorum/QuorumMembershipChangeRequest.java | 20 ++++++++++++++++++++ .../consensus/quorum/RaftQuorumContext.java | 20 ++++++++++++++++++++ .../hbase/consensus/quorum/RepeatingTimer.java | 20 ++++++++++++++++++++ .../hbase/consensus/quorum/ReseedRequest.java | 20 ++++++++++++++++++++ .../hbase/consensus/quorum/SessionResult.java | 20 ++++++++++++++++++++ .../quorum/SingleConsensusPeerManager.java | 20 ++++++++++++++++++++ .../consensus/quorum/TimeoutEventHandler.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/quorum/Timer.java | 20 ++++++++++++++++++++ .../consensus/quorum/VoteConsensusSession.java | 20 ++++++++++++++++++++ .../quorum/VoteConsensusSessionInterface.java | 20 ++++++++++++++++++++ .../hbase/consensus/raft/RaftStateMachine.java | 20 ++++++++++++++++++++ .../raft/events/AppendNotCompleted.java | 20 ++++++++++++++++++++ .../raft/events/AppendRequestEvent.java | 20 ++++++++++++++++++++ .../raft/events/AppendRequestTimeout.java | 20 ++++++++++++++++++++ .../raft/events/AppendResponseEvent.java | 20 ++++++++++++++++++++ .../consensus/raft/events/AppendRetry.java | 20 ++++++++++++++++++++ .../consensus/raft/events/AppendSucceeded.java | 20 ++++++++++++++++++++ .../consensus/raft/events/IsCandidate.java | 20 ++++++++++++++++++++ .../hbase/consensus/raft/events/IsFollower.java | 20 ++++++++++++++++++++ .../hbase/consensus/raft/events/IsLeader.java | 20 ++++++++++++++++++++ .../events/IsTransactionLogNotAccessible.java | 20 ++++++++++++++++++++ .../consensus/raft/events/NeedStepDown.java | 20 ++++++++++++++++++++ .../NoQuorumMembershipChangeInProgress.java | 20 ++++++++++++++++++++ .../raft/events/ProgressTimeoutEvent.java | 20 ++++++++++++++++++++ .../events/QuorumMembershipChangeEvent.java | 20 ++++++++++++++++++++ .../QuorumMembershipChangeInProgress.java | 20 ++++++++++++++++++++ .../consensus/raft/events/RaftEventType.java | 20 ++++++++++++++++++++ .../raft/events/ReplicateEntriesEvent.java | 20 ++++++++++++++++++++ .../raft/events/ReseedRequestEvent.java | 20 ++++++++++++++++++++ .../hbase/consensus/raft/events/StartEvent.java | 20 ++++++++++++++++++++ .../hbase/consensus/raft/events/VoteFailed.java | 20 ++++++++++++++++++++ .../consensus/raft/events/VoteNotCompleted.java | 20 ++++++++++++++++++++ .../consensus/raft/events/VoteRequestEvent.java | 20 ++++++++++++++++++++ .../raft/events/VoteResponseEvent.java | 20 ++++++++++++++++++++ .../consensus/raft/events/VoteSucceeded.java | 20 ++++++++++++++++++++ .../hbase/consensus/raft/states/AckClient.java | 20 ++++++++++++++++++++ .../consensus/raft/states/BecomeFollower.java | 20 ++++++++++++++++++++ .../consensus/raft/states/BecomeLeader.java | 20 ++++++++++++++++++++ .../hbase/consensus/raft/states/Candidate.java | 20 ++++++++++++++++++++ .../raft/states/ChangeQuorumMembership.java | 20 ++++++++++++++++++++ .../hbase/consensus/raft/states/Follower.java | 20 ++++++++++++++++++++ .../hbase/consensus/raft/states/Halt.java | 20 ++++++++++++++++++++ .../raft/states/HandleAppendRequest.java | 20 ++++++++++++++++++++ .../raft/states/HandleAppendResponse.java | 20 ++++++++++++++++++++ .../HandleQuorumMembershipChangeRequest.java | 20 ++++++++++++++++++++ .../raft/states/HandleReseedRequest.java | 20 ++++++++++++++++++++ .../raft/states/HandleVoteRequest.java | 20 ++++++++++++++++++++ .../raft/states/HandleVoteResponse.java | 20 ++++++++++++++++++++ .../hbase/consensus/raft/states/Leader.java | 20 ++++++++++++++++++++ .../consensus/raft/states/ProgressTimeout.java | 20 ++++++++++++++++++++ .../consensus/raft/states/RaftAsyncState.java | 20 ++++++++++++++++++++ .../hbase/consensus/raft/states/RaftState.java | 20 ++++++++++++++++++++ .../consensus/raft/states/RaftStateType.java | 20 ++++++++++++++++++++ .../raft/states/ReSendAppendRequest.java | 20 ++++++++++++++++++++ .../raft/states/SendAppendRequest.java | 20 ++++++++++++++++++++ .../consensus/raft/states/SendVoteRequest.java | 20 ++++++++++++++++++++ .../hbase/consensus/raft/states/Start.java | 20 ++++++++++++++++++++ .../raft/transitions/RaftTransitionType.java | 20 ++++++++++++++++++++ .../hbase/consensus/rpc/AppendRequest.java | 20 ++++++++++++++++++++ .../hbase/consensus/rpc/AppendResponse.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/rpc/LogState.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/rpc/PeerStatus.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/rpc/Request.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/rpc/VoteRequest.java | 20 ++++++++++++++++++++ .../hbase/consensus/rpc/VoteResponse.java | 20 ++++++++++++++++++++ .../consensus/server/ConsensusService.java | 20 ++++++++++++++++++++ .../consensus/server/ConsensusServiceImpl.java | 20 ++++++++++++++++++++ .../InstrumentedConsensusServiceImpl.java | 20 ++++++++++++++++++++ .../consensus/server/LocalConsensusServer.java | 20 ++++++++++++++++++++ .../consensus/server/peer/AbstractPeer.java | 20 ++++++++++++++++++++ .../server/peer/PeerConsensusServer.java | 20 ++++++++++++++++++++ .../hbase/consensus/server/peer/PeerServer.java | 20 ++++++++++++++++++++ .../server/peer/PeerServerImmutableContext.java | 20 ++++++++++++++++++++ .../server/peer/PeerServerMutableContext.java | 20 ++++++++++++++++++++ .../consensus/server/peer/PeerStateMachine.java | 20 ++++++++++++++++++++ .../server/peer/ReconnectTimeoutCallback.java | 20 ++++++++++++++++++++ .../peer/events/PeerAppendRequestEvent.java | 20 ++++++++++++++++++++ .../peer/events/PeerAppendResponseEvent.java | 20 ++++++++++++++++++++ .../server/peer/events/PeerServerEventType.java | 20 ++++++++++++++++++++ .../peer/events/PeerVoteRequestEvent.java | 20 ++++++++++++++++++++ .../peer/events/PeerVoteResponseEvent.java | 20 ++++++++++++++++++++ .../server/peer/states/PeerFollower.java | 20 ++++++++++++++++++++ .../peer/states/PeerHandleAppendResponse.java | 20 ++++++++++++++++++++ .../server/peer/states/PeerHandleRPCError.java | 20 ++++++++++++++++++++ .../peer/states/PeerHandleVoteResponse.java | 20 ++++++++++++++++++++ .../server/peer/states/PeerRecovery.java | 20 ++++++++++++++++++++ .../peer/states/PeerSendAppendRequest.java | 20 ++++++++++++++++++++ .../server/peer/states/PeerSendVoteRequest.java | 20 ++++++++++++++++++++ .../peer/states/PeerServerAsyncState.java | 20 ++++++++++++++++++++ .../server/peer/states/PeerServerState.java | 20 ++++++++++++++++++++ .../server/peer/states/PeerServerStateType.java | 20 ++++++++++++++++++++ .../consensus/server/peer/states/Start.java | 20 ++++++++++++++++++++ .../transition/PeerServerTransitionType.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/util/RaftUtil.java | 20 ++++++++++++++++++++ .../hadoop/hbase/metrics/MetricsBase.java | 20 ++++++++++++++++++++ .../apache/hadoop/hbase/metrics/TimeStat.java | 20 ++++++++++++++++++++ .../hbase/regionserver/DataStoreState.java | 20 ++++++++++++++++++++ .../hbase/regionserver/RaftEventListener.java | 20 ++++++++++++++++++++ .../regionserver/RegionOverloadedException.java | 20 ++++++++++++++++++++ .../hbase/thrift/generated/IllegalArgument.java | 20 ++++++++++++++++++++ .../org/apache/hadoop/hbase/util/Arena.java | 20 ++++++++++++++++++++ .../apache/hadoop/hbase/util/InHeapArena.java | 20 ++++++++++++++++++++ .../apache/hadoop/hbase/util/MemoryBuffer.java | 20 ++++++++++++++++++++ .../serial/AsyncSerialExecutorServiceImpl.java | 20 ++++++++++++++++++++ .../util/serial/SerialExecutorService.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/LocalTestBed.java | 20 ++++++++++++++++++++ .../hbase/consensus/RaftTestDataProvider.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/RaftTestUtil.java | 20 ++++++++++++++++++++ .../consensus/ReplicationLoadForUnitTest.java | 20 ++++++++++++++++++++ .../hbase/consensus/SimulatedNetworkTester.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/TestBasicCommit.java | 20 ++++++++++++++++++++ .../consensus/TestBasicLeaderElection.java | 20 ++++++++++++++++++++ .../hbase/consensus/TestBasicPeerFailure.java | 20 ++++++++++++++++++++ .../hbase/consensus/TestBasicPeerSeeding.java | 20 ++++++++++++++++++++ .../hbase/consensus/TestBasicPeerSlow.java | 20 ++++++++++++++++++++ .../hbase/consensus/TestBasicQuorumCommit.java | 20 ++++++++++++++++++++ .../TestBasicQuorumMembershipChange.java | 20 ++++++++++++++++++++ .../consensus/TestBasicSeedCommitIndex.java | 20 ++++++++++++++++++++ .../hbase/consensus/TestCommitDeadline.java | 20 ++++++++++++++++++++ .../hbase/consensus/TestLogFileViewer.java | 20 ++++++++++++++++++++ .../hbase/consensus/TestLogWriterAndReader.java | 20 ++++++++++++++++++++ .../consensus/TestLowerRankBecomingLeader.java | 20 ++++++++++++++++++++ .../consensus/TestPersistLastVotedFor.java | 20 ++++++++++++++++++++ .../hbase/consensus/TestRaftEventListener.java | 20 ++++++++++++++++++++ .../hbase/consensus/TestRandomAccessLog.java | 20 ++++++++++++++++++++ .../hadoop/hbase/consensus/TestReadOnlyLog.java | 20 ++++++++++++++++++++ .../fsm/TestAsyncStatesInRaftStateMachine.java | 20 ++++++++++++++++++++ .../consensus/fsm/TestFiniteStateMachine.java | 20 ++++++++++++++++++++ .../fsm/TestFiniteStateMachineService.java | 20 ++++++++++++++++++++ .../consensus/fsm/TestIncompleteStates.java | 20 ++++++++++++++++++++ .../consensus/log/TestCachedFileChannel.java | 20 ++++++++++++++++++++ .../consensus/log/TestRemoteLogFetcher.java | 20 ++++++++++++++++++++ .../log/TestTransactionLogCreator.java | 20 ++++++++++++++++++++ .../consensus/metrics/TestPeerMetrics.java | 20 ++++++++++++++++++++ .../consensus/quorum/TestAggregateTimer.java | 20 ++++++++++++++++++++ .../consensus/quorum/TestConstituentTimer.java | 20 ++++++++++++++++++++ .../consensus/quorum/TestRepeatingTimer.java | 20 ++++++++++++++++++++ 202 files changed, 4040 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/client/NoLeaderForRegionException.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/client/NoLeaderForRegionException.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/client/NoLeaderForRegionException.java index 8076873..d84bd4f 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/client/NoLeaderForRegionException.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/client/NoLeaderForRegionException.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.client; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.hadoop.hbase.RegionException; /** http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/FetchTask.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/FetchTask.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/FetchTask.java index 6399634..4b83b71 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/FetchTask.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/FetchTask.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.client; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import com.facebook.swift.codec.ThriftConstructor; import com.facebook.swift.codec.ThriftField; import com.facebook.swift.codec.ThriftStruct; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumClient.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumClient.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumClient.java index 2901a54..0fcca92 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumClient.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumClient.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.client; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.HServerAddress; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumLoadTestClient.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumLoadTestClient.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumLoadTestClient.java index 4b9d8e0..748d3bd 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumLoadTestClient.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumLoadTestClient.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.client; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import java.io.IOException; import java.text.DecimalFormat; import java.util.ArrayList; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumThriftClientAgent.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumThriftClientAgent.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumThriftClientAgent.java index 2d39705..075ed64 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumThriftClientAgent.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumThriftClientAgent.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.client; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import com.facebook.nifty.client.FramedClientConnector; import com.facebook.nifty.duplex.TDuplexProtocolFactory; import com.facebook.swift.service.ThriftClient; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumThriftClientCLI.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumThriftClientCLI.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumThriftClientCLI.java index 04399f1..e3fa9f3 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumThriftClientCLI.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/client/QuorumThriftClientCLI.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.client; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.commons.cli.CommandLine; import org.apache.commons.cli.GnuParser; import org.apache.commons.cli.HelpFormatter; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/CommitQueueOverloadedException.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/CommitQueueOverloadedException.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/CommitQueueOverloadedException.java index 47d830a..027c777 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/CommitQueueOverloadedException.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/CommitQueueOverloadedException.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.exceptions; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.hadoop.hbase.regionserver.RegionOverloadedException; public class CommitQueueOverloadedException extends RegionOverloadedException { http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/LeaderNotReadyException.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/LeaderNotReadyException.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/LeaderNotReadyException.java index ad30cbc..43d9270 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/LeaderNotReadyException.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/LeaderNotReadyException.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.exceptions; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import java.io.IOException; public class LeaderNotReadyException extends IOException { http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/NewLeaderException.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/NewLeaderException.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/NewLeaderException.java index e73d537..81d0cf3 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/NewLeaderException.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/NewLeaderException.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.exceptions; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import java.io.IOException; /** http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/NotEnoughMemoryException.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/NotEnoughMemoryException.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/NotEnoughMemoryException.java index 0e79bbe4..721d32c 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/NotEnoughMemoryException.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/exceptions/NotEnoughMemoryException.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.exceptions; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import java.io.IOException; public class NotEnoughMemoryException extends IOException { http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Conditional.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Conditional.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Conditional.java index aabe9f9..e34ef41 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Conditional.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Conditional.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + /** * A Conditional is used in the State Machine to check if an event meets a * particular condition before making a transition. http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/ConstitutentFSMService.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/ConstitutentFSMService.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/ConstitutentFSMService.java index e68b58e..8502198 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/ConstitutentFSMService.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/ConstitutentFSMService.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import com.google.common.util.concurrent.FutureCallback; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Event.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Event.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Event.java index cc7475a..4f128a6 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Event.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Event.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.slf4j.Logger; import org.slf4j.LoggerFactory; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/EventType.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/EventType.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/EventType.java index 8cbafc5..2ae5029 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/EventType.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/EventType.java @@ -1,3 +1,23 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + public interface EventType {} http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FSMLargeOpsExecutorService.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FSMLargeOpsExecutorService.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FSMLargeOpsExecutorService.java index 246bd8e..56d0e8c 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FSMLargeOpsExecutorService.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FSMLargeOpsExecutorService.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import java.util.concurrent.Callable; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FSMMetrics.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FSMMetrics.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FSMMetrics.java index 84b28d9..d1f1f26 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FSMMetrics.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FSMMetrics.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.hadoop.hbase.metrics.MetricsBase; import org.weakref.jmx.MBeanExporter; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachine.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachine.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachine.java index 963e797..21c5810 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachine.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachine.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import java.util.HashMap; import java.util.Iterator; import java.util.Map.Entry; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachineIf.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachineIf.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachineIf.java index d9d2f66..17c23e4 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachineIf.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachineIf.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import com.google.common.util.concurrent.ListenableFuture; /** http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachineService.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachineService.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachineService.java index 562d2a8..57c69b4 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachineService.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachineService.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import java.util.concurrent.TimeUnit; public interface FiniteStateMachineService { http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachineServiceImpl.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachineServiceImpl.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachineServiceImpl.java index 29052db..9f155a1 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachineServiceImpl.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/FiniteStateMachineServiceImpl.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.LinkedBlockingDeque; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/MutableContext.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/MutableContext.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/MutableContext.java index 5b983ca..b476745 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/MutableContext.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/MutableContext.java @@ -1,3 +1,23 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + public interface MutableContext {} http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/OnEvent.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/OnEvent.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/OnEvent.java index 338e981..f5f6b7f 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/OnEvent.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/OnEvent.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + public class OnEvent implements Conditional { protected EventType t; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/State.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/State.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/State.java index 6f9ef46..8622f61 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/State.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/State.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import com.google.common.util.concurrent.ListenableFuture; /** http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/StateType.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/StateType.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/StateType.java index 921f51c..5ee6a67 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/StateType.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/StateType.java @@ -1,3 +1,23 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + public interface StateType {} http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Transition.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Transition.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Transition.java index 45e08e5..d120f84 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Transition.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Transition.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + /** * Represents a transition in the state machine. */ http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/TransitionType.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/TransitionType.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/TransitionType.java index e5b4a07..56ff5d7 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/TransitionType.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/TransitionType.java @@ -1,3 +1,23 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + public interface TransitionType {} http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Unconditional.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Unconditional.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Unconditional.java index 570e01e..1975a39 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Unconditional.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Unconditional.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + public class Unconditional implements Conditional { @Override http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Util.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Util.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Util.java index 2e3633c..9585d6e 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Util.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/fsm/Util.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.fsm; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import java.util.concurrent.TimeUnit; public class Util { http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/CachedFileChannel.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/CachedFileChannel.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/CachedFileChannel.java index b4c26c5..974e012 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/CachedFileChannel.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/CachedFileChannel.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.log; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import java.io.IOException; import java.io.RandomAccessFile; import java.nio.ByteBuffer; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/CommitLogManagerInterface.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/CommitLogManagerInterface.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/CommitLogManagerInterface.java index 75f2b6b..f23176e 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/CommitLogManagerInterface.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/CommitLogManagerInterface.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.log; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.consensus.protocol.EditId; import org.apache.hadoop.hbase.consensus.quorum.ImmutableRaftContext; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/InMemoryLogManager.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/InMemoryLogManager.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/InMemoryLogManager.java index 968950b..263857d 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/InMemoryLogManager.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/InMemoryLogManager.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.log; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.commons.lang.NotImplementedException; import org.apache.hadoop.hbase.consensus.protocol.EditId; import org.apache.hadoop.hbase.consensus.quorum.ImmutableRaftContext; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFetchPlanCreator.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFetchPlanCreator.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFetchPlanCreator.java index 46c52f9..db44950 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFetchPlanCreator.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFetchPlanCreator.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.log; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.hadoop.hbase.consensus.client.FetchTask; import java.util.Collection; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFileInfoIterator.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFileInfoIterator.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFileInfoIterator.java index 744395e..ad6c0d7 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFileInfoIterator.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFileInfoIterator.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.log; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.hadoop.hbase.consensus.client.FetchTask; import org.apache.hadoop.hbase.util.Pair; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFileInterface.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFileInterface.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFileInterface.java index 2499ec1..648ed62 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFileInterface.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFileInterface.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.log; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.hadoop.hbase.util.Arena; import org.apache.hadoop.hbase.util.MemoryBuffer; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFileViewer.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFileViewer.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFileViewer.java index b89351b..258dcfa 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFileViewer.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogFileViewer.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.log; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.commons.cli.*; import org.apache.hadoop.hbase.regionserver.wal.WALEdit; import org.apache.hadoop.hbase.util.MemoryBuffer; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogReader.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogReader.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogReader.java index 659b466..f04ab6b 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogReader.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogReader.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.log; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.HConstants; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogWriter.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogWriter.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogWriter.java index 4a1947a..0147e1e 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogWriter.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/LogWriter.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.log; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.hadoop.hbase.HConstants; import org.jboss.netty.buffer.ChannelBuffer; import org.jboss.netty.buffer.ChannelBuffers; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/RandomAccessLog.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/RandomAccessLog.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/RandomAccessLog.java index 840dbae..7b9ec8a 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/RandomAccessLog.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/RandomAccessLog.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.log; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.util.Arena; import org.apache.hadoop.hbase.util.MemoryBuffer; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/ReadOnlyLog.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/ReadOnlyLog.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/ReadOnlyLog.java index 4edc875..d48e1e7 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/ReadOnlyLog.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/ReadOnlyLog.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.log; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.hadoop.hbase.util.Arena; import org.apache.hadoop.hbase.util.MemoryBuffer; import org.slf4j.Logger; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/RemoteLogFetcher.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/RemoteLogFetcher.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/RemoteLogFetcher.java index dc3c30f..fb763bd 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/RemoteLogFetcher.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/RemoteLogFetcher.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.log; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import java.io.IOException; import java.util.Collection; import java.util.List; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/SeedLogFile.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/SeedLogFile.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/SeedLogFile.java index 05f3c02..b3b4780 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/SeedLogFile.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/SeedLogFile.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.log; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.hadoop.hbase.HConstants; import java.io.File; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/TransactionLogCreator.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/TransactionLogCreator.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/TransactionLogCreator.java index a20bf70..49ba7c3 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/TransactionLogCreator.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/TransactionLogCreator.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.log; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.hadoop.conf.Configuration; import org.slf4j.Logger; import org.slf4j.LoggerFactory; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/TransactionLogManager.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/TransactionLogManager.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/TransactionLogManager.java index 0c343a8..c7861bb 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/TransactionLogManager.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/log/TransactionLogManager.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.log; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.consensus.exceptions.NotEnoughMemoryException; http://git-wip-us.apache.org/repos/asf/hbase/blob/8e7a91a3/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/metrics/ConsensusMetrics.java ---------------------------------------------------------------------- diff --git a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/metrics/ConsensusMetrics.java b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/metrics/ConsensusMetrics.java index d956563..f23cde9 100644 --- a/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/metrics/ConsensusMetrics.java +++ b/hbase-consensus/src/main/java/org/apache/hadoop/hbase/consensus/metrics/ConsensusMetrics.java @@ -1,5 +1,25 @@ package org.apache.hadoop.hbase.consensus.metrics; +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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 + * + * http://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. + */ + + import io.airlift.stats.CounterStat; import io.airlift.stats.Distribution;
