Lines Matching full:packet
28 PendingPacket(scoped_ptr<MultiplexPacket> packet,
30 : packet(packet.Pass()),
38 bool is_empty() { return pos >= packet->data().size(); }
41 size = std::min(size, packet->data().size() - pos);
42 memcpy(buffer, packet->data().data() + pos, size);
48 scoped_ptr<MultiplexPacket> packet;
80 void OnIncomingPacket(scoped_ptr<MultiplexPacket> packet,
86 bool DoWrite(scoped_ptr<MultiplexPacket> packet,
221 scoped_ptr<MultiplexPacket> packet,
223 DCHECK_EQ(packet->channel_id(), receive_id_);
224 if (packet->data().size() > 0) {
225 pending_packets_.push_back(new PendingPacket(packet.Pass(), done_task));
244 scoped_ptr<MultiplexPacket> packet,
246 packet->set_channel_id(send_id_);
248 packet->set_channel_name(name_);
251 return multiplexer_->DoWrite(packet.Pass(), done_task);
304 scoped_ptr<MultiplexPacket> packet(new MultiplexPacket());
306 packet->mutable_data()->assign(buffer->data(), size);
309 bool result = channel_->DoWrite(packet.Pass(), base::Bind(
483 void ChannelMultiplexer::OnIncomingPacket(scoped_ptr<MultiplexPacket> packet,
485 if (!packet->has_channel_id()) {
486 LOG(ERROR) << "Received packet without channel_id.";
491 int receive_id = packet->channel_id();
499 if (!packet->has_channel_name()) {
500 LOG(ERROR) << "Received packet with unknown channel_id and "
505 channel = GetOrCreateChannel(packet->channel_name());
510 channel->OnIncomingPacket(packet.Pass(), done_task);
513 bool ChannelMultiplexer::DoWrite(scoped_ptr<MultiplexPacket> packet,
515 return writer_.Write(SerializeAndFrameMessage(*packet), done_task);
