LDAPAsynConnection.cpp [plain text]
#include "config.h"
#include "debug.h"
#include "LDAPAsynConnection.h"
#include "LDAPAddRequest.h"
#include "LDAPBindRequest.h"
#include "LDAPCompareRequest.h"
#include "LDAPDeleteRequest.h"
#include "LDAPException.h"
#include "LDAPExtRequest.h"
#include "LDAPEntry.h"
#include "LDAPModDNRequest.h"
#include "LDAPModifyRequest.h"
#include "LDAPRequest.h"
#include "LDAPRebind.h"
#include "LDAPRebindAuth.h"
#include "LDAPSearchRequest.h"
using namespace std;
LDAPAsynConnection::LDAPAsynConnection(const string& hostname, int port,
LDAPConstraints *cons ){
DEBUG(LDAP_DEBUG_CONSTRUCT,"LDAPAsynConnection::LDAPAsynConnection()"
<< endl);
DEBUG(LDAP_DEBUG_CONSTRUCT | LDAP_DEBUG_PARAMETER,
" host:" << hostname << endl << " port:" << port << endl);
cur_session=0;
m_constr = 0;
this->init(hostname, port);
this->setConstraints(cons);
}
LDAPAsynConnection::~LDAPAsynConnection(){
DEBUG(LDAP_DEBUG_DESTROY,
"LDAPAsynConnection::~LDAPAsynConnection()" << endl);
if (cur_session){
ldap_destroy_cache(cur_session);
}
unbind();
}
void LDAPAsynConnection::init(const string& hostname, int port){
DEBUG(LDAP_DEBUG_TRACE,"LDAPAsynConnection::init" << endl);
DEBUG(LDAP_DEBUG_TRACE | LDAP_DEBUG_PARAMETER,
" hostname:" << hostname << endl
<< " port:" << port << endl);
cur_session=ldap_init(hostname.c_str(),port);
m_host=hostname;
m_port=port;
int opt=3;
ldap_set_option(cur_session, LDAP_OPT_REFERRALS, LDAP_OPT_OFF);
ldap_set_option(cur_session, LDAP_OPT_PROTOCOL_VERSION, &opt);
}
int LDAPAsynConnection::start_tls(){
return ldap_start_tls_s( cur_session, NULL, NULL );
}
LDAPMessageQueue* LDAPAsynConnection::bind(const string& dn,
const string& passwd, const LDAPConstraints *cons){
DEBUG(LDAP_DEBUG_TRACE, "LDAPAsynConnection::bind()" << endl);
DEBUG(LDAP_DEBUG_TRACE | LDAP_DEBUG_PARAMETER, " dn:" << dn << endl
<< " passwd:" << passwd << endl);
LDAPBindRequest *req = new LDAPBindRequest(dn,passwd,this,cons);
try{
LDAPMessageQueue *ret = req->sendRequest();
return ret;
}catch(LDAPException e){
delete req;
throw;
}
}
LDAPMessageQueue* LDAPAsynConnection::search(const string& base,int scope,
const string& filter,
const StringList& attrs,
bool attrsOnly,
const LDAPConstraints *cons){
DEBUG(LDAP_DEBUG_TRACE, "LDAPAsynConnection::search()" << endl);
DEBUG(LDAP_DEBUG_TRACE | LDAP_DEBUG_PARAMETER, " base:" << base << endl
<< " scope:" << scope << endl
<< " filter:" << filter << endl );
LDAPSearchRequest *req = new LDAPSearchRequest(base, scope,filter, attrs,
attrsOnly, this, cons);
try{
LDAPMessageQueue *ret = req->sendRequest();
return ret;
}catch(LDAPException e){
delete req;
throw;
}
}
LDAPMessageQueue* LDAPAsynConnection::del(const string& dn,
const LDAPConstraints *cons){
DEBUG(LDAP_DEBUG_TRACE,"LDAPAsynConnection::del()" << endl);
DEBUG(LDAP_DEBUG_TRACE | LDAP_DEBUG_PARAMETER," dn:" << dn << endl);
LDAPDeleteRequest *req = new LDAPDeleteRequest(dn, this, cons);
try{
LDAPMessageQueue *ret = req->sendRequest();
return ret;
}catch(LDAPException e){
delete req;
throw;
}
}
LDAPMessageQueue* LDAPAsynConnection::compare(const string& dn,
const LDAPAttribute& attr, const LDAPConstraints *cons){
DEBUG(LDAP_DEBUG_TRACE,"LDAPAsynConnection::compare()" << endl);
DEBUG(LDAP_DEBUG_TRACE | LDAP_DEBUG_PARAMETER," dn:" << dn << endl
<< " attr:" << attr << endl);
LDAPCompareRequest *req = new LDAPCompareRequest(dn, attr, this, cons);
try{
LDAPMessageQueue *ret = req->sendRequest();
return ret;
}catch(LDAPException e){
delete req;
throw;
}
}
LDAPMessageQueue* LDAPAsynConnection::add( const LDAPEntry* le,
const LDAPConstraints *cons){
DEBUG(LDAP_DEBUG_TRACE,"LDAPAsynConnection::add()" << endl);
DEBUG(LDAP_DEBUG_TRACE | LDAP_DEBUG_PARAMETER," entry:" << *le << endl);
LDAPAddRequest *req = new LDAPAddRequest(le, this, cons);
try{
LDAPMessageQueue *ret = req->sendRequest();
return ret;
}catch(LDAPException e){
delete req;
throw;
}
}
LDAPMessageQueue* LDAPAsynConnection::modify(const string& dn,
const LDAPModList *mod, const LDAPConstraints *cons){
DEBUG(LDAP_DEBUG_TRACE,"LDAPAsynConnection::modify()" << endl);
DEBUG(LDAP_DEBUG_TRACE | LDAP_DEBUG_PARAMETER," dn:" << dn << endl);
LDAPModifyRequest *req = new LDAPModifyRequest(dn, mod, this, cons);
try{
LDAPMessageQueue *ret = req->sendRequest();
return ret;
}catch(LDAPException e){
delete req;
throw;
}
}
LDAPMessageQueue* LDAPAsynConnection::rename(const string& dn,
const string& newRDN, bool delOldRDN, const string& newParentDN,
const LDAPConstraints *cons ){
DEBUG(LDAP_DEBUG_TRACE,"LDAPAsynConnection::rename()" << endl);
DEBUG(LDAP_DEBUG_TRACE | LDAP_DEBUG_PARAMETER," dn:" << dn << endl
<< " newRDN:" << newRDN << endl
<< " newParentDN:" << newParentDN << endl
<< " delOldRDN:" << delOldRDN << endl);
LDAPModDNRequest *req = new LDAPModDNRequest(dn, newRDN, delOldRDN,
newParentDN, this, cons );
try{
LDAPMessageQueue *ret = req->sendRequest();
return ret;
}catch(LDAPException e){
delete req;
throw;
}
}
LDAPMessageQueue* LDAPAsynConnection::extOperation(const string& oid,
const string& value, const LDAPConstraints *cons ){
DEBUG(LDAP_DEBUG_TRACE,"LDAPAsynConnection::extOperation()" << endl);
DEBUG(LDAP_DEBUG_TRACE | LDAP_DEBUG_PARAMETER," oid:" << oid << endl);
LDAPExtRequest *req = new LDAPExtRequest(oid, value, this,cons);
try{
LDAPMessageQueue *ret = req->sendRequest();
return ret;
}catch(LDAPException e){
delete req;
throw;
}
}
void LDAPAsynConnection::abandon(LDAPMessageQueue *q){
DEBUG(LDAP_DEBUG_TRACE,"LDAPAsynConnection::abandon()" << endl);
LDAPRequestStack *reqStack=q->getRequestStack();
LDAPRequest *req;
while(! reqStack->empty()){
req=reqStack->top();
if (ldap_abandon_ext(cur_session, req->getMsgID(), 0, 0)
!= LDAP_SUCCESS){
throw LDAPException(this);
}
delete req;
reqStack->pop();
}
}
void LDAPAsynConnection::unbind(){
DEBUG(LDAP_DEBUG_TRACE,"LDAPAsynConnection::unbind()" << endl);
if(cur_session){
LDAPControl** tmpSrvCtrls=m_constr->getSrvCtrlsArray();
LDAPControl** tmpClCtrls=m_constr->getClCtrlsArray();
int err=ldap_unbind_ext(cur_session, tmpSrvCtrls, tmpClCtrls);
cur_session=0;
LDAPControlSet::freeLDAPControlArray(tmpSrvCtrls);
LDAPControlSet::freeLDAPControlArray(tmpClCtrls);
if(err != LDAP_SUCCESS){
throw LDAPException(err);
}
}
}
void LDAPAsynConnection::setConstraints(LDAPConstraints *cons){
DEBUG(LDAP_DEBUG_TRACE,"LDAPAsynConnection::setConstraints()" << endl);
m_constr=cons;
}
const LDAPConstraints* LDAPAsynConnection::getConstraints() const {
DEBUG(LDAP_DEBUG_TRACE,"LDAPAsynConnection::getConstraints()" << endl);
return m_constr;
}
LDAP* LDAPAsynConnection::getSessionHandle() const{
DEBUG(LDAP_DEBUG_TRACE,"LDAPAsynConnection::getSessionHandle()" << endl);
return cur_session;
}
const string& LDAPAsynConnection::getHost() const{
DEBUG(LDAP_DEBUG_TRACE,"LDAPAsynConnection::setHost()" << endl);
return m_host;
}
int LDAPAsynConnection::getPort() const{
DEBUG(LDAP_DEBUG_TRACE,"LDAPAsynConnection::getPort()" << endl);
return m_port;
}
LDAPAsynConnection* LDAPAsynConnection::referralConnect(
const LDAPUrlList& urls, LDAPUrlList::const_iterator& usedUrl,
const LDAPConstraints* cons) const {
DEBUG(LDAP_DEBUG_TRACE, "LDAPAsynConnection::referralConnect()" << endl)
LDAPUrlList::const_iterator conUrl;
LDAPAsynConnection* tmpConn=0;
const LDAPRebind* rebind = cons->getReferralRebind();
LDAPRebindAuth* auth = 0;
for(conUrl=urls.begin(); conUrl!=urls.end(); conUrl++){
string host= conUrl->getHost();
int port= conUrl->getPort();
DEBUG(LDAP_DEBUG_TRACE," connecting to: " << host << ":" <<
port << endl);
tmpConn=new LDAPAsynConnection(host.c_str(),port);
int err=0;
if(rebind){
auth=rebind->getRebindAuth(host, port);
}
if(auth){
string dn = auth->getDN();
string passwd = auth->getPassword();
const char* c_dn=0;
const char* c_passwd=0;
if(dn != ""){
c_dn = dn.c_str();
}
if(passwd != ""){
c_passwd = passwd.c_str();
}
err = ldap_simple_bind_s(tmpConn->getSessionHandle(), c_dn,
c_passwd);
} else {
err = ldap_simple_bind_s(tmpConn->getSessionHandle(), 0,0);
}
if( err == LDAP_SUCCESS ){
usedUrl=conUrl;
return tmpConn;
}else{
delete tmpConn;
tmpConn=0;
}
auth=0;
}
return 0;
}
int LDAPAsynConnection::enableCache(long timeout, long maxmem){
int retval = ldap_enable_cache(cur_session, timeout, maxmem);
if (!retval)
m_cacheEnabled = true;
return retval;
}
void LDAPAsynConnection::disableCache(){
ldap_disable_cache(cur_session);
m_cacheEnabled = false;
}
void LDAPAsynConnection::uncache_entry(string &dn){
if (m_cacheEnabled){
ldap_uncache_entry(cur_session, dn.c_str());
}
}
void LDAPAsynConnection::flush_cache(){
if (m_cacheEnabled){
ldap_flush_cache(cur_session);
}
}