Method uploadArchive

pkg/devspace/sync/upstream.go:965–1008

(reader io.ReadCloser)

}

func (u *upstream) uploadArchive(reader io.ReadCloser) error {
	defer reader.Close()

	// cancel after 1 hour
	ctx, cancel := context.WithTimeout(u.sync.ctx, time.Hour)
	defer cancel()

	// Create upload client
	uploadClient, err := u.client.Upload(ctx)
	if err != nil {
		return errors.Wrap(err, "upload")
	}

	buf := make([]byte, 16*1024)
	for {
		n, err := reader.Read(buf)
		if n > 0 {
			err := uploadClient.Send(&remote.Chunk{
				Content: buf[:n],
			})
			if err != nil {
				_, recvErr := uploadClient.CloseAndRecv()
				if recvErr != nil {
					return errors.Wrap(recvErr, "upload send")
				}

				return errors.Wrap(err, "upload send")
			}
		}

		if err == io.EOF {
			_, err := uploadClient.CloseAndRecv()
			if err != nil {
				return errors.Wrap(err, "after upload")
			}

			break
		} else if err != nil {
			return errors.Wrap(err, "read tar")
		}
	}

	return nil
}

func (u *upstream) applyRemoves(files []*FileInformation) error {
	u.sync.fileIndex.fileMapMutex.Lock()