Lines Matching defs:std
115 ConnectionHandler::ConnectionHandler(struct ev_loop *loop, std::mt19937 &gen)
193 const std::shared_ptr<TicketKeys> &ticket_keys) {
205 worker->send(std::move(wev));
210 std::shared_ptr<DownstreamConfig> downstreamconf) {
217 worker->send(std::move(wev));
284 single_worker_ = std::make_unique<Worker>(
388 auto worker = std::make_unique<Worker>(
411 workers_.push_back(std::move(worker));
458 worker->send(std::move(wev));
464 thread_join_fut_ = std::async(std::launch::async, [this]() {
541 worker->send(std::move(wev));
554 void ConnectionHandler::add_acceptor(std::unique_ptr<AcceptHandler> h) {
555 acceptors_.push_back(std::move(h));
590 std::shared_ptr<TicketKeys> ticket_keys) {
591 ticket_keys_ = std::move(ticket_keys);
597 const std::shared_ptr<TicketKeys> &ConnectionHandler::get_ticket_keys() const {
674 std::array<uint8_t, 4_k> buf;
696 std::copy_n(std::begin(buf), n, std::back_inserter(ocsp_.resp));
747 std::atomic_store_explicit(
749 std::make_shared<std::vector<uint8_t>>(ocsp_.resp),
750 std::memory_order_release);
752 std::lock_guard<std::mutex> g(quic_tls_ctx_data->mu);
754 std::make_shared<std::vector<uint8_t>>(ocsp_.resp);
765 std::atomic_store_explicit(
767 std::make_shared<std::vector<uint8_t>>(std::move(ocsp_.resp)),
768 std::memory_order_release);
770 std::lock_guard<std::mutex> g(tls_ctx_data->mu);
772 std::make_shared<std::vector<uint8_t>>(std::move(ocsp_.resp));
791 ocsp_.resp = std::vector<uint8_t>();
834 std::unique_ptr<MemcachedDispatcher> dispatcher) {
835 tls_ticket_key_memcached_dispatcher_ = std::move(dispatcher);
863 std::min(MAX_BACKOFF_EXP, tls_ticket_key_memcached_get_retry_count_));
864 auto dist = std::uniform_real_distribution<>(-JITTER * base_backoff,
895 const std::shared_ptr<TicketKeys> &ticket_keys, ev_timer *w) {
955 std::vector<SerialEvent> q;
957 std::lock_guard<std::mutex> g(serial_event_mu_);
984 const std::shared_ptr<DownstreamConfig> &downstreamconf) {
991 std::lock_guard<std::mutex> g(serial_event_mu_);
993 serial_events_.push_back(std::move(ev));
1003 const std::vector<SSL_CTX *> &
1009 const std::vector<SSL_CTX *> &
1027 if (!std::equal(cid_prefix, cid_prefix + SHRPX_QUIC_CID_PREFIXLEN,
1034 wev.quic_pkt = std::make_unique<QUICPacket>(faddr->index, remote_addr,
1037 worker->send(std::move(wev));
1046 std::shared_ptr<QUICKeyingMaterials> qkms) {
1047 quic_keying_materials_ = std::move(qkms);
1050 const std::shared_ptr<QUICKeyingMaterials> &
1056 const std::vector<std::array<uint8_t, SHRPX_QUIC_CID_PREFIXLEN>>
1068 if (std::equal(std::begin(cid_prefix), std::end(cid_prefix), dcid)) {
1078 std::vector<BPFRef> &ConnectionHandler::get_quic_bpf_refs() {
1100 const std::vector<QUICLingeringWorkerProcess> &quic_lwps) {
1108 std::array<uint8_t, 512> header;
1118 p = std::copy_n(reinterpret_cast<const uint8_t *>(&remote_addr.su),
1121 p = std::copy_n(reinterpret_cast<const uint8_t *>(&local_addr.su),
1147 std::array<char, STRERROR_BUFSIZE> errbuf;
1160 std::array<uint8_t, 65536> buf;
1169 std::array<char, STRERROR_BUFSIZE> errbuf;
1203 auto pkt = std::make_unique<QUICPacket>();
1289 std::array<uint8_t, SHRPX_QUIC_DECRYPTED_DCIDLEN> decrypted_dcid;
1298 if (!std::equal(std::begin(decrypted_dcid),
1299 std::begin(decrypted_dcid) + SHRPX_QUIC_CID_PREFIXLEN,
1306 .quic_pkt = std::move(pkt),
1308 worker->send(std::move(wev));