- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 249 for close (0.13 sec)
-
cni/pkg/nodeagent/healthServer_test.go
installReady, watchReady := initRouter(router) assert.Equal(t, installReady.Load(), false) assert.Equal(t, watchReady.Load(), false) server := httptest.NewServer(router) defer server.Close() makeReq(t, server.URL, constants.LivenessEndpoint, http.StatusOK) makeReq(t, server.URL, constants.ReadinessEndpoint, http.StatusServiceUnavailable) installReady.Store(true) watchReady.Store(true)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
udsSock := filepath.Join(udsSockDir, "cni.sock") logger := NewUDSLogger() pluginLog.SetOutputLevel(log.DebugLevel) // this will be configured by global.logging.level stop := make(chan struct{}) defer close(stop) assert.NoError(t, logger.StartUDSLogServer(udsSock, stop)) // Configure log to tee to UDS server stdout := os.Stdout r, w, _ := os.Pipe() os.Stdout = w loggingOptions := log.DefaultOptions()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
logger.warn("Could not close a process input stream.", e); } }); CommonPoolUtil.execute(() -> { try { CloseableUtil.closeQuietly(p.getErrorStream()); } catch (final Exception e) { logger.warn("Could not close a process error stream.", e); } });
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.6K bytes - Viewed (0) -
fastapi/datastructures.py
""" return await super().seek(offset) async def close(self) -> None: """ Close the file. To be awaitable, compatible with async, this is run in threadpool. """ return await super().close() @classmethod def __get_validators__(cls: Type["UploadFile"]) -> Iterable[Callable[..., Any]]:
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Tue Apr 02 02:48:51 GMT 2024 - 5.6K bytes - Viewed (0) -
src/main/java/org/codelibs/core/zip/ZipFileUtil.java
* Zipファイルをクローズします。 * <p> * {@link ZipFile#close()}が例外をスローした場合はログにエラーメッセージを出力します。 例外は再スローされません。 * </p> * * @param zipFile * Zipファイル。{@literal null}であってはいけません */ public static void close(final ZipFile zipFile) { assertArgumentNotNull("zipFile", zipFile); try { zipFile.close(); } catch (final IOException e) {
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 5.1K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultTransport.java
requireNonNull(charset, "charset is null"); putBytes(source.getBytes(charset), relativeTarget); } @Override public void close() { transporter.close(); }
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 16:33:18 GMT 2024 - 5.3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/aether/LegacyRepositorySystemSessionExtender.java
p.setNtlmDomain(authCtx.get(AuthenticationContext.NTLM_DOMAIN)); p.setNtlmHost(authCtx.get(AuthenticationContext.NTLM_WORKSTATION)); authCtx.close(); } return p; } } return null; }
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 6.7K bytes - Viewed (0) -
src/main/java/org/codelibs/core/jar/JarFileUtil.java
* Jarファイルをクローズします。 * <p> * {@link JarFile#close()}が例外をスローした場合はログにエラーメッセージを出力します。 例外は再スローされません。 * </p> * * @param jarFile * Jarファイル。{@literal null}であってはいけません */ public static void close(final JarFile jarFile) { assertArgumentNotNull("jarFile", jarFile); try { jarFile.close(); } catch (final IOException e) {
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 5.4K bytes - Viewed (0) -
cmd/post-policy-fan-out.go
if err != nil { errs[idx] = err return } reader := NewPutObjReader(hr) defer func() { if err := reader.Close(); err != nil { errs[idx] = err } if err := hr.Close(); err != nil { errs[idx] = err } }() userDefined := make(map[string]string, len(req.UserMetadata)) for k, v := range req.UserMetadata { userDefined[k] = v
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 3.5K bytes - Viewed (0) -
internal/bpool/bpool_test.go
} if cap(b) != capWidth { t.Fatalf("bytepool length invalid: got %v want %v", cap(b), capWidth) } bufPool.Put(b) // Close the channel so we can iterate over it. close(bufPool.c) // Check the size of the pool. if uint64(len(bufPool.c)) != size { t.Fatalf("bytepool size invalid: got %v want %v", len(bufPool.c), size) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 19:13:27 GMT 2024 - 2.6K bytes - Viewed (0)