Close connection if this command is over max-conn-rbuf-size (#834)

Update Pink
OpenAtomFoundation · Dec 20, 2019 · af3e890 · af3e890
1 parent 4d5b397
commit af3e890
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 4 deletions.
diff --git a/include/pika_dispatch_thread.h b/include/pika_dispatch_thread.h
@@ -36,7 +36,8 @@ class PikaDispatchThread {
  pink::Thread* server_thread,
  void* worker_specific_data,
  pink::PinkEpoll* pink_epoll) const {
- return std::make_shared<PikaClientConn>(connfd, ip_port, server_thread, pink_epoll, pink::HandleType::kAsynchronous, max_conn_rbuf_size_);
+ return std::static_pointer_cast<pink::PinkConn>
+ (std::make_shared<PikaClientConn>(connfd, ip_port, server_thread, pink_epoll, pink::HandleType::kAsynchronous, max_conn_rbuf_size_));
  }
  private:
  int max_conn_rbuf_size_;

diff --git a/include/pika_repl_client_thread.h b/include/pika_repl_client_thread.h
@@ -29,7 +29,8 @@ class PikaReplClientThread : public pink::ClientThread {
  pink::Thread *thread,
  void* worker_specific_data,
  pink::PinkEpoll* pink_epoll) const override {
- return std::make_shared<PikaReplClientConn>(connfd, ip_port, thread, worker_specific_data, pink_epoll);
+ return std::static_pointer_cast<pink::PinkConn>
+ (std::make_shared<PikaReplClientConn>(connfd, ip_port, thread, worker_specific_data, pink_epoll));
  }
  };
  class ReplClientHandle : public pink::ClientHandle {

diff --git a/include/pika_repl_server_thread.h b/include/pika_repl_server_thread.h
@@ -35,7 +35,8 @@ class PikaReplServerThread : public pink::HolyThread {
  pink::Thread* thread,
  void* worker_specific_data,
  pink::PinkEpoll* pink_epoll) const override {
- return std::make_shared<PikaReplServerConn>(connfd, ip_port, thread, binlog_receiver_, pink_epoll);
+ return std::static_pointer_cast<pink::PinkConn>
+ (std::make_shared<PikaReplServerConn>(connfd, ip_port, thread, binlog_receiver_, pink_epoll));
  }
  private:
  PikaReplServerThread* binlog_receiver_;

diff --git a/third/pink b/third/pink