/6.6.0/couchbase-cli/ |
H A D | pump_json.py | 4 import os 39 'buckets': [{'name': os.path.normpath(os.path.basename(spec)), 65 return os.path.splitext(os.path.basename(filename))[0] 69 for item in os.listdir(subdir): 70 path = os.path.join(subdir, item) 71 if os.path.isfile(path): 94 dir = os.path.basename(os.path.dirname(path)) 101 elif os.path.isdir(f): 105 if os.path.isfile(path): 165 dir = os.path.basename(os.path.dirname(path)) [all …]
|
H A D | pump_bfd.py | 7 import os 42 bucket_path = os.path.join(os.path.normpath(spec), "bucket-" + bucket_name) 55 return os.path.join(parent, 344 if os.path.isdir(spec): 423 if os.path.exists(os.path.join(base_dir, FTS_ALIAS_FILE_NAME)): 746 return (os.path.isdir(spec) or (not os.path.exists(spec) and 747 os.path.isdir(os.path.dirname(spec)))) 760 if not os.access(spec, os.W_OK): 771 if not os.access(parent_dir, os.W_OK): 859 os.mkdir(spec) [all …]
|
/6.6.0/goproj/src/github.com/couchbase/query/shell/cbq/ |
D | interactive.go | 45 *outputFile, err = os.OpenFile(command.FILE_OUTPUT, os.O_RDWR|os.O_CREATE|os.O_TRUNC, 0600) 83 os.Clearenv() 84 os.Exit(1) 88 os.Clearenv() 89 os.Exit(0) 134 os.Exit(1) 140 os.Clearenv() 141 os.Exit(0) 311 os.Exit(0) 344 outputFile, err = os.OpenFile(command.FILE_OUTPUT, os.O_RDWR|os.O_CREATE|os.O_APPEND, 0600) [all …]
|
/6.6.0/ns_server/deps/gocode/src/gozip/ |
H A D | main.go | 48 fmt.Fprintln(os.Stderr, "Usage:") 50 fmt.Fprintln(os.Stderr, "Options:") 51 f.SetOutput(os.Stderr) 54 os.Exit(code) 67 os.Exit(exitFailure) 80 type walkFn func(string, *os.File, os.FileInfo) error 83 file, err := os.Open(root) 143 fn := func(path string, f *os.File, info os.FileInfo) error { 210 name = os.Args[0] 219 err := f.Parse(os.Args[1:]) [all …]
|
/6.6.0/couchdb/test/etap/ |
H A D | runtest.py | 6 import os 28 dname, fname = os.path.split(os.path.abspath(__file__)) 43 LIBS = os.path.join(PREFIX, 'lib') 46 env = os.environ.copy() 139 env = os.getenv("ERL_LIBS") 146 env = os.getenv("ERL_FLAGS") 158 if os.path.isdir(os.path.join(path, d))] 173 os.putenv("ERL_FLAGS", erl_flags) 177 os.putenv("ERL_LIBS", erl_libs) 184 env = os.getenv("PATH") [all …]
|
/6.6.0/goproj/src/github.com/couchbase/cbgt/rest/ |
D | bindata_assetfs.go | 141 info os.FileInfo 147 mode os.FileMode 157 func (fi bindataFileInfo) Mode() os.FileMode { 185 …info := bindataFileInfo{name: "static/css/app.css", size: 1081, mode: os.FileMode(420), modTime: t… 525 …info := bindataFileInfo{name: "static/js/app.js", size: 3058, mode: os.FileMode(420), modTime: tim… 545 …info := bindataFileInfo{name: "static/js/b64.js", size: 5309, mode: os.FileMode(420), modTime: tim… 2179 func AssetInfo(name string) (os.FileInfo, error) { 2491 err = os.MkdirAll(_filePath(dir, filepath.Dir(name)), os.FileMode(0755)) 2499 err = os.Chtimes(_filePath(dir, name), info.ModTime(), info.ModTime()) 2529 assetInfo := func(path string) (os.FileInfo, error) { [all …]
|
/6.6.0/ns_server/ |
H A D | cbcollect_info | 18 import os 89 os._exit(status) 300 ofile = os.path.join(self.target_dir, os.path.basename(name)) 465 tmp_dir = os.path.abspath(os.path.expanduser(tmp_dir)) 475 if not tmp_dir and os.getenv("TMPDIR") and os.path.split( 772 os.path.join( 1031 rebdir = os.path.realpath(os.path.join( 1452 if not os.access(initargs_path, os.R_OK): 1723 zip_dir = os.path.dirname(os.path.abspath(zip_filename)) 1725 if not os.access(zip_dir, os.W_OK | os.X_OK): [all …]
|
H A D | cluster_run | 17 import os 18 import os.path 115 dirs = os.walk(path_name) 152 os.mkdir("couch") 153 except os.error: 212 in_file = os.path.join(os.getcwd(), "etc", "ssl_dist_opts.in") 215 if not os.path.exists(cfg_dir): 216 os.makedirs(cfg_dir, 0o755) 330 os.makedirs(logdir) 364 (r, w) = os.pipe() [all …]
|
/6.6.0/ns_server/deps/gocode/src/godu/ |
H A D | godu.go | 31 f, err := os.Open(".") 44 _, err := os.Stat(entry) 45 if os.IsNotExist(err) { 54 var infos []os.FileInfo 57 old, err := os.Getwd() 61 defer os.Chdir(old) 63 err = os.Chdir(entry) 79 if (mode & os.ModeType) == 0 { 157 rd := bufio.NewReader(os.Stdin) 177 if len(os.Args) < 2 { [all …]
|
/6.6.0/testrunner/pysystests/tools/ |
H A D | compare_stats.py | 1 import os 168 dirs0 = os.path.dirname(files[0]).split(os.sep) 169 dirs1 = os.path.dirname(files[1]).split(os.sep) 170 fn, fe = os.path.splitext(files[0]) 182 folders = os.walk(folder1).next()[1] 184 sub_folder = os.path.join(folder1, folder) 185 … files = [ f for f in os.listdir(sub_folder) if os.path.isfile(os.path.join(sub_folder, f))] 187 fileName, fileExtension = os.path.splitext(os.path.join(folder1, folder, file)) 193 …print "Generate report for %s & %s" % (os.path.join(folder1, folder, file), os.path.join(folder2,… 194 … compare_stats(os.path.join(folder1, folder, file), os.path.join(folder2, folder, file)) [all …]
|
/6.6.0/goproj/src/github.com/couchbase/cbft/ |
D | bindata_assetfs.go | 92 info os.FileInfo 98 mode os.FileMode 108 func (fi bindataFileInfo) Mode() os.FileMode { 136 …info := bindataFileInfo{name: "staticx/css/cbft.css", size: 2796, mode: os.FileMode(420), modTime:… 176 …info := bindataFileInfo{name: "staticx/index.html", size: 7252, mode: os.FileMode(420), modTime: t… 196 …info := bindataFileInfo{name: "staticx/js/debug.js", size: 2344, mode: os.FileMode(420), modTime: … 1150 func AssetInfo(name string) (os.FileInfo, error) { 1362 err = os.MkdirAll(_filePath(dir, filepath.Dir(name)), os.FileMode(0755)) 1370 err = os.Chtimes(_filePath(dir, name), info.ModTime(), info.ModTime()) 1400 assetInfo := func(path string) (os.FileInfo, error) { [all …]
|
/6.6.0/goproj/src/github.com/couchbase/indexing/secondary/cmd/cbindexplan/ |
D | main.go | 33 fmt.Fprintln(os.Stderr, "") 36 fmt.Fprintln(os.Stderr, "") 100 fmt.Fprintln(os.Stderr, 106 fmt.Fprintln(os.Stderr, 111 fmt.Fprintln(os.Stderr, 124 fmt.Fprintln(os.Stderr, 221 cmd := exec.Command(os.Args[0], os.Args[1:]...) 222 cmd.Stdin = os.Stdin 223 cmd.Stdout = os.Stdout 224 cmd.Stderr = os.Stderr [all …]
|
/6.6.0/sigar/src/ |
H A D | CMakeLists.txt | 7 SET(SIGAR_SRC os/linux/linux_sigar.c) 8 INCLUDE_DIRECTORIES(os/linux/) 15 INCLUDE_DIRECTORIES(os/darwin/) 30 os/solaris/solaris_sigar.c 31 os/solaris/get_mib2.c 32 os/solaris/kstats.c 33 os/solaris/procfs.c 45 INCLUDE_DIRECTORIES(os/hpux/) 54 INCLUDE_DIRECTORIES(os/aix/) 61 SET(SIGAR_SRC os/win32/peb.c os/win32/win32_sigar.c os/win32/wmi.cpp) [all …]
|
/6.6.0/kv_engine/engines/ep/src/ |
H A D | stored-value.cc | 518 os << ' '; in operator <<() 527 os << "Cm"; in operator <<() 530 os << "Cp"; in operator <<() 533 os << "Pe"; in operator <<() 536 os << "Pv"; in operator <<() 539 os << "Pa"; in operator <<() 542 os << "Pc"; in operator <<() 555 os << ' '; in operator <<() 558 os << "temp:" in operator <<() 591 os << "\""; in operator <<() [all …]
|
/6.6.0/goproj/src/github.com/couchbase/indexing/secondary/cmd/cbindex/ |
D | main.go | 19 fmt.Fprintln(os.Stderr, "Usage: cbindex [options]") 21 fmt.Fprintln(os.Stderr, `Examples: 57 os.Exit(1) 60 os.Exit(0) 66 os.Setenv("CBAUTH_REVRPC_URL", revrpc) 67 cmd := exec.Command(os.Args[0], os.Args[1:]...) 68 cmd.Stdin = os.Stdin 69 cmd.Stdout = os.Stdout 70 cmd.Stderr = os.Stderr 77 os.Exit(exitcode) [all …]
|
/6.6.0/goproj/src/github.com/couchbase/indexing/secondary/tools/querycmd/ |
D | main.go | 16 fmt.Fprintf(os.Stderr, "Usage: %s (sanity|bench|...)\n", os.Args[0]) 23 fd, err := os.Create("queryport.pprof") 33 os.Exit(0) 36 os.Exit(0) 61 fmt.Fprintf(os.Stderr, "Error occured %v\n", err) 67 fmt.Fprintf(os.Stderr, "Error occured %v\n", err) 73 fmt.Fprintf(os.Stderr, "Error occured %v\n", err) 79 fmt.Fprintf(os.Stderr, "Error occured %v\n", err) 85 fmt.Fprintf(os.Stderr, "Error occured %v\n", err) 97 fmt.Fprintf(os.Stderr, "Error occured %v\n", err) [all …]
|
/6.6.0/goproj/src/github.com/couchbase/goxdcr/metadata/ |
D | internal_settings.go | 514 if os.TopologyChangeCheckInterval == 0 { 523 if os.MaxWorkersForCheckpointing == 0 { 526 if os.TimeoutCheckpointBeforeStop == 0 { 529 if os.CapiDataChanSizeMultiplier == 0 { 532 if os.RefreshRemoteClusterRefInterval == 0 { 535 if os.CapiMaxRetryBatchUpdateDocs == 0 { 538 if os.CapiBatchTimeout == 0 { 541 if os.CapiWriteTimeout == 0 { 544 if os.CapiReadTimeout == 0 { 547 if os.MaxCheckpointRecordsToKeep == 0 { [all …]
|
/6.6.0/goproj/src/github.com/couchbase/cbgt/ |
D | feed_files_test.go | 54 defer os.RemoveAll(testDir) 55 err = os.MkdirAll(testDir+ 56 string(os.PathSeparator)+"files"+ 71 err = os.MkdirAll(testDir+ 72 string(os.PathSeparator)+"files"+ 73 string(os.PathSeparator)+"foo"+ 90 string(os.PathSeparator) + "foo" + 105 string(os.PathSeparator) + "foo" + 295 defer os.RemoveAll(emptyDir) 310 string(os.PathSeparator) [all …]
|
/6.6.0/goproj/src/github.com/couchbase/query/tutorial/ |
D | tutorial.go | 33 dstF, dstE := os.Stat(dst) 36 if !os.IsNotExist(dstE) && 42 if os.IsNotExist(dstE) { 90 srcD, srcE := os.Stat(*xsrc) 91 if os.IsNotExist(srcE) || !srcD.IsDir() { 96 dstD, dstE := os.Stat(*xdst) 162 tempDir += string(os.PathSeparator) 163 defer os.RemoveAll(tempDir) 166 c := make(chan os.Signal, 1) 167 signal.Notify(c, os.Interrupt) [all …]
|
/6.6.0/goproj/src/github.com/couchbase/query/planner/ |
D | build_window.go | 230 var os *SortGroup 262 os = other[i] 263 if os != nil && len(os.groups) > 0 { 264 osPbyMap = os.groups.GetSortGroupStringMap(len(os.groups)) 269 if os == nil || ts.exprStr != os.exprStr { 274 checkFalg := (ts.pos == os.pos) 283 os.descending = ts.descending 294 os.nullsPos = ts.nullsPos 295 os.flags |= _SORT_NULLS_FIXED 390 if os != nil && this.exprStr == os.exprStr { [all …]
|
/6.6.0/testrunner/ |
H A D | testrunner.py | 6 import os 10 from os.path import basename, splitext 238 if os.path.exists("conf{0}{1}".format(os.sep, filename)): 298 if os.path.isdir(dirpath): 299 dirpath=dirpath+os.sep+"**"+os.sep+"*.conf" 353 os.mkdir('logs') 556 abs_path = os.path.dirname(os.path.abspath(sys.argv[0])) 605 os.mkdir(logs_folder) 693 … ns_server_path = os.path.normpath(abs_path + os.sep + os.pardir + os.sep + "ns_server") 883 abs_path = os.path.dirname(os.path.abspath(sys.argv[0])) [all …]
|
/6.6.0/testrunner/pytests/breakpad/ |
H A D | verifydumptests.py | 1 import os 33 assert dmp_path and os.access(dmp_path, os.R_OK) 50 assert dmp_path and os.access(dmp_path, os.R_OK) 57 assert dmp_path and os.access(dmp_path, os.R_OK) 134 assert dmp_path and os.access(dmp_path, os.R_OK) 196 assert os.access(dmp_path, os.R_OK) 199 assert os.access(f_core, os.R_OK) 227 assert os.access(dmp_path, os.R_OK) 278 assert dmp_path and os.access(dmp_path, os.R_OK)
|
/6.6.0/kv_engine/tests/ |
H A D | breakpad_test.py | 30 import os 89 if os.name == 'nt': 150 os.environ['MEMCACHED_UNIT_TESTS'] = "true" 151 os.environ['MEMCACHED_CRASH_TEST'] = crash_mode 158 os.environ['MEMCACHED_UNIT_TESTS'] + 170 os.remove(config_file.name) 171 os.remove(rbac_file.name) 201 if not os.path.exists(minidump): 216 os.remove(minidump) 311 statinfo = os.stat(minidump) [all …]
|
/6.6.0/testrunner/scripts/ |
H A D | testrunner.py | 6 import os 10 from os.path import basename, splitext 114 if os.path.exists(filename): 202 os.write(1, ".") 209 os.remove(filename) 233 child = os.fork() 236 os.wait() 260 if not os.path.exists("logs"): 261 os.makedirs("logs") 267 if not os.path.exists(logs_folder): [all …]
|
/6.6.0/godeps/src/github.com/couchbase/retriever/lockfile/ |
D | lockfile.go | 32 func (l Lockfile) GetOwner() (*os.Process, error) { 49 p, err := os.FindProcess(pid) 53 err = p.Signal(os.Signal(syscall.Signal(0))) 94 defer os.Remove(tmplock.Name()) 97 _, err = tmplock.WriteString(fmt.Sprintf("%d\n", os.Getpid())) 103 _ = os.Link(tmplock.Name(), name) 105 fiTmp, err := os.Lstat(tmplock.Name()) 109 fiLock, err := os.Lstat(name) 115 if os.SameFile(fiTmp, fiLock) { 131 err = os.Remove(name) [all …]
|