Message.h

Go to the documentation of this file.

/*
 *
 * Copyright 2006 Savarese Software Research Corporation
 *
 * 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.savarese.com/software/ApacheLicense-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.
 */

#ifndef __SSRC_SPREAD_MESSAGE_H
#define __SSRC_SPREAD_MESSAGE_H

#include <ssrc/spread/detail/ByteBuffer.h>
#include <ssrc/spread/MembershipInfo.h>

__BEGIN_NS_SSRC_SPREAD

class Message : public BaseMessage, public detail::ByteBuffer {
protected:

#ifdef LIBSSRCSPREAD_ENABLE_MEMBERSHIP_INFO

  virtual int sp_get_membership_info(Spread::membership_info *info) const {
    return Spread::SP_get_memb_info(&(this->operator[](0)), service(), info);
  }

  virtual int sp_get_vs_set_members(const Spread::vs_set_info *vs_set,
                                    Spread::group_type member_names[],
                                    unsigned int member_names_count)
    const
  {
    return
      Spread::SP_get_vs_set_members(&(this->operator[](0)),
                                    vs_set, member_names, member_names_count);
  }

  virtual int sp_get_vs_sets_info(Spread::vs_set_info *vs_sets,
                                  unsigned int num_vs_sets,
                                  unsigned int *index)
    const
  {
    return
      Spread::SP_get_vs_sets_info(&(this->operator[](0)),
                                  vs_sets, num_vs_sets, index);
  }

#endif

public:

  enum {
    DefaultCapacity = 4096
  };

  explicit Message(const unsigned int capacity = DefaultCapacity) :
    detail::ByteBuffer(capacity) { }

  virtual unsigned int size() const {
    return detail::ByteBuffer::size();
  }

  virtual void clear() {
    return detail::ByteBuffer::clear();
  }

};

__END_NS_SSRC_SPREAD

#endif