aboutsummaryrefslogtreecommitdiff
path: root/src/supplemental/websocket
diff options
context:
space:
mode:
Diffstat (limited to 'src/supplemental/websocket')
-rw-r--r--src/supplemental/websocket/websocket.c28
1 files changed, 14 insertions, 14 deletions
diff --git a/src/supplemental/websocket/websocket.c b/src/supplemental/websocket/websocket.c
index 08b3a071..f40fbb4a 100644
--- a/src/supplemental/websocket/websocket.c
+++ b/src/supplemental/websocket/websocket.c
@@ -121,7 +121,7 @@ struct nni_ws_dialer {
nng_stream_dialer ops;
nni_http_req *req;
nni_http_res *res;
- nni_http_client *client;
+ nng_http_client *client;
nni_mtx mtx;
nni_cv cv;
char *proto;
@@ -1279,7 +1279,7 @@ ws_http_cb_dialer(nni_ws *ws, nni_aio *aio)
return;
}
- status = nni_http_get_status(ws->http);
+ status = nng_http_get_status(ws->http);
switch (status) {
case NNG_HTTP_STATUS_SWITCHING:
break;
@@ -1585,7 +1585,7 @@ ws_handler(nng_http *conn, void *arg, nng_aio *aio)
nni_list_append(&l->reply, ws);
nng_http_write_response(conn, &ws->httpaio);
- (void) nni_http_hijack(conn);
+ (void) nng_http_hijack(conn);
nni_aio_set_output(aio, 0, NULL);
nni_aio_finish(aio, 0, 0);
nni_mtx_unlock(&l->mtx);
@@ -2026,8 +2026,8 @@ nni_ws_listener_alloc(nng_stream_listener **wslp, const nng_url *url)
return (rv);
}
- nni_http_handler_set_host(l->handler, host);
- nni_http_handler_set_data(l->handler, l, 0);
+ nng_http_handler_set_host(l->handler, host);
+ nng_http_handler_set_data(l->handler, l, 0);
if ((rv = nni_http_server_init(&l->server, url)) != 0) {
ws_listener_free(l);
@@ -2103,7 +2103,7 @@ ws_conn_cb(void *arg)
nni_base64_encode(raw, 16, ws->keybuf, 24);
ws->keybuf[24] = '\0';
- if ((rv = nni_http_set_uri(
+ if ((rv = nng_http_set_uri(
ws->http, d->url->u_path, d->url->u_query)) != 0) {
goto err;
}
@@ -2123,7 +2123,7 @@ ws_conn_cb(void *arg)
}
NNI_LIST_FOREACH (&d->headers, hdr) {
- if ((rv = nni_http_set_header(
+ if ((rv = nng_http_set_header(
ws->http, hdr->name, hdr->value)) != 0) {
goto err;
}
@@ -2186,7 +2186,7 @@ ws_dialer_free(void *arg)
NNI_FREE_STRUCT(hdr);
}
if (d->client) {
- nni_http_client_fini(d->client);
+ nng_http_client_free(d->client);
}
if (d->url) {
nng_url_free(d->url);
@@ -2243,7 +2243,7 @@ ws_dialer_dial(void *arg, nni_aio *aio)
ws->recv_text = d->recv_text;
ws->send_text = d->send_text;
nni_list_append(&d->wspend, ws);
- nni_http_client_connect(d->client, &ws->connaio);
+ nng_http_client_connect(d->client, &ws->connaio);
nni_mtx_unlock(&d->mtx);
}
@@ -2510,14 +2510,14 @@ static int
ws_dialer_get_tls(void *arg, nng_tls_config **cfgp)
{
nni_ws_dialer *d = arg;
- return (nni_http_client_get_tls(d->client, cfgp));
+ return (nng_http_client_get_tls(d->client, cfgp));
}
static int
ws_dialer_set_tls(void *arg, nng_tls_config *cfg)
{
nni_ws_dialer *d = arg;
- return (nni_http_client_set_tls(d->client, cfg));
+ return (nng_http_client_set_tls(d->client, cfg));
}
int
@@ -2540,7 +2540,7 @@ nni_ws_dialer_alloc(nng_stream_dialer **dp, const nng_url *url)
return (rv);
}
- if ((rv = nni_http_client_init(&d->client, url)) != 0) {
+ if ((rv = nng_http_client_alloc(&d->client, url)) != 0) {
ws_dialer_free(d);
return (rv);
}
@@ -2666,7 +2666,7 @@ static int
ws_get_request_uri(void *arg, void *buf, size_t *szp, nni_type t)
{
nni_ws *ws = arg;
- return (nni_copyout_str(nni_http_get_uri(ws->http), buf, szp, t));
+ return (nni_copyout_str(nng_http_get_uri(ws->http), buf, szp, t));
}
static int
@@ -2716,7 +2716,7 @@ ws_get_header(nni_ws *ws, const char *nm, void *buf, size_t *szp, nni_type t)
{
const char *s;
nm += strlen(NNG_OPT_WS_HEADER);
- s = nni_http_get_header(ws->http, nm);
+ s = nng_http_get_header(ws->http, nm);
if (s == NULL) {
return (NNG_ENOENT);
}