service.runSecondBarrier.await();
    service.awaitTerminated();
    // Only called once overall.
    assertEquals(1, service.numberOfTimesSchedulerCalled.get());
  }

  public void testTimeout() {
    // Create a service whose executor will never run its commands
    Service service =
        new AbstractScheduledService() {
          @Override
          protected Scheduler scheduler() {

		select {
		case resp := <-responseCh:
			_, err := w.Write([]byte(resp))
			writeErrCh <- err
		case panicReason := <-panicCh:
			panic(panicReason)
		}
	})
}

func TestTimeout(t *testing.T) {
	origReallyCrash := runtime.ReallyCrash
	runtime.ReallyCrash = false
	defer func() {
		runtime.ReallyCrash = origReallyCrash
	}()

	sendResponse := make(chan string, 1)

						g.Expect(line).To(ContainSubstring(msg.ConflictingGateways.Code()))
						foundCount++
					}
				}
			}
			g.Expect(foundCount).To(Equal(6))
		})
}

func TestTimeout(t *testing.T) {
	t.Skip("https://github.com/istio/istio/issues/25893")
	// nolint: staticcheck
	framework.
		NewTest(t).
		RequiresSingleCluster().
		Run(func(t framework.TestContext) {
			g := NewWithT(t)

pilot,TestJsonInputFile
pilot,TestJsonOutput
pilot,TestJsonOutput/invalid_file_does_not_output_error_in_stdout
pilot,TestJsonOutput/no_other_output_except_analysis_json_output
pilot,TestKubeOnly
pilot,TestNamespace
pilot,TestTimeout
pilot,TestValidation
pilot,TestWebhook
galley_test,TestAllNamespaces
galley_test,TestConversion/config.istio.io_v1alpha2_rule
galley_test,TestConversion/core_v1_namespace
galley_test,TestConversion/core_v1_service