com.qualcomm.hardware.modernrobotics.comm

Interface ReadWriteRunnable

All Superinterfaces:

java.lang.Runnable

All Known Implementing Classes:

ReadWriteRunnableStandard

public interface ReadWriteRunnable
extends java.lang.Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ReadWriteRunnable.BlockingState
static interface	ReadWriteRunnable.Callback
static class	ReadWriteRunnable.EmptyCallback

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_BUFFER_SIZE

Method Summary

Modifier and Type	Method and Description
void	close()
ReadWriteRunnableSegment	createSegment(int key, int address, int size)
void	destroySegment(int key)
void	drainPendingWrites()
void	executeUsing(java.util.concurrent.ExecutorService service)
boolean	getAcceptingWrites()
ReadWriteRunnableSegment	getSegment(int key)
void	queueSegmentRead(int key)
void	queueSegmentWrite(int key)
byte[]	read(int address, int size)
byte[]	readFromWriteCache(int address, int size)
void	resetWriteNeeded()
void	run()
void	setAcceptingWrites(boolean acceptingWrites)
void	setCallback(ReadWriteRunnable.Callback callback)
void	suppressReads(boolean suppress)
void	write(int address, byte[] data)
boolean	writeNeeded()

Field Detail

MAX_BUFFER_SIZE

static final int MAX_BUFFER_SIZE

See Also:

Constant Field Values

Method Detail

setCallback

void setCallback(ReadWriteRunnable.Callback callback)

writeNeeded

boolean writeNeeded()

resetWriteNeeded

void resetWriteNeeded()

write

void write(int address,
           byte[] data)

setAcceptingWrites

void setAcceptingWrites(boolean acceptingWrites)

getAcceptingWrites

boolean getAcceptingWrites()

drainPendingWrites

void drainPendingWrites()

suppressReads

void suppressReads(boolean suppress)

readFromWriteCache

byte[] readFromWriteCache(int address,
                          int size)

read

byte[] read(int address,
            int size)

close

void close()

createSegment

ReadWriteRunnableSegment createSegment(int key,
                                       int address,
                                       int size)

destroySegment

void destroySegment(int key)

getSegment

ReadWriteRunnableSegment getSegment(int key)

queueSegmentRead

void queueSegmentRead(int key)

queueSegmentWrite

void queueSegmentWrite(int key)

executeUsing

void executeUsing(java.util.concurrent.ExecutorService service)

run

void run()

Specified by:

run in interface java.lang.Runnable