Lines Matching +defs:dbc +defs:close
141 void set_cursor(BaseType *dbc)
143 assert(dbc != NULL);
150 csr_ptr_ = dbc;
210 // wraps the Berkeley DB cursor, in order for the ResourceManager to close
217 // DbCursorBase* pointer, so that when need to close the cursor, it calls
218 // DbCursorBase::close() function.
245 inline int close()
250 ret = csr_->close();
279 close();
342 // state(move/close, etc).
690 BDBOP2(csr_->count(&cnt, 0), ret, close());
722 pos), ret, DB_KEYEXIST, close());
725 pos), ret, close());
751 ret, close());
793 BDBOP2(csr_->del(0), ret, close());
855 DbCursor(const DbCursor<key_dt, data_dt>& dbc) :
856 DbCursorBase(dbc),
857 curr_key_(dbc.curr_key_), curr_data_(dbc.curr_data_)
861 dbc.dup(*this);
862 csr_status_ = dbc.csr_status_;
863 if (csr_ || dbc.csr_)
864 this->rmw_get_ = set_rmw(dbc.rmw_get_,
865 ((DBC*)dbc.csr_)->dbenv);
867 rmw_get_ = dbc.rmw_get_;
869 bulk_retrieval_ = dbc.bulk_retrieval_;
873 key_buf_.set_data(pk = DbstlMalloc(dbc.key_buf_.get_ulen()));
874 key_buf_.set_ulen(dbc.key_buf_.get_ulen());
875 key_buf_.set_size(dbc.key_buf_.get_size());
877 memcpy(pk, dbc.key_buf_.get_data(), key_buf_.get_ulen());
879 data_buf_.set_data(pd = DbstlMalloc(dbc.data_buf_.get_ulen()));
880 data_buf_.set_ulen(dbc.data_buf_.get_ulen());
881 data_buf_.set_size(dbc.data_buf_.get_size());
883 memcpy(pd, dbc.data_buf_.get_data(), data_buf_.get_ulen());
884 if (dbc.recno_itr_) {
887 recno_itr_->set_pointer(dbc.recno_itr_->get_pointer());
890 if (dbc.multi_itr_) {
893 multi_itr_->set_pointer(dbc.multi_itr_->get_pointer());
898 directdb_get_ = dbc.directdb_get_;
906 close(); // Call close() ahead of freeing following buffers.
918 (const DbCursor<key_dt, data_dt>& dbc)
923 DbCursorBase::operator =(dbc);
924 dbc.dup(*this);
925 curr_key_ = dbc.curr_key_;
926 curr_data_ = dbc.curr_data_;
927 rmw_get_ = dbc.rmw_get_;
928 this->bulk_retrieval_ = dbc.bulk_retrieval_;
929 this->directdb_get_ = dbc.directdb_get_;
933 ulen = dbc.key_buf_.get_ulen()));
935 key_buf_.set_size(dbc.key_buf_.get_size());
937 memcpy(pk, dbc.key_buf_.get_data(), ulen);
940 ulen = dbc.key_buf_.get_ulen()));
942 data_buf_.set_size(dbc.data_buf_.get_size());
944 memcpy(pk, dbc.key_buf_.get_data(), ulen);
946 if (dbc.recno_itr_) {
953 recno_itr_->set_pointer(dbc.recno_itr_->get_pointer());
959 if (dbc.multi_itr_) {
966 multi_itr_->set_pointer(dbc.multi_itr_->get_pointer());
973 return dbc;
1099 inline void close()