common4189%python.module
fault.defects

Common tools and tests employed across fault.defects.system.io tests.

pickle
import

threading0
import

contextlib0
import

os0
import

socket0
import

time0
import

io0
import

network0
import

kernel0
import

thread0
import

allocpipe0
function

allocpipe(A)

allocsockets0
function

allocsockets(A)

allocports60%
function

allocports(A)

ralloc_index0
data

ralloc_index = {
	io.Octets: bytearray,
}

rallocate0
function

rallocate(channel, quantity)

Terminated0
class

Exception

Delta
class

tuple

Delta__slots__0
data

__slots__ = ()
	@property

Deltachannel0
property

Deltademand0
property

Deltatermination0
property

Deltaterminated0
property

Deltaresource10%
property

Deltaslice10%
property

Deltatransferred0
property

Deltaconstruct0
classmethod

construct(typ, channel)

snapshot0
function

snapshot(array)

cycle0
function

cycle(array)

loop271%
function

loop(deliver, array)

Continuously deliver transfers enqueued into the array.

ArrayActionManager0
class

object

Manages the Array cycle in a separate thread to avoid inline management of event collection.

ArrayActionManager__init__0
method

__init__(self)

ArrayActionManagerview70%
method

view(self)

Utility function for displaying the contents of a Array.

ArrayActionManagerforce0
method

force(self)

ArrayActionManagercycle0
method

cycle(self, activity)

ArrayActionManagerloop0
method

loop(self)

ArrayActionManagerthread0
method

thread(self)

ArrayActionManagermanage0
method

manage(self, ct)

ArrayActionManagerdelta0
method

delta(self)

Wait for a cycle to occur; use to regulate transfer progress.

Events0
class

object

For cases involving single Channels.

No autoread setup.

Events__init__0
method

__init__(self, *channels)

Eventsterminate0
method

terminate(self)

Events_term_check30%
method

_term_check(self)

Eventsraised0
method

raised(self)

Eventsvacancies0
method

vacancies(self)

Eventsterminated0
property

Eventsexhausted0
method

exhausted(self)

Eventsexhaustions0
property

Eventssockets50%
property

Eventsget_data0
method

get_data(self)

Eventsdata0
property

Eventsclear0
method

clear(self)

Eventssetup_read0
method

setup_read(self, quantity)

Eventssetup_write0
method

setup_write(self, resource)

Endpoint0
class

object

For cases involving send and receives.

Endpoint__init__0
method

__init__(self, channels)

Endpoint_read_event0
method

_read_event(self, activity)

Endpointterminate0
method

terminate(self)

Endpoint_write_term_check150%
method

_write_term_check(self)

Endpoint_read_term_check150%
method

_read_term_check(self)

Endpointread_exhaustions0
property

Endpointwrite_exhaustions0
property

Endpointread_payload_int60%
property

Endpointread_payload0
property

Endpointunits_written0
property

Endpointunits_read0
property

Endpointclear0
method

clear(self)

Endpointclear_reads10%
method

clear_reads(self)

Endpointclear_writes10%
method

clear_writes(self)

Endpointsetup_read0
method

setup_read(self, rallocation)

Endpointsetup_write0
method

setup_write(self, resource)

Objects0
class

object

Endpoint that transfers objects.

Objects__init__0
method

__init__(self, channels)

Objects_read_event0
method

_read_event(self, activity)

Objects_write_event0
method

_write_event(self, activity)

Objectsterminate0
method

terminate(self)

Objects_write_term_check150%
method

_write_term_check(self)

Objects_read_term_check20%
method

_read_term_check(self)

Objectsdone_writing20%
property

Objectsclear0
method

clear(self)

Objectssend0
method

send(self, obj)

exchange_nothing0
function

exchange_nothing(test, am, client, server)

exchange_few_bytes0
function

exchange_few_bytes(test, am, client, server)

exchange_many_bytes0
function

exchange_many_bytes(test, am, client, server)

exchange_many_bytes_many_times0
function

exchange_many_bytes_many_times(test, am, client, server)

exchange_kilobytes0
function

exchange_kilobytes(test, am, client, server)

transfer_cases0
data

transfer_cases = [
	exchange_nothing,
	exchange_few_bytes,
	exchange_many_bytes,
	exchange_many_bytes_many_times,
	exchange_kilobytes,
]

echo_objects0
function

echo_objects(test, am, client, server)

object_transfer_cases0
data

object_transfer_cases = [
	echo_objects,
]

stream_listening_connection198%
function

stream_listening_connection(test, version, address)