func.return %0 : tensor<1xf32>
  }

// CHECK: func.func private @main_0
// CHECK: func.func @main
}

// -----

// Tests when a function called @main already exists and @main_{i} also already
// exists, it increments the suffix number until there's no conflict.
module attributes {tf_saved_model.semantics}  {

func TestH12_RequestContentLength_Known_Zero(t *testing.T) {
	h12requestContentLength(t, func() io.Reader { return nil }, 0)
}

func TestH12_RequestContentLength_Unknown(t *testing.T) {
	h12requestContentLength(t, func() io.Reader { return struct{ io.Reader }{strings.NewReader("Stuff")} }, -1)
}

func h12requestContentLength(t *testing.T, bodyfn func() io.Reader, wantLen int64) {
	h12Compare{

  func.func @f() attributes { tf_saved_model.exported_names = 1 : i32} {
    func.return
  }

}

// -----

module attributes {tf_saved_model.semantics} {

  // expected-note@+1 {{previously seen here}}
  func.func @f() attributes { tf_saved_model.exported_names = ["foo"]} {
    func.return
  }

  // expected-error@+1 {{duplicate exported name 'foo'}}

)

func init() {
	localSchemeBuilder.Register(RegisterConversions)
}

// RegisterConversions adds conversion functions to the given scheme.
// Public to allow building arbitrary schemes.
func RegisterConversions(s *runtime.Scheme) error {
	if err := s.AddGeneratedConversionFunc((*APIEndpoint)(nil), (*kubeadm.APIEndpoint)(nil), func(a, b interface{}, scope conversion.Scope) error {

// CHECK-SAME: index = [[const_index:.*]]
func.func private @some_func(
    %arg: tensor<!tf_type.resource<tensor<i32>>>) -> tensor<i32> {
  // CHECK: tf.ReadVariableOp
  %0 = "tf.ReadVariableOp"(%arg) {device = "cpu"} : (tensor<!tf_type.resource<tensor<i32>>>) -> tensor<i32>
  func.return %0 : tensor<i32>
}

// CHECK-LABEL: func @test_not_hoist_stateful_call

	var f func(x int) int
	f = func(x int) int {
		return x * x
	}
	ch := make(chan bool, 1)
	go func() {
		f = func(x int) int {
			return x
		}
		ch <- true
	}()
	y := f(1)
	<-ch
	x := y
	y = x
}

func TestRaceFuncVariableWW(t *testing.T) {
	var f func(x int) int
	_ = f
	ch := make(chan bool, 1)
	go func() {
		f = func(x int) int {
			return x
		}

type T int

var x interface{}
var c chan int

func external() int // ok

func _() int {
} // ERROR "missing return"

func _() int {
	print(1)
} // ERROR "missing return"

// return is okay
func _() int {
	print(1)
	return 2
}

// goto is okay
func _() int {
L:
	print(1)
	goto L
}

// panic is okay
func _() int {
	print(1)
	panic(2)
}

 func (t <type 39>) Key () <type 26>;
 func (t <type 39>) Len () <type -11>;
 func (t <type 39>) NumField () <type -11>;
 func (t <type 39>) NumIn () <type -11>;
 func (t <type 39>) NumOut () <type -11>;
 func (t <type 39>) Out (i <type -11>) <type 26>;
 func (t <type 39>) .reflect.runtimeType () <type 21>;
 func (ct <type 39>) .reflect.ptrTo () <type 39>;
 func (t <type 39>) Implements (u <type 26>) <type -15>;

func bind(s int, addr unsafe.Pointer, addrlen _Socklen) (err error) {
	_, _, e1 := syscall(abi.FuncPCABI0(libc_bind_trampoline), uintptr(s), uintptr(addr), uintptr(addrlen))
	if e1 != 0 {
		err = errnoErr(e1)
	}
	return
}

func libc_bind_trampoline()

//go:cgo_import_dynamic libc_bind bind "libc.so"

// THIS FILE IS GENERATED BY THE COMMAND AT THE TOP; DO NOT EDIT

  func.return %r : tensor<i32>
}

// -----

// Test inputs to the child streams are merged to the parent streams

// CHECK-LABEL: func private @main_stream_1
// CHECK-SAME: ([[INPUT0:%.*]]: tensor<i32>, [[INPUT1:%.*]]: tensor<i32>
// CHECK: tf.Sub
// CHECK: tf.Sub
// CHECK: mlrt.async({{%.*}}, [[INPUT1]]

// CHECK-LABEL: func @main