- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 122 for Finnish (0.24 sec)
-
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/PluginsMetadataGenerator.java
return Collections.emptyList(); } @Override public Artifact transformArtifact(Artifact artifact) { return artifact; } @Override public Collection<? extends Metadata> finish(Collection<? extends Artifact> artifacts) { LinkedHashMap<String, PluginsMetadata> plugins = new LinkedHashMap<>(); for (Artifact artifact : artifacts) {
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 6.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/LineBufferTest.java
int off = 0; while (off < chars.length) { int len = Math.min(chars.length, off + chunk) - off; lineBuf.add(chars, off, len); off += len; } lineBuf.finish(); return lines; } private static List<String> readUsingJava(String input, int chunk) throws IOException { BufferedReader r = new BufferedReader(getChunkedReader(input, chunk));
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4.7K bytes - Viewed (0) -
docs/distributed/decom-encrypted-sse-s3.sh
./mc admin decom start myminio/ http://localhost:9000/tmp/xl/{1...10}/disk{0...1} until $(./mc admin decom status myminio/ | grep -q Complete); do echo "waiting for decom to finish..." sleep 1 done kill $pid_1 kill $pid_2 sleep 5 (minio server --address ":9001" http://localhost:9001/tmp/xl/{11...30}/disk{0...3} 2>&1 >/tmp/removed.log) & pid=$! sleep 30
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.5K bytes - Viewed (0) -
misc/go_android_exec/main.go
// along stderr from adb. cmd.Stderr = struct{ io.Writer }{os.Stderr} err := cmd.Run() // Before we process err, flush any further output and get the exit code. exitCode, err2 := filter.Finish() if err != nil { return 0, fmt.Errorf("adb exec-out %s: %v", args, err) } return exitCode, err2 } func adb(args ...string) error { if out, err := adbCmd(args...).CombinedOutput(); err != nil {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Aug 21 17:46:57 GMT 2023 - 15.3K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
if f.testWG != nil { defer f.testWG.Done() } args := f.Called(ambientPods) return args.Error(0) } // Custom "wait group with timeout" for waiting for fakeServer calls in a goroutine to finish type WaitGroup struct { count int32 done chan struct{} } func NewWaitGroup() *WaitGroup { return &WaitGroup{ done: make(chan struct{}), } }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
*/ RecordingRunnable earlyListener = new RecordingRunnable(); listenable.addListener(earlyListener, directExecutor()); input.allowGetToComplete.countDown(); // Now give the get() thread time to finish: assertTrue(earlyListener.wasRun.await(1, SECONDS)); // Now test an additional addListener call, which will be run in-thread: RecordingRunnable lateListener = new RecordingRunnable();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 9.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
*/ RecordingRunnable earlyListener = new RecordingRunnable(); listenable.addListener(earlyListener, directExecutor()); input.allowGetToComplete.countDown(); // Now give the get() thread time to finish: assertTrue(earlyListener.wasRun.await(1, SECONDS)); // Now test an additional addListener call, which will be run in-thread: RecordingRunnable lateListener = new RecordingRunnable();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 9.7K bytes - Viewed (0) -
prepare_stmt.go
// 2. g2 select lock `conn.PrepareContext(ctx, query)`, now db.numOpen == db.maxOpen , wait for release. // 3. g1 tx exec insert, wait for unlock `conn.PrepareContext(ctx, query)` to finish tx and release. stmt, err := conn.PrepareContext(ctx, query) if err != nil { cacheStmt.prepareErr = err db.Mux.Lock() delete(db.Stmts, query) db.Mux.Unlock() return Stmt{}, err }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Mar 28 08:47:39 GMT 2024 - 6.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* * @param executor the executor to modify to make sure it exits when the application is finished * @param terminationTimeout how long to wait for the executor to finish before terminating the * JVM * @param timeUnit unit of time for the time parameter * @return an unmodifiable version of the input which will not hang the JVM */ @J2ktIncompatible
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
} /** * Returns a future that delegates to this future but will finish early (via a {@link * TimeoutException} wrapped in an {@link ExecutionException}) if the specified timeout expires. * If the timeout expires, not only will the output future finish, but also the input future * ({@code this}) will be cancelled and interrupted. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 11 19:08:44 GMT 2023 - 18.7K bytes - Viewed (0)