| Index: appengine/logdog/coordinator/endpoints/services/registerStream.go
|
| diff --git a/appengine/logdog/coordinator/endpoints/services/registerStream.go b/appengine/logdog/coordinator/endpoints/services/registerStream.go
|
| index 9b0535beada586286be12ae0b32b7d751de96e0b..0a2f82629f94e19b50fb70a9f8c6f36183acce47 100644
|
| --- a/appengine/logdog/coordinator/endpoints/services/registerStream.go
|
| +++ b/appengine/logdog/coordinator/endpoints/services/registerStream.go
|
| @@ -181,15 +181,13 @@ func (m registerStreamMutation) RollForward(c context.Context) ([]tumble.Mutatio
|
| return nil, grpcutil.Errf(codes.InvalidArgument, "Failed to load descriptor.")
|
| }
|
|
|
| - now := ds.RoundTime(clock.Now(c).UTC())
|
| m.Secret = m.req.Secret
|
| m.ProtoVersion = m.req.ProtoVersion
|
| - m.State = coordinator.LSPending
|
| - m.Created = now
|
| - m.Updated = now
|
| + m.State = coordinator.LSStreaming
|
| + m.Created = ds.RoundTime(clock.Now(c).UTC())
|
| m.TerminalIndex = -1
|
|
|
| - if err := m.Put(di); err != nil {
|
| + if err := di.Put(m); err != nil {
|
| log.Fields{
|
| log.ErrorKey: err,
|
| }.Errorf(c, "Failed to Put() LogStream.")
|
|
|