summaryrefslogtreecommitdiff
path: root/go/golang/gocache/8f/8f35490f588bd24411a2ed70dc7534bc617daf193af4bcd3190fb890b4740439-d
diff options
context:
space:
mode:
Diffstat (limited to 'go/golang/gocache/8f/8f35490f588bd24411a2ed70dc7534bc617daf193af4bcd3190fb890b4740439-d')
-rw-r--r--go/golang/gocache/8f/8f35490f588bd24411a2ed70dc7534bc617daf193af4bcd3190fb890b4740439-d165
1 files changed, 165 insertions, 0 deletions
diff --git a/go/golang/gocache/8f/8f35490f588bd24411a2ed70dc7534bc617daf193af4bcd3190fb890b4740439-d b/go/golang/gocache/8f/8f35490f588bd24411a2ed70dc7534bc617daf193af4bcd3190fb890b4740439-d
new file mode 100644
index 00000000..fa182f6f
--- /dev/null
+++ b/go/golang/gocache/8f/8f35490f588bd24411a2ed70dc7534bc617daf193af4bcd3190fb890b4740439-d
@@ -0,0 +1,165 @@
+// Code generated by cmd/cgo; DO NOT EDIT.
+
+//line /workdir/go/src/plugin/plugin_dlopen.go:1:1
+// Copyright 2016 The Go Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style
+// license that can be found in the LICENSE file.
+
+// +build linux,cgo darwin,cgo
+
+package plugin; import _cgo_unsafe "unsafe"
+
+/*
+#cgo linux LDFLAGS: -ldl
+#include <dlfcn.h>
+#include <limits.h>
+#include <stdlib.h>
+#include <stdint.h>
+
+#include <stdio.h>
+
+static uintptr_t pluginOpen(const char* path, char** err) {
+ void* h = dlopen(path, RTLD_NOW|RTLD_GLOBAL);
+ if (h == NULL) {
+ *err = (char*)dlerror();
+ }
+ return (uintptr_t)h;
+}
+
+static void* pluginLookup(uintptr_t h, const char* name, char** err) {
+ void* r = dlsym((void*)h, name);
+ if (r == NULL) {
+ *err = (char*)dlerror();
+ }
+ return r;
+}
+*/
+import _ "unsafe"
+
+import (
+ "errors"
+ "sync"
+ "unsafe"
+)
+
+// avoid a dependency on strings
+func lastIndexByte(s string, c byte) int {
+ for i := len(s) - 1; i >= 0; i-- {
+ if s[i] == c {
+ return i
+ }
+ }
+ return -1
+}
+
+func open(name string) (*Plugin, error) {
+ cPath := make([]byte, (_Ciconst_PATH_MAX)+1)
+ cRelName := make([]byte, len(name)+1)
+ copy(cRelName, name)
+ if (_Cfunc_realpath)(
+ (*_Ctype_char)(unsafe.Pointer(&cRelName[0])),
+ (*_Ctype_char)(unsafe.Pointer(&cPath[0]))) == nil {
+ return nil, errors.New(`plugin.Open("` + name + `"): realpath failed`)
+ }
+
+ filepath := (_Cfunc_GoString)((*_Ctype_char)(unsafe.Pointer(&cPath[0])))
+
+ pluginsMu.Lock()
+ if p := plugins[filepath]; p != nil {
+ pluginsMu.Unlock()
+ if p.err != "" {
+ return nil, errors.New(`plugin.Open("` + name + `"): ` + p.err + ` (previous failure)`)
+ }
+ <-p.loaded
+ return p, nil
+ }
+ var cErr *_Ctype_char
+ h := func(_cgo0 *_Ctype_char, _cgo1 **_Ctype_char) _Ctype_uintptr_t {; _cgoCheckPointer(_cgo1, true); return (_Cfunc_pluginOpen)(_cgo0, _cgo1);}((*_Ctype_char)(unsafe.Pointer(&cPath[0])), &cErr)
+ if h == 0 {
+ pluginsMu.Unlock()
+ return nil, errors.New(`plugin.Open("` + name + `"): ` + (_Cfunc_GoString)(cErr))
+ }
+ // TODO(crawshaw): look for plugin note, confirm it is a Go plugin
+ // and it was built with the correct toolchain.
+ if len(name) > 3 && name[len(name)-3:] == ".so" {
+ name = name[:len(name)-3]
+ }
+ if plugins == nil {
+ plugins = make(map[string]*Plugin)
+ }
+ pluginpath, syms, errstr := lastmoduleinit()
+ if errstr != "" {
+ plugins[filepath] = &Plugin{
+ pluginpath: pluginpath,
+ err: errstr,
+ }
+ pluginsMu.Unlock()
+ return nil, errors.New(`plugin.Open("` + name + `"): ` + errstr)
+ }
+ // This function can be called from the init function of a plugin.
+ // Drop a placeholder in the map so subsequent opens can wait on it.
+ p := &Plugin{
+ pluginpath: pluginpath,
+ loaded: make(chan struct{}),
+ }
+ plugins[filepath] = p
+ pluginsMu.Unlock()
+
+ initStr := make([]byte, len(pluginpath)+6)
+ copy(initStr, pluginpath)
+ copy(initStr[len(pluginpath):], ".init")
+
+ initFuncPC := func(_cgo0 _Ctype_uintptr_t, _cgo1 *_Ctype_char, _cgo2 **_Ctype_char) _cgo_unsafe.Pointer {; _cgoCheckPointer(_cgo2, true); return (_Cfunc_pluginLookup)(_cgo0, _cgo1, _cgo2);}(h, (*_Ctype_char)(unsafe.Pointer(&initStr[0])), &cErr)
+ if initFuncPC != nil {
+ initFuncP := &initFuncPC
+ initFunc := *(*func())(unsafe.Pointer(&initFuncP))
+ initFunc()
+ }
+
+ // Fill out the value of each plugin symbol.
+ updatedSyms := map[string]interface{}{}
+ for symName, sym := range syms {
+ isFunc := symName[0] == '.'
+ if isFunc {
+ delete(syms, symName)
+ symName = symName[1:]
+ }
+
+ fullName := pluginpath + "." + symName
+ cname := make([]byte, len(fullName)+1)
+ copy(cname, fullName)
+
+ p := func(_cgo0 _Ctype_uintptr_t, _cgo1 *_Ctype_char, _cgo2 **_Ctype_char) _cgo_unsafe.Pointer {; _cgoCheckPointer(_cgo2, true); return (_Cfunc_pluginLookup)(_cgo0, _cgo1, _cgo2);}(h, (*_Ctype_char)(unsafe.Pointer(&cname[0])), &cErr)
+ if p == nil {
+ return nil, errors.New(`plugin.Open("` + name + `"): could not find symbol ` + symName + `: ` + (_Cfunc_GoString)(cErr))
+ }
+ valp := (*[2]unsafe.Pointer)(unsafe.Pointer(&sym))
+ if isFunc {
+ (*valp)[1] = unsafe.Pointer(&p)
+ } else {
+ (*valp)[1] = p
+ }
+ // we can't add to syms during iteration as we'll end up processing
+ // some symbols twice with the inability to tell if the symbol is a function
+ updatedSyms[symName] = sym
+ }
+ p.syms = updatedSyms
+
+ close(p.loaded)
+ return p, nil
+}
+
+func lookup(p *Plugin, symName string) (Symbol, error) {
+ if s := p.syms[symName]; s != nil {
+ return s, nil
+ }
+ return nil, errors.New("plugin: symbol " + symName + " not found in plugin " + p.pluginpath)
+}
+
+var (
+ pluginsMu sync.Mutex
+ plugins map[string]*Plugin
+)
+
+// lastmoduleinit is defined in package runtime
+func lastmoduleinit() (pluginpath string, syms map[string]interface{}, errstr string)