pika_binlog_sender_thread.h

// Copyright (c) 2015-present, Qihoo, Inc.  All rights reserved.
// This source code is licensed under the BSD-style license found in the
// LICENSE file in the root directory of this source tree. An additional grant
// of patent rights can be found in the PATENTS file in the same directory.

#ifndef PIKA_BINLOG_SENDER_THREAD_H_
#define PIKA_BINLOG_SENDER_THREAD_H_

#include "pink_thread.h"
//#include "redis_cli.h"
#include "slice.h"
#include "status.h"

#include "env.h"
#include "slash_mutex.h"


namespace pink {
class RedisCli;
}

class PikaBinlogSenderThread : public pink::Thread {
 public:

  PikaBinlogSenderThread(std::string &ip, int port, slash::SequentialFile *queue, uint32_t filenum, uint64_t con_offset);

  virtual ~PikaBinlogSenderThread();

  /*
   * Get and Set
   */
  uint64_t last_record_offset () {
    slash::RWLock l(&rwlock_, false);
    return last_record_offset_;
  }
  uint32_t filenum() {
    slash::RWLock l(&rwlock_, false);
    return filenum_;
  }
  uint64_t con_offset() {
    slash::RWLock l(&rwlock_, false);
    return con_offset_;
  }

  int trim();
  uint64_t get_next(bool &is_error);


 private:

  slash::Status Parse(std::string &scratch);
  slash::Status Consume(std::string &scratch);
  unsigned int ReadPhysicalRecord(slash::Slice *fragment);

  uint64_t con_offset_;
  uint32_t filenum_;

  uint64_t initial_offset_;
  uint64_t last_record_offset_;
  uint64_t end_of_buffer_offset_;

  slash::SequentialFile* queue_;
  char* const backing_store_;
  slash::Slice buffer_;


  std::string ip_;
  int port_;

  pthread_rwlock_t rwlock_;


  pink::RedisCli *cli_;

  virtual void* ThreadMain();
};

#endif