Re: Geode client attempting to connect to 40404 port

2017-12-05 Thread Barry Oglesby
pingInterval != null) { pf.setPingInterval(pingInterval); } pf.create(poolName); You'll get a pool called DEFAULT and another called Group2Pool, Thanks, Barry Oglesby On Tue, Dec 5, 2017 at 3:45 AM, Vahram Aharonyan wrote: > HI Jens, > > > > Please see the snippets of code we ha

Re: WAN Replication

2018-01-11 Thread Barry Oglesby
hput? I'd like to see the configuration as well as the stats for all three sites. Thanks, Barry Oglesby On Thu, Jan 11, 2018 at 12:35 PM, Xu, Nan wrote: > Not sure I follow, understand the replication is async, but I only > publish to 1 dc with 1.5k/sec, how come other 2 dc have differ

Re: Function Executor thread stacked

2018-01-12 Thread Barry Oglesby
he latest Geode develop code. What version are you running? Thanks, Barry Oglesby On Fri, Jan 12, 2018 at 11:46 AM, Bruce Schuchardt wrote: > This shouldn't normally cause a hang. The code that handles receipt of > tcp/ip messages reads the message's "reply processor" ide

Re: Function Executor thread stacked

2018-01-19 Thread Barry Oglesby
you have SSL enabled. I'll change my test to use both of those and see if I can reproduce the hang. Thanks, Barry Oglesby On Fri, Jan 19, 2018 at 9:33 AM, Dan Smith wrote: > Hi Vahram, > > Well, it's definitely getting corrupted on reading the function arguments > base

Re: Function Executor thread stacked

2018-01-19 Thread Barry Oglesby
the getMessage method, when the Connection sendFailureReply method is called, the dm is null, so no reply is sent. When setFailure is invoked properly, the dm is not null, and the reply is sent. I'm not really sure when/how the dm is set, but setFailure method has to be invoked for this code to

Re: sync up 2 data centers

2018-01-19 Thread Barry Oglesby
ed as well? Also, if we're thinking about this kind of idea, maybe its time to revisit WAN GII? Thanks, Barry Oglesby On Thu, Jan 18, 2018 at 12:37 PM, Xu, Nan wrote: > that certainly helps. For us, the sender not started because some > configuration issues. But in prod, if somehow the

Re: client notification & message ack

2018-01-24 Thread Barry Oglesby
adID=1;sequenceID=0]] Thanks, Barry Oglesby On Wed, Jan 24, 2018 at 10:30 AM, Dan Smith wrote: > Hi Oliver, > > The server won't get an acknowledgement for your event until after your > cache listener completes. After the cache listener calls completes, geode > adds informat

Re: client notification & message ack

2018-01-25 Thread Barry Oglesby
Olivier, Just to be clear, that was logging I added to a local build. The fine-level logging doesn't have much in the code around adding to the ack map. Thanks, Barry Oglesby On Thu, Jan 25, 2018 at 1:24 AM, Olivier Mallassi < olivier.malla...@gmail.com> wrote: > gentlemen, than

Re: [Proposal] Thread monitoring mechanism

2018-02-23 Thread Barry Oglesby
, Barry Oglesby On Wed, Feb 21, 2018 at 11:41 AM, Gregory Vortman < gregory.vort...@amdocs.com> wrote: > That's the point exactly to have a single very thin and generic mechanism > to cover all threads/threads pool. Nothing is specific in this solution. > Regards > &g

Re: Thread block on org.apache.geode.cache.CacheFactory.getAnyInstance(CacheFactory.java:282)

2018-10-25 Thread Barry Oglesby
possible to create the VSDCountersManager in the main thread before the P2P message reader thread attempts to do it (like in a Function init)? Thanks, Barry Oglesby On Wed, Oct 24, 2018 at 7:40 AM Anthony Baker wrote: > Sorry I don’t think I understand your question. Did you encounter a &

Re: Creating Regions Dynamically using Functions

2018-11-01 Thread Barry Oglesby
t false. That will cause the function to be executed on the primary bucket. Thanks, Barry Oglesby On Wed, Oct 31, 2018 at 11:53 AM Marcus Dushshantha Chandradasa < dushshantha.chandarad...@gmail.com> wrote: > Hi Udo, > > This is perfect. This is exactly what I was looking for.

Re: IllegalStateException: Unknown PDX Type on Client Side

2019-01-30 Thread Barry Oglesby
T disk store is used like: BACKUPDEFAULT_1.crf BACKUPDEFAULT_1.drf BACKUPDEFAULT_1.krf BACKUPDEFAULT.if Thanks, Barry Oglesby On Wed, Jan 30, 2019 at 3:26 AM aashish choudhary < aashish.choudha...@gmail.com> wrote: > Thanks Dan for explanation. So if we replace the files with old one(It > has an

Re: Some Geode management metrics returning 0s after OS upgrade

2019-02-06 Thread Barry Oglesby
Do you see values for other MBean attributes? If you do a thread dump in your server JVM(s), you should see a thread like this running: "StatSampler" #39 daemon prio=10 os_prio=31 tid=0x7fdcbf004000 nid=0x7003 in Object.wait() [0x7c50a000] java.lang.Thread.State: TIMED_WAITING (on

Re: About hitCount and missCount counters incrementing in partitioned regions using the Java API vs gfsh

2019-05-17 Thread Barry Oglesby
edRegion and once for the BucketRegion. The misses is incremented for the PartitionedRegion. So, misses is incremented when it shouldn't be. For gfsh, I only see CachePerfStats.endGet called one - for the BucketRegion. This does not increment the misses. Thanks, Barry Oglesby On Fri, May

Re: About hitCount and missCount counters incrementing in partitioned regions using the Java API vs gfsh

2019-05-22 Thread Barry Oglesby
method with the BucketRegion. Thanks, Barry Oglesby On Tue, May 21, 2019 at 11:57 PM Alberto Gomez wrote: > Barry, > > Thanks a lot for the hint. > > As you figured out, I was getting the hitCount and missCount from the > members. > > I still do not understand why th

Re: Gemfire functions giving duplicate records

2019-08-19 Thread Barry Oglesby
, are they co-located? How do you determine the keys to getAll? Are they passed into the function? If so, as a filter or as an argument? What does optimizeForWrite return? How many members are running? Thanks, Barry Oglesby On Mon, Aug 19, 2019 at 1:19 PM aashish choudhary < aashish.chou

Re: Gemfire functions giving duplicate records

2019-08-19 Thread Barry Oglesby
=6; keys=[122, 279, 237, 381, 131, 351] regionKeysAndValues=6; regionKeysAndValues={122=122, 279=279, 237=237, 381=381, 131=131, 351=351} Thanks, Barry Oglesby On Mon, Aug 19, 2019 at 2:18 PM aashish choudhary < aashish.choudha...@gmail.com> wrote: > You have a data-aware function (inv

Re: Gemfire functions giving duplicate records

2019-08-20 Thread Barry Oglesby
ys=[77, 264, 342, 125, 433, 405, 193, 196] regionKeysAndValues=8; regionKeysAndValues={77=77, 264=264, 342=342, 125=125, 433=433, 405=405, 193=193, 196=196} Thanks, Barry Oglesby On Tue, Aug 20, 2019 at 2:55 AM aashish choudhary < aashish.choudha...@gmail.com> wrote: > Thanks Barry for thorou

Re: RECOVERING A WAN INSTALLATION

2019-10-24 Thread Barry Oglesby
Types are persistent in site2, you won't need to work around JIRA GEODE-6271 If your senders are persistent, you may need to delete the disk files before restarting the senders. Thanks, Barry Oglesby On Wed, Oct 23, 2019 at 10:36 PM evaristo.camar...@yahoo.es < evaristo.camar...@yahoo.es

Re: RECOVERING A WAN INSTALLATION

2019-10-28 Thread Barry Oglesby
e an onRegion function to stream the values back to the caller. The function would iterate the entries and batch them back to the client using sendResults. A ResultCollector on the client would process each batch in addResult and do the same thing the CqListener is doing. Thanks, Barry Oglesby On Mon

Re: Question about ordering of events in a partition in WAN deployments with parallel gateway senders

2019-12-02 Thread Barry Oglesby
event will not overwrite a later event. Thanks, Barry Oglesby On Mon, Dec 2, 2019 at 8:57 AM Alberto Gomez wrote: > Hi, > > On the subject of parallel gateway sender receivers, according to the > Geode documentation: > > [1]: > Although parallel gateway senders

Re: WAN replication of transactions

2020-01-21 Thread Barry Oglesby
) { region.create(e.getKey(), e.getValue()); } else if (e.getOperation().isDestroy()) { region.destroy(e.getKey()); } } ctm.commit(); } } Thanks, Barry Oglesby On Mon, Jan 20, 2020 at 11:52 AM John Blum wrote: > From within... > > c

Removing unused PdxTypes from a Distributed System

2020-04-29 Thread Barry Oglesby
Geode Users, I published an article describing how to remove unused PdxTypes from a Distributed System here: https://medium.com/@boglesby_2508/remove-unused-pdxtypes-from-an-apache-geode-distributed-system-5a4f0e199e34 Thanks, Barry Oglesby

Re: issue while region close using two pools

2020-05-05 Thread Barry Oglesby
he createRegion method is: private Region createRegion(String poolName) { return this.cache .createClientRegionFactory(ClientRegionShortcut.PROXY) .setPoolName(poolName) .create(this.regionName); } Thanks, Barry Oglesby On Tue, May 5, 2020 at 9:37 AM aashish choudhary &l

Re: issue while region close using two pools

2020-05-05 Thread Barry Oglesby
Yes, you can't have a single region pointing at 2 pools. What I posted is the way I've done it in the past. I just tried it, and it still works. Maybe if you post your full code, I can take a look. Thanks, Barry Oglesby On Tue, May 5, 2020 at 10:19 AM aashish choudhary < aa

Re: Removing unused PdxTypes from a Distributed System

2020-05-05 Thread Barry Oglesby
n the RemoveUnusedPdxTypesFunction - removes the PdxTypes from the in-memory maps - releases the DistributedLock Thanks, Barry Oglesby On Sat, May 2, 2020 at 9:03 AM Jacob Barrett wrote: > This is awesome! It sounds like a good solid thing to have as a feature to > me. What’s the smal

Re: issue while region close using two pools

2020-05-05 Thread Barry Oglesby
the Region. Something like this should work: this.region1 = clientCache.createClientRegionFactory(ClientRegionShortcut.PROXY) .setPoolName("B") .create("region1"); Thanks, Barry Oglesby On Tue, May 5, 2020 at 11:14 AM aashish choudhary < aashish.choudha...@gmail.com

Re: issue while region close using two pools

2020-05-11 Thread Barry Oglesby
x27;ll have to handle the RegionDestroyedExceptions that occur when the region is closed out from under them - I don't know if your clients are REST-enabled, but a REST API to switch pools would be pretty cool. Thanks, Barry Oglesby On Wed, May 6, 2020 at 9:40 AM aashish choudhary < aa

Converting all Geode statistics to Micrometer meters

2020-05-15 Thread Barry Oglesby
Geode Users, I published an article describing how to convert all Geode statistics to Micrometer meters here: https://medium.com/@boglesby_2508/converting-all-apache-geode-statistics-to-micrometer-meters-e5c94fdc1c56 Thanks, Barry Oglesby

Re: On conserve-sockets=true with WAN and/or transactions - Follow-up on April's Geode Community Meeting

2022-04-15 Thread Barry Oglesby
Alberto, I can only speak to the WAN question in your email. The conserve-sockets setting was (or is) a limitation on serial WAN, but I just ran a few tests, and it is not deadlocking. Its been a while since I've tried serial WAN with conserve-sockets=true, but I'm pretty sure a test with sever

Re: User wants to start JMX Manager without Jetty

2017-01-23 Thread Barry Oglesby
Yes, the ManagementAgent.startHttpService checks for HTTP_SERVICE_PORT != 0. If it is 0, it doesn't start Jetty. Also, if none of the geode-web.war, geode-pulse.war or geode-web-api.war files are available. Jetty won't be started. Thanks, Barry Oglesby On Mon, Jan 23, 2017 at 1:1

Re: OutOfMemoryError with cq listener

2017-02-09 Thread Barry Oglesby
r to crash. Thanks, Barry Oglesby On Thu, Feb 9, 2017 at 2:42 AM, Thacker, Dharam wrote: > Hi Team, > > > > I am facing below error while working with continuous query listener. We > are receiving high number of events matching to various continuous query > listeners wh

Re: OutOfMemoryError with cq listener

2017-02-10 Thread Barry Oglesby
ever to recover its connection to the server. The QueueManagerImpl uses a ScheduledThreadPoolExecutor with a maximum pool size of Integer.MAX_VALUE, so the number of available threads in this area is limited only by the JVM and OS resources. Thanks, Barry Oglesby On Fri, Feb 10, 2017 at 6:27 AM, Th

Re: The gap between Heap Memory usage and region entry size

2017-05-05 Thread Barry Oglesby
Bing, The gfsh gc command is reporting incorrect results. I filed https://issues.apache.org/jira/browse/GEODE-2883. Thanks for finding this. Thanks, Barry Oglesby On Fri, May 5, 2017 at 1:03 AM, Bing Jiang wrote: > > hi, All. > > We launch a geode locator and 7 geode servers (m

Re: Getting stackoverflow error

2017-06-06 Thread Barry Oglesby
Amit, What is being serialized? Is there any chance the value being serialized references itself? Thanks, Barry Oglesby On Tue, Jun 6, 2017 at 12:40 PM, Amit Pandey wrote: > Hi , > > Can any one please help with below error. I get it whenever I am trying to > load a region >

Re: Create a streaming result collector

2017-08-14 Thread Barry Oglesby
ution Thread-2: Processing batch 11 member boglesbymac-2(4145):3184 containing 35 values (total=975) Function Execution Thread-3: Processing batch 12 member boglesbymac-2(4131):46709 containing 25 values (total=1000) Thanks, Barry Oglesby On Mon, Aug 14, 2017 at 9:14 AM, Amit Pandey wrote: >

Re: Subscription Queue Full

2017-09-28 Thread Barry Oglesby
eue. - the network is preventing or slowing transmission between the server and client. Does the network traffic stop completely or slow to a crawl? Can you provide these in the JIRA? - client and server stats - client and server thread dumps Thanks, Barry Oglesby On Wed, Sep 27, 2017 at 3:53 P

Re: view region config from gfsh

2017-11-03 Thread Barry Oglesby
ither. That would be a modification to org.apache.geode.management.internal.beans.RegionMBeanCompositeDataFactory. It looks like you'd have to write your own function to get this data currently. Thanks, Barry Oglesby On Fri, Nov 3, 2017 at 1:03 PM, Xu, Nan wrote: > Hi, > > > >