← Back to branch summary

~ubuntu-branches/ubuntu/raring/ceph/raring

« back to all changes in this revision

Viewing changes to src/messages/MOSDPGQuery.h

  • Committer: Package Import Robot
  • Author(s): James Page
  • Date: 2012-06-08 15:54:37 UTC
  • mfrom: (1.1.8) (0.1.13 sid)
  • Revision ID: package-import@ubuntu.com-20120608155437-gy3j9k6wzv7w4gn9
Tags: 0.44.1-1ubuntu1
* Merge from Debian unstable.  Remaining changes:
  - d/control: Switch from libcryptopp to libnss as libcryptopp
    is not seeded.
  - d/control,d/rules: Move from python-support to dh_python2.
  - d/patches/manpage_updates*.patch: cherry picked upstream manpage
    updates warning about lack of encryption, per MIR review.
  - d/rules,d/control: Drop radosgw since libfcgi is not in main and
    the code may not be suitable for LTS.
  - d/rules,d/control: Drop tcmalloc since google perftools is not
    in main yet.
  - d/rules,d/control: Drop ceph-fuse entirely per MIR review
    recommendation.
* d/patches/fix-radosgw-tests.patch: Cherry picked patch from upstream
  VCS to fixup tests to conditionally use radosgw if enabled.

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/messages/MOSDPGQuery.h
27
27
 
28
28
 public:
29
29
  version_t get_epoch() { return epoch; }
30
 
  map<pg_t,PG::Query>  pg_list;
 
30
  map<pg_t,pg_query_t>  pg_list;
31
31
 
32
 
  MOSDPGQuery() {}
33
 
  MOSDPGQuery(epoch_t e, map<pg_t,PG::Query>& ls) :
 
32
  MOSDPGQuery() : Message(MSG_OSD_PG_QUERY) {}
 
33
  MOSDPGQuery(epoch_t e, map<pg_t,pg_query_t>& ls) :
34
34
    Message(MSG_OSD_PG_QUERY),
35
35
    epoch(e) {
36
36
    pg_list.swap(ls);
39
39
  ~MOSDPGQuery() {}
40
40
 
41
41
public:  
42
 
  const char *get_type_name() { return "pg_query"; }
43
 
  void print(ostream& out) {
 
42
  const char *get_type_name() const { return "pg_query"; }
 
43
  void print(ostream& out) const {
44
44
    out << "pg_query(";
45
 
    for (map<pg_t,PG::Query>::iterator p = pg_list.begin(); p != pg_list.end(); ++p) {
 
45
    for (map<pg_t,pg_query_t>::const_iterator p = pg_list.begin(); p != pg_list.end(); ++p) {
46
46
      if (p != pg_list.begin())
47
47
        out << ",";
48
48
      out << p->first;
50
50
    out << " epoch " << epoch << ")";
51
51
  }
52
52
 
53
 
  void encode_payload(CephContext *cct) {
 
53
  void encode_payload(uint64_t features) {
54
54
    ::encode(epoch, payload);
55
55
    ::encode(pg_list, payload);
56
56
  }
57
 
  void decode_payload(CephContext *cct) {
 
57
  void decode_payload() {
58
58
    bufferlist::iterator p = payload.begin();
59
59
    ::decode(epoch, p);
60
60
    ::decode(pg_list, p);