Searched refs:io_ (Results 1 – 14 of 14) sorted by relevance
15 : io_(transport), connected_(true), ack_enabled_(true) {} in Session()17 void Session::WaitForDebugStubEvent() { io_->WaitForDebugStubEvent(); } in WaitForDebugStubEvent()19 bool Session::SignalThreadEvent() { return io_->SignalThreadEvent(); } in SignalThreadEvent()21 bool Session::IsDataAvailable() const { return io_->IsDataAvailable(); } in IsDataAvailable()26 io_->Disconnect(); in Disconnect()31 if (!io_->Read(ch, 1)) { in GetChar()47 if (!io_->Write(data.data(), static_cast<int32_t>(data.length()))) { in SendPacket()132 return io_->Write(out, 3); in GetPacket()134 return io_->Write(out, 1); in GetPacket()139 io_->Write("-", 1); in GetPacket()
63 TransportBase* io_; // Transport object not owned by the Session. variable
70 VP8Io io_; member117 idec->io_.data = new_base; in DoRemap()118 idec->io_.data_size = MemDataSize(mem); in DoRemap()291 VP8ExitCritical((VP8Decoder*)idec->dec_, &idec->io_); in IDecError()303 idec->io_.data = mem->buf_ + mem->start_; in ChangeState()304 idec->io_.data_size = MemDataSize(mem); in ChangeState()364 idec->io_.data = data; in DecodeVP8FrameHeader()365 idec->io_.data_size = curr_size; in DecodeVP8FrameHeader()401 VP8Io* const io = &idec->io_; in DecodePartition0()454 VP8Io* const io = &idec->io_; in DecodeRemaining()[all …]
792 assert(row <= dec->io_->crop_bottom); in ProcessRows()797 VP8Io* const io = dec->io_; in ProcessRows()868 ALPHDecoder* const alph_dec = (ALPHDecoder*)dec->io_->opaque; in ExtractPalettedAlphaRows()871 alph_dec->filter_ == WEBP_FILTER_HORIZONTAL) ? dec->io_->crop_top in ExtractPalettedAlphaRows()874 assert(last_row <= dec->io_->crop_bottom); in ExtractPalettedAlphaRows()877 const int width = dec->io_->width; in ExtractPalettedAlphaRows()1553 assert(last_row <= dec->io_->crop_bottom); in ExtractAlphaRows()1558 ALPHDecoder* const alph_dec = (ALPHDecoder*)dec->io_->opaque; in ExtractAlphaRows()1560 const int width = dec->io_->width; // the final width (!= dec->width_) in ExtractAlphaRows()1587 dec->io_ = &alph_dec->io_; in VP8LDecodeAlphaHeader()[all …]
34 VP8Io io_; member
55 VP8Io* const io = &dec->io_; in ALPHInit()113 const int height = alph_dec->io_.crop_bottom; in ALPHDecode()
61 VP8Io* io_; member
171 VP8Io io_; // copy of the VP8Io to pass to put() member
519 ctx->io_ = *io; in VP8ProcessRow()650 worker->data2 = (void*)&dec->thread_ctx_.io_; in InitThreadContext()
752 if (io_ != nullptr) in StartIoThread()762 io_ = InspectorIo::Start(client_->getThreadHandle(), in StartIoThread()766 if (io_ == nullptr) { in StartIoThread()774 io_.reset(); in Stop()827 if (io_ != nullptr) { in WaitForDisconnect()828 io_->StopAcceptingNewConnections(); in WaitForDisconnect()953 return io_ != nullptr || client_->IsActive(); in IsActive()997 if (io_ == nullptr) in GetWsUrl()999 return io_->GetWsUrl(); in GetWsUrl()
56 bool IsListening() { return io_ != nullptr; } in IsListening()126 std::unique_ptr<InspectorIo> io_; variable
796 …�~O���~|||{{~�����������������adeefgjlmmmopqrqpnooppoqrqpqrsqsstuvok��oj]io_�^Xy �~���}~�����…
4145 …�Ø��z�����˧�����������{}�l݃xYut����xusoo�wXzzKW���ɖ���~Яw�ȟU��kQq��Z��i�io_��~q�U���{}��|g����…
57007 zkq7N~9yCQBJS&io_(y`KmA8t|AM<m9|9O61aBJgjg8v2HE+{YZi{jf3-XT6;64}!d