Search Options

Results per page
Sort
Preferred Languages
Advance

Results 861 - 870 of 977 for close1 (0.07 sec)

  1. src/main/java/org/codelibs/fess/ldap/LdapManager.java

                counter++;
            }
    
            @Override
            public void close() {
                if (counter > 1) {
                    counter--;
                } else {
                    contextLocal.remove();
                    if (context != null) {
                        try {
                            context.close();
                        } catch (final NamingException e) {
                            // ignored
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 65.9K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/cache/CacheBuilderTest.java

      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      public void testRemovalNotification_clear_basher() throws InterruptedException {
        // If a clear() happens close to the end of computation, one of two things should happen:
        // - computation ends first: the removal listener is called, and the cache does not contain the
        //   key/value pair
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 15:00:32 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    	obj, _, h, err := c.GetObject(ctx, tgt.Bucket, object, gopts)
    	if err != nil {
    		return nil, proxy, err
    	}
    	closeReader := func() { obj.Close() }
    	reader, err := fn(obj, h, closeReader)
    	if err != nil {
    		return nil, proxy, err
    	}
    	reader.ObjInfo = oi.Clone()
    	if rs != nil {
    		contentSize, err := parseSizeFromContentRange(h)
    		if err != nil {
    			return nil, proxy, err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom.go

    	Decommission *PoolDecommissionInfo `json:"decommissionInfo,omitempty" msg:"dec"`
    }
    
    // Clone returns a copy of PoolStatus
    func (ps PoolStatus) Clone() PoolStatus {
    	return PoolStatus{
    		ID:           ps.ID,
    		CmdLine:      ps.CmdLine,
    		LastUpdate:   ps.LastUpdate,
    		Decommission: ps.Decommission.Clone(),
    	}
    }
    
    //go:generate msgp -file $GOFILE -unexported
    type poolMeta struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

              assertThat(b).isEqualTo(2.toByte())
            }
          }
        }
      }
    
      private fun gzip(data: ByteArray): Buffer {
        val buffer = Buffer()
        GzipSink(buffer).buffer().write(data).close()
        return buffer
      }
    
      /** Create a sufficiently large header set to overflow INITIAL_MAX_FRAME_SIZE bytes.  */
      private fun largeHeaders(): List<Header> {
        val nameValues = arrayOfNulls<String>(32)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  6. docs/en/docs/tutorial/bigger-applications.md

    This is because we want to include their *path operations* in the OpenAPI schema and the user interfaces.
    
    As we cannot just isolate them and "mount" them independently of the rest, the *path operations* are "cloned" (re-created), not included directly.
    
    ///
    
    ## Check the automatic API docs
    
    Now, run your app:
    
    <div class="termy">
    
    ```console
    $ fastapi dev app/main.py
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

       * be made {@code static} and its instances can be safely constructed and added in the {@link
       * ServiceManager} constructor without having to close over the partially constructed {@link
       * ServiceManager} instance (i.e. avoid leaking a pointer to {@code this}).
       */
      private final ServiceManagerState state;
    
      private final ImmutableList<Service> services;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/ServiceManager.java

       * be made {@code static} and its instances can be safely constructed and added in the {@link
       * ServiceManager} constructor without having to close over the partially constructed {@link
       * ServiceManager} instance (i.e. avoid leaking a pointer to {@code this}).
       */
      private final ServiceManagerState state;
    
      private final ImmutableList<Service> services;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  9. cmd/format-erasure.go

    		if format == nil {
    			continue
    		}
    		if format.Drives() == maxDrives {
    			format := formats[i].Clone()
    			format.Erasure.This = ""
    			return format, nil
    		}
    	}
    
    	return nil, errErasureReadQuorum
    }
    
    func formatErasureV3Check(reference *formatErasureV3, format *formatErasureV3) error {
    	tmpFormat := format.Clone()
    	this := tmpFormat.Erasure.This
    	tmpFormat.Erasure.This = ""
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  10. tests/hooks_test.go

    		t.Fatalf("Failed to query product, got error: %v", err)
    	}
    
    	var resultClone Product2
    	if err := DB.First(&resultClone, "name = ?", "Nice_clone").Error; err != nil {
    		t.Fatalf("Failed to find cloned product, got error: %v", err)
    	}
    
    	result.Price *= 2
    	result.Name += "_clone"
    	AssertObjEqual(t, result, resultClone, "Price", "Name")
    
    	DB.Model(&result).Update("Price", 500)
    	var result2 Product2
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 17 03:59:06 UTC 2024
    - 16.7K bytes
    - Viewed (0)
Back to top