Lines Matching defs:const
29 int WriteRaw(const std::vector<char>& buffer, uv_write_cb write_cb);
42 const uv_buf_t* buf);
45 void ReclaimUvBuf(const uv_buf_t* buf, ssize_t read);
48 const InspectorSocket::DelegatePointer delegate_;
58 virtual void AcceptUpgrade(const std::string& accept_key) = 0;
61 virtual void Write(const std::vector<char> data) = 0;
64 std::string GetHost() const;
73 int WriteRaw(const std::vector<char>& buffer, uv_write_cb write_cb);
76 InspectorSocket* const inspector_;
83 static void dump_hex(const char* buf, size_t len) {
84 const char* ptr = buf;
85 const char* end = ptr + len;
86 const char* cptr;
110 WriteRequest(ProtocolHandler* handler, const std::vector<char>& buffer)
124 ProtocolHandler* const handler;
138 static const char CLOSE_FRAME[] = {'\x88', '\x00'};
144 static void generate_accept_string(const std::string& client_key,
147 static const char ws_magic[] = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
150 USE(SHA1(reinterpret_cast<const unsigned char*>(input.data()),
156 static std::string TrimPort(const std::string& host) {
166 static bool IsIPAddress(const std::string& host) {
236 const OpCode kOpCodeContinuation = 0x0;
237 const OpCode kOpCodeText = 0x1;
238 const OpCode kOpCodeBinary = 0x2;
239 const OpCode kOpCodeClose = 0x8;
240 const OpCode kOpCodePing = 0x9;
241 const OpCode kOpCodePong = 0xA;
243 const unsigned char kFinalBit = 0x80;
244 const unsigned char kReserved1Bit = 0x40;
245 const unsigned char kReserved2Bit = 0x20;
246 const unsigned char kReserved3Bit = 0x10;
247 const unsigned char kOpCodeMask = 0xF;
248 const unsigned char kMaskBit = 0x80;
249 const unsigned char kPayloadLengthMask = 0x7F;
251 const size_t kMaxSingleBytePayloadLength = 125;
252 const size_t kTwoBytePayloadLengthField = 126;
253 const size_t kEightBytePayloadLengthField = 127;
254 const size_t kMaskingKeyWidthInBytes = 4;
256 static std::vector<char> encode_frame_hybi17(const std::vector<char>& message) {
260 const size_t data_length = message.size();
284 static ws_decode_result decode_frame_hybi17(const std::vector<char>& buffer,
347 static const uint64_t max_payload_length = 0x7FFFFFFFFFFFFFFFull;
348 static const size_t max_length = SIZE_MAX;
379 void AcceptUpgrade(const std::string& accept_key) override { }
400 void Write(const std::vector<char> data) override {
440 int ParseWsFrames(const std::vector<char>& buffer) {
471 HttpEvent(const std::string& path, bool upgrade, bool isGET,
472 const std::string& ws_key, const std::string& host)
496 void AcceptUpgrade(const std::string& accept_key) override {
499 const char accept_ws_prefix[] = "HTTP/1.1 101 Switching Protocols\r\n"
503 const char accept_ws_suffix[] = "\r\n\r\n";
518 const char HANDSHAKE_FAILED_RESPONSE[] =
547 for (const HttpEvent& event : events) {
562 void Write(const std::vector<char> data) override {
578 static int OnHeaderValue(llhttp_t* parser, const char* at, size_t length) {
585 static int OnHeaderField(llhttp_t* parser, const char* at, size_t length) {
595 static int OnPath(llhttp_t* parser, const char* at, size_t length) {
620 std::string HeaderValue(const std::string& header) const {
623 for (const auto& header_value : headers_) {
635 bool IsAllowedHost(const std::string& host_with_port) const {
660 int ProtocolHandler::WriteRaw(const std::vector<char>& buffer,
669 std::string ProtocolHandler::GetHost() const {
679 const sockaddr_in6* v6 = reinterpret_cast<const sockaddr_in6*>(&addr);
682 const sockaddr_in* v4 = reinterpret_cast<const sockaddr_in*>(&addr);
721 int TcpHolder::WriteRaw(const std::vector<char>& buffer, uv_write_cb write_cb) {
747 const uv_buf_t* buf) {
771 void TcpHolder::ReclaimUvBuf(const uv_buf_t* buf, ssize_t read) {
798 void InspectorSocket::AcceptUpgrade(const std::string& ws_key) {
814 void InspectorSocket::Write(const char* data, size_t len) {