bsonobjiterator.h

// bsonobjiterator.h
 
/*    Copyright 2009 10gen Inc.
 *
 *    Licensed under the Apache License, Version 2.0 (the "License");
 *    you may not use this file except in compliance with the License.
 *    You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 *    Unless required by applicable law or agreed to in writing, software
 *    distributed under the License is distributed on an "AS IS" BASIS,
 *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *    See the License for the specific language governing permissions and
 *    limitations under the License.
 */
 
#pragma once
 
#include <boost/preprocessor/cat.hpp>  // like the ## operator but works with __LINE__
 
#include "mongo/bson/bsonobj.h"
#include "mongo/base/disallow_copying.h"
 
namespace mongo {
 
class BSONObjIterator {
public:
    BSONObjIterator(const BSONObj& jso) {
        int sz = jso.objsize();
        if (MONGO_unlikely(sz == 0)) {
            _pos = _theend = 0;
            return;
        }
        _pos = jso.objdata() + 4;
        _theend = jso.objdata() + sz - 1;
    }
 
    BSONObjIterator(const char* start, const char* end) {
        _pos = start + 4;
        _theend = end - 1;
    }
 
    bool more() {
        return _pos < _theend;
    }
 
    bool moreWithEOO() {
        return _pos <= _theend;
    }
 
    BSONElement next(bool checkEnd) {
        verify(_pos <= _theend);
 
        int maxLen = -1;
        if (checkEnd) {
            maxLen = _theend + 1 - _pos;
            verify(maxLen > 0);
        }
 
        BSONElement e(_pos, maxLen);
        int esize = e.size(maxLen);
        massert(16446, "BSONElement has bad size", esize > 0);
        _pos += esize;
 
        return e;
    }
    BSONElement next() {
        verify(_pos <= _theend);
        BSONElement e(_pos);
        _pos += e.size();
        return e;
    }
    void operator++() {
        next();
    }
    void operator++(int) {
        next();
    }
 
    BSONElement operator*() {
        verify(_pos <= _theend);
        return BSONElement(_pos);
    }
 
private:
    const char* _pos;
    const char* _theend;
};
 
class BSONIteratorSorted {
    MONGO_DISALLOW_COPYING(BSONIteratorSorted);
 
public:
    ~BSONIteratorSorted() {
        verify(_fields);
        delete[] _fields;
        _fields = 0;
    }
 
    bool more() {
        return _cur < _nfields;
    }
 
    BSONElement next() {
        verify(_fields);
        if (_cur < _nfields)
            return BSONElement(_fields[_cur++]);
        return BSONElement();
    }
 
protected:
    class ElementFieldCmp;
    BSONIteratorSorted(const BSONObj& o, const ElementFieldCmp& cmp);
 
private:
    const char** _fields;
    int _nfields;
    int _cur;
};
 
class BSONObjIteratorSorted : public BSONIteratorSorted {
public:
    BSONObjIteratorSorted(const BSONObj& object);
};
 
class BSONArrayIteratorSorted : public BSONIteratorSorted {
public:
    BSONArrayIteratorSorted(const BSONArray& array);
};
 
#define BSONForEach(e, obj)                                                                   \
    ::mongo::BSONObjIterator BOOST_PP_CAT(it_, __LINE__)(obj);                                \
    for (::mongo::BSONElement e;                                                              \
         (BOOST_PP_CAT(it_, __LINE__).more() ? (e = BOOST_PP_CAT(it_, __LINE__).next(), true) \
                                             : false);                                        \
         /*nothing*/)
}