Lines Matching refs:ChannelMultiplexer
57 const char ChannelMultiplexer::kMuxChannelName[] = "mux";
59 struct ChannelMultiplexer::PendingChannel {
68 class ChannelMultiplexer::MuxChannel {
70 MuxChannel(ChannelMultiplexer* multiplexer, const std::string& name,
78 // Called by ChannelMultiplexer.
91 ChannelMultiplexer* multiplexer_;
102 class ChannelMultiplexer::MuxSocket : public net::StreamSocket,
195 ChannelMultiplexer::MuxChannel::MuxChannel(
196 ChannelMultiplexer* multiplexer,
207 ChannelMultiplexer::MuxChannel::~MuxChannel() {
213 scoped_ptr<net::StreamSocket> ChannelMultiplexer::MuxChannel::CreateSocket() {
220 void ChannelMultiplexer::MuxChannel::OnIncomingPacket(
233 void ChannelMultiplexer::MuxChannel::OnWriteFailed() {
238 void ChannelMultiplexer::MuxChannel::OnSocketDestroyed() {
243 bool ChannelMultiplexer::MuxChannel::DoWrite(
254 int ChannelMultiplexer::MuxChannel::DoRead(net::IOBuffer* buffer,
272 ChannelMultiplexer::MuxSocket::MuxSocket(MuxChannel* channel)
279 ChannelMultiplexer::MuxSocket::~MuxSocket() {
283 int ChannelMultiplexer::MuxSocket::Read(
299 int ChannelMultiplexer::MuxSocket::Write(
310 &ChannelMultiplexer::MuxSocket::OnWriteComplete, AsWeakPtr()));
328 void ChannelMultiplexer::MuxSocket::OnWriteComplete() {
337 void ChannelMultiplexer::MuxSocket::OnWriteFailed() {
345 void ChannelMultiplexer::MuxSocket::OnPacketReceived() {
356 ChannelMultiplexer::ChannelMultiplexer(ChannelFactory* factory,
364 ChannelMultiplexer::~ChannelMultiplexer() {
373 void ChannelMultiplexer::CreateStreamChannel(
391 base::Bind(&ChannelMultiplexer::OnBaseChannelReady,
397 void ChannelMultiplexer::CreateDatagramChannel(
404 void ChannelMultiplexer::CancelChannelCreation(const std::string& name) {
414 void ChannelMultiplexer::OnBaseChannelReady(
422 base::Bind(&ChannelMultiplexer::OnIncomingPacket,
425 base::Bind(&ChannelMultiplexer::OnWriteFailed,
432 void ChannelMultiplexer::DoCreatePendingChannels() {
441 FROM_HERE, base::Bind(&ChannelMultiplexer::DoCreatePendingChannels,
452 ChannelMultiplexer::MuxChannel* ChannelMultiplexer::GetOrCreateChannel(
467 void ChannelMultiplexer::OnWriteFailed(int error) {
471 FROM_HERE, base::Bind(&ChannelMultiplexer::NotifyWriteFailed,
476 void ChannelMultiplexer::NotifyWriteFailed(const std::string& name) {
483 void ChannelMultiplexer::OnIncomingPacket(scoped_ptr<MultiplexPacket> packet,
513 bool ChannelMultiplexer::DoWrite(scoped_ptr<MultiplexPacket> packet,
