調(diào)用/glance/api/v2/images.py文件中ImagesController類下的create方法

# 獲取對(duì)應(yīng)后端對(duì)鏡像的操作對(duì)象
image_factory = self.gateway.get_image_factory(req.context)
    ->  # `glance.location.ImageFactoryProxy`：存儲(chǔ)位置處理欠橘。
  ->    # `glance.quota.ImageFactoryProxy`：存儲(chǔ)配額處理眠菇。
  ->    # `policy.ImageFactoryProxy`：存儲(chǔ)策略處理咙好。
  ->    # `glance.notifier.ImageFactoryProxy`：存儲(chǔ)消息通知處理。
  ->    # `glance.*.ImageFactoryProxy`四個(gè)類均繼承自工廠類`/glance/domain/proxy.py`文件中的`ImageFactory`類垢啼，
        # 工廠類是用來(lái)創(chuàng)建封裝鏡像對(duì)象的，子類實(shí)現(xiàn)權(quán)限檢查、消息通知筋粗、策略檢查、配額檢查等功能炸渡。
  ->    # `glance.*.ImageFactoryProxy`四個(gè)類依賴`glance.*.ImageProxy`類娜亿，`glance.*.ImageProxy`均繼承
        # 自`/glance/domain/proxy.py`文件中的`Image`類，而`Image`類描述了鏡像的基本屬性信息蚌堵，`glance.*.Image
        # Proxy`類是對(duì)`Image`類的擴(kuò)展买决。
# get_image_factory實(shí)現(xiàn)
def get_image_factory(self, context):
        image_factory = glance.domain.ImageFactory()
    store_image_factory = glance.location.ImageFactoryProxy(image_factory, context, ....)
    quota_image_factory = glance.quota.ImageFactoryProxy(store_image_factory, context, ...)
    policy_image_factory = policy.ImageFactoryProxy(quota_image_factory, context, ...)
    notifier_image_factory = glance.notifier.ImageFactoryProxy(policy_image_factory, context, ...)
    if property_utils.is_property_protection_enabled():
            property_rules = property_utils.PropertyRules(self.policy)
            pif = property_protections.ProtectedImageFactoryProxy(notifier_image_factory, context, ...)
            authorized_image_factory = authorization.ImageFactoryProxy(pif, context)
    else:
        authorized_image_factory = authorization.ImageFactoryProxy(notifier_image_factory, context) 
    return authorized_image_factory
# 創(chuàng)建新的鏡像-調(diào)用入口
image = image_factory.new_image(extra_properties=extra_properties, tags=tags, **image)
    ->  # 以下文件均是在glance目錄下。該過(guò)程采用的是責(zé)任鏈調(diào)用模式吼畏。
    ->  # image_factory.new_image(...)首先調(diào)用`api.authorization.ImageFactoryProxy.new_image`督赤。
  ->    # `api.authorization.ImageFactoryProxy.new_image(...)`調(diào)用`domain.proxy.ImageFactory.new_image`。
  ->    # `domain.proxy.ImageFactory.new_image(...)`調(diào)用`notifier.ImageFactoryProxy.new_image`泻蚊。
  ->    # `notifier.ImageFactoryProxy.new_image(...)`調(diào)用`domain.proxy.ImageFactory.new_image`躲舌。
  ->    #   `domain.proxy.ImageFactory.new_image(...)`調(diào)用`api.policy.ImageFactoryProxy.new_image`。
  ->    #   `api.policy.ImageFactoryProxy.new_image(...)`調(diào)用`domain.proxy.ImageFactory.new_image`性雄。
  ->    #   `domain.proxy.ImageFactory.new_image(...)`調(diào)用`quota.ImageFactoryProxy.new_image`孽糖。
  ->    #   `quota.ImageFactoryProxy.new_image(...)`調(diào)用`domain.proxy.ImageFactory.new_image`枯冈。
  ->    #   `domain.proxy.ImageFactory.new_image(...)`調(diào)用`location.ImageFactoryProxy.new_image`。
  ->    #   `location.ImageFactoryProxy.new_image(...)`調(diào)用`domain.proxy.ImageFactory.new_image`办悟。
  ->    #   `domain.proxy.ImageFactory.new_image(...)`調(diào)用`domain.ImageFactory.new_image`尘奏。
  ->    # 通過(guò)`domain.ImageFactory.new_image(...)`生成Image對(duì)象并返回。
# 數(shù)據(jù)庫(kù)操作對(duì)象病蛉，image_repo流程和image_factory類似
image_repo = self.gateway.get_repo(req.context)
# 鏡像數(shù)據(jù)庫(kù)操作
image_repo.add(image)

調(diào)用/glance/api/v2/image_data.py文件中ImageDataController類下的upload方法

# 獲取存儲(chǔ)后端類型炫加，例如：CONF.glance_store.default_backend配置為rbd
backend = req.headers.get('x-image-meta-store', CONF.glance_store.default_backend)
# 更新數(shù)據(jù)庫(kù)內(nèi)容
image_repo.save(image, from_state='queued')
# 調(diào)用存儲(chǔ)
image.set_data(data, size, backend=backend)
# 只對(duì)存儲(chǔ)操作進(jìn)行說(shuō)明，數(shù)據(jù)庫(kù)操作不做說(shuō)明铺然，具體和調(diào)用存儲(chǔ)的邏輯一致
    -> # 以下文件均是在glance目錄下俗孝。該過(guò)程采用的是責(zé)任鏈調(diào)用模式。
  -> # 調(diào)用的都是`glance.*.ImageProxy`下的`set_data(...)`方法魄健。
  -> # 最后調(diào)用的是`location.ImageProxy`下的`set_data`方法赋铝。
  -> # 在模塊下分別處理權(quán)限，通知沽瘦，策略革骨，配額，存儲(chǔ)等處理析恋。

調(diào)用/glance/location.py文件中ImageProxy類下的set_data方法

# 主要調(diào)用下面的方法
(location, size, checksum, multihash, loc_meta) = self.store_api.add_with_multihash(CONF, ...)
# 方法指向
self.store_api = store_api or glance_store   # store_api=None良哲，即self.store_api=glance_store

調(diào)用/glance_store/multi_backend.py文件中的add_with_multihash方法

# 獲取存儲(chǔ)后端類型，配置的為rbd類型
if not backend:
        backend = conf.glance_store.default_backend
# 加載存儲(chǔ)驅(qū)動(dòng)并獲取
store = get_store_from_store_identifier(backend)    # store即為`glance_store._drivers.rbd.Store`實(shí)例化對(duì)象
# 然后執(zhí)行并返回
store_add_to_backend_with_multihash(..., store, ...)
    -> # 執(zhí)行`store.add(...)`進(jìn)行存儲(chǔ)鏡像

調(diào)用/glance_store/_drivers/rbd.py文件中Store類下的add方法

# 獲取rados連接
with self.get_connection(conffile=self.conf_file, rados_id=self.user) as conn:
# 存儲(chǔ)主要是下面的方法
with rbd.Image(ioctx, image_name) as image:
    bytes_written = 0
    offset = 0
    chunks = utils.chunkreadable(image_file, self.WRITE_CHUNKSIZE)
    for chunk in chunks:
            chunk_length = len(chunk)
            self.size = self._resize_on_write(image, image_size, bytes_written, chunk_length)
            bytes_written += chunk_length
            if not (self.thin_provisioning and not any(chunk)):
                image.write(chunk, offset)
        offset += chunk_length
        os_hash_value.update(chunk)
        checksum.update(chunk)
        if verifier:
                verifier.update(chunk)
        if image_size == 0:
            image.resize(bytes_written)
        if loc.snapshot:
            image.create_snap(loc.snapshot)
            image.protect_snap(loc.snapshot)
# 其中向后端存儲(chǔ)設(shè)備寫(xiě)入數(shù)據(jù)的是通過(guò)`image.write(chunk, offset)`方法寫(xiě)入, 其中`image`為`rbd.c`的對(duì)象助隧。