public abstract class ResilientOutputStreamBase
extends java.io.OutputStream
| Modifier and Type | Field and Description |
|---|---|
private Context |
context |
private int |
noContextWarning |
protected java.io.OutputStream |
os |
protected boolean |
presumedClean |
private RecoveryCoordinator |
recoveryCoordinator |
(package private) static int |
STATUS_COUNT_LIMIT |
private int |
statusCount |
| Constructor and Description |
|---|
ResilientOutputStreamBase() |
| Modifier and Type | Method and Description |
|---|---|
void |
addStatus(Status status) |
(package private) void |
addStatusIfCountNotOverLimit(Status s) |
(package private) void |
attemptRecovery() |
void |
close() |
void |
flush() |
Context |
getContext() |
(package private) abstract java.lang.String |
getDescription() |
private boolean |
isPresumedInError() |
(package private) abstract java.io.OutputStream |
openNewOutputStream() |
void |
postIOFailure(java.io.IOException e) |
private void |
postSuccessfulWrite() |
void |
setContext(Context context) |
void |
write(byte[] b,
int off,
int len) |
void |
write(int b) |
static final int STATUS_COUNT_LIMIT
private int noContextWarning
private int statusCount
private Context context
private RecoveryCoordinator recoveryCoordinator
protected java.io.OutputStream os
protected boolean presumedClean
private boolean isPresumedInError()
public void write(byte[] b,
int off,
int len)
write in class java.io.OutputStreampublic void write(int b)
write in class java.io.OutputStreampublic void flush()
flush in interface java.io.Flushableflush in class java.io.OutputStreamabstract java.lang.String getDescription()
abstract java.io.OutputStream openNewOutputStream()
throws java.io.IOException
java.io.IOExceptionprivate void postSuccessfulWrite()
public void postIOFailure(java.io.IOException e)
public void close()
throws java.io.IOException
close in interface java.io.Closeableclose in interface java.lang.AutoCloseableclose in class java.io.OutputStreamjava.io.IOExceptionvoid attemptRecovery()
void addStatusIfCountNotOverLimit(Status s)
public void addStatus(Status status)
public Context getContext()
public void setContext(Context context)