]> git.proxmox.com Git - libgit2.git/blobdiff - src/transport.c
Include stacktrace summary in memory leak output.
[libgit2.git] / src / transport.c
index 9c88d983eb2e600b7c288e17b3efe5a6453ef882..5c65c7c06cedceca14f45fbd20c968f1d2ea5a6c 100644 (file)
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2009-2012 the libgit2 contributors
+ * Copyright (C) the libgit2 contributors. All rights reserved.
  *
  * This file is part of libgit2, distributed under the GNU GPL v2 with
  * a Linking Exception. For full terms see the included COPYING file.
 #include "git2/remote.h"
 #include "git2/net.h"
 #include "git2/transport.h"
+#include "git2/sys/transport.h"
 #include "path.h"
 
 typedef struct transport_definition {
        char *prefix;
-       unsigned priority;
        git_transport_cb fn;
        void *param;
 } transport_definition;
 
-static transport_definition local_transport_definition = { "file://", 1, git_transport_local, NULL };
-static transport_definition dummy_transport_definition = { NULL, 1, git_transport_dummy, NULL };
+static git_smart_subtransport_definition http_subtransport_definition = { git_smart_subtransport_http, 1, NULL };
+static git_smart_subtransport_definition git_subtransport_definition = { git_smart_subtransport_git, 0, NULL };
+#ifdef GIT_SSH
+static git_smart_subtransport_definition ssh_subtransport_definition = { git_smart_subtransport_ssh, 0, NULL };
+#endif
 
-static git_smart_subtransport_definition http_subtransport_definition = { git_smart_subtransport_http, 1 };
-static git_smart_subtransport_definition git_subtransport_definition = { git_smart_subtransport_git, 0 };
+static transport_definition local_transport_definition = { "file://", git_transport_local, NULL };
 
 static transport_definition transports[] = {
-       {"git://", 1, git_transport_smart, &git_subtransport_definition},
-       {"http://", 1, git_transport_smart, &http_subtransport_definition},
-       {"https://", 1, git_transport_smart, &http_subtransport_definition},
-       {"file://", 1, git_transport_local, NULL},
-       {"git+ssh://", 1, git_transport_dummy, NULL},
-       {"ssh+git://", 1, git_transport_dummy, NULL},
-       {NULL, 0, 0}
+       { "git://",   git_transport_smart, &git_subtransport_definition },
+       { "http://",  git_transport_smart, &http_subtransport_definition },
+#if defined(GIT_OPENSSL) || defined(GIT_WINHTTP) || defined(GIT_SECURE_TRANSPORT)
+       { "https://", git_transport_smart, &http_subtransport_definition },
+#endif
+       { "file://",  git_transport_local, NULL },
+#ifdef GIT_SSH
+       { "ssh://",   git_transport_smart, &ssh_subtransport_definition },
+#endif
+       { NULL, 0, 0 }
 };
 
+static git_vector custom_transports = GIT_VECTOR_INIT;
+
 #define GIT_TRANSPORT_COUNT (sizeof(transports)/sizeof(transports[0])) - 1
 
-static int transport_find_fn(const char *url, git_transport_cb *callback, void **param)
+static transport_definition * transport_find_by_url(const char *url)
 {
        size_t i = 0;
-       unsigned priority = 0;
-       transport_definition *definition = NULL, *definition_iter;
+       transport_definition *d;
 
-       // First, check to see if it's an obvious URL, which a URL scheme
-       for (i = 0; i < GIT_TRANSPORT_COUNT; ++i) {
-               definition_iter = &transports[i];
+       /* Find a user transport who wants to deal with this URI */
+       git_vector_foreach(&custom_transports, i, d) {
+               if (strncasecmp(url, d->prefix, strlen(d->prefix)) == 0) {
+                       return d;
+               }
+       }
 
-               if (strncasecmp(url, definition_iter->prefix, strlen(definition_iter->prefix)))
-                       continue;
+       /* Find a system transport for this URI */
+       for (i = 0; i < GIT_TRANSPORT_COUNT; ++i) {
+               d = &transports[i];
 
-               if (definition_iter->priority > priority)
-                       definition = definition_iter;
+               if (strncasecmp(url, d->prefix, strlen(d->prefix)) == 0) {
+                       return d;
+               }
        }
 
-       if (!definition) {
-               /* still here? Check to see if the path points to a file on the local file system */
-               if ((git_path_exists(url) == 0) && git_path_isdir(url))
-                       definition = &local_transport_definition;
+       return NULL;
+}
 
-               /* It could be a SSH remote path. Check to see if there's a : */
-               if (strrchr(url, ':'))
-                       definition = &dummy_transport_definition; /* SSH is an unsupported transport mechanism in this version of libgit2 */
+static int transport_find_fn(
+       git_transport_cb *out,
+       const char *url,
+       void **param)
+{
+       transport_definition *definition = transport_find_by_url(url);
+
+#ifdef GIT_WIN32
+       /* On Windows, it might not be possible to discern between absolute local
+        * and ssh paths - first check if this is a valid local path that points
+        * to a directory and if so assume local path, else assume SSH */
+
+       /* Check to see if the path points to a file on the local file system */
+       if (!definition && git_path_exists(url) && git_path_isdir(url))
+               definition = &local_transport_definition;
+#endif
+
+       /* For other systems, perform the SSH check first, to avoid going to the
+        * filesystem if it is not necessary */
+
+       /* It could be a SSH remote path. Check to see if there's a :
+        * SSH is an unsupported transport mechanism in this version of libgit2 */
+       if (!definition && strrchr(url, ':')) {
+               // re-search transports again with ssh:// as url so that we can find a third party ssh transport
+               definition = transport_find_by_url("ssh://");
        }
 
+#ifndef GIT_WIN32
+       /* Check to see if the path points to a file on the local file system */
+       if (!definition && git_path_exists(url) && git_path_isdir(url))
+               definition = &local_transport_definition;
+#endif
+
        if (!definition)
-               return -1;
+               return GIT_ENOTFOUND;
 
-       *callback = definition->fn;
+       *out = definition->fn;
        *param = definition->param;
-       
+
        return 0;
 }
 
@@ -76,15 +113,6 @@ static int transport_find_fn(const char *url, git_transport_cb *callback, void *
  * Public API *
  **************/
 
-int git_transport_dummy(git_transport **transport, git_remote *owner, void *param)
-{
-       GIT_UNUSED(transport);
-       GIT_UNUSED(owner);
-       GIT_UNUSED(param);
-       giterr_set(GITERR_NET, "This transport isn't implemented. Sorry");
-       return -1;
-}
-
 int git_transport_new(git_transport **out, git_remote *owner, const char *url)
 {
        git_transport_cb fn;
@@ -92,36 +120,101 @@ int git_transport_new(git_transport **out, git_remote *owner, const char *url)
        void *param;
        int error;
 
-       if (transport_find_fn(url, &fn, &param) < 0) {
+       if ((error = transport_find_fn(&fn, url, &param)) == GIT_ENOTFOUND) {
                giterr_set(GITERR_NET, "Unsupported URL protocol");
                return -1;
-       }
+       } else if (error < 0)
+               return error;
 
-       error = fn(&transport, owner, param);
-       if (error < 0)
+       if ((error = fn(&transport, owner, param)) < 0)
                return error;
 
+       GITERR_CHECK_VERSION(transport, GIT_TRANSPORT_VERSION, "git_transport");
+
        *out = transport;
 
        return 0;
 }
 
-/* from remote.h */
-int git_remote_valid_url(const char *url)
+int git_transport_register(
+       const char *scheme,
+       git_transport_cb cb,
+       void *param)
 {
-       git_transport_cb fn;
-       void *param;
+       git_buf prefix = GIT_BUF_INIT;
+       transport_definition *d, *definition = NULL;
+       size_t i;
+       int error = 0;
+
+       assert(scheme);
+       assert(cb);
+
+       if ((error = git_buf_printf(&prefix, "%s://", scheme)) < 0)
+               goto on_error;
+
+       git_vector_foreach(&custom_transports, i, d) {
+               if (strcasecmp(d->prefix, prefix.ptr) == 0) {
+                       error = GIT_EEXISTS;
+                       goto on_error;
+               }
+       }
 
-       return !transport_find_fn(url, &fn, &param);
+       definition = git__calloc(1, sizeof(transport_definition));
+       GITERR_CHECK_ALLOC(definition);
+
+       definition->prefix = git_buf_detach(&prefix);
+       definition->fn = cb;
+       definition->param = param;
+
+       if (git_vector_insert(&custom_transports, definition) < 0)
+               goto on_error;
+
+       return 0;
+
+on_error:
+       git_buf_free(&prefix);
+       git__free(definition);
+       return error;
 }
 
-int git_remote_supported_url(const char* url)
+int git_transport_unregister(const char *scheme)
 {
-       git_transport_cb fn;
-       void *param;
+       git_buf prefix = GIT_BUF_INIT;
+       transport_definition *d;
+       size_t i;
+       int error = 0;
+
+       assert(scheme);
+
+       if ((error = git_buf_printf(&prefix, "%s://", scheme)) < 0)
+               goto done;
 
-       if (transport_find_fn(url, &fn, &param) < 0)
-               return 0;
+       git_vector_foreach(&custom_transports, i, d) {
+               if (strcasecmp(d->prefix, prefix.ptr) == 0) {
+                       if ((error = git_vector_remove(&custom_transports, i)) < 0)
+                               goto done;
 
-       return fn != &git_transport_dummy;
+                       git__free(d->prefix);
+                       git__free(d);
+
+                       if (!custom_transports.length)
+                               git_vector_free(&custom_transports);
+
+                       error = 0;
+                       goto done;
+               }
+       }
+
+       error = GIT_ENOTFOUND;
+
+done:
+       git_buf_free(&prefix);
+       return error;
+}
+
+int git_transport_init(git_transport *opts, unsigned int version)
+{
+       GIT_INIT_STRUCTURE_FROM_TEMPLATE(
+               opts, version, git_transport, GIT_TRANSPORT_INIT);
+       return 0;
 }