test_numbaModel

Unit tests for NumbaModel.

Section Topic ——- ———————————————————————- 1 Basic scalar I/O + memory namespace (smoke test) 2 Auto-convert scalar / list memory at Reset time 3 Post-Reset convenience writes via memory namespace 4 CurrentSimNanos parameter 5 IsLinked: scalar reader (unlinked, linked, becomes linked mid-sim) 6 Message chain: producer -> consumer (scalar I/O, memory) 7 List readers: all linked, partial link (IsLinked array) 8 List writers 9 Dict readers: key introspection, data round-trip, unlinked error 10 Dict writers 11 2-D memory array 12 moduleID parameter 13 Re-wiring: subscribeTo after Reset 14 Memory persistence across resets 15 Error cases (incl. empty containers, empty memory) 16 Dict reader IsLinked keyed access 17 bskLogger proxy

class test_numbaModel.AutoConvertModel(*args, **kwargs)

Bases: NumbaModel

Model used to verify scalar and list memory auto-conversion.

static UpdateStateImpl(dataOutMsgPayload, memory)

Write the gain-plus-bias result into the outgoing message.

class test_numbaModel.BasicModel(*args, **kwargs)

Bases: NumbaModel

Minimal scalar input/output model with one integer memory field.

static UpdateStateImpl(dataInMsgPayload, dataInMsgIsLinked, dataOutMsgPayload, CurrentSimNanos, memory)

Forward the input vector when linked and increment the step count.

class test_numbaModel.ConsumerModel(*args, **kwargs)

Bases: NumbaModel

Sink model that scales the producer output by a fixed factor.

static UpdateStateImpl(dataInMsgPayload, dataInMsgIsLinked, dataOutMsgPayload)

Copy the input vector into the output after multiplying by ten.

class test_numbaModel.DictInModel(*args, **kwargs)

Bases: NumbaModel

Dictionary-based input reader model used for key-order tests.

static UpdateStateImpl(dataInMsgPayload, dataOutMsgPayload)

Route the named inputs into separate output vector components.

class test_numbaModel.DictOutModel(*args, **kwargs)

Bases: NumbaModel

One input reader → two named output messages.

static UpdateStateImpl(dataInMsgPayload, dataInMsgIsLinked, dataOutMsgPayload)

Write positive and negative copies of the input value.

class test_numbaModel.GuardedReaderModel(*args, **kwargs)

Bases: NumbaModel

Forwards payload when linked; writes sentinel −1 when unlinked.

static UpdateStateImpl(dataInMsgPayload, dataInMsgIsLinked, dataOutMsgPayload, memory)

Copy the input when linked and publish a sentinel otherwise.

class test_numbaModel.MatrixMemoryModel(*args, **kwargs)

Bases: NumbaModel

Stores a 3×3 diagonal matrix; outputs the diagonal each tick.

static UpdateStateImpl(dataOutMsgPayload, memory)

Copy the matrix diagonal into the output vector.

class test_numbaModel.ModuleIDModel(*args, **kwargs)

Bases: NumbaModel

Helper model that captures the module ID seen by the compiled kernel.

static UpdateStateImpl(dataOutMsgPayload, memory, moduleID)

Store the provided module identifier in persistent memory.

class test_numbaModel.MultiInModel(*args, **kwargs)

Bases: NumbaModel

Two input readers summed into one output.

static UpdateStateImpl(dataInMsgPayload, dataInMsgIsLinked, dataOutMsgPayload)

Sum the first component from each linked reader.

class test_numbaModel.MultiOutModel(*args, **kwargs)

Bases: NumbaModel

One input reader → two indexed output writers.

static UpdateStateImpl(dataInMsgPayload, dataInMsgIsLinked, dataOutMsgPayload)

Write the input value and its doubled copy to the outputs.

class test_numbaModel.ProducerModel(*args, **kwargs)

Bases: NumbaModel

Source model used to exercise chained message passing.

static UpdateStateImpl(dataOutMsgPayload, memory)

Increment the counter and publish three scaled copies.

class test_numbaModel.TimeRecorderModel(*args, **kwargs)

Bases: NumbaModel

Records the last simulation time and a tick counter in memory.

static UpdateStateImpl(dataOutMsgPayload, CurrentSimNanos, memory)

Store the current simulation time and publish it as a float.

test_numbaModel.test_2dMemoryArrayPythonWrite()

Python-side assignment to a 2-D memory field propagates to the C buffer.

test_numbaModel.test_2dMemoryArrayRead()

Cfunc reads 2-D memory field correctly.

test_numbaModel.test_autoConvertMemory()

Check scalar and list memory fields are converted at reset.

test_numbaModel.test_basicModel()

Smoke-test scalar I/O and persistent memory updates.

test_numbaModel.test_bsklogger()

bskLog / bskLog1 inside UpdateStateImpl should not crash; logic must run.

test_numbaModel.test_cacheDiskImplBodyChange(tmp_path)

Edit UpdateStateImpl on disk between processes and require the new implementation to run.

This verifies the full production invalidation chain. The implementation body hash changes, the fingerprint changes, a new wrapper file is emitted, and Numba recompiles the implementation after its source timestamp changes. A stale-cache bug would show up as process 2 still returning 11.0.

test_numbaModel.test_cacheDiskReuseAfterInProcessClear()

Clear _NBMODEL_CFUNC_CACHE, re-run same config → disk path gives correct result.

test_numbaModel.test_cacheDiskSurvivesProcessRestart(tmp_path)

Disk cache written in process 1 is used correctly by process 2.

test_numbaModel.test_cacheImplIdentityIsolation()

Two classes with same dtype/structure but different UpdateStateImpl must not share cfunc.

test_numbaModel.test_cacheLoggerLevelRuntime(monkeypatch, tmp_path, capfd)

Logger level is read at runtime; models with different levels share one cfunc.

test_numbaModel.test_cacheMultipleResetsReusesCfunc()

Re-running InitializeSimulation reuses the in-process cfunc (Tier 2 benefit).

test_numbaModel.test_cacheNoDtypeCollision()

Same class, different reader dtypes → distinct fingerprints, no in-process collision.

Regression test for the location-based idHash bug: md5(file:qualname) produced the same key for all instances of a class regardless of message-type configuration.

test_numbaModel.test_cacheSameDtypeSharesCfunc()

Two instances with identical dtype config share exactly one cfunc.

test_numbaModel.test_cacheSharedCfuncIndependentState()

Two instances share one cfunc but each has its own allPtrs_ buffer, so outputs never bleed.

test_numbaModel.test_currentSimNanos()

Check the compiled model receives the current simulation time.

test_numbaModel.test_dictIslinkedKeyed()

Dict reader IsLinked is accessible by key name: dataInMsgIsLinked[‘a’].

test_numbaModel.test_dictReaderData()

Payload from each dict key is routed to the correct output field.

test_numbaModel.test_dictReaderKeys()

Key order is preserved and accessible from Python after Reset.

test_numbaModel.test_dictWriter()

Check dictionary-based output messages are written by key.

test_numbaModel.test_emptyListReader()

Empty list attribute is allowed; cfunc receives a zero-element array (never iterated).

test_numbaModel.test_emptyMemory()

No memory fields defined: ‘memory’ param still compiles as a valid (ignored) Record.

test_numbaModel.test_errorIslinkedWithoutPayload()

An IsLinked flag without a matching Payload param leaves the variable undefined in the generated wrapper, which Numba catches as a TypingError.

test_numbaModel.test_errorMissingInMsg()

Check Reset fails when a referenced input message is missing.

test_numbaModel.test_errorNotOverridden()

Check Reset fails when UpdateStateImpl is not overridden.

test_numbaModel.test_errorNotStaticmethod()

Check Reset fails when UpdateStateImpl is not static.

test_numbaModel.test_errorUnlinkedWithoutIslinkedGuard()

Declaring InMsgPayload without InMsgIsLinked crashes at reset if a reader is unlinked.

test_numbaModel.test_errorUnrecognisedParam()

Check Reset fails when the compiled signature has an unknown parameter.

test_numbaModel.test_islinkedBecomesLinkedMidSim()

Reader starts unlinked; subscribed after first tick - cfunc picks it up.

test_numbaModel.test_islinkedLinked()

Subscribed reader → IsLinked is True; payload is forwarded.

test_numbaModel.test_islinkedUnlinked()

Unlinked reader → IsLinked is False; cfunc takes the else branch.

test_numbaModel.test_listReaderBothLinked()

Both readers subscribed → sum of both sources.

test_numbaModel.test_listReaderNoneLinked()

Both readers unlinked → output stays zero.

test_numbaModel.test_listReaderPartialLink()

reader[0] subscribed, reader[1] unlinked → only reader[0] contributes.

test_numbaModel.test_listWriter()

Check list-based output messages are written by index.

test_numbaModel.test_memoryWritePersistsThroughReset()

Both Python-side writes and cfunc-internal writes survive a subsequent Reset.

test_numbaModel.test_messageChain()

Check a NumbaModel output can feed another NumbaModel input.

test_numbaModel.test_moduleIdParameter()

Check the compiled model receives the owning module identifier.

test_numbaModel.test_multipleResets()

Reset always continues from the current buffer value; cfunc writes and Python writes are treated identically.

test_numbaModel.test_postResetConvenienceWrite()

Check post-reset memory writes update existing fields and reject new ones.

test_numbaModel.test_rewireAfterReset()

Switching sources mid-sim is transparent - no Reset required.