Searched refs:messages_ (Results 1 – 10 of 10) sorted by relevance
52 message_ = messages_.front(); in GetNextResult()53 messages_.pop_front(); in GetNextResult()73 messages_.push_back(""); in Observe()81 messages_.push_back(*(Details<std::string>(details).ptr())); in Observe()
62 std::deque<std::string> messages_; variable
169 messages_.push_back(message); in AddWebSocketMessage()184 for (size_t i = 0; i < messages_.size(); i++) { in DoCloseFlushPendingWriteTest()187 frame.insert(frame.end(), messages_[i].begin(), messages_[i].end()); in DoCloseFlushPendingWriteTest()202 std::vector<std::string> messages_; member in net::SocketStreamTest
228 return messages_; in GetMessages()235 active_log_->messages_.push_back(message); in HandleLog()
84 vector<string> messages_;
3063 messages_ = NewArray<CommandMessage>(size); in CommandMessageQueue()3072 DeleteArray(messages_); in ~CommandMessageQueue()3080 return messages_[result]; in Get()3088 messages_[end_] = message; in Put()3098 CommandMessage* array_to_free = messages_; in Expand()3100 new_queue.messages_ = array_to_free; in Expand()
663 CommandMessage* messages_; variable
766 messages_.push_back(""); in Observe()771 messages_.push_back(*(Details<std::string>(details).ptr())); in Observe()793 reply_message, results_.front(), messages_.front()); in MaybeSendResult()795 messages_.pop_front(); in MaybeSendResult()
417 std::deque<std::string> messages_; variable
398 vector<Message*> messages_; // All messages in the pool. member in google::protobuf::DescriptorPool::Tables489 STLDeleteElements(&messages_); in ~Tables()504 messages_before_checkpoint_ = messages_.size(); in Checkpoint()531 messages_.begin() + messages_before_checkpoint_, messages_.end()); in Rollback()539 messages_.resize(messages_before_checkpoint_); in Rollback()724 messages_.push_back(result); in AllocateMessage()