| 117 | Future<Void> afterWrite(Future<WriteResult> result, int releasePermits = 1); |
| 118 | |
| 119 | ExtConnection(Reference<DocumentLayer> docLayer, Reference<BufferedConnection> bc, int64_t connectionId) |
| 120 | : docLayer(docLayer), |
| 121 | bc(bc), |
| 122 | lastWrite(WriteResult()), |
| 123 | options(docLayer->defaultConnectionOptions), |
| 124 | lock(Reference<FlowLock>(new FlowLock(DOCLAYER_KNOBS->CONNECTION_MAX_PIPELINE_DEPTH))), |
| 125 | cursors(), |
| 126 | mm(docLayer->mm), |
| 127 | connectionId(connectionId), |
| 128 | maxReceivedRequestID(0), |
| 129 | nextServerGeneratedRequestID(0) {} |
| 130 | |
| 131 | /** |
| 132 | * Get a new server-generated request ID for this connection. Used in Exhaust mode |
nothing calls this directly
no test coverage detected