From f2b5fa18b58db09562d03a7d247e21c111e78056 Mon Sep 17 00:00:00 2001
From: Yannick Lecaillez <yannick.lecaillez@forgerock.com>
Date: Mon, 07 Nov 2016 13:59:40 +0000
Subject: [PATCH] OPENDJ-3179: Migrate LDAP Connection Handler to SDK Grizzly transport
---
opendj-grizzly/src/main/java/org/forgerock/opendj/grizzly/GrizzlyLDAPConnection.java | 20 ++++++++++----------
1 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/opendj-grizzly/src/main/java/org/forgerock/opendj/grizzly/GrizzlyLDAPConnection.java b/opendj-grizzly/src/main/java/org/forgerock/opendj/grizzly/GrizzlyLDAPConnection.java
index 42c33de..cffc311 100644
--- a/opendj-grizzly/src/main/java/org/forgerock/opendj/grizzly/GrizzlyLDAPConnection.java
+++ b/opendj-grizzly/src/main/java/org/forgerock/opendj/grizzly/GrizzlyLDAPConnection.java
@@ -186,7 +186,7 @@
}
private LdapPromise<Void> sendAbandonRequest(final AbandonRequest request) {
- final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter();
+ final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter(connection.getMemoryManager());
try {
final int messageID = nextMsgID.getAndIncrement();
writer.writeAbandonRequest(messageID, request);
@@ -212,7 +212,7 @@
pendingRequests.put(messageID, promise);
}
try {
- final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter();
+ final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter(connection.getMemoryManager());
try {
writer.writeAddRequest(messageID, request);
connection.write(writer.getASN1Writer().getBuffer(), null);
@@ -285,7 +285,7 @@
}
try {
- final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter();
+ final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter(connection.getMemoryManager());
try {
// Use the bind client to get the initial request instead of
// using the bind request passed to this method.
@@ -333,7 +333,7 @@
pendingRequests.put(messageID, promise);
}
try {
- final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter();
+ final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter(connection.getMemoryManager());
try {
writer.writeCompareRequest(messageID, request);
connection.write(writer.getASN1Writer().getBuffer(), null);
@@ -363,7 +363,7 @@
pendingRequests.put(messageID, promise);
}
try {
- final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter();
+ final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter(connection.getMemoryManager());
try {
writer.writeDeleteRequest(messageID, request);
connection.write(writer.getASN1Writer().getBuffer(), null);
@@ -409,7 +409,7 @@
pendingRequests.put(messageID, promise);
}
try {
- final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter();
+ final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter(connection.getMemoryManager());
try {
writer.writeExtendedRequest(messageID, request);
connection.write(writer.getASN1Writer().getBuffer(), null);
@@ -454,7 +454,7 @@
pendingRequests.put(messageID, promise);
}
try {
- final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter();
+ final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter(connection.getMemoryManager());
try {
writer.writeModifyRequest(messageID, request);
connection.write(writer.getASN1Writer().getBuffer(), null);
@@ -484,7 +484,7 @@
pendingRequests.put(messageID, promise);
}
try {
- final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter();
+ final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter(connection.getMemoryManager());
try {
writer.writeModifyDNRequest(messageID, request);
connection.write(writer.getASN1Writer().getBuffer(), null);
@@ -524,7 +524,7 @@
pendingRequests.put(messageID, promise);
}
try {
- final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter();
+ final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter(connection.getMemoryManager());
try {
writer.writeSearchRequest(messageID, request);
connection.write(writer.getASN1Writer().getBuffer(), null);
@@ -668,7 +668,7 @@
* connection and release resources.
*/
if (notifyClose) {
- final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter();
+ final LDAPWriter<ASN1BufferWriter> writer = GrizzlyUtils.getWriter(connection.getMemoryManager());
try {
writer.writeUnbindRequest(nextMsgID.getAndIncrement(), unbindRequest);
connection.write(writer.getASN1Writer().getBuffer(), null);
--
Gitblit v1.10.0