Lines Matching refs:std

41 const std::chrono::duration kConnectionDeadline = std::chrono::seconds(5);
46 std::mutex mutex_;
50 std::unordered_map<uint32_t, std::unique_ptr<Stream>> streams_;
51 std::unordered_map<uint32_t, grpc::ClientContext> contexts_;
54 std::string server_;
55 std::shared_ptr<grpc::Channel> channel_;
57 std::unique_ptr<netsim::packet::PacketStreamer::Stub> stub_;
66   std::unique_lock<std::mutex> lock(mutex_);  in StreamPackets()
67   auto server = std::string(server_rust);  in StreamPackets()
71     auto deadline = std::chrono::system_clock::now() + kConnectionDeadline;  in StreamPackets()
83   streams_[stream_id_max_] = std::move(stream);  in StreamPackets()
95       std::unique_lock<std::mutex> lock(mutex_);  in ReadPacketResponseLoop()
106     std::vector<unsigned char> proto_bytes(response.ByteSizeLong());  in ReadPacketResponseLoop()
116                         const rust::Slice<::std::uint8_t const> proto_bytes) {  in WritePacketRequest()
123   std::unique_lock<std::mutex> lock(mutex_);  in WritePacketRequest()