[jira] [Created] (THRIFT-4240) Go TSimpleServer does not close properly

["Zach Wasserman (JIRA)" <ji...@apache.org>]

Zach Wasserman created THRIFT-4240:
--------------------------------------

             Summary: Go TSimpleServer does not close properly
                 Key: THRIFT-4240
                 URL: https://issues.apache.org/jira/browse/THRIFT-4240
             Project: Thrift
          Issue Type: Bug
          Components: Go - Library
    Affects Versions: 0.10.0
            Reporter: Zach Wasserman


Improper use of {{sync.Once}} results in only the first call to {{Close()}} in a given process actually executing.

The {{sync.Once}} object should be a struct member, and not package global.

Test:

{code}
type mockProcessor struct {
	ProcessFunc func(in, out TProtocol) (bool, TException)
}

func (m *mockProcessor) Process(in, out TProtocol) (bool, TException) {
	return m.ProcessFunc(in, out)
}

type mockServerTransport struct {
	ListenFunc    func() error
	AcceptFunc    func() (TTransport, error)
	CloseFunc     func() error
	InterruptFunc func() error
}

func (m *mockServerTransport) Listen() error {
	return m.ListenFunc()
}

func (m *mockServerTransport) Accept() (TTransport, error) {
	return m.AcceptFunc()
}

func (m *mockServerTransport) Close() error {
	return m.CloseFunc()
}

func (m *mockServerTransport) Interrupt() error {
	return m.InterruptFunc()
}

func TestMultipleStop(t *testing.T) {
	proc := &mockProcessor{
		ProcessFunc: func(in, out TProtocol) (bool, TException) {
			return false, nil
		},
	}

	var interruptCalled bool
	c := make(chan struct{})
	trans := &mockServerTransport{
		ListenFunc: func() error {
			return nil
		},
		AcceptFunc: func() (TTransport, error) {
			<-c
			return nil, nil
		},
		CloseFunc: func() error {
			c <- struct{}{}
			return nil
		},
		InterruptFunc: func() error {
			interruptCalled = true
			return nil
		},
	}

	serv := NewTSimpleServer2(proc, trans)
	go serv.Serve()
	serv.Stop()
	if !interruptCalled {
		t.Error("first server transport should have been interrupted")
	}

	serv = NewTSimpleServer2(proc, trans)
	interruptCalled = false
	go serv.Serve()
	serv.Stop()
	if !interruptCalled {
		t.Error("second server transport should have been interrupted")
	}
}
{code}

Output:
{code}
go test -race -run TestMultipleStop
--- FAIL: TestMultipleStop (0.00s)
	simple_server_test.go:96: second server transport should have been interrupted
FAIL
exit status 1
FAIL	github.com/kolide/launcher/vendor/git.apache.org/thrift.git/lib/go/thrift	0.020s
{code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)