ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [42/50] [abbrv] incubator-ignite git commit: Merge branch 'sprint-2' of https://git-wip-us.apache.org/repos/asf/incubator-ignite into ignite-sql-tests
Date Mon, 23 Feb 2015 23:33:56 GMT
Merge branch 'sprint-2' of https://git-wip-us.apache.org/repos/asf/incubator-ignite into ignite-sql-tests


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/969731f0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/969731f0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/969731f0

Branch: refs/heads/ignite-sql-tests
Commit: 969731f0b292e884f890908fa85bea1b1b3e0abf
Parents: 0eadd39 02e5c37
Author: S.Vladykin <svladykin@gridgain.com>
Authored: Sat Feb 21 09:31:21 2015 +0300
Committer: S.Vladykin <svladykin@gridgain.com>
Committed: Sat Feb 21 09:31:21 2015 +0300

----------------------------------------------------------------------
 README.md                                       | 179 -------------------
 bin/setup-hadoop.sh                             |   2 +-
 .../examples/datagrid/CacheQueryExample.java    |   2 +-
 .../ClientAbstractMultiNodeSelfTest.java        |   2 +-
 .../ignite/codegen/MessageCodeGenerator.java    | 133 ++++++++------
 .../ignite/internal/GridJobCancelRequest.java   |  26 ++-
 .../ignite/internal/GridJobExecuteRequest.java  |  70 ++++----
 .../ignite/internal/GridJobExecuteResponse.java |  34 ++--
 .../ignite/internal/GridJobSiblingsRequest.java |  24 ++-
 .../internal/GridJobSiblingsResponse.java       |  22 ++-
 .../ignite/internal/GridTaskCancelRequest.java  |  22 ++-
 .../ignite/internal/GridTaskSessionRequest.java |  26 ++-
 .../internal/direct/DirectByteBufferStream.java |  44 +++--
 .../internal/direct/DirectMessageReader.java    |  33 +++-
 .../internal/direct/DirectMessageWriter.java    |  23 ++-
 .../direct/DirectMessageWriterState.java        |  13 +-
 .../internal/managers/GridManagerAdapter.java   |   4 +-
 .../checkpoint/GridCheckpointRequest.java       |  26 ++-
 .../managers/communication/GridIoManager.java   |  30 ++--
 .../managers/communication/GridIoMessage.java   |  38 ++--
 .../communication/GridIoMessageFactory.java     |  33 ++--
 .../communication/GridIoUserMessage.java        |  38 ++--
 .../deployment/GridDeploymentCommunication.java |   4 +-
 .../deployment/GridDeploymentInfoBean.java      |  35 ++--
 .../deployment/GridDeploymentRequest.java       |  34 ++--
 .../deployment/GridDeploymentResponse.java      |  26 ++-
 .../eventstorage/GridEventStorageMessage.java   |  42 +++--
 .../processors/cache/GridCacheAdapter.java      |   2 +-
 .../cache/GridCacheEvictionRequest.java         |  26 ++-
 .../cache/GridCacheEvictionResponse.java        |  30 ++--
 .../processors/cache/GridCacheMessage.java      |  21 ++-
 .../processors/cache/GridCacheUtils.java        |  18 ++
 .../processors/cache/GridCacheValueBytes.java   |  24 ++-
 .../processors/cache/IgniteCacheProxy.java      |   2 +-
 ...idCacheOptimisticCheckPreparedTxRequest.java |  30 ++--
 ...dCacheOptimisticCheckPreparedTxResponse.java |  26 ++-
 .../distributed/GridCacheTtlUpdateRequest.java  |  58 +++---
 .../distributed/GridDistributedBaseMessage.java |  33 ++--
 .../distributed/GridDistributedLockRequest.java |  52 +++---
 .../GridDistributedLockResponse.java            |  30 ++--
 .../GridDistributedTxFinishRequest.java         |  42 +++--
 .../GridDistributedTxFinishResponse.java        |  24 ++-
 .../GridDistributedTxPrepareRequest.java        |  58 +++---
 .../GridDistributedTxPrepareResponse.java       |  24 ++-
 .../GridDistributedUnlockRequest.java           |  26 ++-
 .../dht/GridDhtAffinityAssignmentRequest.java   |  22 ++-
 .../dht/GridDhtAffinityAssignmentResponse.java  |  24 ++-
 .../distributed/dht/GridDhtLockRequest.java     |  42 +++--
 .../distributed/dht/GridDhtLockResponse.java    |  40 +++--
 .../distributed/dht/GridDhtTxFinishRequest.java |  42 +++--
 .../dht/GridDhtTxFinishResponse.java            |  22 ++-
 .../dht/GridDhtTxPrepareRequest.java            |  48 ++---
 .../dht/GridDhtTxPrepareResponse.java           |  42 +++--
 .../distributed/dht/GridDhtUnlockRequest.java   |  26 ++-
 .../GridDhtAtomicDeferredUpdateResponse.java    |  26 ++-
 .../dht/atomic/GridDhtAtomicUpdateRequest.java  |  92 +++++-----
 .../dht/atomic/GridDhtAtomicUpdateResponse.java |  32 ++--
 .../dht/atomic/GridNearAtomicUpdateRequest.java |  78 ++++----
 .../atomic/GridNearAtomicUpdateResponse.java    |  54 +++---
 .../dht/preloader/GridDhtForceKeysRequest.java  |  32 ++--
 .../dht/preloader/GridDhtForceKeysResponse.java |  32 ++--
 .../GridDhtPartitionDemandMessage.java          |  36 ++--
 .../preloader/GridDhtPartitionExchangeId.java   |  27 +--
 .../GridDhtPartitionSupplyMessage.java          |  40 +++--
 .../GridDhtPartitionsAbstractMessage.java       |  19 +-
 .../preloader/GridDhtPartitionsFullMessage.java |  24 ++-
 .../GridDhtPartitionsSingleMessage.java         |  22 ++-
 .../GridDhtPartitionsSingleRequest.java         |  18 +-
 .../distributed/near/GridNearGetRequest.java    |  47 +++--
 .../distributed/near/GridNearGetResponse.java   |  38 ++--
 .../distributed/near/GridNearLockRequest.java   |  52 +++---
 .../distributed/near/GridNearLockResponse.java  |  42 +++--
 .../near/GridNearTxFinishRequest.java           |  32 ++--
 .../near/GridNearTxFinishResponse.java          |  26 ++-
 .../near/GridNearTxPrepareRequest.java          |  44 +++--
 .../near/GridNearTxPrepareResponse.java         |  48 ++---
 .../distributed/near/GridNearUnlockRequest.java |  18 +-
 .../cache/query/GridCacheQueryRequest.java      |  58 +++---
 .../cache/query/GridCacheQueryResponse.java     |  40 +++--
 .../cache/version/GridCacheVersion.java         |  29 +--
 .../clock/GridClockDeltaSnapshotMessage.java    |  28 +--
 .../processors/clock/GridClockDeltaVersion.java |  24 ++-
 .../continuous/GridContinuousMessage.java       |  28 +--
 .../dataload/GridDataLoadRequest.java           |  50 +++---
 .../dataload/GridDataLoadResponse.java          |  26 ++-
 .../processors/igfs/IgfsAckMessage.java         |  26 ++-
 .../internal/processors/igfs/IgfsBlockKey.java  |  28 +--
 .../processors/igfs/IgfsBlocksMessage.java      |  30 ++--
 .../igfs/IgfsCommunicationMessage.java          |  18 +-
 .../processors/igfs/IgfsDeleteMessage.java      |  24 ++-
 .../processors/igfs/IgfsFileAffinityRange.java  |  30 ++--
 .../igfs/IgfsFragmentizerRequest.java           |  28 +--
 .../igfs/IgfsFragmentizerResponse.java          |  22 ++-
 .../processors/igfs/IgfsSyncMessage.java        |  24 ++-
 .../plugin/IgnitePluginProcessor.java           |   2 +-
 .../handlers/task/GridTaskResultRequest.java    |  24 ++-
 .../handlers/task/GridTaskResultResponse.java   |  28 +--
 .../streamer/GridStreamerCancelRequest.java     |  22 ++-
 .../streamer/GridStreamerExecutionRequest.java  |  38 ++--
 .../streamer/GridStreamerResponse.java          |  24 ++-
 .../processors/streamer/IgniteStreamerImpl.java |   4 +-
 .../ignite/internal/util/GridByteArrayList.java |  24 ++-
 .../ignite/internal/util/GridLongList.java      |  24 ++-
 .../ignite/internal/util/IgniteUtils.java       |  32 ++--
 .../internal/util/ipc/IpcToNioAdapter.java      |   4 +-
 .../util/nio/GridCommunicationClient.java       |   2 +-
 .../internal/util/nio/GridDirectParser.java     |  33 +++-
 .../internal/util/nio/GridNioMessageReader.java |   2 +-
 .../internal/util/nio/GridNioMessageWriter.java |   4 +-
 .../ignite/internal/util/nio/GridNioServer.java |  59 ++++--
 .../util/nio/GridShmemCommunicationClient.java  |   2 +-
 .../util/nio/GridTcpCommunicationClient.java    |   2 +-
 .../util/nio/GridTcpNioCommunicationClient.java |   2 +-
 .../extensions/communication/Message.java       |  58 ++++++
 .../communication/MessageAdapter.java           | 143 ---------------
 .../MessageCollectionItemType.java              | 101 +++++++++++
 .../communication/MessageFactory.java           |   4 +-
 .../communication/MessageFormatter.java         |   3 +-
 .../extensions/communication/MessageReader.java |  24 ++-
 .../extensions/communication/MessageWriter.java |  26 ++-
 .../jobstealing/JobStealingRequest.java         |  22 ++-
 .../communication/tcp/TcpCommunicationSpi.java  |  80 +++++----
 .../GridJobMasterLeaveAwareSelfTest.java        |   4 +-
 .../GridCommunicationSendMessageSelfTest.java   |  13 +-
 .../communication/GridIoManagerSelfTest.java    |  18 +-
 .../GridDeploymentMessageCountSelfTest.java     |   2 +-
 .../GridCacheAtomicMessageCountSelfTest.java    |   2 +-
 ...ridCacheReplicatedSynchronousCommitTest.java |   2 +-
 .../IgniteCacheAbstractStopBusySelfTest.java    |   5 +-
 .../cache/IgniteTxReentryAbstractSelfTest.java  |   2 +-
 .../GridCacheAbstractJobExecutionTest.java      |  15 +-
 .../GridCacheAtomicTimeoutSelfTest.java         |   3 +-
 ...xOriginatingNodeFailureAbstractSelfTest.java |   2 +-
 ...cOriginatingNodeFailureAbstractSelfTest.java |   2 +-
 .../GridCacheDhtPreloadMessageCountTest.java    |   2 +-
 ...eAtomicInvalidPartitionHandlingSelfTest.java |   2 +-
 .../GridCacheReplicatedInvalidateSelfTest.java  |   2 +-
 .../communication/GridIoManagerBenchmark0.java  |   6 +-
 .../communication/GridTestMessage.java          |   9 +-
 .../GridAbstractCommunicationSelfTest.java      |  22 +--
 .../spi/communication/GridTestMessage.java      |  25 +--
 .../tcp/GridCacheDhtLockBackupSelfTest.java     |   4 +-
 .../GridTcpCommunicationSpiAbstractTest.java    |   2 +-
 ...mmunicationSpiConcurrentConnectSelfTest.java |  16 +-
 .../tcp/GridTcpCommunicationSpiLanTest.java     |   4 +-
 ...cpCommunicationSpiMultithreadedSelfTest.java |  22 +--
 ...dTcpCommunicationSpiRecoveryAckSelfTest.java |  10 +-
 ...GridTcpCommunicationSpiRecoverySelfTest.java |  10 +-
 .../testframework/GridSpiTestContext.java       |   6 +-
 modules/hadoop/pom.xml                          |   6 -
 .../tcp/GridOrderedMessageCancelSelfTest.java   |   2 +-
 151 files changed, 2443 insertions(+), 1761 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/969731f0/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheQueryExample.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/969731f0/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
----------------------------------------------------------------------


Mime
View raw message