Lines Matching defs:context
533 struct lws_context_per_thread *pt = &h->context->pt[h->tsi];
549 lws_service_assert_loop_thread(h->context, h->tsi);
557 ms = lws_retry_get_delay_ms(h->context, h->policy->retry_bo,
596 * lws service thread context.
610 lws_service_assert_loop_thread(h->context, h->tsi);
638 lws_service_assert_loop_thread(h->context, h->tsi);
653 p = lws_smd_msg_alloc(h->context, _class, len - LWS_SMD_SS_RX_HEADER_LEN);
661 if (lws_smd_msg_send(h->context, p)) {
683 lws_service_assert_loop_thread(h->context, h->tsi);
710 h->u.smd.smd_peer = lws_smd_register(h->context, h,
766 i.context = h->context;
781 i.vhost = lws_get_vhost_by_name(h->context,
851 path = lws_malloc(h->context->max_http_header_data, __func__);
858 ssp->munge(h, path, h->context->max_http_header_data, &i, &ct);
864 h->policy->plugins[0]->munge(h, path, h->context->max_http_header_data);
873 lws_metrics_caliper_bind(h->cal_txn, h->context->mth_ss_conn);
927 lws_service_assert_loop_thread(h->context, h->tsi);
943 lws_ss_create(struct lws_context *context, int tsi, const lws_ss_info_t *ssi,
947 struct lws_context_per_thread *pt = &context->pt[tsi];
957 lws_service_assert_loop_thread(context, tsi);
968 * We have to do a temp inherit from context to find out
974 lws_xos_init(&temp_fic.xos, lws_xos(&context->fic.xos));
975 lws_fi_inherit_copy(&temp_fic, &context->fic, "ss", ssi->streamtype);
980 pol = lws_ss_policy_lookup(context, ssi->streamtype);
984 pol = lws_ss_policy_lookup(context, ssi->streamtype);
987 lwsl_cx_info(context, "unknown stream type %s",
1049 h->lc.log_cx = context->log_cx;
1052 __lws_lc_tag(context, &context->lcg[LWSLCG_WSI_SS_CLIENT],
1058 __lws_lc_tag(context, &context->lcg[LWSLCG_WSI_SS_CLIENT],
1064 lws_xos_init(&h->fic.xos, lws_xos(&context->fic.xos));
1068 lws_fi_inherit_copy(&h->fic, &context->fic, "ss", ssi->streamtype);
1073 h->context = context;
1108 lwsl_cx_info(context, "%s metadata count %d",
1160 h->u.smd.smd_peer = lws_smd_register(context, h, 0,
1165 lwsl_cx_info(context, "registered SS SMD");
1175 lwsl_cx_info(context, "creating server");
1186 vho = lws_get_vhost_by_name(context,
1246 vho = lws_create_vhost(context, &i);
1250 lwsl_cx_err(context, "failed to create vh");
1263 lwsl_cx_info(context, "CREATING returned status %d", (int)r);
1268 lwsl_cx_notice(context, "created server %s",
1287 if (!lws_ss_policy_ref_trust_store(context, h->policy, 1 /* do the ref */) ||
1295 !lws_ss_policy_ref_trust_store(context, h->policy, 1 /* do the ref */)) {
1375 lws_service_assert_loop_thread(h->context, h->tsi);
1419 pt = &h->context->pt[h->tsi];
1437 v = lws_get_vhost_by_name(h->context, h->policy->streamtype);
1503 lws_ss_policy_unref_trust_store(h->context, h->policy);
1507 lws_ss_policy_unref_trust_store(h->context, h->policy);
1535 lws_sul_debug_zombies(h->context, h, sizeof(*h) + h->info.user_alloc,
1538 __lws_lc_untag(h->context, &h->lc);
1584 lws_service_assert_loop_thread(h->context, h->tsi);
1614 lws_sul_schedule(h->context, 0, &h->u.smd.sul_write,
1650 lws_service_assert_loop_thread(h->context, h->tsi);
1667 /* used on context destroy when iterating listed lws_ss on a pt */
1699 return h->context;
1716 lws_service_assert_loop_thread(h->context, h->tsi);
1731 lws_service_assert_loop_thread(h->context, h->tsi);
1766 lws_service_assert_loop_thread(h->context, h->tsi);
1771 lws_sul_schedule(h->context, 0, &h->sul_timeout, lws_ss_to_cb,
1779 lws_service_assert_loop_thread(h->context, h->tsi);