* OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
*/
#include <arpa/inet.h>
+#include <dlfcn.h>
#include <libubox/ustream-ssl.h>
#include "uclient.h"
#include "uclient-utils.h"
#include "uclient-backend.h"
+#ifdef __APPLE__
+#define LIB_EXT "dylib"
+#else
+#define LIB_EXT "so"
+#endif
+
char *uclient_get_addr(char *dest, int *port, union uclient_addr *a)
{
int portval;
&uri_buf, strlen(location) + 1,
&auth_buf, auth_str ? strlen(auth_str) + 1 : 0);
+ if (!url)
+ return NULL;
+
url->backend = backend;
url->location = strcpy(uri_buf, location);
if (host)
return location;
}
+struct uclient_url __hidden *
+uclient_get_url_location(struct uclient_url *url, const char *location)
+{
+ struct uclient_url *new_url;
+ char *host_buf, *uri_buf, *auth_buf, *port_buf;
+ int host_len = strlen(url->host) + 1;
+ int auth_len = url->auth ? strlen(url->auth) + 1 : 0;
+ int port_len = url->port ? strlen(url->port) + 1 : 0;
+ int uri_len;
+
+ if (strstr(location, "://"))
+ return uclient_get_url(location, url->auth);
+
+ if (location[0] == '/')
+ uri_len = strlen(location) + 1;
+ else
+ uri_len = strlen(url->location) + strlen(location) + 2;
+
+ new_url = calloc_a(sizeof(*url),
+ &host_buf, host_len,
+ &port_buf, port_len,
+ &uri_buf, uri_len,
+ &auth_buf, auth_len);
+
+ if (!new_url)
+ return NULL;
+
+ new_url->backend = url->backend;
+ new_url->prefix = url->prefix;
+ new_url->host = strcpy(host_buf, url->host);
+ if (url->port)
+ new_url->port = strcpy(port_buf, url->port);
+ if (url->auth)
+ new_url->auth = strcpy(auth_buf, url->auth);
+
+ new_url->location = uri_buf;
+ if (location[0] == '/')
+ strcpy(uri_buf, location);
+ else {
+ int len = strcspn(url->location, "?#");
+ char *buf = uri_buf;
+
+ memcpy(buf, url->location, len);
+ if (buf[len - 1] != '/') {
+ buf[len] = '/';
+ len++;
+ }
+
+ buf += len;
+ strcpy(buf, location);
+ }
+
+ return new_url;
+}
+
struct uclient_url __hidden *
uclient_get_url(const char *url_str, const char *auth_str)
{
struct uclient_url *url;
const char *location;
int host_len;
- int i;
+ unsigned int i;
for (i = 0; i < ARRAY_SIZE(backends); i++) {
int prefix_len = 0;
uclient_backend_set_error(cl, UCLIENT_ERROR_TIMEDOUT);
}
+static void __uclient_read_notify(struct uloop_timeout *timeout)
+{
+ struct uclient *cl = container_of(timeout, struct uclient, read_notify);
+
+ if (cl->cb->data_read)
+ cl->cb->data_read(cl);
+}
+
struct uclient *uclient_new(const char *url_str, const char *auth_str, const struct uclient_cb *cb)
{
struct uclient *cl;
cl->url = url;
cl->timeout_msecs = UCLIENT_DEFAULT_TIMEOUT_MS;
cl->connection_timeout.cb = uclient_connection_timeout;
+ cl->read_notify.cb = __uclient_read_notify;
return cl;
}
int uclient_set_url(struct uclient *cl, const char *url_str, const char *auth_str)
{
const struct uclient_backend *backend = cl->backend;
- struct uclient_url *url = cl->url;
+ struct uclient_url *url;
url = uclient_get_url(url_str, auth_str);
if (!url)
return 0;
}
+struct ustream_ssl_ctx *uclient_new_ssl_context(const struct ustream_ssl_ops **ops)
+{
+ static const struct ustream_ssl_ops *ssl_ops;
+ void *dlh;
+
+ if (!ssl_ops) {
+ dlh = dlopen("libustream-ssl." LIB_EXT, RTLD_LAZY | RTLD_LOCAL);
+ if (!dlh)
+ return NULL;
+
+ ssl_ops = dlsym(dlh, "ustream_ssl_ops");
+ if (!ssl_ops) {
+ dlclose(dlh);
+ return NULL;
+ }
+ }
+
+ *ops = ssl_ops;
+ return ssl_ops->context_new(false);
+}
+
int uclient_read(struct uclient *cl, char *buf, int len)
{
if (!cl->backend->read)
return cl->backend->read(cl, buf, len);
}
+int uclient_pending_bytes(struct uclient *cl, bool write)
+{
+ if (!cl->backend->pending_bytes)
+ return -1;
+
+ return cl->backend->pending_bytes(cl, write);
+}
+
void uclient_disconnect(struct uclient *cl)
{
uloop_timeout_cancel(&cl->connection_timeout);
+ uloop_timeout_cancel(&cl->timeout);
+ uloop_timeout_cancel(&cl->read_notify);
if (!cl->backend->disconnect)
return;
cl->eof = false;
cl->error_code = 0;
uloop_timeout_cancel(&cl->timeout);
+ uloop_timeout_cancel(&cl->read_notify);
+}
+
+const char * uclient_strerror(unsigned err)
+{
+ switch (err) {
+ case UCLIENT_ERROR_UNKNOWN:
+ return "unknown error";
+ case UCLIENT_ERROR_CONNECT:
+ return "connect failed";
+ case UCLIENT_ERROR_TIMEDOUT:
+ return "timeout";
+ case UCLIENT_ERROR_SSL_INVALID_CERT:
+ return "ssl invalid cert";
+ case UCLIENT_ERROR_SSL_CN_MISMATCH:
+ return "ssl cn mismatch";
+ case UCLIENT_ERROR_MISSING_SSL_CONTEXT:
+ return "missing ssl context";
+ default:
+ return "invalid error code";
+ }
}