- Sort Score
- Result 10 results
- Languages All
Results 211 - 220 of 2,466 for JOIN (0.17 sec)
-
internal/s3select/json/preader_test.go
func TestNewPReader(t *testing.T) { files, err := os.ReadDir("testdata") if err != nil { t.Fatal(err) } for _, file := range files { t.Run(file.Name(), func(t *testing.T) { f, err := os.Open(filepath.Join("testdata", file.Name())) if err != nil { t.Fatal(err) } r := NewPReader(f, &ReaderArgs{}) var record sql.Record for { record, err = r.Read(record) if err != nil { break
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 2.5K bytes - Viewed (0) -
internal/s3select/json/reader_test.go
) func TestNewReader(t *testing.T) { files, err := os.ReadDir("testdata") if err != nil { t.Fatal(err) } for _, file := range files { t.Run(file.Name(), func(t *testing.T) { f, err := os.Open(filepath.Join("testdata", file.Name())) if err != nil { t.Fatal(err) } r := NewReader(f, &ReaderArgs{}) var record sql.Record for { record, err = r.Read(record) if err != nil { break }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 2.5K bytes - Viewed (0) -
src/path/filepath/path_unix.go
} return strings.Split(path, string(ListSeparator)) } func abs(path string) (string, error) { return unixAbs(path) } func join(elem []string) string { // If there's a bug here, fix the logic in ./path_plan9.go too. for i, e := range elem { if e != "" { return Clean(strings.Join(elem[i:], string(Separator))) } } return "" } func sameWord(a, b string) bool { return a == b
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 23:07:50 UTC 2024 - 970 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/testing/utils.go
func PathPrefix() string { pref := os.Getenv("ETCD_PREFIX") if pref == "" { pref = "registry" } return path.Join("/", pref) } // AddPrefix adds the ETCD_PREFIX to the provided key func AddPrefix(in string) string { return path.Join(PathPrefix(), in)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 01 13:02:49 UTC 2019 - 962 bytes - Viewed (0) -
src/cmd/nm/nm_test.go
if err != nil { t.Fatal(err) } defer os.RemoveAll(tmpdir) gopath := filepath.Join(tmpdir, "gopath") libpath := filepath.Join(gopath, "src", "mylib") err = os.MkdirAll(libpath, 0777) if err != nil { t.Fatal(err) } src := filepath.Join(libpath, "a.go") file, err := os.Create(src) if err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 20 23:32:34 UTC 2023 - 8.8K bytes - Viewed (0) -
src/cmd/compile/internal/test/reproduciblebuilds_test.go
libpath string }{ {tag: "serial", args: "-c=1"}, {tag: "concurrent", args: "-c=2"}} tmpdir := t.TempDir() src := filepath.Join("testdata", "reproducible", "issue38068.go") for i := range scenarios { s := &scenarios[i] s.libpath = filepath.Join(tmpdir, s.tag+".a") // Note: use of "-p" required in order for DWARF to be generated.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 06 18:07:35 UTC 2023 - 2.8K bytes - Viewed (0) -
src/cmd/cgo/internal/testsanitizers/cshared_test.go
dir := newTempDir(t) defer dir.RemoveAll(t) lib := dir.Join(fmt.Sprintf("lib%s.%s", name, libExt)) mustRun(t, config.goCmd("build", "-buildmode=c-shared", "-o", lib, srcPath(tc.src))) cSrc := dir.Join("main.c") if err := os.WriteFile(cSrc, cMain, 0600); err != nil { t.Fatalf("failed to write C source file: %v", err) } dstBin := dir.Join(name) cmd, err := cc(config.cFlags...) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 19 01:37:31 UTC 2023 - 2.1K bytes - Viewed (0) -
src/cmd/internal/testdir/testdir_test.go
for _, pkg := range pkgs { pkgpath := path.Join("test", strings.TrimSuffix(pkg.files[0], ".go")) cfg += "\npackagefile " + pkgpath + "=" + filepath.Join(tempDir, pkgpath+".a") } filename := filepath.Join(tempDir, "importcfg") err := os.WriteFile(filename, []byte(cfg), 0644) if err != nil { t.Fatal(err) } return filename } long := filepath.Join(t.gorootTestDir, t.goFileName()) switch action {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 20:08:06 UTC 2024 - 57.5K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib.cc
tensorflow::condition_variable finished_execute_; // Notifies a StartExecute that the previous Join has finished. tensorflow::condition_variable finished_join_; // Temporary state between `StartExecute` and `Join`. // // Inputs; pointers are to objects not owned by the DeviceThread, but which // are expected to live at least until `Join` finishes: TFE_Context* context_ TF_GUARDED_BY(execution_mutex_);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Feb 09 07:47:20 UTC 2024 - 25.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
service.stopAsync().awaitTerminated(); assertTrue(service.shutDownCalled); assertEquals(Service.State.TERMINATED, service.state()); executionThread.join(); } public void testServiceStopIdempotence() throws Exception { WaitOnRunService service = new WaitOnRunService(); service.startAsync().awaitRunning();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 12.7K bytes - Viewed (0)