a

[r`e/
ã@s2dZd
dl
mZ
d
dlZd
dlmZ
d
dlZd
dlZd
dl	Z	d
dl
Z
d
dlZd
dlm
Z
d
dlZd
dlmZ
d
dlmZ
d
dlZd
dlmZ
d
d	lmZ
d
d
lmZ
d
dlmZ
d
dlm Z 
d
d
l!m"Z"
d
dl#m$Z%
d
dl&m'Z'
d
dl(m)Z*
d
dl+m,Z,
d
dl-m.Z.
d
dl/m0Z

d
dl+m1Z1
d
dl2m3Z4
d
dl+m5Z5
d
dl6m7Z8
d
dl6m9Z:
d
dl+m;Z<
d
dl+m=Z=
d
dl+m9Z9
d
dl>m?Z?
d
dl@mAZA
d
dl+mBZB
dZCejDZDddd œaEd!aFGd"d#„d#ejGƒZHGd$d%„d%ejIƒZJGd&d'„d'ejGƒZKGd(d)„d)ejGƒZLGd*d+„d+ejGƒZMGd,d-„d-ejGƒZNGd.d/„d/ejGƒZOGd0d1„d1e=jPƒZQGd2d3„d3ejGƒZRGd4d5„d5ejGƒZSGd6d7„d7ejGƒZTGd8d9„d9ejGƒZUGd:d;„d;ejGƒZVGd<d=„d=ejGƒZWGd>d?„d?ejGƒZXGd@dA„dAejGƒZYGdBdC„dCejGƒZZGdDdE„dEejGƒZ[GdFdG„dGejGƒZ\GdHdI„dIe]ƒZ^GdJdK„dKejGƒZ_GdLdM„dMejGƒZ`GdNdO„dOejGƒZaGdPdQ„dQejGƒZbGdRdS„dSejGƒZcGdTdU„dUejGƒZdGdVdW„dWe]ƒZeGdXdY„dYejGƒZfGdZd[„d[ejGƒZgGd\d]„d]ejGƒZhGd^d_„d_ejGƒZiGd`da„dae]ƒZjGdbdc„dcejGƒZkGddde„deejlƒZmGdfdg„dgejGƒZnGdhdi„diejGƒZodS)jzFixtures for Nova tests.é)
Úabsolute_importN)
Úcontextmanager)
Úsession)
Ú	lockutils)
Úcfg)
Úconffixture)
Údaemon)
Ú	uuidutils)
Úadapters)
Úinterceptor)
Útenant_networks)
Údeploy)
Úwsgi_app)
Úrpcapi©
Úcontext)
Ú	migration)
Úapi)
Ú	exception)
Úmodel)
Úobjects)
Úbase)
Úservice)
Úquota)
Úrpc)
Úclient)
Úuuidsentinel)
Úwsgi)ÚTrueÚtrueÚ
1ZyesÚ)ÚmainrFcs*eZ
dZd
Zddd„
Z‡f
dd„Z‡ZS)ÚServiceFixturez Run a service as a test fixture.NcKs2|
}
|p
|
}| d
|¡
| dd|
¡
||_
dS)NÚhostZbinaryznova-%s)Ú
setdefaultÚkwargs)ÚselfÚnamer$r&©r)ú8/usr/lib/python3.9/site-packages/dmapi/tests/fixtures.pyÚ__init__8s




zServiceFixture.__init__c

s@tt
|ƒ ¡
tjjfi|j¤
Ž
|_|j ¡
| |jj	¡

dS©
N)
Úsuperr#ÚsetUprZServiceÚcreater&ÚstartÚ
addCleanupÚkill©
r'©
Ú	__class__r)r*r.Bs




zServiceFixture.setUp)
N©Ú__name__Ú
__module__Ú__qualname__Ú__doc__r+r.Ú
__classcell__r)r)r4r*r#5s


r#c@s(eZ
dZd
Zdd„Zdd„Zdd„ZdS)	ÚNullHandlerzÜcustom default NullHandler to attempt to format the record.

    Used in conjunction with
    log_fixture.get_logging_handle_error_fixture to detect formatting errors in
    debug level logs without saving the logs.
    cCs| |
¡

dSr,)
Úformat©r'Úrecordr)r)r*ÚhandlePs
zNullHandler.handlec
CsdSr,r)r>r)r)r*ÚemitSs
zNullHandler.emitc

Cs
d|_dSr,)
Úlockr3r)r)r*Ú
createLockVs
zNullHandler.createLockN)r7r8r9r:r@rArCr)r)r)r*r<Is
r<cs eZ
dZd
Z‡f
dd„Z‡ZS)ÚStandardLoggingaÅSetup Logging redirection for tests.

    There are a number of things we want to handle with logging in tests:

    * Redirect the logging to somewhere that we can test or dump it later.

    * Ensure that as many DEBUG messages as possible are actually
       executed, to ensure they are actually syntactically valid (they
       often have not been).

    * Ensure that we create useful output for tests that doesn't
      overwhelm the testing system (which means we can't capture the
      100 MB of debug logging on every run).

    To do this we create a logger fixture at the root level, which
    defaults to INFO and create a Null Logger at DEBUG which lets
    us execute log messages at DEBUG but not keep the output.

    To support local debugging OS_DEBUG=True can be set in the
    environment, which will print out the full debug logging.

    There are also a set of overrides for particularly verbose
    modules to be even less than INFO.

    c
sÊtt
|ƒ ¡
t ¡}
|
 tj¡

tj 	d
¡
t
vr:tj}ntj}d}| t
j|dd¡
|_|
jd |¡

|tjkr¬tƒ}| t
j|dd¡

| tj¡

t d¡
 tj¡

dd	„}| t
 d
|¡¡

dS)NZOS_DEBUGz0%(asctime)s %(levelname)s [%(name)s] %(message)s)r=Úlevelr
F)
Z
nuke_handlerszmigrate.versioning.apic

WsdSr,r))
Úargsr)r)r*Úfake_logging_setupšs
z1StandardLogging.setUp.<locals>.fake_logging_setupzoslo_log.log.setup)r-rDr.Ústd_loggingZ	getLoggerZsetLevelÚDEBUGÚosÚenvironÚgetÚ_TRUE_VALUESÚINFOÚ
useFixtureÚfixturesZ
FakeLoggerÚloggerÚhandlersr<Z
LogHandlerZWARNINGÚMonkeyPatch)r'ÚrootrEZfsZhandlerrGr4r)r*r.us0




ÿ



ÿ
ÿ

ÿzStandardLogging.setUp©r7r8r9r:r.r;r)r)r4r*rDZs
rDcs8eZ
dZd
Z‡f
dd„Zedd„ƒ
Zedd„ƒ
Z‡ZS)ÚOutputStreamCapturezýCapture output streams during tests.

    This fixture captures errant printing to stderr / stdout during
    the tests and lets us see those streams at the end of the test
    runs instead. Useful to see what was happening during failed
    tests.
    c

s‚tt
|ƒ ¡
tj d
¡
tvrF| t 	d¡
¡
|_
| t d|j
j¡¡

tj d¡
tvr~| t 	d¡
¡
|_
| t d|j
j¡¡

dS)NZOS_STDOUT_CAPTUREÚstdoutz
sys.stdoutZOS_STDERR_CAPTUREÚstderrz
sys.stderr)r-rVr.rJrKrLrMrOrPZStringStreamÚoutrSÚstreamÚerrr3r4r)r*r.©s




ÿ


ÿzOutputStreamCapture.setUpc

Cs|jj
d
 ¡S)NrX)r[Ú_detailsÚas_textr3r)r)r*rX´szOutputStreamCapture.stderrc

Cs|jj
d
 ¡S)NrW)rYr\r]r3r)r)r*rW¸szOutputStreamCapture.stdout)	r7r8r9r:r.ÚpropertyrXrWr;r)r)r4r*rV¡s



rVcs.eZ
dZd
Zd‡f
dd„	Z‡f
dd„Z‡ZS)ÚTimeoutaZ
Setup per test timeouts.

    In order to avoid test deadlocks we support setting up a test
    timeout parameter read from the environment. In almost all
    cases where the timeout is reached this means a deadlock.

    A class level TIMEOUT_SCALING_FACTOR also exists, which allows
    extremely long tests to specify they need more time.
    é
csZtt
|ƒ ¡
zt|
ƒ
|_Wnty4


d
|_Yn0|dkrN|j|9_ntdƒ
‚
dS)Nr
r`zscaling value must be >= 1)r-r_r+ÚintÚtest_timeoutÚ
ValueError)r'ÚtimeoutZscalingr4r)r*r+Ès





zTimeout.__init__c

s2tt
|ƒ ¡
|jd
kr.| tj
|jdd¡

dS)Nr
T)
Zgentle)r-r_r.rbrOrPr3r4r)r*r.Ôs



z
Timeout.setUp)
r`r6r)r)r4r*r_½s

r_cs$eZ
dZ‡f
d
d„Zdd„Z‡ZS)ÚDatabasePoisonFixturec

s&tt
|ƒ ¡
| t d
|j¡¡

dS)NzCoslo_db.sqlalchemy.enginefacade._TransactionFactory._create_session)r-rer.rOrPrSÚ_poison_configurer3r4r)r*r.Ûs



ýzDatabasePoisonFixture.setUpc
Ostd
ƒ
‚
dS)NzÀThis test uses methods that set internal oslo_db state, but it does not claim to use the database. This will conflict with the setup of tests that do use the database and cause failures later.©
Ú	Exception)r'Ú
aÚ
kr)r)r*rfâsz'DatabasePoisonFixture._poison_configure)r7r8r9r.rfr;r)r)r4r*reÚs
recsneZ
dZd
Zddd„
Z‡f
dd„Zdd„Zd	d
„Zdd„Zd
d„Z	dd„Z
dd„Zdd„Ze
dd„ƒ
Z‡ZS)ÚSingleCellSimplea
Setup the simplest cells environment possible

    This should be used when you do not care about multiple cells,
    or having a "real" environment for tests that should not care.
    This will give you a single cell, and map any and all accesses
    to that cell (even things that would go to cell0).

    If you need to distinguish between cell0 and cellN, then you
    should use the CellDatabases fixture.

    If instances should appear to still be in scheduling state, pass
    instances_created=False to init.
    TcCs
|
|_dSr,)
Úinstances_created)r'rlr)r)r*r+
s
zSingleCellSimple.__init__c

s´tt
|ƒ ¡
| t d
|j¡¡

| t d|j¡¡

| t d|j¡¡

| t d|j	¡¡

| t d|j
¡¡

| t d|j¡¡

| t d|j¡¡

| t dd	d
„¡¡

dS)Nz-nova.objects.CellMappingList._get_all_from_dbz-nova.objects.CellMapping._get_by_uuid_from_dbz-nova.objects.HostMapping._get_by_host_from_dbz:nova.objects.InstanceMapping._get_by_instance_uuid_from_dbz?nova.objects.InstanceMappingList._get_by_instance_uuids_from_dbz(nova.objects.InstanceMapping._save_in_dbúnova.context.target_cellznova.context.set_target_cellc
SsdSr,r))Ú
cÚ
mr)r)r*Ú<lambda>(
óz(SingleCellSimple.setUp.<locals>.<lambda>)
r-rkr.rOrPrSÚ_fake_cell_listÚ_fake_cell_getÚ_fake_hostmapping_getÚ_fake_instancemapping_getÚ_fake_instancemapping_get_uuidsÚ_fake_instancemapping_get_saveÚ_fake_target_cellr3r4r)r*r.
sB



þ

þ

þ

þ

þ

þ

þ

þzSingleCellSimple.setUpc
Gsd
ddd| ¡ddœS)Nr`Zhost1r
)ÚidÚ
updated_atÚ
created_atr$Úcell_mapping©
rr©r'rFr)r)r*rt*
s





üz&SingleCellSimple._fake_hostmapping_getcCs,d
dd|
|jrd
pdd|jr$| 
¡p&ddœS)Nr`Zproject)ryrzr{Ú
instance_uuidZcell_idÚ
project_idr|)rlrs)r'rr)r)r*Ú _fake_instancemapping_get_common1
s




øz1SingleCellSimple._fake_instancemapping_get_commonc
Gs| |
d
¡
S)Néþÿÿÿ©
rr~r)r)r*rw=
s
z/SingleCellSimple._fake_instancemapping_get_savec
Gs| |
d
¡
S)Néÿÿÿÿrƒr~r)r)r*ru@
s
z*SingleCellSimple._fake_instancemapping_getc
s‡f
d
d„|
dDƒ
S)Nc
sg|]}
ˆ |
¡
‘qSr))
ru)Ú.0Úuuidr3r)r*Ú
<listcomp>D
s
ÿzDSingleCellSimple._fake_instancemapping_get_uuids.<locals>.<listcomp>r„r)r~r)r3r*rvC
s


ÿz0SingleCellSimple._fake_instancemapping_get_uuidsc
Gs| ¡d
S)Nr
r}r~r)r)r*rsG
s
zSingleCellSimple._fake_cell_getc
Gsd
ddtj
ddddœg
S)Nr`Zonlycellzfake://nowhere/z
sqlite:///)ryrzr{r†r(Z
transport_urlÚdatabase_connection)rZcell1r~r)r)r*rrJ
s






úz SingleCellSimple._fake_cell_listc
cs
|
V
dSr,r))r'rÚtarget_cellr)r)r*rxS
sz"SingleCellSimple._fake_target_cell)
T)r7r8r9r:r+r.rtrrwrurvrsrrrrxr;r)r)r4r*rkýs

	
rkcs,eZ
dZd
Z‡f
dd„Z‡f
dd„Z‡ZS)ÚCheatingSerializeraA messaging.RequestContextSerializer that helps with cells.

    Our normal serializer does not pass in the context like db_connection
    and mq_connection, for good reason. We don't really want/need to
    force a remote RPC server to use our values for this. However,
    during unit and functional tests, since we're all in the same
    process, we want cell-targeted RPC calls to preserve these values.
    Unless we had per-service config and database layer state for
    the fake services we start, this is a reasonable cheat.
    cs(tt
|ƒ |
¡
}|
j|d
<|
j|d<|S)z0Serialize context with the db_connection inside.Ú
db_connectionÚ
mq_connection)r-rŠÚserialize_contextr‹rŒ)r'rÚvaluesr4r)r*re
s




z$CheatingSerializer.serialize_contextcs0tt
|ƒ |
¡
}|
 d
d¡|_|
 dd¡|_|S)z7Deserialize context and honor db_connection if present.r‹NrŒ)r-rŠÚdeserialize_contextÚpopr‹rŒ)r'rŽÚctxtr4r)r*rl
s


z&CheatingSerializer.deserialize_context)r7r8r9r:rrr;r)r)r4r*rŠZ
s

rŠcsteZ
dZd
Zdd„Zdd„Zedd„ƒ
Zdd	d
„
Zdd„Z	dd
d„
Z
ddd„
Zddd„
Z‡f
dd„Z
dd„Z‡ZS)Ú
CellDatabasesaU
Create per-cell databases for testing.

    How to use::

      fix = CellDatabases()
      fix.add_cell_database('connection1')
      fix.add_cell_database('connection2', default=True)
      self.useFixture(fix)

    Passing default=True tells the fixture which database should
    be given to code that doesn't target a specific cell.
    c

Cs i|_d|_
d|_t ¡|_dSr,)Ú
_ctxt_mgrsÚ_last_ctxt_mgrÚ_default_ctxt_mgrrZReaderWriterLockÚ
_cell_lockr3r)r)r*r+
s


zCellDatabases.__init__cCs\td
sX|j
|
}| ¡ ¡}| ¡}tjd
d

d dd„|j 	¡Dƒ
¡
td
<| 
¡
dS)Nr"©
Údatabaser!c
ss|]
}
|
V
qdSr,r)©r…Úliner)r)r*Ú	<genexpr>–
rqz.CellDatabases._cache_schema.<locals>.<genexpr>)Ú	DB_SCHEMAr“Úget_legacy_facadeÚ
get_engineÚconnectrÚdb_syncÚjoinÚ
connectionÚiterdumpÚdispose)r'Úconnection_strÚctxt_mgrÚengineÚconnr)r)r*Ú
_cache_schema
s







ÿzCellDatabases._cache_schemac	csÔ|j 
¡¶
|durV| |
|¡}|V
Wdƒ
n1s<0


Y
Wdƒ
dS|j|j}||_z>| |
|¡}|V
Wdƒ
n1s’0


Y
W|j|_n
|j|_0Wdƒ
n1sÆ0


Y
dSr,)r–Z
write_lockÚ_real_target_cellr“rˆr”r•)r'rr|rnr¦Zccontextr)r)r*Ú_wrap_target_cellš
s

$




&zCellDatabases._wrap_target_cellNcCs|j|
}|Sr,)
r“)r'r¢r¦r)r)r*Ú_wrap_create_context_manager²
s


z*CellDatabases._wrap_create_context_managercCsZz|
jr|
jWSWnt
y$


Yn0|j ¡
|jWdƒ
S1sL0


Y
dSr,)r‹ÚAttributeErrorr–Z	read_lockr”©r'rr)r)r*Ú_wrap_get_context_manager¶
s


z'CellDatabases._wrap_get_context_managercCst|ƒ
}t
jtj|
|d
|dS)z3Mirror rpc.get_server() but with our special sauce.Zeventlet)ÚexecutorÚ
serializer)rŠÚ	messagingZget_rpc_serverrÚ	TRANSPORT)r'ÚtargetZ	endpointsr±r)r)r*Ú_wrap_get_serverÈ
s




üzCellDatabases._wrap_get_servercCst|ƒ
}t
jtj|
||d
S)z3Mirror rpc.get_client() but with our special sauce.)Úversion_capr±)rŠr²Z	RPCClientrr³)r'r´r¶r±r)r)r*Ú_wrap_get_clientÑ
s



ýzCellDatabases._wrap_get_clientFcsžt 
¡‰ˆ|j|
<ˆ|_|jd
us&|r,ˆ|_‡f
dd„}t d|¡F
| |
¡

ˆ ¡ 	¡}| 
¡
| ¡}|j 
td¡

Wd
ƒ
n1s0


Y
d
S)zõAdd a cell database to the fixture.

        :param connection_str: An identifier used to represent the connection
        string for this database. It should match the database_connection field
        in the corresponding CellMapping.
        Nc


sˆSr,r)r©
r¦r)r*Úget_context_managerô
s
z<CellDatabases.add_cell_database.<locals>.get_context_managerú*nova.db.sqlalchemy.api.get_context_managerr")rÚcreate_context_managerr“r”r•rPrSr©rržr¤rŸr¢Ú
executescriptrœ)r'r¥Údefaultr¹r§r¨r)r¸r*Úadd_cell_databaseÙ
s




þ




zCellDatabases.add_cell_databasec

sŠtt
|ƒ ¡
| |j¡

tj|_| t	 
d
|j¡¡

| t	 
d|j¡¡

| t	 
d|j
¡¡

| t	 
d|j¡¡

| t	 
d|j¡¡

dS)Nz-nova.db.sqlalchemy.api.create_context_managerrºrmznova.rpc.get_serverznova.rpc.get_client)r-r’r.r1Úcleanuprr‰rªrOrPrSr¬r¯r«rµr·r3r4r)r*r.s.




þ

þ

þ

þ

þzCellDatabases.setUpc
Cs,t|j
 ¡ƒ
D]}
|
 ¡ ¡}| ¡
qdSr,)Úlistr“rŽrržr¤)r'r¦r§r)r)r*r¿s


zCellDatabases.cleanup)
N)
N)NN)
F)r7r8r9r:r+r©rr«r¬r¯rµr·r¾r.r¿r;r)r)r4r*r’t
s





	

*r’csBeZ
dZd
‡f
dd„	Zdd„Zdd„Zd	d
„Z‡f
dd„Z‡ZS)ÚDatabaser"Ncsrtt
|ƒ ¡
ts t t¡

d
a|
|_|
dkr^|du
rTtj|d
}| 	¡}|j
|_
qntj
|_
n|
dkrntj|_
dS)z›Create a database fixture.

        :param database: The type of database, 'main' or 'api'
        :param connection: The connection string to use
        Tr"N)
r¢r)r-rÁr+ÚSESSION_CONFIGUREDrZ	configureÚCONFr˜r»rržÚget_api_engine)r'r˜r¢r¦Zfacader4r)r*r+#s







ÿ




zDatabase.__init__c
CsTt|j
sP| ¡}
|
 ¡}tj|j
d


d dd„|j ¡Dƒ
¡
t|j
<|
 	¡
dS)Nr—r!c
ss|]
}
|
V
qdSr,r)r™r)r)r*r›Brqz)Database._cache_schema.<locals>.<genexpr>)
rœr˜ržrŸrr r¡r¢r£r¤©r'r§r¨r)r)r*r©<s






ÿzDatabase._cache_schemac
Cs| ¡}
|
 
¡
dSr,©ržr¤©r'r§r)r)r*r¿Fs

zDatabase.cleanupc
Cs6| ¡
| 
¡}
|
 ¡
|
 ¡}|j t|j¡

dSr,)r©ržr¤rŸr¢r¼rœr˜rÅr)r)r*ÚresetJs





zDatabase.resetc

s&tt
|ƒ ¡
| ¡
| |j¡

dSr,)r-rÁr.rÈr1r¿r3r4r)r*r.Qs


zDatabase.setUp)r"N)	r7r8r9r+r©r¿rÈr.r;r)r)r4r*rÁ"s


rÁcs:eZ
dZd
‡f
dd„	Zdd„Zdd„Z‡f
dd	„Z‡ZS)ÚDatabaseAtVersionr"cs@tt
|ƒ ¡
||_|
|_|d
kr,tj|_n|dkr<tj|_dS)z¨Create a database fixture.

        :param version: Max version to sync to (or None for current)
        :param database: The type of database, 'main' or 'api'
        r"rN)r-rÉr+r˜ÚversionrržrÄ)r'rÊr˜r4r)r*r+Xs






zDatabaseAtVersion.__init__c
Cs| ¡}
|
 
¡
dSr,rÆrÇr)r)r*r¿fs

zDatabaseAtVersion.cleanupc
Cs.| ¡}
|
 
¡
|
 ¡
tj|j|jd

dS)N)rÊr˜)ržr¤rŸrr rÊr˜rÇr)r)r*rÈjs



zDatabaseAtVersion.resetc

s&tt
|ƒ ¡
| ¡
| |j¡

dSr,)r-rÉr.rÈr1r¿r3r4r)r*r.ps


zDatabaseAtVersion.setUp)
r")r7r8r9r+r¿rÈr.r;r)r)r4r*rÉWs
rÉcseZ
dZ‡f
d
d„Z‡ZS)ÚDefaultFlavorsFixturec
sött
|ƒ ¡
t ¡}
d
dddddœ}dddd	œ}tjf|
d
dddd
dœ|¤
Ž
tjf|
ddddddœ|¤
Ž
tjf|
ddddddœ|¤
Ž
tjf|
ddddddœ|¤
Ž
tjf|
dddd d!dœ|¤
Ž
tjf|
d
ddd"d#|d$œ|¤
Ž
g}|D]}| ¡
qädS)%Ngð?FTr
)Zrxtx_factorZdisabledZ	is_publicZephemeral_gbZswapZSandyBridgeZ2048Z	dedicated)zhw:cpu_modelzhw:mem_page_sizez
hw:cpu_policyir`r zm1.tiny)rÚ	memory_mbÚvcpusÚroot_gbÚflavoridr(iéÚ
2zm1.smalliéé(Ú
3z	m1.mediumi ééPÚ
4zm1.largei@éé Ú
5z	m1.xlargeÚ
6z
m1.tiny.specs)rrÌrÍrÎrÏr(Úextra_specs)r-rËr.rZget_admin_contextrZFlavorr/)r'r‘ÚdefaultsrÜZdefault_flavorsZflavorr4r)r*r.wsV



ÿ

ý
ÿþ
ÿþ
ÿþ
ÿþ
ÿþ

þþð
zDefaultFlavorsFixture.setUp©r7r8r9r.r;r)r)r4r*rËvs
rËcs0eZ
dZ‡f
d
d„Zdd„Z‡f
dd„Z‡ZS)Ú
RPCFixturec
s*tt
|ƒ ¡
g|_|j |
¡

i|_dSr,)r-rßr+ÚexmodsÚextendÚ_buses)r'ràr4r)r*r+šs



zRPCFixture.__init__cCs6d}
|
|jv
r,t
 ¡}tjt|
|d
|j|
<|j|
S)N)ÚurlZallowed_remote_exmods)rârZget_allowed_exmodsr²Zget_rpc_transportrÃ)r'rãràr)r)r*Ú_fake_create_transport s





ýz!RPCFixture._fake_create_transportc
s¤tt
|ƒ ¡
| tj¡

tj|jŽ
| tj¡

t	 
t¡
|_d
|j_
| |j¡

| t d|j¡¡

t d¡
 }
d|
_t t¡

Wdƒ
n1s–0


Y
dS)NÚfakeznova.rpc.create_transportznova.rpc.get_transport_url)r-rßr.r1rr¿Zadd_extra_exmodsràZclear_extra_exmodsÚmessaging_conffixtureZConfFixturerÃZmessaging_confZtransport_driverrOrPrSräÚmockZpatchZreturn_valueÚinit)r'Zmock_gtur4r)r*r.³s








ÿ

zRPCFixture.setUp)r7r8r9r+rär.r;r)r)r4r*rߙs
rßcs eZ
dZd
Z‡f
dd„Z‡ZS)ÚWarningsFixturez&Filters out warnings during test runs.c

sbtt
|ƒ ¡
t d
t¡
tjddd
tjddd
tjddd
tjddd
| tj¡

dS)	NÚonceÚignorez>With-statements now directly support multiple context managers)
ÚmessageZ
pkg_resources)
Úmodulez“Policy enforcement is depending on the value of is_admin. This key is deprecated. Please update your policy file to use the standard policy values.zmox3.mox)	r-rér.ÚwarningsÚsimplefilterÚDeprecationWarningÚfilterwarningsr1Ú
resetwarningsr3r4r)r*r.És


ÿ
ÿ
ÿ
ÿzWarningsFixture.setUprUr)r)r4r*réÆs
récs,eZ
dZd
Z‡f
dd„Z‡f
dd„Z‡ZS)ÚConfPatcherzˆFixture to patch and restore global CONF.

    This also resets overrides for everything that is patched during
    it's teardown.

    c
s&tt
|ƒ ¡
|
 d
d¡|_|
|_dS)zëConstructor

        :params group: if specified all config options apply to that group.

        :params **kwargs: the rest of the kwargs are processed as a
        set of key/value pairs to be set as configuration override.

        ÚgroupN)r-rór+rrôrF)r'r&r4r)r*r+ís	

zConfPatcher.__init__c
sLtt
|ƒ ¡
t|j ¡ƒ
D]*\}
}| tj|
|j	¡
t 
|
||j	¡
qdSr,)r-rór.rÀrFÚitemsr1rÃÚclear_overriderôÚset_override)r'rjÚ
vr4r)r*r.ús



zConfPatcher.setUpr6r)r)r4r*róås

rócs.eZ
dZd
Zd‡f
dd„	Z‡f
dd„Z‡ZS)	ÚOSAPIFixturea_Create an OS API server as a fixture.

    This spawns an OS API server as a fixture in a new greenthread in
    the current test. The fixture has a .api parameter with is a
    simple rest client that can communicate with it.

    This fixture is extremely useful for testing REST responses
    through the WSGI stack easily in functional tests.

    Usage:

        api = self.useFixture(fixtures.OSAPIFixture()).api
        resp = api.api_request('/someurl')
        self.assertEqual(200, resp.status_code)
        resp = api.api_request('/otherurl', method='POST', body='{foo}')

    The resp is a requests library response. Common attributes that
    you'll want to use are:

    - resp.status_code - integer HTTP status code returned by the request
    - resp.content - the body of the response
    - resp.headers - dictionary of HTTP headers returned

    Úv2Ú 6f70656e737461636b20342065766572cstt
|ƒ ¡
|
|_||_d
S)zêConstructor

        :param api_version: the API version that we're interested in
        using. Currently this expects 'v2' or 'v2.1' as possible
        options.
        :param project_id: the project id to use on the API.

        N)r-rùr+Úapi_versionr€)r'rür€r4r)r*r+s


zOSAPIFixture.__init__c
sòtt
|ƒ ¡
tj}
d
}d}d|
|f}|
|ddœ}| tfi|¤
Ž
¡

| t dt	j
j¡¡

t 
¡ |¡
‰‡f
dd„}t tj|¡
tj||d	}| ¡
| |j¡

d
|
||jdœ|_t dd|j|j¡|_t d
d
|j|j¡|_||_dS)NrÖZ
osapi_computeú
http://%s:%s/T)Zosapi_compute_listenZosapi_compute_listen_portÚdebugú:keystoneauth1.session.TCPKeepAliveAdapter.init_poolmanagerc
sˆSr,r)r)©
Úloaderr)r*rp?rqz$OSAPIFixture.setUp.<locals>.<lambda>©
rãz(http://%(host)s:%(port)s/%(api_version)s)r$ÚportrüråÚadmin) r-rùr.rZ
osapi_hostrOrórPrSr
ÚHTTPAdapterÚinit_poolmanagerrÚLoaderZload_apprZ_setup_servicerÃr$rÚRequestsInterceptorÚinstall_interceptr1Úuninstall_interceptrüZauth_urlrZTestOpenStackClientr€rZ	admin_apiÚapp)r'Úhostnamer
Zservice_nameÚendpointÚconf_overridesr
Ú	interceptr4r
r*r.)s<





ý

þ




ÿ

ÿ
ÿzOSAPIFixture.setUp)rúrûr6r)r)r4r*rù
s


ÿrùcs eZ
dZd
Z‡f
dd„Z‡ZS)ÚOSMetadataServera9
Create an OS Metadata API server as a fixture.

    This spawns an OS Metadata API server as a fixture in a new
    greenthread in the current test.

    TODO(sdague): ideally for testing we'd have something like the
    test client which acts like requests, but connects any of the
    interactions needed.

    c
s‚tt
|ƒ ¡
d
dddœ}
| tfi|
¤
Ž
¡

| t ddd„¡¡

t d¡
|_	|j	 
¡
| |j	j¡

d	|
d
|j	j
f|_dS)Nz	127.0.0.1r
T)Úmetadata_listenZmetadata_listen_portrþz-nova.network.linux_net.IptablesManager._applyc


SsdSr,r))
Ú
_r)r)r*rpmrqz(OSMetadataServer.setUp.<locals>.<lambda>Úmetadatarýr
)r-r
r.rOrórPrSrZWSGIServicer
r0r1Ústopr
Zmd_url)r'r
r4r)r*r.^s"


ý

þ





þzOSMetadataServer.setUprUr)r)r4r*r
Ss

r
cs eZ
dZd
Z‡f
dd„Z‡ZS)ÚPoisonFunctionsa
Poison functions so they explode if we touch them.

    When running under a non full stack test harness there are parts
    of the code that you don't want to go anywhere near. These include
    things like code that spins up extra threads, which just
    introduces races.

    c
s4tt
|ƒ ¡
d
dl}
dd„}| t d|¡¡

dS)Nr
c_s d
dl}t
 d¡

| d¡

dS)Nr
z&Forgot to disable libvirt event threadr`)ÚsysrîÚwarnÚexit)rFr&r
r)r)r*Úevloops



z%PoisonFunctions.setUp.<locals>.evloopz(nova.virt.libvirt.host.Host._init_events)r-r
r.Znova.virt.libvirt.hostrOrPrS)r'Únovar
r4r)r*r.s
	

þzPoisonFunctions.setUprUr)r)r4r*r
ws
	r
cs4eZ
dZd
Z‡f
dd„Zdd„Z‡f
dd„Z‡ZS)ÚIndirectionAPIFixturez8Patch and restore the global NovaObject indirection api.cstt
|ƒ ¡
|
|_d
S)z`Constructor

        :param indirection_api: the indirection API to be used for tests.

        N)r-r
r+Úindirection_api)r'r
r4r)r*r+šs
zIndirectionAPIFixture.__init__c

Cs|jt
j_dSr,)Úorig_indirection_apiÚobj_baseÚ
NovaObjectr
r3r)r)r*r¿£s
zIndirectionAPIFixture.cleanupc

s2tt
|ƒ ¡
tjj|_|jtj_| |j¡

dSr,)	r-r
r.r
r
r
r
r1r¿r3r4r)r*r.¦s





zIndirectionAPIFixture.setUp)r7r8r9r:r+r¿r.r;r)r)r4r*r
—s
	r
c@s<eZ
dZd
d„Zdd„Zdd„Zdd„Zd	d
„Zdd„Zd
S)Ú_FakeGreenThreadcOs|
|i|¤
Ž
|_dSr,©
Z_result©r'ÚfuncrFr&r)r)r*r+®s
z_FakeGreenThread.__init__c

OsdSr,r)©r'rFr&r)r)r*Úcancel±sz_FakeGreenThread.cancelc

OsdSr,r)r$
r)r)r*r2¶sz_FakeGreenThread.killcOs|
|g
|¢
Ri|¤
Ž

dSr,r)r"
r)r)r*Úlink»s
z_FakeGreenThread.linkc
OsdSr,r)r"
r)r)r*Úunlink¾sz_FakeGreenThread.unlinkc


Cs|jSr,r!
r3r)r)r*ÚwaitÃs
z_FakeGreenThread.waitN)	r7r8r9r+r%
r2r&
r'
r(
r)r)r)r*r 
­s
r 
cs eZ
dZd
Z‡f
dd„Z‡ZS)ÚSpawnIsSynchronousFixturez>Patch and restore the spawn_n utility method to be synchronousc

s6tt
|ƒ ¡
| t d
t¡¡

| t dt¡¡

dS)Nznova.utils.spawn_nznova.utils.spawn)r-r)
r.rOrPrSr 
r3r4r)r*r.Ês


ÿ
ÿzSpawnIsSynchronousFixture.setUprUr)r)r4r*r)
Çs
r)
cs:eZ
dZd
Zd	‡f
dd„	Zedd„ƒ
Z‡f
dd„Z‡ZS)
ÚBannedDBSchemaOperationsz"Ban some operations for migrationsNcstt
|ƒ ¡
|
pg|_dSr,)r-r*
r+Ú_banned_resources)r'Zbanned_resourcesr4r)r*r+Ôs

z!BannedDBSchemaOperations.__init__cCst 
d
||
f¡
‚
dS)Nz8Operation %s.%s() is not allowed in a database migration)rZDBNotAllowed)ÚresourceÚopr)r)r*Ú_explodeØs


ÿÿz!BannedDBSchemaOperations._explodec

	s^tt
ˆƒ ¡
ˆjD]D‰
ˆ t d
ˆ
‡‡
fdd„¡¡

ˆ t dˆ
‡‡
fdd„¡¡

qdS)Nzsqlalchemy.%s.dropcsˆ ˆ
d
¡S)NZdrop©
r.
©rirj©r'Úthingr)r*rpãrqz0BannedDBSchemaOperations.setUp.<locals>.<lambda>zsqlalchemy.%s.altercsˆ ˆ
d
¡S)NZalterr/
r0
r1
r)r*rpærq)r-r*
r.r+
rOrPrSr3r4r1
r*r.Þs





þ

þzBannedDBSchemaOperations.setUp)
N)	r7r8r9r:r+Ústaticmethodr.
r.r;r)r)r4r*r*
Òs




r*
cs4eZ
dZd
Z‡f
dd„Z‡f
dd„Zdd„Z‡ZS)Ú"ForbidNewLegacyNotificationFixturez<Make sure the test fails if new legacy notification is addedc

stt
|ƒ ¡
tj|_dSr,)r-r4
r+rZLegacyValidatingNotifierÚnotifierr3r4r)r*r+ës

z+ForbidNewLegacyNotificationFixture.__init__c

s4tt
|ƒ ¡
d
|j_|jj d¡

| |j¡

dS)NTÚ_decorated_function)	r-r4
r.r5
ÚfatalÚ'allowed_legacy_notification_event_typesÚappendr1r¿r3r4r)r*r.ïs


ÿz(ForbidNewLegacyNotificationFixture.setUpc

Csd
|j_
|jj d¡

dS)NFr6
)r5
r7
r8
Úremover3r)r)r*r¿ús


ÿz*ForbidNewLegacyNotificationFixture.cleanup)r7r8r9r:r+r.r¿r;r)r)r4r*r4
és

r4
cs$eZ
dZ‡f
d
d„Zdd„Z‡ZS)ÚAllServicesCurrentc

s,tt
|ƒ ¡
| t d
|j¡¡

dt_dS)Nz.nova.objects.Service.get_minimum_version_multi)	r-r;
r.rOrPrSÚ
_fake_minimumÚcompute_rpcapiZLAST_VERSIONr3r4r)r*r.
s



þzAllServicesCurrent.setUpc

Ostj
Sr,)Úservice_objZSERVICE_VERSIONr$
r)r)r*r<
s
z AllServicesCurrent._fake_minimum)r7r8r9r.r<
r;r)r)r4r*r;
s
r;
cs$eZ
dZ‡f
d
d„Zdd„Z‡ZS)ÚRegisterNetworkQuotac

s&tt
|ƒ ¡
t ¡
| |j¡

dSr,)r-r?
r.rZ_register_network_quotar1r¿r3r4r)r*r.
s

zRegisterNetworkQuota.setUpc

Cstj
j d
d¡
dS©NZnetworks)Ú
nova_quotaZQUOTASZ
_resourcesrr3r)r)r*r¿s
zRegisterNetworkQuota.cleanup)r7r8r9r.r¿r;r)r)r4r*r?
s
r?
csŠ
eZ
dZd
ZdZdgddeddœZdded	egd
ddœg
gd
d
dddœZed	g
ed<ded	dddded	dœg
edœZded	dddded	dœg
edœZidddid
dgddœg
d
iggd id
d!d"d#œd$œg
ded%d&œd'd(d)œd*d+d,iddd-œd.dd/dd,d0œg
Z	‡f
d1d2„Z
‡f
d3d4„Zd5d6„Zd7d8„Z
d9d:„Zd;d<„Zd=d>„ZdKd?d@„
ZdLdAdB„
ZdMdCdD„
ZdNdEdF„
ZdGdH„ZdOdIdJ„
Z‡ZS)PÚNeutronFixturez.A fixture to boot instances with neutron portsrûZACTIVEzprivate-networkTz$3cb9bc59-5699-4588-a4b1-b87f96708bc6)ÚstatusÚsubnetsr(Úadmin_state_upÚ	tenant_idryzprivate-subnetryz192.168.1.1z
192.168.1.254)r0ÚendrÕz192.168.1.1/24z$f8a6e8f8-c2ec-497c-9f23-da9616de54ef)r(Zenable_dhcpÚ
network_idrF
Zdns_nameserversZallocation_poolsZhost_routesZ
ip_versionZ
gateway_ipÚcidrryrD
z$ce531f90-199f-48c0-816c-13e38010b442zfa:16:3e:4c:2c:30z192.168.1.3)Z
ip_addressZ	subnet_id)ryrH
rE
rC
Zmac_addressZ	fixed_ipsrF
z$88dae9fa-0dc6-49e3-8c29-3abc41e99ac9z00:0c:29:0d:11:74z192.168.1.30z$b71f1699-42be-4515-930a-f3ef01f94aa7Fzbr-intÚfixedz10.0.0.4)ÚmetarÊÚtypeZfloating_ipsÚaddressz10.0.0.0/26Úgatewayz10.0.0.1)rK
rÊrL
rM
)ZipsrÊrK
ZdnsZroutesrI
rN
iÜ)ZinjectedrF
Zmtuz$e1882e38-38c2-4239-ade7-35d644cb963aZpublic)ZbridgerD
rK
ryZlabelztapb71f1699-42ZnormalN)Zport_filterZovs_hybrid_plugzfa:16:3e:47:94:4aZovs)ZprofileZovs_interfaceidZpreserve_on_deleteZnetworkZdevnameZ	vnic_typeZ
qbh_paramsrK
ZdetailsrM
ZactiverL
ryZ
qbg_paramscsHtt
|ƒ ¡
|
|_t t
j¡
g
|_g|_t
j	g
|_
t
jg
|_g|_
dSr,)r-rB
r+ÚtestÚcopyÚdeepcopyÚport_1Ú_portsÚ_extensionsÚ	network_1Ú	_networksÚsubnet_1Ú_subnetsÚ_floatingips©r'rO
r4r)r*r+Šs








zNeutronFixture.__init__c

s¸tt
ˆƒ ¡
ˆj d
dd„¡
ˆj ddd„¡
ˆj ddd„¡
ˆj dd	d„¡
ˆj d
dd„¡
ˆj dd
d„¡
ˆj ddd„¡
ˆj ddd„¡
ˆj d‡f
dd„¡
dS)Nz0nova.network.neutronv2.api.API.validate_networksc
_sd
S)Nr`r)©rFr&r)r)r*rp™rqz&NeutronFixture.setUp.<locals>.<lambda>zBnova.network.neutronv2.api.API.create_pci_requests_for_sriov_portsc
_sdSr,r)r[
r)r)r*rprqz5nova.network.neutronv2.api.API.setup_networks_on_hostc
_sdSr,r)r[
r)r)r*rp rqz5nova.network.neutronv2.api.API.migrate_instance_startc
_sdSr,r)r[
r)r)r*rp£rqz7nova.network.neutronv2.api.API.add_fixed_ip_to_instancec_stj
 tj¡
Sr,©Ú
network_modelZNetworkInfoZhydraterB
Únw_infor[
r)r)r*rp¦s
ÿz<nova.network.neutronv2.api.API.remove_fixed_ip_from_instancec_stj
 tj¡
Sr,r\
r[
r)r)r*rpªs
ÿz6nova.network.neutronv2.api.API.migrate_instance_finishc
_sdSr,r)r[
r)r)r*rp®rqzbnova.network.security_group.neutron_driver.SecurityGroupAPI.get_instances_security_groups_bindingsc
_siSr,r)r[
r)r)r*rp²rqz%nova.network.neutronv2.api.get_clientc
sˆSr,r)r[
r3r)r*rpµrq)r-rB
r.rO
Ústub_outr3r4r3r*r.“sH

ý
ý

þ

þ

þ

þ

þ
ý

ÿzNeutronFixture.setUpcs.‡f
d
d„|Dƒ
}t|ƒ
dkr&|dSdSdS)Nc
sg|]}
|
dˆkr|
‘qS©
ryr)©r…Ú
pr`
r)r*r‡¸rqz6NeutronFixture._get_first_id_match.<locals>.<listcomp>r
)
Úlen)r'ryrÀZ
filtered_listr)r`
r*Ú_get_first_id_match·s


z"NeutronFixture._get_first_id_matchc
s6t 
|j¡
}ˆD]‰
‡‡
fd
d„|Dƒ
}|}qd|i
S)Nc
s"g|]}
|
 ˆ
¡
ˆˆ
kr|
‘qSr))
rLra
©Ú_paramsÚoptr)r*r‡Árqz0NeutronFixture._filter_ports.<locals>.<listcomp>Úports)rP
rQ
rS
)r'rf
rh
Zfiltered_portsr)re
r*Ú
_filter_ports¾s





zNeutronFixture._filter_portsc
Ost 
d
|ji
¡
S)NÚ
extensions)rP
rQ
rT
r$
r)r)r*Úlist_extensionsÅs
zNeutronFixture.list_extensionscKs*| |
|j
¡}|dur"tj|
d

‚
d|i
S)N)
Úport_idr
)rd
rS
rZPortNotFound)r'rl
rf
r
r)r)r*Ú	show_portÈs



zNeutronFixture.show_portcKs(|jD]}|d
|
kr|j 
|¡

qdS)Nry)rS
r:
)r'r
rf
Zcurrent_portr)r)r*Údelete_portÎs



zNeutronFixture.delete_portcKst 
d
|ji
¡
Sr@
)rP
rQ
rV
©r'Zretrieve_allrf
r)r)r*Ú
list_networksÓs
zNeutronFixture.list_networkscKs|jfi|¤
Ž
Sr,)
ri
ro
r)r)r*Ú
list_portsÖs
zNeutronFixture.list_portscKst 
d
|ji
¡
S)NrD
)rP
rQ
rX
ro
r)r)r*Úlist_subnetsÙs
zNeutronFixture.list_subnetscKst 
d
|ji
¡
S)NZfloatingips)rP
rQ
rY
ro
r)r)r*Úlist_floatingipsÜs
zNeutronFixture.list_floatingipsc
Os$|j 
t tj¡
¡

t d
tji
¡
S©Nr
)rS
r9
rP
rQ
rB
Úport_2r$
r)r)r*Úcreate_portßs

zNeutronFixture.create_portcCs@| |
|j
¡}|du
r8t|d
 ¡ƒ
D]\}}|||<q&d
|i
Srt
)rd
rS
rÀrõ)r'rl
ÚbodyZnew_portrjrør)r)r*Úupdate_portãs




zNeutronFixture.update_port)
T)
T)
T)
T)
N)r7r8r9r:rF
rU
rW
rR
ru
r^
r+r.rd
ri
rk
rm
rn
rp
rq
rr
rs
rv
rx
r;r)r)r4r*rB
sÊ





ú	




þÿ



ð




üÿò




þÿô





û






üó

ý
ä



þ



Ò1	$



rB
c@seZ
dZd
d„ZdS)Ú_NoopConductorcCsd
d„}|S)Nc
_sdSr,r)r[
r)r)r*Ú	_noop_rpcïs
z-_NoopConductor.__getattr__.<locals>._noop_rpcr))r'Úkeyrz
r)r)r*Ú__getattr__îs
z_NoopConductor.__getattr__N)r7r8r9r|
r)r)r)r*ry
ís
ry
cs eZ
dZd
Z‡f
dd„Z‡ZS)ÚNoopConductorFixturez(Stub out the conductor API to do nothingc

s6tt
|ƒ ¡
| t d
t¡¡

| t dt¡¡

dS)Nznova.conductor.ComputeTaskAPIznova.conductor.API)r-r}
r.rOrPrSry
r3r4r)r*r.÷s


ÿ
ÿzNoopConductorFixture.setUprUr)r)r4r*r}
ôs
r}
cseZ
dZ‡f
d
d„Z‡ZS)ÚEventReporterStubc

s(tt
|ƒ ¡
| t d
dd„¡¡

dS)Nz nova.compute.utils.EventReporterc_st 
¡Sr,)rçZ	MagicMockr[
r)r)r*rprqz)EventReporterStub.setUp.<locals>.<lambda>)r-r~
r.rOrPrSr3r4r)r*r.
s




þzEventReporterStub.setUprÞr)r)r4r*r~
ÿsr~
csDeZ
dZd
ZdZdZdZdZdZdZ	‡f
dd	„Z
‡f
d
d„Z‡ZS)Ú
CinderFixturezA fixture to volume operationsrûú$a07f71dc-8151-4e7d-a0cc-cd24a3f11113ú$227cc671-f30b-4488-96fd-7d0bf13648d8ú$828419fa-3efb-4533-b458-4267ca5fe9b1ú$9c6d9c2d-7a8f-4c80-938d-3bf062b8d489ú$6ca404f3-d844-4169-bb96-bc792f37de98cs>tt
|ƒ ¡
|
|_d
|_d|_d|_tƒ|_t	 
t¡
|_dS©NF)r-r
r+rO
Ú
swap_errorÚswap_volume_instance_uuidÚswap_volume_instance_error_uuidrÀÚreserved_volumesÚcollectionsÚdefaultdictÚattachmentsrZ
r4r)r*r+s





zCinderFixture.__init__c
s
tt
ˆƒ ¡
d ‡f
d
d„	}
dd„}dd„}‡f
dd„}‡f
d	d
„}d!‡f
dd
„	}ˆj d|¡
d"‡f
dd„	}ˆj d|¡
ˆj ddd„¡
ˆj d|
¡
ˆj d|¡
ˆj d|¡
ˆj d|¡
ˆj ddd„¡
ˆj ddd„¡
ˆj d|¡
ˆj ddd„¡
dS)#Ncs
|tj
tjfvrxd
dd|dddœ}ˆjr2|tj
ksBˆjrx|tjkrx|tj
krRˆjnˆj}| d|d|d	œi
d
dœ¡

|Stˆj ¡ƒ
D]2\}}||vr†d|d
|dd||ddœi
d
œ}
qÞq†|ˆj	v}|rÌdnd
dd|dddœ}|ˆj
krüd|d<ddi
|d<|S)NÚ	availableÚTEST1ÚdetachedFr`©rC
Údisplay_nameÚ
attach_statusryÚmultiattachÚsizeúin-useú/dev/vdb©Ú
mountpointÚ
attachment_idÚattached©rC
rŒ
r’
©r™
r˜
©rC
r‘
r’
ryr“
r”
rŒ
Z	attachingÚTEST2TÚbootableÚimage_idú$155d900f-4e14-4e4c-a73d-069cbf4541e6Úvolume_image_metadata)r
ÚSWAP_OLD_VOLÚSWAP_ERR_OLD_VOLr‡
rˆ
ÚupdaterÀrŒ
rõr‰
ÚIMAGE_BACKED_VOL)Úself_apirÚ	volume_idÚmicroversionÚvolumerÚvolumesZreserved_volumer3r)r*Úfake_get%sv
ÿ




ú
ÿþýÿþ


þÿø








þÿù






ú

þz%CinderFixture.setUp.<locals>.fake_getcSs|tj
krd
SiS)Nr))r
ÚSWAP_ERR_NEW_VOL)r'rr¨
Ú	connectorr)r)r*Úfake_initialize_connectionps


z7CinderFixture.setUp.<locals>.fake_initialize_connectioncSsd
|i
S©NZsave_volume_idr)©r'rZ
old_volume_idZ
new_volume_idÚerrorr)r)r*Úfake_migrate_volume_completionvsz;CinderFixture.setUp.<locals>.fake_migrate_volume_completioncsˆj 
|¡

dSr,)r‰
r9
©r§
rr¨
r3r)r*Úfake_reserve_volumezs
z0CinderFixture.setUp.<locals>.fake_reserve_volumecs |ˆjvrˆj 
|¡

d
ˆ_dS)NT)r‰
r:
r†
r´
r3r)r*Úfake_unreserve_volume}s

z2CinderFixture.setUp.<locals>.fake_unreserve_volumeÚrwcsHtˆj
 ¡ƒ
D]$\}}||vrtjd
||fd
‚
qˆj
| |¡

dS)Nz,Volume %s is already attached to instance %s)
Úreason)rÀrŒ
rõrZInvalidInputr9
)Ú_selfrr¨
rr˜
ÚmodeÚinstancer«
r3r)r*Úfake_attach‰s



ÿÿz(CinderFixture.setUp.<locals>.fake_attachznova.volume.cinder.API.attachcsb|ˆjvrˆj 
|¡

|du
r0ˆj| 
|¡

n.tˆj ¡ƒ
D]\}}||vr>| 
|¡


q^q>dSr,)r‰
r:
rŒ
rÀrõ)r¹
rr¨
rr™
r»
r«
r3r)r*Úfake_detach—s





z(CinderFixture.setUp.<locals>.fake_detachznova.volume.cinder.API.detachú&nova.volume.cinder.API.begin_detachingc
_sdSr,r)r[
r)r)r*rp­rqz%CinderFixture.setUp.<locals>.<lambda>únova.volume.cinder.API.getz,nova.volume.cinder.API.initialize_connectionú0nova.volume.cinder.API.migrate_volume_completionz%nova.volume.cinder.API.reserve_volumeú%nova.volume.cinder.API.roll_detachingc
_sdSr,r)r[
r)r)r*rp¸rqz+nova.volume.cinder.API.terminate_connectionc
_sdSr,r)r[
r)r)r*rpºrqz'nova.volume.cinder.API.unreserve_volumeú%nova.volume.cinder.API.check_attachedc
_sdSr,r)r[
r)r)r*rp¾rq)
N)
r·
)NN)r-r
r.rO
r_
)r'r¬
r¯
r³
rµ
r¶
r¼
r½
r4r3r*r."sV
K
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ

þ
ÿ
ÿ
ÿ
ÿ
ÿzCinderFixture.setUp)
r7r8r9r:rF
r£
ÚSWAP_NEW_VOLr¤
r­
r¦
r+r.r;r)r)r4r*r
s



r
csLeZ
dZd
ZdZdZdZdZdZdZ	dZ
d	Z‡f
d
d„Z‡f
dd
„Z
‡ZS)ÚCinderFixtureNewAttachFlowzDA fixture to volume operations with the new Cinder attach/detach APIrûr€
r
r‚
rƒ
z$4a3cd440-b9c2-11e1-afa6-0800200c9a66z$4757d51f-54eb-4442-8684-3399a6431f67r„
cs<tt
|ƒ ¡
|
|_d
|_d|_d|_d|_t 	t
¡
|_dSr…
)r-rÄ
r+rO
r†
r‡
rˆ
Úattachment_error_idrŠ
r‹
rÀrŒ
rZ
r4r)r*r+Õs





z#CinderFixtureNewAttachFlow.__init__c
s
tt
ˆƒ ¡
d‡f
d
d„	}
dd„}d‡f
dd„	}‡f
dd„}d d	d
„
}dd„}ˆj d
|¡
ˆj d|¡
ˆj d|¡
ˆj ddd„¡
ˆj d|¡
ˆj ddd„¡
ˆj d|
¡
ˆj d|¡
ˆj ddd„¡
ˆj ddd„¡
ˆj ddd„¡
dS)!Ncsú|tj
tjfvrxd
dd|dddœ}ˆjr2|tj
ksBˆjrx|tjkrx|tj
krRˆjnˆj}| d|d|d	œi
d
dœ¡

|Stˆj ¡ƒ
D]8\}}||vr†d|d
||ˆj	kd||ddœi
d
œ}
qØq†d
dd||ˆj	kddœ}|ˆj
kröd|d<ddi
|d<|S)Nr
rŽ
r
Fr`r
r•
r–
r—
rš
r›
rœ
r
rž
TrŸ
r 
r¡
r¢
)r
r£
r¤
r‡
rˆ
r¥
rÀrŒ
rõÚMULTIATTACH_VOLr¦
)r§
rr¨
r©
rª
rr«
r3r)r*r¬
ãst
ÿ




ú
ÿþýÿþ


þÿø








þÿù




ú

þz2CinderFixtureNewAttachFlow.setUp.<locals>.fake_getcSsd
|i
Sr°
r)r±
r)r)r*r³
-szHCinderFixtureNewAttachFlow.setUp.<locals>.fake_migrate_volume_completioncsJt 
¡}ˆjdu
rˆj}|d
ii
dœ}ˆjd |¡

ˆj| |¡

|S)NÚdata)ryÚconnection_infor)r	Z
generate_uuidrÅ
rŒ
r9
)r¹
rr¨
rr®
r˜
r™
Z
attachmentr3r)r*Úfake_attachment_create1s





z@CinderFixtureNewAttachFlow.setUp.<locals>.fake_attachment_createcs:ˆjd
d}ˆj|d=ˆjd
d=|t
jkr6dˆ_dS)Nrr
T)rŒ
rÄ
ÚSWAP_ERR_ATTACH_IDr†
)r¹
rr™
rr3r)r*Úfake_attachment_delete<s






z@CinderFixtureNewAttachFlow.setUp.<locals>.fake_attachment_deletecSs,d
|ddddœi
dœ}|tj
kr(ddi
}|S)	NÚ	fake_typerÇ
Úbarr ©ZfooZ
target_lun©Zdriver_volume_typeryrÈ
rÈ
r))rÄ
rÊ
)r¹
rr™
r®
r˜
Úattachment_refr)r)r*Úfake_attachment_updateCs



ÿÿþ


z@CinderFixtureNewAttachFlow.setUp.<locals>.fake_attachment_updatecSsd
|ddddœi
dœ}|S)NrÌ
rÇ
rÍ
r rÎ
rÏ
r))r¹
rr™
rÐ
r)r)r*Úfake_attachment_getNs




ÿÿþz=CinderFixtureNewAttachFlow.setUp.<locals>.fake_attachment_getz(nova.volume.cinder.API.attachment_createz(nova.volume.cinder.API.attachment_deletez(nova.volume.cinder.API.attachment_updatez*nova.volume.cinder.API.attachment_completec
_sdSr,r)r[
r)r)r*rp]rqz2CinderFixtureNewAttachFlow.setUp.<locals>.<lambda>z%nova.volume.cinder.API.attachment_getr¾
c
_sdSr,r)r[
r)r)r*rparqr¿
rÀ
rÁ
c
_sdSr,r)r[
r)r)r*rphrqz,nova.volume.cinder.is_microversion_supportedc
_sdSr,r)r[
r)r)r*rpjrqrÂ
c
_sdSr,r)r[
r)r)r*rplrq)
N)NN)
N)r-rÄ
r.rO
r_
)r'r¬
r³
rÉ
rË
rÑ
rÒ
r4r3r*r.àsV
Jÿÿ

ÿ
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ

þ
ÿ
ÿ
ÿz CinderFixtureNewAttachFlow.setUp)r7r8r9r:rF
r£
rÃ
r¤
r­
rÊ
rÆ
r¦
r+r.r;r)r)r4r*rÄ
Äs





rÄ
c@s$eZ
dZd
d„Zdd„Zdd„ZdS)ÚPlacementApiClientcCs
|
|_dSr,)
Úfixture)r'Zplacement_fixturer)r)r*r+ps
zPlacementApiClient.__init__cKst 
|jjd|
fi|¤
Ž
¡
Sr,)rÚAPIResponserÔ
Ú	_fake_get)r'rãr&r)r)r*rLss
zPlacementApiClient.getcKst 
|jjd|
|fi|¤
Ž
¡
Sr,)rrÕ
rÔ
Ú	_fake_put)r'rãrw
r&r)r)r*Úputvs

ÿzPlacementApiClient.putN)r7r8r9r+rLrØ
r)r)r)r*rÓ
os
rÓ
csVeZ
dZd
Zddd„
Z‡f
dd„Zedd„ƒ
Zd	d
„Zdd„Z	d
d„Z
dd„Z‡ZS)ÚPlacementFixtureaj
A fixture to placement operations.

    Runs a local WSGI server bound on a free port and having the Placement
    application with NoAuth middleware.
    This fixture also prevents calling the ServiceCatalog for getting the
    endpoint.

    It's possible to ask for a specific token when running the fixtures so
    all calls would be passing this token.
    r
cCs
|
|_dSr,)
Útoken)r'rÚ
r)r)r*r+‡s
zPlacementFixture.__init__c
sìtt
|ƒ ¡
| td
dd¡

t t¡
‰‡f
dd„}
tj	}d||_
tj|
|j
d}| 
¡
| |j¡

| t dtjj¡¡

tjdd	
|_| t d
|j¡¡

| t d|j¡¡

| t d|j¡¡

| t d
|j¡¡

t|ƒ
|_dS)NrZnoauth2)rôZ
auth_strategyc
sˆSr,r)r)r
r)r*rprqz(PlacementFixture.setUp.<locals>.<lambda>zhttp://%s/placementr
rÿ)
Zauthz6nova.scheduler.client.report.SchedulerReportClient.getz7nova.scheduler.client.report.SchedulerReportClient.postz6nova.scheduler.client.report.SchedulerReportClient.putz9nova.scheduler.client.report.SchedulerReportClient.delete)r-rÙ
r.rOróÚplacement_deployZloadapprÃrZplacement_hostr

rr
r	
r1r

rPrSr
r
r
ÚksZSessionÚ_clientrÖ
Ú
_fake_postr×
Ú_fake_deleterÓ
r)r'r
r$r
r4r
r*r.Šs>











þ

þ

þ

þ

þzPlacementFixture.setUpc
Ks(|
 d
¡
}|du
r$| 
dd|i
¡

dS)NrÊzOpenStack-API-Versionzplacement %s)rLr¥
)Úheadersr&rÊr)r)r*Ú_update_headers_with_version°s



ÿz-PlacementFixture._update_headers_with_versionc
Os@|
d
d…\
}d|ji
}|j
|f
i|¤
Ž

|jj||j|ddS©Nr`úx-auth-tokenF)Úendpoint_overriderà
Ú	raise_exc)rÚ
rá
rÝ
rLr

)r'rFr&rãrà
r)r)r*rÖ
¹s







üzPlacementFixture._fake_getc
OsD|
d
d…\}}d|ji
}|j
|f
i|¤
Ž

|jj|||j|ddS©Nr`rã
F)Zjsonrä
rà
rå
)rÚ
rá
rÝ
Zpostr

©r'rFr&rãrÇ
rà
r)r)r*rÞ
Æs







üzPlacementFixture._fake_postc
OsD|
d
d…\}}d|ji
}|j
|f
i|¤
Ž

|jj|||j|ddSræ
)rÚ
rá
rÝ
rØ
r

rç
r)r)r*r×
×s







üzPlacementFixture._fake_putc
Os*|
d
d…\
}|jj
||jd|ji
ddSrâ
)rÝ
Údeleter

rÚ
)r'rFr&rãr)r)r*rß
ès




üzPlacementFixture._fake_delete)
r
)
r7r8r9r:r+r.r3
rá
rÖ
rÞ
r×
rß
r;r)r)r4r*rÙ
{s

&


rÙ
c@seZ
dZd
d„ZdS)ÚUnHelperfulClientChannelcCstd
ƒ
‚
dS)NzYou have attempted to start a privsep helper. This is not allowed in the gate, and indicates a failure to have mocked your tests.rgr®r)r)r*r+õs
z!UnHelperfulClientChannel.__init__N)r7r8r9r+r)r)r)r*ré
ôs
ré
cs eZ
dZd
Z‡f
dd„Z‡ZS)ÚPrivsepNoHelperFixturea¢
A fixture to catch failures to mock privsep's rootwrap helper.

    If you fail to mock away a privsep'd method in a unit test, then
    you may well end up accidentally running the privsep rootwrap
    helper. This will fail in the gate, but it fails in a way which
    doesn't identify which test is missing a mock. Instead, we
    raise an exception so that you at least know where you've missed
    something.
    c

s$tt
|ƒ ¡
| t d
t¡¡

dS)Nz)oslo_privsep.daemon.RootwrapClientChannel)r-rê
r.rOrPrSré
r3r4r)r*r.s



þzPrivsepNoHelperFixture.setUprUr)r)r4r*rê
ûs

rê
cs eZ
dZd
Z‡f
dd„Z‡ZS)ÚNoopQuotaDriverFixtureaÎ
A fixture to run tests using the NoopQuotaDriver.

    We can't simply set self.flags to the NoopQuotaDriver in tests to use the
    NoopQuotaDriver because the QuotaEngine object is global. Concurrently
    running tests will fail intermittently because they might get the
    NoopQuotaDriver globally when they expected the default DbQuotaDriver
    behavior. So instead, we can patch the _driver property of the QuotaEngine
    class on a per-test basis.
    c

sFtt
|ƒ ¡
| t d
t ¡¡¡

t 	ddd¡
| 
tjdd¡
dS)Nznova.quota.QuotaEngine._driverZdriverznova.quota.NoopQuotaDriverr)r-rë
r.rOrPrSrA
ZNoopQuotaDriverrÃr÷r1rör3r4r)r*r.s



ÿ
zNoopQuotaDriverFixture.setUprUr)r)r4r*rë
s

rë
)pr:Z
__future__rrŠ
Ú
contextlibrrP
ZloggingrHrJrîrPZ
keystoneauth1rrÜ
rçZoslo_concurrencyrZoslo_configrZoslo_messagingr²rræZoslo_privseprZprivsep_daemonZ
oslo_utilsr	Zrequestsr
Zwsgi_interceptrZnova.api.openstack.computerZnova.api.openstack.placementr
rÛ
Znova.api.openstackrZnova.computerr=
r
rZnova.dbrZnova.db.sqlalchemyrrZnova.networkrr]
rZnova.objectsrr
rr>
rrA
rZnova.tests.functional.apirZ
nova.testsrrrMrÃrœrÂZFixturer#ZHandlerr<rDrVr_rerkZRequestContextSerializerrŠr’rÁrÉrËrßrérórùr
r
r
Úobjectr 
r)
r*
r4
r;
r?
rB
ry
r}
r~
r
rÄ
rÓ
rÙ
Z_ClientChannelré
rê
rë
r)r)r)r*Ú<module>s 


































G#]/5#-R$ V	=,y