Device - Code Search

src/main/webapp/WEB-INF/orig/view/advance.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
<html>
<head profile="http://a9.com/-/spec/opensearch/1.1/">
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<title><la:message key="labels.search_title" /></title>
<c:if test="${osddLink}">
	<link rel="search" type="application/opensearchdescription+xml" href="${fe:url('/osdd')}"

Others

- Registered: Mon May 06 08:04:11 GMT 2024

- Last Modified: Fri Feb 17 12:13:41 GMT 2023

- 14.9K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem_test.cc

      TF_DeleteStatus(status);
      return "";
    }
    TF_DeleteStatus(status);

    // We add a random value into `test_dir` to ensures that two consecutive
    // runs are unlikely to clash.
    std::random_device rd;
    std::mt19937 gen(rd());
    std::uniform_int_distribution<> distribution;
    std::string rng_val = std::to_string(distribution(gen));
    return tensorflow::io::JoinPath(std::string(test_dir), rng_val);
  } else {

C++

- Registered: Tue Apr 23 12:39:09 GMT 2024

- Last Modified: Mon Aug 31 12:04:23 GMT 2020

- 24.9K bytes

- Viewed (0)

github.com/minio/minio

cmd/server-main.go

		Usage:  "custom TCP_USER_TIMEOUT for socket buffers",
		Hidden: true,
		Value:  10 * time.Minute,
		EnvVar: "MINIO_CONN_USER_TIMEOUT",
	},
	cli.StringFlag{
		Name:   "interface",
		Usage:  "bind to right VRF device for MinIO services",
		Hidden: true,
		EnvVar: "MINIO_INTERFACE",
	},
	cli.DurationFlag{
		Name:   "dns-cache-ttl",
		Usage:  "custom DNS cache TTL",
		Hidden: true,
		Value: func() time.Duration {

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Fri May 03 15:54:03 GMT 2024

- 34.9K bytes

- Viewed (1)

github.com/golang/go

src/archive/tar/writer_test.go

		if string(data) != string(origdata) {
			t.Fatalf("got file content %v, want %v",
				data, origdata)
		}
	}
}

func TestWriterAddFSNonRegularFiles(t *testing.T) {
	fsys := fstest.MapFS{
		"device":  {Data: []byte("hello"), Mode: 0755 | fs.ModeDevice},
		"symlink": {Data: []byte("world"), Mode: 0755 | fs.ModeSymlink},
	}
	var buf bytes.Buffer
	tw := NewWriter(&buf)
	if err := tw.AddFS(fsys); err == nil {

Go

- Registered: Tue Apr 30 11:13:12 GMT 2024

- Last Modified: Tue Feb 27 16:39:23 GMT 2024

- 38.7K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

CHANGELOG/CHANGELOG-1.2.md

     * Kubernetes clusters can now span zones within a cloud provider. Pods from a
service will be automatically spread across zones, enabling applications to
tolerate zone failure.
     * Simplified way to run a container on every node (DaemonSet API (Beta) in the
Extensions API group): Kubernetes can schedule a service (such as a logging
agent) that runs one, and only one, pod per node.

Plain Text

- Registered: Fri May 03 09:05:14 GMT 2024

- Last Modified: Fri Dec 04 06:36:19 GMT 2020

- 41.4K bytes

- Viewed (0)

github.com/golang/go

src/archive/tar/reader_test.go

			Uid:      010000000,
			ModTime:  time.Unix(0, 0),
			Typeflag: '0',
		}},
	}, {
		// USTAR archive with a regular entry with non-zero device numbers.
		file: "testdata/ustar-file-devs.tar",
		headers: []*Header{{
			Name:     "file",
			Mode:     0644,
			Typeflag: '0',
			ModTime:  time.Unix(0, 0),
			Devmajor: 1,
			Devminor: 1,

Go

- Registered: Tue Apr 30 11:13:12 GMT 2024

- Last Modified: Mon Nov 21 21:14:38 GMT 2022

- 47.1K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/Service.java

   * @since 15.0
   */
  @CanIgnoreReturnValue
  Service startAsync();

  /** Returns {@code true} if this service is {@linkplain State#RUNNING running}. */
  boolean isRunning();

  /** Returns the lifecycle state of the service. */
  State state();

  /**
   * If the service is {@linkplain State#STARTING starting} or {@linkplain State#RUNNING running},

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Tue Apr 04 09:45:04 GMT 2023

- 10.7K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

            };
          }
        };
    service.useBarriers = false;
    service.startAsync().awaitRunning();
    Thread.sleep(50);
    service.useBarriers = true;
    service.firstBarrier.await();
    int numIterations = service.numIterations.get();
    service.stopAsync();
    service.secondBarrier.await();
    service.awaitTerminated();
    assertEquals(numIterations, service.numIterations.get());
  }

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Wed Sep 06 17:04:31 GMT 2023

- 22.5K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/AbstractService.java

import static com.google.common.util.concurrent.Service.State.FAILED;
import static com.google.common.util.concurrent.Service.State.NEW;
import static com.google.common.util.concurrent.Service.State.RUNNING;
import static com.google.common.util.concurrent.Service.State.STARTING;
import static com.google.common.util.concurrent.Service.State.STOPPING;
import static com.google.common.util.concurrent.Service.State.TERMINATED;

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Fri May 12 18:32:03 GMT 2023

- 20.4K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

  }

  private static void assertState(
      ServiceManager manager, Service.State state, Service... services) {
    Collection<Service> managerServices = manager.servicesByState().get(state);
    for (Service service : services) {
      assertEquals(service.toString(), state, service.state());

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Mon Oct 02 17:20:27 GMT 2023

- 23.2K bytes

- Viewed (0)

Search Options