chore: setup codecov and fix data race. (#69)

Author: jjeffcaii

.gitignore

@@ -24,4 +24,4 @@ suppressions/
 
 cmd/rsocket-cli/rsocket-cli
 
-coverage.out
+coverage.txt

.travis.yml

@@ -7,13 +7,16 @@ go:
 env:
   - GO111MODULE=on
 
+before_install:
+  - go get -t -v ./...
+
 install:
   - go get golang.org/x/lint/golint
   - curl -sSfL https://raw.githubusercontent.com/golangci/golangci-lint/master/install.sh | sh -s -- -b $(go env GOPATH)/bin v1.30.0
-  - go get golang.org/x/tools/cmd/cover
-  - go get github.com/mattn/goveralls
 
 script:
   - golangci-lint run ./...
-  - go test -v -covermode=atomic -coverprofile=coverage.out -count=1 ./...
-  - goveralls -coverprofile=coverage.out -service=travis-ci -repotoken $COVERALLS_TOKEN
+  - go test -race -coverprofile=coverage.txt -covermode=atomic ./...
+
+after_success:
+  - bash <(curl -s https://codecov.io/bash)

README.md

@@ -2,7 +2,7 @@
 ![logo](./logo.jpg)
 
 [![Build Status](https://travis-ci.com/rsocket/rsocket-go.svg?branch=master)](https://travis-ci.com/rsocket/rsocket-go)
-[![Coverage Status](https://coveralls.io/repos/github/rsocket/rsocket-go/badge.svg?branch=master)](https://coveralls.io/github/rsocket/rsocket-go?branch=master)
+[![codecov](https://codecov.io/gh/rsocket/rsocket-go/branch/master/graph/badge.svg)](https://codecov.io/gh/rsocket/rsocket-go)
 [![Go Report Card](https://goreportcard.com/badge/github.com/rsocket/rsocket-go)](https://goreportcard.com/report/github.com/rsocket/rsocket-go)
 [![Slack](https://img.shields.io/badge/slack-rsocket--go-blue.svg)](https://rsocket.slack.com/messages/C9VGZ5MV3)
 [![GoDoc](https://godoc.org/github.com/rsocket/rsocket-go?status.svg)](https://godoc.org/github.com/rsocket/rsocket-go)

core/transport/transport.go

@@ -60,6 +60,7 @@ const (
 
 // Transport is RSocket transport which is used to carry RSocket frames.
 type Transport struct {
+	sync.RWMutex
 	conn        Conn
 	maxLifetime time.Duration
 	lastRcvPos  uint64
@@ -69,6 +70,8 @@ type Transport struct {
 
 // Handle register event handlers
 func (p *Transport) Handle(event EventType, handler FrameHandler) {
+	p.Lock()
+	defer p.Unlock()
 	p.handlers[int(event)] = handler
 }
 
@@ -174,6 +177,9 @@ func (p *Transport) DispatchFrame(_ context.Context, frame core.Frame) (err erro
 
 	var handler FrameHandler
 
+	p.RLock()
+	defer p.RUnlock()
+
 	switch t {
 	case core.FrameTypeSetup:
 		p.maxLifetime = frame.(*framing.SetupFrame).MaxLifetime()

internal/socket/duplex.go

@@ -1018,7 +1018,9 @@ func (dc *DuplexConnection) drainOutBack() {
 		dc.outsPriority = dc.outsPriority[:0]
 	}()
 
+	dc.locker.RLock()
 	tp := dc.tp
+	dc.locker.RUnlock()
 	if tp == nil {
 		return
 	}