]> git.sur5r.net Git - openldap/blob - contrib/ldapc++/src/LDAPModifyRequest.cpp
Entry rwlock is no longer needed as concurrency is managed
[openldap] / contrib / ldapc++ / src / LDAPModifyRequest.cpp
1 /*
2  * Copyright 2000, OpenLDAP Foundation, All Rights Reserved.
3  * COPYING RESTRICTIONS APPLY, see COPYRIGHT file
4  */
5
6 #include <ldap.h>
7
8 #include "debug.h"
9
10 #include "LDAPModifyRequest.h"
11 #include "LDAPException.h"
12 #include "LDAPMessageQueue.h"
13 #include "LDAPResult.h"
14
15 using namespace std;
16
17 LDAPModifyRequest::LDAPModifyRequest(const LDAPModifyRequest& req) :
18         LDAPRequest(req){
19     DEBUG(LDAP_DEBUG_CONSTRUCT, 
20             "LDAPModifyRequest::LDAPModifyRequest(&)" << endl);
21     m_modList = new LDAPModList(*(req.m_modList));
22     m_dn = req.m_dn;
23 }
24
25 LDAPModifyRequest::LDAPModifyRequest(const string& dn, 
26         const LDAPModList *modList, LDAPAsynConnection *connect,
27         const LDAPConstraints *cons, bool isReferral,
28         const LDAPRequest* parent) :
29         LDAPRequest(connect, cons, isReferral, parent){
30     DEBUG(LDAP_DEBUG_CONSTRUCT, 
31             "LDAPModifyRequest::LDAPModifyRequest(&)" << endl);            
32     DEBUG(LDAP_DEBUG_CONSTRUCT | LDAP_DEBUG_PARAMETER, 
33             "   dn:" << dn << endl);
34     m_dn = dn;
35     m_modList = new LDAPModList(*modList);
36 }
37
38 LDAPModifyRequest::~LDAPModifyRequest(){
39     DEBUG(LDAP_DEBUG_DESTROY, 
40             "LDAPModifyRequest::~LDAPModifyRequest()" << endl);
41     delete m_modList;
42     // flush this entry from cache.
43     m_connection->uncache_entry(m_dn);
44 }
45
46 LDAPMessageQueue* LDAPModifyRequest::sendRequest(){
47     DEBUG(LDAP_DEBUG_TRACE, "LDAPModifyRequest::sendRequest()" << endl);
48     int msgID=0;
49     LDAPControl** tmpSrvCtrls=m_cons->getSrvCtrlsArray();
50     LDAPControl** tmpClCtrls=m_cons->getClCtrlsArray();
51     LDAPMod** tmpMods=m_modList->toLDAPModArray();
52     int err=ldap_modify_ext(m_connection->getSessionHandle(),m_dn.c_str(),
53             tmpMods, tmpSrvCtrls, tmpClCtrls,&msgID);
54     LDAPControlSet::freeLDAPControlArray(tmpSrvCtrls);
55     LDAPControlSet::freeLDAPControlArray(tmpClCtrls);
56     ldap_mods_free(tmpMods,1);
57     if(err != LDAP_SUCCESS){
58         throw LDAPException(err);
59     }else{
60         m_msgID=msgID;
61         return new LDAPMessageQueue(this);
62     }
63 }
64
65 LDAPRequest* LDAPModifyRequest::followReferral(LDAPMsg* ref){
66     DEBUG(LDAP_DEBUG_TRACE, "LDAPModifyRequest::followReferral()" << endl);
67     LDAPUrlList::const_iterator usedUrl;
68     LDAPUrlList urls = ((LDAPResult*)ref)->getReferralUrls();
69     LDAPAsynConnection* con = 0;
70     try {
71         con = getConnection()->referralConnect(urls,usedUrl,m_cons);
72     } catch(LDAPException e){
73         delete con;
74         return 0;
75     }
76     if(con != 0){
77         return new LDAPModifyRequest(m_dn, m_modList, con, m_cons,true,this);
78     }
79     return 0;
80 }
81
82