progress func(int64)

flushOffset int64

takeoverOffset int64

takeoverObj *storagepb.Object // Object returned by takeover stream reopening.

objResource *storagepb.Object // Captures received obj to set w.Attrs.

// Fields used to report responses from the receive side of the stream

// recvs is closed when the current recv goroutine is complete. recvErr is set

if err := s.connect(ctx); err != nil {

return nil, fmt.Errorf("storage: opening appendable write stream: %w", err)

}

_, err := s.sendOnConnectedStream(nil, 0, true, false, true)

_, err := s.sendOnConnectedStream(nil, 0, false, false, true)

if err != nil {

return nil, err

}

firstResp := <-s.recvs

// Object resource is returned in the first response on takeover, so capture

// this now.

s.takeoverObj = firstResp.GetResource()

s.objResource = firstResp.GetResource()

s.takeoverOffset = firstResp.GetResource().GetSize()

return s, nil

}

// When closing the stream, update the object resource to reflect

// the persisted size. We get a new object from the stream if

// the object was finalized, but not if it's unfinalized.

if s.takeoverObj != nil && resp.GetPersistedSize() > 0 {

s.takeoverObj.Size = resp.GetPersistedSize()

if s.objResource != nil && resp.GetPersistedSize() > 0 {

s.objResource.Size = resp.GetPersistedSize()

}

}

if s.recvErr != io.EOF {

}

obj, err = s.sendOnConnectedStream(buf, offset, flush, finishWrite, sendFirstMessage)

if obj != nil {

s.objResource = obj

}

if err == nil {

return

}