Merge pull request #1 from silentred/bugfix

update real allocated size of a volume, after it is created

pkg/agent/pool/engine/service.go

@@ -1,6 +1,8 @@
 package engine
 
-import v1 "code.alipay.com/dbplatform/node-disk-controller/pkg/api/volume.antstor.alipay.com/v1"
+import (
+	v1 "code.alipay.com/dbplatform/node-disk-controller/pkg/api/volume.antstor.alipay.com/v1"
+)
 
 type VolumeServiceIface interface {
 	CreateVolume(req CreateVolumeRequest) (resp CreateVolumeResponse, err error)

pkg/agent/sync/sync_volume.go

@@ -639,15 +639,16 @@ func GetSocketPathFromeUUID(uuid string) (path string) {
 
 func (vs *VolumeSyncer) applyVolume(volume *v1.AntstorVolume) (needReturn bool, err error) {
 	// apply allocated size of LV to Annotation
-	if _, has := volume.Annotations[v1.AllocatedSizeAnnoKey]; !has {
+	if _, has := volume.Annotations[v1.AllocatedSizeAnnoKey]; !has && volume.Status.Status == v1.VolumeStatusReady {
 		// get allocated size
 		var (
 			lvName   = volume.Name
 			vol      engine.VolumeInfo
 			sizeByte uint64
 		)
 		vol, err = vs.poolService.PoolEngine().GetVolume(lvName)
-		if err != nil {
+		// ignore NotFoundDeviceError, because this error blocks the volume creation process
+		if err != nil && !spdk.IsNotFoundDeviceError(err) {
 			return
 		}