diff --git a/coherence/session.go b/coherence/session.go index 000f2ab..3d957fd 100644 --- a/coherence/session.go +++ b/coherence/session.go @@ -691,7 +691,7 @@ func validateFilePath(file string) error { // String returns a string representation of SessionOptions. func (s *SessionOptions) String() string { var sb = strings.Builder{} - sb.WriteString(fmt.Sprintf("SessionOptions{address=%v, plainText=%v, scope=%v, format=%v, request timeout=%v, disconnect timeout=%v, ready timeout=%v", + sb.WriteString(fmt.Sprintf("SessionOptions{address=%v, plainText=%v, scope=%v, format=%v, requestTimeout=%v, disconnectTimeout=%v, readyTimeout=%v", s.Address, s.PlainText, s.Scope, s.Format, s.RequestTimeout, s.DisconnectTimeout, s.ReadyTimeout)) if !s.PlainText { diff --git a/java/pom.xml b/java/pom.xml index fd112d9..9a05fb4 100644 --- a/java/pom.xml +++ b/java/pom.xml @@ -216,7 +216,7 @@ -Dcoherence.security.key=${coherence.security.key} -Dcoherence.security.cert=${coherence.security.cert} -Dcoherence.security.ca.cert=${coherence.security.ca.cert} - -Dcoherence.io.json.debug=true + -Dcoherence.log.level=9 -Dcoherence.distributed.localstorage=true -Dcoherence.management.refresh.expiry=1s diff --git a/test/e2e/standalone/event_test.go b/test/e2e/standalone/event_test.go index f223c2e..7702367 100644 --- a/test/e2e/standalone/event_test.go +++ b/test/e2e/standalone/event_test.go @@ -109,8 +109,8 @@ func TestEventDisconnect(t *testing.T) { t.Setenv("COHERENCE_SESSION_DEBUG", "true") //g, session := initTest(t) g, session := initTest(t, - coherence.WithDisconnectTimeout(time.Duration(130000)*time.Millisecond), - coherence.WithReadyTimeout(time.Duration(70)*time.Second)) + coherence.WithDisconnectTimeout(time.Duration(130)*time.Second), + coherence.WithReadyTimeout(time.Duration(130)*time.Second)) defer session.Close() namedCache := GetNamedCache[string, string](g, session, "test-reconnect-cache") @@ -132,7 +132,7 @@ func TestEventDisconnectWithReadyTimeoutDelay(t *testing.T) { t.Error("Unable to issue post request to stop gRPC proxy") } - g, session := initTest(t, coherence.WithReadyTimeout(time.Duration(130000)*time.Millisecond)) + g, session := initTest(t, coherence.WithReadyTimeout(time.Duration(130)*time.Second)) defer session.Close() namedCache := GetNamedCache[string, string](g, session, "test-reconnect-cache") @@ -275,11 +275,19 @@ func RunTestReconnect(g *gomega.WithT, namedMap coherence.NamedMap[string, strin // issue a stop, which better simulates a sudden disconnect // vs shutdown (which is graceful), for the "$GRPC:GrpcProxy" on node 1. // the client should eventually connect - fmt.Println("Issue stop of $GRPC:GrpcProxy") + log.Println("Issue stop of $GRPC:GrpcProxy") _, err = IssuePostRequest("http://127.0.0.1:30000/management/coherence/cluster/services/$GRPC:GrpcProxy/members/1/stop") g.Expect(err).ShouldNot(gomega.HaveOccurred()) } + // get the size to force reconnect + log.Println("Issue Size() to force reconnect") + _, err = namedMap.Size(ctx) + g.Expect(err).ShouldNot(gomega.HaveOccurred()) + + log.Println("Sleeping to test re-connect") + Sleep(5) + // add another 'additional' mutations createMutations(g, namedMap, additional) @@ -295,6 +303,7 @@ func RunTestReconnect(g *gomega.WithT, namedMap coherence.NamedMap[string, strin // createMutations creates a specified number of data mutations. func createMutations(g *gomega.WithT, namedMap coherence.NamedMap[string, string], iters int) { var err error + log.Println("createMutations, iters=", iters) for i := 0; i < iters; i++ { key := fmt.Sprintf("key-%d", i) value := fmt.Sprintf("value-%d", i)