Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 181 - 190 of 374 for chainG (0.14 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top