jndi/ldap/LdapClient.java

70  *   conn - no sync; Connection takes care of its own sync
118     Connection conn;  // Connection to server; has reader thread
137         conn = new Connection(this, host, port, socketFactory, connectTimeout, readTimeout,
153         int readTimeout = conn.readTimeout;
154         conn.readTimeout = conn.connectTimeout;
195                             conn.setBound();
200                             conn.host + ":" + conn.port);
216                         conn.setBound();
221                             conn.host + ":" + conn.port);
236                     res = LdapSasl.saslBind(this, conn, conn.host, name, pw,
239                         conn.setBound();
244                         conn.host + ":" + conn.port);
268                         conn.setBound();
273                             conn.host +     ":" + conn.port);
297             conn.setV3(isLdapv3);
300             conn.readTimeout = readTimeout;
319         conn.abandonOutstandingReqs(null);
322         int curMsgId = conn.getMsgId();
359         LdapRequest req = conn.writeRequest(ber, curMsgId, pauseAfterReceipt);
365         BerDecoder rber = conn.readReply(req);
385         conn.removeRequest(req);
396         return (conn.inStream instanceof SaslInputStream);
436         if (referenceCount <= 0 && conn != null) {
440                 conn.cleanup(reqCtls, false);
441                 conn = null;
445                 // Is this a real close or a request to return conn to pool
447                     conn.cleanup(reqCtls, false);
448                     conn = null;
465         if (conn != null) {
468             conn.cleanup(null, false);
469             conn = null;
500             if (conn != null) {
501                 msg = conn.host + ":" + conn.port + " connection closed";
536         int curMsgId = conn.getMsgId();
556                 conn.writeRequest(ber, curMsgId, false, replyQueueCapacity);
571         if (res != null && conn != null) {
575             LdapRequest req = conn.findRequest(res.msgId);
586                 conn.removeRequest(req);
588                 conn.abandonRequest(req, ctls);
603         if ((req = conn.findRequest(res.msgId)) == null) {
639             replyBer = conn.readReply(req);
703                 conn.removeRequest(req);
888         BerDecoder rber = conn.readReply(req);
900         conn.removeRequest(req);
935         int curMsgId = conn.getMsgId();
960         LdapRequest req = conn.writeRequest(ber, curMsgId);
1013         int curMsgId = conn.getMsgId();
1039         LdapRequest req = conn.writeRequest(ber, curMsgId);
1062         int curMsgId = conn.getMsgId();
1070         LdapRequest req = conn.writeRequest(ber, curMsgId);
1104         int curMsgId = conn.getMsgId();
1121         LdapRequest req = conn.writeRequest(ber, curMsgId);
1145         int curMsgId = conn.getMsgId();
1166         LdapRequest req = conn.writeRequest(ber, curMsgId);
1189         int curMsgId = conn.getMsgId();
1204         LdapRequest req = conn.writeRequest(ber, curMsgId, pauseAfterReceipt);
1206         BerDecoder rber = conn.readReply(req);
1216         conn.removeRequest(req);
1590         if (conn == null || !conn.useable) {
1591             if (conn != null && conn.closureReason != null) {
1592                 throw conn.closureReason;