Module org.firebirdsql.jaybird
Class V16WireOperations
java.lang.Object
org.firebirdsql.gds.ng.wire.AbstractWireOperations
org.firebirdsql.gds.ng.wire.version10.V10WireOperations
org.firebirdsql.gds.ng.wire.version11.V11WireOperations
org.firebirdsql.gds.ng.wire.version13.V13WireOperations
org.firebirdsql.gds.ng.wire.version15.V15WireOperations
org.firebirdsql.gds.ng.wire.version16.V16WireOperations
- All Implemented Interfaces:
FbWireOperations
- Direct Known Subclasses:
V18WireOperations
- Since:
- 5
- Author:
- Mark Rotteveel
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.firebirdsql.gds.ng.wire.FbWireOperations
FbWireOperations.ProcessAttachCallback
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionV16WireOperations
(WireConnection<?, ?> connection, WarningMessageCallback defaultWarningMessageCallback) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
Action to perform after the deferred action has been queued inV11WireOperations.enqueueDeferredAction(DeferredAction)
.protected void
afterProcessDeferredActions
(int processedDeferredActions) Can be used for additional actions after processing deferred actions (e.g.void
Completes pending deferred actions.protected int
protected BatchCompletionResponse
Reads the batch completion response (op_batch_cs
) without reading the operation code itself.Methods inherited from class org.firebirdsql.gds.ng.wire.version15.V15WireOperations
readCryptKeyCallback, writeCryptKeyCallback
Methods inherited from class org.firebirdsql.gds.ng.wire.version13.V13WireOperations
authReceiveResponse, enableEncryption, handleCryptKeyCallback
Methods inherited from class org.firebirdsql.gds.ng.wire.version11.V11WireOperations
completeDeferredActionsRequiresSync, deferredActionCount, enqueueDeferredAction, processDeferredActions
Methods inherited from class org.firebirdsql.gds.ng.wire.AbstractWireOperations
addServerKeys, clearServerKeys, consumePackets, getAttachProperties, getClientAuthBlock, getConnection, getDefaultWarningMessageCallback, getEncoding, getPluginSpecificData, getXdrIn, getXdrOut, getXdrStreamAccess, processOperation, processResponse, processResponseWarnings, readGenericResponse, readNextOperation, readOperationResponse, readResponse, readSqlResponse, readStatusVector, readStatusVector, setNetworkTimeout, withLock, writeDirect
-
Field Details
-
BATCH_LIMIT
protected static final int BATCH_LIMIT- See Also:
-
-
Constructor Details
-
V16WireOperations
public V16WireOperations(WireConnection<?, ?> connection, WarningMessageCallback defaultWarningMessageCallback)
-
-
Method Details
-
afterEnqueueDeferredAction
Description copied from class:V11WireOperations
Action to perform after the deferred action has been queued inV11WireOperations.enqueueDeferredAction(DeferredAction)
.This method should only be called by
V11WireOperations.enqueueDeferredAction(DeferredAction)
, and can be used to implement forcing processing of deferred actions if too many are queued.- Overrides:
afterEnqueueDeferredAction
in classV11WireOperations
- Throws:
SQLException
- for errors forcing handling of oversized queue usingop_ping
(orop_batch_sync
)
-
completeDeferredActions
Description copied from interface:FbWireOperations
Completes pending deferred actions.Wire protocol implementations that do not support deferred actions should simply do nothing.
- Specified by:
completeDeferredActions
in interfaceFbWireOperations
- Overrides:
completeDeferredActions
in classV11WireOperations
- Throws:
SQLException
- for errors forcing ping/batch sync
-
getBatchSyncOperation
protected int getBatchSyncOperation()- Returns:
- operation code that synchronizes deferred batch operations (
op_ping
orop_batch_sync
)
-
afterProcessDeferredActions
protected void afterProcessDeferredActions(int processedDeferredActions) Description copied from class:V11WireOperations
Can be used for additional actions after processing deferred actions (e.g. trim a large deferred actions list to its default capacity).This implementation trims if
processedDeferredActions > 10
. When overridden, it is recommend to call this method throughsuper
to still trim (e.g. in a more limited set of circumstances) and perform any other actions this method may perform. If the overridden method wants to forgo trimming, it should pass-1
forprocessedDeferredActions
.- Overrides:
afterProcessDeferredActions
in classV11WireOperations
- Parameters:
processedDeferredActions
- number of processed deferred actions, or-1
to ensure no trim is performed
-
readBatchCompletionResponse
protected BatchCompletionResponse readBatchCompletionResponse(XdrInputStream xdrIn) throws SQLException, IOException Description copied from class:AbstractWireOperations
Reads the batch completion response (op_batch_cs
) without reading the operation code itself.- Overrides:
readBatchCompletionResponse
in classAbstractWireOperations
- Parameters:
xdrIn
- XDR input stream to read- Returns:
- batch completion response
- Throws:
SQLException
- for errors reading the response from the connectionSQLFeatureNotSupportedException
- when the protocol version does not support this responseIOException
- for errors reading the response from the connection
-