Skip to content

Commit f8074dc

Browse files
committed
Avoid data race in DynamoDB server
1 parent 141f5cb commit f8074dc

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

adapter/dynamodb.go

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -33,18 +33,19 @@ type DynamoDBServer struct {
3333
}
3434

3535
func NewDynamoDBServer(listen net.Listener, st store.ScanStore, coordinate *kv.Coordinate) *DynamoDBServer {
36-
return &DynamoDBServer{
36+
d := &DynamoDBServer{
3737
listen: listen,
3838
store: st,
3939
coordinator: coordinate,
4040
dynamoTranscoder: newDynamoDBTranscoder(),
4141
}
42-
}
43-
44-
func (d *DynamoDBServer) Run() error {
4542
mux := http.NewServeMux()
4643
mux.HandleFunc("/", d.handle)
4744
d.httpServer = &http.Server{Handler: mux, ReadHeaderTimeout: time.Second}
45+
return d
46+
}
47+
48+
func (d *DynamoDBServer) Run() error {
4849
if err := d.httpServer.Serve(d.listen); err != nil && !errors.Is(err, http.ErrServerClosed) {
4950
return errors.WithStack(err)
5051
}

0 commit comments

Comments
 (0)