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 voidAction to perform after the deferred action has been queued inV11WireOperations.enqueueDeferredAction(DeferredAction).protected voidafterProcessDeferredActions(int processedDeferredActions) Can be used for additional actions after processing deferred actions (e.g.voidCompletes pending deferred actions.protected intprotected BatchCompletionResponseReads 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, writeCryptKeyCallbackMethods inherited from class org.firebirdsql.gds.ng.wire.version13.V13WireOperations
authReceiveResponse, enableEncryption, handleCryptKeyCallbackMethods inherited from class org.firebirdsql.gds.ng.wire.version11.V11WireOperations
completeDeferredActionsRequiresSync, deferredActionCount, enqueueDeferredAction, processDeferredActionsMethods 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:V11WireOperationsAction 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:
afterEnqueueDeferredActionin classV11WireOperations- Throws:
SQLException- for errors forcing handling of oversized queue usingop_ping(orop_batch_sync)
-
completeDeferredActions
Description copied from interface:FbWireOperationsCompletes pending deferred actions.Wire protocol implementations that do not support deferred actions should simply do nothing.
- Specified by:
completeDeferredActionsin interfaceFbWireOperations- Overrides:
completeDeferredActionsin classV11WireOperations- Throws:
SQLException- for errors forcing ping/batch sync
-
getBatchSyncOperation
protected int getBatchSyncOperation()- Returns:
- operation code that synchronizes deferred batch operations (
op_pingorop_batch_sync)
-
afterProcessDeferredActions
protected void afterProcessDeferredActions(int processedDeferredActions) Description copied from class:V11WireOperationsCan 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 throughsuperto 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-1forprocessedDeferredActions.- Overrides:
afterProcessDeferredActionsin classV11WireOperations- Parameters:
processedDeferredActions- number of processed deferred actions, or-1to ensure no trim is performed
-
readBatchCompletionResponse
protected BatchCompletionResponse readBatchCompletionResponse(XdrInputStream xdrIn) throws SQLException, IOException Description copied from class:AbstractWireOperationsReads the batch completion response (op_batch_cs) without reading the operation code itself.- Overrides:
readBatchCompletionResponsein 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
-