[infinispan-dev] Hotrod 5.3.0.Beta1
Mircea Markus
mmarkus at redhat.com
Tue May 14 08:44:36 EDT 2013
Hi Mark,
Can you please share your config with us, both client and server?
If you can reproduce this on a single server node even better.
On 14 May 2013, at 10:05, Mark Addy wrote:
> Hi,
> Not sure if I have missed something really obvious but I am unable to
> get Hotrod to work with this release. If I do a put I can see the new
> entry being written but a subsequent get fails to find it...
> Set up is a vanilla install with the distributed-udp.xml configuration file.
> Hopefully I have done something daft, any help would be great!
> Thanks
> Mark
>
> Here is the put logging:
>
> 2013-05-14 10:02:25,052 TRACE (HotRodServerWorker-4)
> [org.infinispan.server.hotrod.Decoder10$] Operation code: 1 has been
> matched to PutRequest
> 2013-05-14 10:02:25,052 TRACE (HotRodServerWorker-4)
> [org.infinispan.server.hotrod.HotRodDecoder] Decoded header
> HotRodHeader{op=PutRequest, version=12, messageId=6, cacheName=, flag=6,
> clientIntelligence=3, topologyId=0}
> 2013-05-14 10:02:25,052 TRACE (HotRodServerWorker-4)
> [org.infinispan.server.hotrod.HotRodDecoder] Decode using instance @4aa193fe
> 2013-05-14 10:02:25,052 TRACE (HotRodServerWorker-4)
> [org.infinispan.server.hotrod.HotRodDecoder] Decode using instance @4aa193fe
> 2013-05-14 10:02:25,053 TRACE (HotRodServerWorker-4)
> [org.infinispan.server.hotrod.HotRodDecoder] Decode using instance @4aa193fe
> 2013-05-14 10:02:25,053 TRACE (HotRodServerWorker-4)
> [org.infinispan.interceptors.InvocationContextInterceptor] Invoked with
> command VersionedPutKeyValueCommand{key=[B0x034b00000000..,
> value=[B0x033e0474657374.., version=ServerEntr
> yVersion(4294967299), flags=null, putIfAbsent=false, lifespanMillis=-1,
> maxIdleTimeMillis=-1} and InvocationContext
> [org.infinispan.context.SingleKeyNonTxInvocationContext at 5a388c74]
> 2013-05-14 10:02:25,053 TRACE (HotRodServerWorker-4)
> [org.infinispan.statetransfer.StateTransferInterceptor]
> handleTopologyAffectedCommand for command
> VersionedPutKeyValueCommand{key=[B0x034b00000000..,
> value=[B0x033e0474657374..,
> version=ServerEntryVersion(4294967299), flags=null, putIfAbsent=false,
> lifespanMillis=-1, maxIdleTimeMillis=-1}
> 2013-05-14 10:02:25,053 TRACE (HotRodServerWorker-4)
> [org.infinispan.interceptors.locking.NonTransactionalLockingInterceptor]
> Are (kegley-53518) we the lock owners for key '[B at 368d41f2'? true
> 2013-05-14 10:02:25,053 TRACE (HotRodServerWorker-4)
> [org.infinispan.util.concurrent.locks.LockManagerImpl] Attempting to
> lock [B0x034b00000000.. with acquisition timeout of 10000 millis
> 2013-05-14 10:02:25,054 TRACE (HotRodServerWorker-4)
> [org.infinispan.util.concurrent.locks.containers.ReentrantPerEntryLockContainer]
> Creating and acquiring new lock instance for key [B0x034b00000000..
> 2013-05-14 10:02:25,054 TRACE (HotRodServerWorker-4)
> [org.infinispan.util.concurrent.locks.LockManagerImpl] Successfully
> acquired lock [B0x034b00000000..!
> 2013-05-14 10:02:25,054 TRACE (HotRodServerWorker-4)
> [org.infinispan.interceptors.EntryWrappingInterceptor] Wrapping entry
> '[B0x034b00000000..'? true
> 2013-05-14 10:02:25,054 TRACE (HotRodServerWorker-4)
> [org.infinispan.container.EntryFactoryImpl] Exists in context? null
> 2013-05-14 10:02:25,054 TRACE (HotRodServerWorker-4)
> [org.infinispan.container.EntryFactoryImpl] Retrieved from container null
> 2013-05-14 10:02:25,054 TRACE (HotRodServerWorker-4)
> [org.infinispan.container.EntryFactoryImpl] Creating new entry.
> 2013-05-14 10:02:25,054 TRACE (HotRodServerWorker-4)
> [org.infinispan.interceptors.distribution.NonTxDistributionInterceptor]
> Not doing a remote get for key [B at 368d41f2 since entry is not affected
> by rehash or is already in data container. We are kegley-53518, owners
> are [kegley-53518]
> 2013-05-14 10:02:25,054 TRACE (HotRodServerWorker-4)
> [org.infinispan.interceptors.distribution.NonTxConcurrentDistributionInterceptor]
> I'm the primary owner, sending the command to all ([kegley-53518]) the
> recipients in order to be applied.
> 2013-05-14 10:02:25,055 TRACE (HotRodServerWorker-4)
> [org.infinispan.interceptors.CallInterceptor] Executing command:
> VersionedPutKeyValueCommand{key=[B0x034b00000000..,
> value=[B0x033e0474657374.., version=ServerEntryVersion(4294967299),
> flags=null, putIfAbsent=false, lifespanMillis=-1, maxIdleTimeMillis=-1}.
> 2013-05-14 10:02:25,055 TRACE (HotRodServerWorker-4)
> [org.infinispan.remoting.rpc.RpcManagerImpl] kegley-53518 invoking
> VersionedPutKeyValueCommand{key=[B0x034b00000000..,
> value=[B0x033e0474657374.., version=ServerEntryVersion(4294967299),
> flags=null, putIfAbsent=false, lifespanMillis=-1, maxIdleTimeMillis=-1}
> to recipient list [kegley-53518] with options RpcOptions{timeout=15000,
> unit=MILLISECONDS, fifoOrder=true, totalOrder=false,
> responseFilter=null, responseMode=SYNCHRONOUS, skipReplicationQueue=false}
> 2013-05-14 10:02:25,055 TRACE (HotRodServerWorker-4)
> [org.infinispan.remoting.transport.jgroups.JGroupsTransport]
> dests=[kegley-53518],
> command=SingleRpcCommand{cacheName='___defaultcache',
> command=VersionedPutKeyValueCommand{key=[B0x034b00000000..,
> value=[B0x033e0474657374.., version=ServerEntryVersion(4294967299),
> flags=null, putIfAbsent=false, lifespanMillis=-1,
> maxIdleTimeMillis=-1}}, mode=SYNCHRONOUS, timeout=15000
> 2013-05-14 10:02:25,055 TRACE (HotRodServerWorker-4)
> [org.infinispan.remoting.rpc.RpcManagerImpl] Response(s) to
> SingleRpcCommand{cacheName='___defaultcache',
> command=VersionedPutKeyValueCommand{key=[B0x034b00000000..,
> value=[B0x033e0474657374.., version=ServerEntryVersion(4294967299),
> flags=null, putIfAbsent=false, lifespanMillis=-1, maxIdleTimeMillis=-1}}
> is {}
> 2013-05-14 10:02:25,055 TRACE (HotRodServerWorker-4)
> [org.infinispan.interceptors.EntryWrappingInterceptor] About to commit
> entry ReadCommittedEntry(73e492d8){key=[B0x034b00000000..,
> value=[B0x033e0474657374.., oldValue=null, isCreated=true,
> isChanged=true, isRemoved=false, isValid=true}
> 2013-05-14 10:02:25,056 TRACE (HotRodServerWorker-4)
> [org.infinispan.container.entries.ReadCommittedEntry] Updating entry
> (key=[B0x034b00000000.. removed=false valid=true changed=true
> created=true loaded=false value=[B0x033e0474657374..]
> 2013-05-14 10:02:25,056 TRACE (HotRodServerWorker-4)
> [org.infinispan.interceptors.EntryWrappingInterceptor] The return value
> is null
> 2013-05-14 10:02:25,056 TRACE (HotRodServerWorker-4)
> [org.infinispan.util.concurrent.locks.LockManagerImpl] Attempting to
> unlock [B0x034b00000000..
> 2013-05-14 10:02:25,056 TRACE (HotRodServerWorker-4)
> [org.infinispan.util.concurrent.locks.containers.ReentrantPerEntryLockContainer]
> Unlocking lock instance for key [B0x034b00000000..
> 2013-05-14 10:02:25,056 TRACE (HotRodServerWorker-4)
> [org.infinispan.statetransfer.StateTransferManagerImpl]
> CommandTopologyId=0, localTopologyId=0
> 2013-05-14 10:02:25,056 TRACE (HotRodServerWorker-4)
> [org.infinispan.server.hotrod.HotRodDecoder] Write response
> Response{version=12, messageId=6, operation=PutResponse, status=Success,
> cacheName=}
> 2013-05-14 10:02:25,056 TRACE (HotRodServerWorker-4)
> [org.infinispan.server.hotrod.HotRodEncoder] Encode msg
> Response{version=12, messageId=6, operation=PutResponse, status=Success,
> cacheName=}
>
>
>
> And here is the get logging:
>
> 2013-05-14 10:02:25,063 TRACE (HotRodServerWorker-4)
> [org.infinispan.server.hotrod.Decoder10$] Operation code: 3 has been
> matched to GetRequest
> 2013-05-14 10:02:25,063 TRACE (HotRodServerWorker-4)
> [org.infinispan.server.hotrod.HotRodDecoder] Decoded header
> HotRodHeader{op=GetRequest, version=12, messageId=8, cacheName=, flag=0,
> clientIntelligence=3, topologyId=0}
> 2013-05-14 10:02:25,063 TRACE (HotRodServerWorker-4)
> [org.infinispan.server.hotrod.HotRodDecoder] Decode using instance @4aa193fe
> 2013-05-14 10:02:25,063 TRACE (HotRodServerWorker-4)
> [org.infinispan.interceptors.InvocationContextInterceptor] Invoked with
> command GetCacheEntryCommand {key=[B0x034b00000000.., flags=null} and
> InvocationContext
> [org.infinispan.context.SingleKeyNonTxInvocationContext at 2364de59]
> 2013-05-14 10:02:25,063 TRACE (HotRodServerWorker-4)
> [org.infinispan.statetransfer.StateTransferInterceptor]
> handleTopologyAffectedCommand for command GetCacheEntryCommand
> {key=[B0x034b00000000.., flags=null}
> 2013-05-14 10:02:25,064 TRACE (HotRodServerWorker-4)
> [org.infinispan.container.EntryFactoryImpl] Exists in context? null
> 2013-05-14 10:02:25,064 TRACE (HotRodServerWorker-4)
> [org.infinispan.container.EntryFactoryImpl] Retrieved from container null
> 2013-05-14 10:02:25,064 TRACE (HotRodServerWorker-4)
> [org.infinispan.interceptors.CallInterceptor] Executing command:
> GetCacheEntryCommand {key=[B0x034b00000000.., flags=null}.
> 2013-05-14 10:02:25,064 TRACE (HotRodServerWorker-4)
> [org.infinispan.commands.read.GetKeyValueCommand] Entry not found
> 2013-05-14 10:02:25,064 TRACE (HotRodServerWorker-4)
> [org.infinispan.interceptors.distribution.BaseDistributionInterceptor]
> Not doing a remote get for key [B0x034b00000000.. since entry is mapped
> to current node (kegley-53518) or is in L1. Owners are [kegley-53518]
> 2013-05-14 10:02:25,064 TRACE (HotRodServerWorker-4)
> [org.infinispan.server.hotrod.HotRodDecoder] Write response
> GetResponse{version=12, messageId=8, operation=GetResponse,
> status=KeyDoesNotExist, data=null}
> 2013-05-14 10:02:25,064 TRACE (HotRodServerWorker-4)
> [org.infinispan.server.hotrod.HotRodEncoder] Encode msg
> GetResponse{version=12, messageId=8, operation=GetResponse,
> status=KeyDoesNotExist, data=null}
> 2013-05-14 10:02:25,064 TRACE (HotRodServerWorker-4)
> [org.infinispan.server.hotrod.Encoders$Encoder12$] Write topology
> response header with no change
> 2013-05-14 10:02:25,064 TRACE (HotRodServerWorker-4)
> [org.infinispan.server.hotrod.HotRodEncoder] Write buffer contents
> A108040200 to channel [id: 0xe9c51ab1, /127.0.0.1:40222 => /127.0.1.1:11111]
>
>
>
> _______________________________________________
> infinispan-dev mailing list
> infinispan-dev at lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/infinispan-dev
Cheers,
--
Mircea Markus
Infinispan lead (www.infinispan.org)
More information about the infinispan-dev
mailing list