"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "tests/e2e/ctl_v3_auth_no_proxy_test.go" between
etcd-3.5.5.tar.gz and etcd-3.5.6.tar.gz

About: etcd is a distributed reliable key-value store for the most critical data of a distributed system (written in "Go").

ctl_v3_auth_no_proxy_test.go  (etcd-3.5.5)	:	ctl_v3_auth_no_proxy_test.go  (etcd-3.5.6)
skipping to change at line 15		skipping to change at line 15
// You may obtain a copy of the License at		// You may obtain a copy of the License at
//		//
// http://www.apache.org/licenses/LICENSE-2.0		// http://www.apache.org/licenses/LICENSE-2.0
//		//
// Unless required by applicable law or agreed to in writing, software		// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,		// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.		// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and		// See the License for the specific language governing permissions and
// limitations under the License.		// limitations under the License.
// These tests depends on certificate-based authentication that is NOT supported		// These tests depend on certificate-based authentication that is NOT supported
// by gRPC proxy.		// by gRPC proxy.
//go:build !cluster_proxy		//go:build !cluster_proxy
// +build !cluster_proxy		// +build !cluster_proxy
package e2e		package e2e
import (		import (
		"fmt"
		"sync"
"testing"		"testing"
		"time"
)		)
func TestCtlV3AuthCertCN(t *testing.T) {		func TestCtlV3AuthCertCN(t *testing.T) {
testCtl(t, authTestCertCN, withCfg(*newConfigClientTLSCertAuth()))		testCtl(t, authTestCertCN, withCfg(*newConfigClientTLSCertAuth()))
}		}
func TestCtlV3AuthCertCNAndUsername(t *testing.T) {		func TestCtlV3AuthCertCNAndUsername(t *testing.T) {
testCtl(t, authTestCertCNAndUsername, withCfg(*newConfigClientTLSCertAuth ()))		testCtl(t, authTestCertCNAndUsername, withCfg(*newConfigClientTLSCertAuth ()))
}		}
func TestCtlV3AuthCertCNAndUsernameNoPassword(t *testing.T) {		func TestCtlV3AuthCertCNAndUsernameNoPassword(t *testing.T) {
testCtl(t, authTestCertCNAndUsernameNoPassword, withCfg(*newConfigClientT LSCertAuth()))		testCtl(t, authTestCertCNAndUsernameNoPassword, withCfg(*newConfigClientT LSCertAuth()))
}		}
		func TestCtlV3AuthCertCNWithWithConcurrentOperation(t *testing.T) {
		BeforeTest(t)
		// apply the certificate which has `root` CommonName,
		// and reset the setting when the test case finishes.
		// TODO(ahrtr): enhance the e2e test framework to support
		// certificates with CommonName.
		t.Log("Apply certificate with root CommonName")
		resetCert := applyTLSWithRootCommonName()
		defer resetCert()
		t.Log("Create an etcd cluster")
		cx := getDefaultCtlCtx(t)
		cx.cfg = etcdProcessClusterConfig{
		clusterSize: 1,
		clientTLS: clientTLS,
		clientCertAuthEnabled: true,
		initialToken: "new",
		}
		epc, err := newEtcdProcessCluster(t, &cx.cfg)
		if err != nil {
		t.Fatalf("Failed to start etcd cluster: %v", err)
		}
		cx.epc = epc
		cx.dataDir = epc.procs[0].Config().dataDirPath
		defer func() {
		if err := epc.Close(); err != nil {
		t.Fatalf("could not close test cluster (%v)", err)
		}
		}()
		t.Log("Enable auth")
		authEnableTest(cx)
		// Create two goroutines, one goroutine keeps creating & deleting users,
		// and the other goroutine keeps writing & deleting K/V entries.
		var wg sync.WaitGroup
		wg.Add(2)
		errs := make(chan error, 2)
		donec := make(chan struct{})
		// Create the first goroutine to create & delete users
		t.Log("Create the first goroutine to create & delete users")
		go func() {
		defer wg.Done()
		for i := 0; i < 100; i++ {
		user := fmt.Sprintf("testuser-%d", i)
		pass := fmt.Sprintf("testpass-%d", i)
		if err := ctlV3User(cx, []string{"add", user, "--interact
		ive=false"}, fmt.Sprintf("User %s created", user), []string{pass}); err != nil {
		errs <- fmt.Errorf("failed to create user %q: %w"
		, user, err)
		break
		}
		err := ctlV3User(cx, []string{"delete", user}, fmt.Sprint
		f("User %s deleted", user), []string{})
		if err != nil {
		errs <- fmt.Errorf("failed to delete user %q: %w"
		, user, err)
		break
		}
		}
		t.Log("The first goroutine finished")
		}()
		// Create the second goroutine to write & delete K/V entries
		t.Log("Create the second goroutine to write & delete K/V entries")
		go func() {
		defer wg.Done()
		for i := 0; i < 100; i++ {
		key := fmt.Sprintf("key-%d", i)
		value := fmt.Sprintf("value-%d", i)
		if err := ctlV3Put(cx, key, value, ""); err != nil {
		errs <- fmt.Errorf("failed to put key %q: %w", ke
		y, err)
		break
		}
		if err := ctlV3Del(cx, []string{key}, 1); err != nil {
		errs <- fmt.Errorf("failed to delete key %q: %w",
		key, err)
		break
		}
		}
		t.Log("The second goroutine finished")
		}()
		t.Log("Waiting for the two goroutines to complete")
		go func() {
		wg.Wait()
		close(donec)
		}()
		t.Log("Waiting for test result")
		select {
		case err := <-errs:
		t.Fatalf("Unexpected error: %v", err)
		case <-donec:
		t.Log("All done!")
		case <-time.After(60 * time.Second):
		t.Fatal("Test case timeout after 60 seconds")
		}
		}
End of changes. 4 change blocks.
1 lines changed or deleted		4 lines changed or added

---