← Back to branch summary

~ubuntu-branches/ubuntu/utopic/mongodb/utopic

« back to all changes in this revision

Viewing changes to src/mongo/s/field_parser-inl.h

  • Committer: Package Import Robot
  • Author(s): James Page
  • Date: 2014-07-03 09:23:46 UTC
  • mfrom: (1.3.10) (44.1.14 sid)
  • Revision ID: package-import@ubuntu.com-20140703092346-c5bvt46wnzougyly
Tags: 1:2.6.3-0ubuntu1
https://launchpad.net/bugs/1295723
https://launchpad.net/bugs/1294455
* New upstream stable release:
  - Dropped patches, included upstream:
    + 0003-All-platforms-but-Windows-find-hash-in-std-tr1.patch
    + 0008-Use-system-libstemmer.patch
    + 0011-Use-a-signed-char-to-store-BSONType-enumerations.patch
    + 0001-SERVER-12064-Atomic-operations-for-gcc-non-Intel-arc.patch
    + 0002-SERVER-12065-Support-ARM-and-AArch64-builds.patch
  - d/p/*: Refreshed/rebased remaining patches.
  - Use system provided libyaml-cpp:
    + d/control: Add libyaml-cpp-dev to BD's.
    + d/rules: Enable --with-system-yaml option.
    + d/p/fix-yaml-detection.patch: Fix detection of libyaml-cpp library.
  - d/mongodb-server.mongodb.upstart: Sync changes from upstream.
  - d/control,mongodb-dev.*: Drop mongodb-dev package; it has no reverse
    dependencies and upstream no longer install header files.
  - d/NEWS: Point users to upstream upgrade documentation for upgrades
    from 2.4 to 2.6.
* Merge from Debian unstable.
* d/control: BD on libv8-3.14-dev to ensure that transitioning to new v8
  versions is a explicit action due to changes in behaviour in >= 3.25
  (LP: #1295723).
* d/mongodb-server.prerm: Dropped debug echo call from maintainer script
  (LP: #1294455).

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/mongo/s/field_parser-inl.h
1
 
/**
2
 
 *    Copyright (C) 2012 10gen Inc.
3
 
 *
4
 
 *    This program is free software: you can redistribute it and/or  modify
5
 
 *    it under the terms of the GNU Affero General Public License, version 3,
6
 
 *    as published by the Free Software Foundation.
7
 
 *
8
 
 *    This program is distributed in the hope that it will be useful,
9
 
 *    but WITHOUT ANY WARRANTY; without even the implied warranty of
10
 
 *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
11
 
 *    GNU Affero General Public License for more details.
12
 
 *
13
 
 *    You should have received a copy of the GNU Affero General Public License
14
 
 *    along with this program.  If not, see <http://www.gnu.org/licenses/>.
15
 
 */
16
 
 
17
 
#include "mongo/s/field_parser.h"
18
 
#include "mongo/util/mongoutils/str.h"
19
 
 
20
 
namespace mongo {
21
 
 
22
 
    using mongoutils::str::stream;
23
 
 
24
 
    // Extracts an array into a vector
25
 
    template<typename T>
26
 
    FieldParser::FieldState FieldParser::extract(BSONObj doc,
27
 
                              const BSONField<vector<T> >& field,
28
 
                              vector<T>* out,
29
 
                              string* errMsg)
30
 
    {
31
 
        BSONElement elem = doc[field.name()];
32
 
        if (elem.eoo()) {
33
 
            if (field.hasDefault()) {
34
 
                *out = field.getDefault();
35
 
                return FIELD_DEFAULT;
36
 
            }
37
 
            else {
38
 
                return FIELD_NONE;
39
 
            }
40
 
        }
41
 
 
42
 
        if (elem.type() == Array) {
43
 
            BSONArray arr = BSONArray(elem.embeddedObject());
44
 
            string elErrMsg;
45
 
 
46
 
            // Append all the new elements to the end of the vector
47
 
            size_t initialSize = out->size();
48
 
            out->resize(initialSize + arr.nFields());
49
 
 
50
 
            int i = 0;
51
 
            BSONObjIterator objIt(arr);
52
 
            while (objIt.more()) {
53
 
                BSONElement next = objIt.next();
54
 
                BSONField<T> fieldFor(next.fieldName(), out->at(initialSize + i));
55
 
 
56
 
                if (!FieldParser::extract(arr,
57
 
                                          fieldFor,
58
 
                                          &out->at(initialSize + i),
59
 
                                          &elErrMsg))
60
 
                {
61
 
                    if (errMsg) {
62
 
                        *errMsg = stream() << "error parsing element " << i << " of field "
63
 
                                           << field() << causedBy(elErrMsg);
64
 
                    }
65
 
                    return FIELD_INVALID;
66
 
                }
67
 
                i++;
68
 
            }
69
 
 
70
 
            return FIELD_SET;
71
 
        }
72
 
 
73
 
        if (errMsg) {
74
 
            *errMsg = stream() << "wrong type for '" << field() << "' field, expected "
75
 
                               << "vector array" << ", found " << doc[field.name()].toString();
76
 
        }
77
 
        return FIELD_INVALID;
78
 
    }
79
 
 
80
 
    // Extracts an object into a map
81
 
    template<typename K, typename T>
82
 
    FieldParser::FieldState FieldParser::extract(BSONObj doc,
83
 
                              const BSONField<map<K, T> >& field,
84
 
                              map<K, T>* out,
85
 
                              string* errMsg)
86
 
    {
87
 
        BSONElement elem = doc[field.name()];
88
 
        if (elem.eoo()) {
89
 
            if (field.hasDefault()) {
90
 
                *out = field.getDefault();
91
 
                return FIELD_DEFAULT;
92
 
            }
93
 
            else {
94
 
                return FIELD_NONE;
95
 
            }
96
 
        }
97
 
 
98
 
        if (elem.type() == Object) {
99
 
            BSONObj obj = elem.embeddedObject();
100
 
            string elErrMsg;
101
 
 
102
 
            BSONObjIterator objIt(obj);
103
 
            while (objIt.more()) {
104
 
                BSONElement next = objIt.next();
105
 
                T& value = (*out)[next.fieldName()];
106
 
 
107
 
                BSONField<T> fieldFor(next.fieldName(), value);
108
 
                if (!FieldParser::extract(obj, fieldFor, &value, &elErrMsg)) {
109
 
                    if (errMsg) {
110
 
                        *errMsg = stream() << "error parsing map element " << next.fieldName()
111
 
                                           << " of field " << field() << causedBy(elErrMsg);
112
 
                    }
113
 
                    return FIELD_INVALID;
114
 
                }
115
 
            }
116
 
 
117
 
            return FIELD_SET;
118
 
        }
119
 
 
120
 
        if (errMsg) {
121
 
            *errMsg = stream() << "wrong type for '" << field() << "' field, expected "
122
 
                               << "vector array" << ", found " << doc[field.name()].toString();
123
 
        }
124
 
        return FIELD_INVALID;
125
 
    }
126
 
 
127
 
} // namespace mongo