- Sort Score
- Num 10 results
- Language All
Results 181 - 190 of 374 for chainG (0.05 seconds)
-
src/test/java/jcifs/smb1/util/transport/TransportExceptionTest.java
assertTrue(exception instanceof Exception); assertTrue(exception instanceof Throwable); } @Test @DisplayName("Should preserve message through exception chain") void testMessagePreservation() { String originalMessage = "Original error"; TransportException original = new TransportException(originalMessage);
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 11.5K bytes - Click Count (0) -
compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/DefaultModelResolver.java
/** * A model resolver to assist building of dependency POMs. This resolver gives priority to those repositories that have * been initially specified and repositories discovered in dependency POMs are recessively merged into the search chain. * * @see DefaultArtifactDescriptorReader * @deprecated since 4.0.0, use {@code maven-api-impl} jar instead */ @Deprecated(since = "4.0.0") class DefaultModelResolver implements ModelResolver {Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Mon Apr 14 13:42:17 GMT 2025 - 10.8K bytes - Click Count (0) -
internal/event/target/amqp.go
confirms := ch.NotifyPublish(make(chan amqp091.Confirmation, 1)) if err := ch.Confirm(false); err != nil { ch.Close() return nil, nil, err } return ch, confirms, nil } return ch, nil, nil } // send - sends an event to the AMQP091. func (target *AMQPTarget) send(eventData event.Event, ch *amqp091.Channel, confirms chan amqp091.Confirmation) error {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 21 04:25:07 GMT 2025 - 10K bytes - Click Count (0) -
cmd/namespace-lock_test.go
// not be required but makes reproduction much easier. nsLk.lockMapMutex.Lock() // lk3 blocks. lk3ch := make(chan bool) go func() { lk3ch <- nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 0) }() // lk4, blocks. lk4ch := make(chan bool) go func() { lk4ch <- nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 0) }() runtime.Gosched()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3K bytes - Click Count (0) -
internal/once/singleton.go
// Singleton contains a pointer to T that must be set once. // Until the value is set all Get() calls will block. type Singleton[T any] struct { v *T set chan struct{} } // NewSingleton creates a new unset singleton. func NewSingleton[T any]() *Singleton[T] { return &Singleton[T]{set: make(chan struct{}), v: nil} } // Get will return the singleton value. func (s *Singleton[T]) Get() *T { <-s.set return s.v }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 15 12:04:40 GMT 2024 - 952 bytes - Click Count (0) -
src/main/java/jcifs/internal/smb1/com/SmbComWriteAndX.java
* @param b the data buffer containing bytes to write * @param off the offset in the buffer where data starts * @param len the number of bytes to write * @param andx the next command in the AndX chain, or null */ public SmbComWriteAndX(final Configuration config, final int fid, final long offset, final int remaining, final byte[] b, final int off, final int len, final ServerMessageBlock andx) {Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 6.1K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb1/com/SmbComOpenAndX.java
* @param access the desired access mode * @param shareAccess the share access mode * @param flags the open flags * @param fileAttributes the file attributes * @param andx the next command in the chain */ public SmbComOpenAndX(final Configuration config, final String fileName, final int access, final int shareAccess, final int flags, final int fileAttributes, final ServerMessageBlock andx) {Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 7.3K bytes - Click Count (0) -
src/test/java/jcifs/SmbTreeTest.java
/** * Test for unwrap with nested wrapping. * Verifies that unwrap works correctly with multiple levels of wrapping. */ @Test void testUnwrap_nestedWrapping() { // Create a chain of wrapped trees CustomSmbTree innerTree = mock(CustomSmbTree.class); ExtendedSmbTree middleTree = mock(ExtendedSmbTree.class); when(smbTree.unwrap(ExtendedSmbTree.class)).thenReturn(middleTree);Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 9.2K bytes - Click Count (0) -
cmd/metacache-server-pool.go
saver := z.serverPools[o.pool].sets[o.set] // Disconnect from call above, but cancel on exit. listCtx, cancel := context.WithCancel(GlobalContext) saveCh := make(chan metaCacheEntry, metacacheBlockSize) inCh := make(chan metaCacheEntry, metacacheBlockSize) outCh := make(chan metaCacheEntry, o.Limit) filteredResults := o.gatherResults(ctx, outCh) mc := o.newMetacache()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 12.9K bytes - Click Count (0) -
compat/maven-compat/src/main/resources/META-INF/maven/plugin-expressions/project.paramdoc.xml
the current project. NOTE: This will likely contain much more than the direct dependencies of the current POM, since Maven uses transitive, or chained, dependency resolution. ]]></description> </expression> <expression> <syntax>project.parentArtifact</syntax> <configuration> <![CDATA[ <parent> <groupId>project.group</groupId>Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 5.6K bytes - Click Count (0)