- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 364 for recessive (0.04 sec)
-
cmd/sftp-server-driver.go
// Send object names that are needed to be removed to objectsCh go func() { defer xioutil.SafeClose(objectsCh) opts := minio.ListObjectsOptions{ Prefix: prefix, Recursive: true, } for object := range clnt.ListObjects(cctx, bucket, opts) { if object.Err != nil { return } objectsCh <- object } }() // Call RemoveObjects API
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Feb 10 16:35:49 UTC 2025 - 11.6K bytes - Viewed (0) -
docs/chroot/README.md
cp $(go env GOPATH)/bin/minio /mnt/export/${USER}/bin/minio chmod +x /mnt/export/${USER}/bin/minio ``` Alternatively, if you have an existing legacy binary, you can still use it, but note that it will not receive updates. Bind your `proc` mount to the target chroot directory ``` sudo mount --bind /proc /mnt/export/${USER}/proc ``` ## 3. Run Standalone MinIO in Chroot ### GNU/Linux ```shRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Oct 15 17:29:55 UTC 2025 - 2.2K bytes - Viewed (0) -
src/main/java/jcifs/SmbConstants.java
*/ int DEFAULT_RESPONSE_TIMEOUT = 30000; /** * Default socket timeout in milliseconds. */ int DEFAULT_SO_TIMEOUT = 35000; /** * Default receive buffer size for SMB transport. */ int DEFAULT_RCV_BUF_SIZE = 0xFFFF; /** * Default send buffer size for SMB transport. */ int DEFAULT_SND_BUF_SIZE = 0xFFFF; /**Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 24 00:49:49 UTC 2025 - 12.8K bytes - Viewed (0) -
fastapi/routing.py
""" # assert asyncio.iscoroutinefunction(func), "WebSocket endpoints must be async" async def app(scope: Scope, receive: Receive, send: Send) -> None: session = WebSocket(scope, receive=receive, send=send) async def app(scope: Scope, receive: Receive, send: Send) -> None: async with AsyncExitStack() as request_stack: scope["fastapi_inner_astack"] = request_stackRegistered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Dec 27 12:54:56 UTC 2025 - 174.6K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbTreeHandleInternalTest.java
// Arrange when(handle.getReceiveBufferSize()).thenThrow(new CIFSException("receive size failed")); // Act + Assert CIFSException ex = assertThrows(CIFSException.class, () -> handle.getReceiveBufferSize()); assertEquals("receive size failed", ex.getMessage()); verify(handle).getReceiveBufferSize(); } @TestRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 9.3K bytes - Viewed (0) -
internal/s3select/jstream/scanner_test.go
break } if c != mockData { t.Fatalf("expected \"%s\", got \"%s\"", string(mockData), string(c)) } i++ } c := scanner.next() if scanner.readerErr == nil { t.Fatalf("failed to receive expected error after %d bytes", failAfter) } if c != byte(0) { t.Fatalf("expected null byte, got %v", c) } } func BenchmarkBufioScanner(b *testing.B) { b.Run("small", func(b *testing.B) {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 3.1K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/DcerpcBind.java
} @Override public void decode_out(final NdrBuffer buf) throws NdrException { buf.dec_ndr_short(); /* max transmit frag size */ buf.dec_ndr_short(); /* max receive frag size */ buf.dec_ndr_long(); /* assoc. group */ final int n = buf.dec_ndr_short(); /* secondary addr len */ buf.advance(n); /* secondary addr */ buf.align(4);Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 3.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/DcerpcBind.java
} @Override public void decode_out(final NdrBuffer buf) throws NdrException { buf.dec_ndr_short(); /* max transmit frag size */ buf.dec_ndr_short(); /* max receive frag size */ buf.dec_ndr_long(); /* assoc. group */ final int n = buf.dec_ndr_short(); /* secondary addr len */ buf.advance(n); /* secondary addr */ buf.align(4);Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 3.5K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TransTransactNamedPipeResponse.java
if (pipe.pipeIn != null) { final TransactNamedPipeInputStream in = (TransactNamedPipeInputStream) pipe.pipeIn; synchronized (in.lock) { in.receive(buffer, bufferIndex, len); in.lock.notify(); } } return len; } @Override public String toString() {
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 2.2K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/execution/MavenExecutionRequest.java
/** * @return the degree of concurrency for the build. */ int getDegreeOfConcurrency(); // Recursive (really to just process the top-level POM) MavenExecutionRequest setRecursive(boolean recursive); boolean isRecursive(); MavenExecutionRequest setPom(File pom); File getPom(); // ErrorsRegistered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Thu Dec 12 11:02:17 UTC 2024 - 18.6K bytes - Viewed (0)