- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,154 for Kappen (0.23 sec)
-
maven-core/src/main/java/org/apache/maven/project/DefaultProjectBuilder.java
buffer.append("<?xml version='1.0'?>"); buffer.append("<project>"); buffer.append("<modelVersion>4.0.0</modelVersion>"); buffer.append("<groupId>").append(artifact.getGroupId()).append("</groupId>"); buffer.append("<artifactId>").append(artifact.getArtifactId()).append("</artifactId>"); buffer.append("<version>").append(artifact.getBaseVersion()).append("</version>");
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 56.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/ByteSourceTest.java
// Slice it starting at offset 10. ByteSource slice = source.slice(10, 5); // Open a stream to the slice. InputStream in = slice.openStream(); // Append 10 more bytes to the source. source.append(newPreFilledByteArray(5, 10)); // The stream reports no bytes... importantly, it doesn't read the byte at index 5 when it // should be reading the byte at index 10.
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 16.9K bytes - Viewed (0) -
cmd/admin-handlers-pools.go
}{ID: id}) if err != nil { writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL) return } writeSuccessResponseJSON(w, b) // Notify peers to load rebalance.bin and start rebalance routine if they happen to be // participating pool's leader node globalNotificationSys.LoadRebalanceMeta(ctx, true) } func (a adminAPIHandlers) RebalanceStatus(w http.ResponseWriter, r *http.Request) { ctx := r.Context()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 10.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
public void testRemovalNotification_clear_basher() throws InterruptedException { // If a clear() happens close to the end of computation, one of two things should happen: // - computation ends first: the removal listener is called, and the cache does not contain the // key/value pair // - clear() happens first: the removal listener is not called, and the cache contains the pair
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Oct 03 20:10:02 GMT 2023 - 23.2K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
assertPodAnnotated(t, client, pod) // Assert expected calls actually made fs.AssertExpectations(t) // unlabelling the namespace should cause only one RemovePodFromMesh to happen fs.On("RemovePodFromMesh", ctx, mock.Anything, ).Once().Return(nil) // unlabel the namespace labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":null}}}`,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
internal/s3select/json/preader.go
if err != nil && err != io.ErrUnexpectedEOF { // If an EOF happens after reading some but not all the bytes, // ReadFull returns ErrUnexpectedEOF. return dst[:n], err } dst = dst[:n] if err == io.ErrUnexpectedEOF { return dst, io.EOF } } // Read until next line. in, err := r.buf.ReadBytes('\n') dst = append(dst, in...) return dst, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 6.4K bytes - Viewed (0) -
cmd/s3-zip-handlers.go
if len(listObjectsInfo.Prefixes) == 0 || commonPrefix != listObjectsInfo.Prefixes[len(listObjectsInfo.Prefixes)-1] { listObjectsInfo.Prefixes = append(listObjectsInfo.Prefixes, commonPrefix) count++ } goto next } } listObjectsInfo.Objects = append(listObjectsInfo.Objects, ObjectInfo{ Bucket: bucket, Name: objName, Size: int64(file.UncompressedSize64),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 09 10:41:25 GMT 2024 - 15.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CharSourceTest.java
try { in.copyTo(out); fail(); } catch (IOException expected) { return CloserTest.getSuppressed(expected).length; } throw new AssertionError(); // can't happen } private static CharSource newNormalCharSource() { return CharSource.wrap("ABC"); } private static CharSink newNormalCharSink() { return new CharSink() { @Override
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 13K bytes - Viewed (0) -
internal/config/config.go
kvs.Set(kv.Key, kv.Value) } } targets = append(targets, Target{ SubSystem: inputs[0], KVS: kvs, }) } else { // Use help for sub-system to preserve the order. Add deprecated // keys at the end (in some order). kvsOrder := append([]HelpKV{}, HelpSubSysMap[""]...) for _, v := range HelpDeprecatedSubSysMap { kvsOrder = append(kvsOrder, v) } for _, hkv := range kvsOrder {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0) -
cmd/metacache-set.go
for i, info := range infos { mutations := info.Metrics.TotalDeletes + info.Metrics.TotalWrites if mutations >= commonMutations { newDisks = append(newDisks, disks[i]) newInfos = append(newInfos, infos[i]) } } return newDisks, newInfos } func getQuorumDisks(disks []StorageAPI, infos []DiskInfo, readQuorum int) (newDisks []StorageAPI) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0)