read1 - Code Search

tensorflow/c/kernels_test.cc

  s->created = true;
  s->compute_called = false;

  // Exercise attribute reads.
  TF_DataType type;
  TF_Status* status = TF_NewStatus();
  TF_OpKernelConstruction_GetAttrType(ctx, "SomeDataTypeAttr", &type, status);
  EXPECT_EQ(TF_OK, TF_GetCode(status));
  EXPECT_EQ(TF_FLOAT, type);
  TF_DeleteStatus(status);

  // Exercise kernel NodeDef name read
  TF_StringView name_string_view = TF_OpKernelConstruction_GetName(ctx);

Registered: Sun Jun 16 05:45:23 UTC 2024

- Last Modified: Wed Sep 06 19:12:29 UTC 2023

- 50.4K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt

    a.setString(0, "a1")
    assertThat(cache.remove("a")).isTrue()
    a.setString(1, "a2")
    a.commit()
    assertAbsent("a")
  }

  /**
   * Each read sees a snapshot of the file at the time read was called. This means that two reads of
   * the same key can see different data.
   */
  @ParameterizedTest
  @ArgumentsSource(FileSystemParamProvider::class)

Registered: Sun Jun 16 04:42:17 UTC 2024

- Last Modified: Mon Apr 15 14:55:09 UTC 2024

- 75.8K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/core-configuration/model-core/src/test/groovy/org/gradle/api/internal/provider/CollectionPropertySpec.groovy

        then:
        def e3 = thrown(IllegalStateException)
        e3.message == 'The value for this property cannot be changed any further.'
    }

    def "finalizes upstream properties when value read using #method and disallow unsafe reads"() {
        def a = property()
        def b = property()
        def c = elementProperty()
        def property = property()
        property.disallowUnsafeRead()

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Fri May 17 11:41:55 UTC 2024

- 49.7K bytes

- Viewed (0)

github.com/gradle/gradle

subprojects/core/src/test/groovy/org/gradle/execution/plan/DefaultExecutionPlanParallelTest.groovy

        @TaskAction
        void execute() {
            throw new RuntimeException("BOOM!")
        }
    }

    /**
     * Asserts there is a task ready to run, and runs it.
     */
    void assertNextTaskReady(Task task) {
        def node = selectNextTaskNode()
        assert node.task == task
        assertWorkReadyToStart()
        finishedExecuting(node)

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Tue Mar 05 22:18:26 UTC 2024

- 93.5K bytes

- Viewed (0)

github.com/golang/go

src/cmd/vendor/golang.org/x/sys/unix/syscall_linux.go

// may be re-used repeatedly with subsequent Write and Read operations.
//
// When hashing a small byte slice or string, a single Write and Read may
// be used:
//
//	// Assume hashfd is already configured using the setup process.
//	hash := os.NewFile(hashfd, "sha1")
//	// Hash an input string and read the results. Each Write discards
//	// previous hash state. Read always reads the current state.
//	b := make([]byte, 20)

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Thu Mar 07 05:26:45 UTC 2024

- 77.5K bytes

- Viewed (0)

github.com/golang/go

src/regexp/testdata/testregex.c

H("<BODY bgcolor=white>\n");
H("<PRE>\n");
T("NAME\n");
T("  testregex - regex(3) test harness\n");
T("\n");
T("SYNOPSIS\n");
T("  testregex [ options ]\n");
T("\n");
T("DESCRIPTION\n");
T("  testregex reads regex(3) test specifications, one per line, from the\n");
T("  standard input and writes one output line for each failed test. A\n");
T("  summary line is written after all tests are done. Each successful\n");

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Mon Sep 08 04:08:51 UTC 2014

- 51.3K bytes

- Viewed (0)

github.com/golang/go

src/cmd/link/internal/ld/lib.go

			err := binary.Read(r, f.ByteOrder, &namesize)
			if err != nil {
				if err == io.EOF {
					break
				}
				return nil, fmt.Errorf("read namesize failed: %v", err)
			}
			err = binary.Read(r, f.ByteOrder, &descsize)
			if err != nil {
				return nil, fmt.Errorf("read descsize failed: %v", err)
			}
			err = binary.Read(r, f.ByteOrder, &noteType)
			if err != nil {

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Tue May 21 18:45:27 UTC 2024

- 88.6K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/core-configuration/model-core/src/test/groovy/org/gradle/api/internal/provider/MapPropertySpec.groovy

        def result2 = property.get()

        then:
        0 * _

        and:
        result2 == [k1: "value"]
    }

    def "finalizes upstream properties when value read using #method and disallow unsafe reads"() {
        def a = property()
        def b = property()
        def c = valueProperty()
        def property = property()
        property.disallowUnsafeRead()

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Fri May 17 11:41:55 UTC 2024

- 58.7K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/controller/volume/attachdetach/cache/actual_state_of_world_test.go

}

// Populates data struct with one volume/node entry.
// Calls SetVolumesMountedByNode twice, first setting mounted to true then false.
// Calls AddVolumeNode to readd the same volume/node.
// Verifies mountedByNode is false and detachRequestedTime is zero.
func Test_SetVolumesMountedByNode_Positive_UnsetWithInitialSetAddVolumeNodeNotReset(t *testing.T) {
	// Arrange

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Thu Apr 11 07:35:17 UTC 2024

- 66.1K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/kubelet/kuberuntime/kuberuntime_container.go

		}
		return string(data), (fallbackToLogs && len(data) == 0)
	}
	return "", fallbackToLogs
}

// readLastStringFromContainerLogs attempts to read up to the max log length from the end of the CRI log represented
// by path. It reads up to max log lines.
func (m *kubeGenericRuntimeManager) readLastStringFromContainerLogs(path string) string {
	value := int64(kubecontainer.MaxContainerTerminationMessageLogLines)

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Tue Jun 04 06:25:43 UTC 2024

- 54.7K bytes

- Viewed (0)

Search Options