Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 461 - 470 of 934 for _clone (0.04 seconds)

  1. fastapi/middleware/asyncexitstack.py

    from contextlib import AsyncExitStack
    
    from starlette.types import ASGIApp, Receive, Scope, Send
    
    
    # Used mainly to close files after the request is done, dependencies are closed
    # in their own AsyncExitStack
    class AsyncExitStackMiddleware:
        def __init__(
            self, app: ASGIApp, context_name: str = "fastapi_middleware_astack"
        ) -> None:
            self.app = app
            self.context_name = context_name
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Mon Sep 29 03:29:38 GMT 2025
    - 637 bytes
    - Click Count (0)
  2. cmd/utils.go

    		return path, ""
    	}
    	return path[:m], path[m+len(SlashSeparator):]
    }
    
    func path2BucketObject(s string) (bucket, prefix string) {
    	return path2BucketObjectWithBasePath("", s)
    }
    
    // cloneMSS will clone a map[string]string.
    // If input is nil an empty map is returned, not nil.
    func cloneMSS(v map[string]string) map[string]string {
    	r := make(map[string]string, len(v))
    	maps.Copy(r, v)
    	return r
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  3. cmd/naughty-disk_test.go

    	return d.disk.Hostname()
    }
    
    func (d *naughtyDisk) Healing() *healingTracker {
    	return d.disk.Healing()
    }
    
    func (d *naughtyDisk) Close() (err error) {
    	if err = d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.Close()
    }
    
    func (d *naughtyDisk) calcError() (err error) {
    	d.mu.Lock()
    	defer d.mu.Unlock()
    	d.callNR++
    	if err, ok := d.errors[d.callNR]; ok {
    		return err
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 10.1K bytes
    - Click Count (0)
  4. internal/grid/muxserver.go

    		case <-t.C:
    			last := time.Since(time.Unix(atomic.LoadInt64(&m.LastPing), 0))
    			if last > 4*m.clientPingInterval {
    				gridLogIf(m.ctx, fmt.Errorf("canceling remote connection %s not seen for %v", m.parent, last))
    				m.close()
    				return
    			}
    		}
    	}
    }
    
    // checkSeq will check if sequence number is correct and increment it by 1.
    func (m *muxServer) checkSeq(seq uint32) (ok bool) {
    	if seq != m.RecvSeq {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 9.7K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

     *
     * ```java
     * client.connectionPool().evictAll();
     * ```
     *
     * If your client has a cache, call [close()][Cache.close]. Note that it is an error to create calls
     * against a cache that is closed, and doing so will cause the call to crash.
     *
     * ```java
     * client.cache().close();
     * ```
     *
     * OkHttp also uses daemon threads for HTTP/2 connections. These will exit automatically if they
     * remain idle.
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 51.4K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt

      /**
       * Closes the response body. Equivalent to `body().close()`.
       *
       * Prior to OkHttp 5.0, it was an error to close a response that is not eligible for a body. This
       * includes the responses returned from [cacheResponse], [networkResponse], and [priorResponse].
       */
      override fun close() {
        body.close()
      }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Jul 28 14:39:28 GMT 2025
    - 18.1K bytes
    - Click Count (0)
  7. guava/src/com/google/common/io/ByteStreams.java

       * approaches 2 or 3 are used.
       */
      private static final int ZERO_COPY_CHUNK_SIZE = 512 * 1024;
    
      private ByteStreams() {}
    
      /**
       * Copies all bytes from the input stream to the output stream. Does not close or flush either
       * stream.
       *
       * <p><b>Java 9 users and later:</b> this method should be treated as deprecated; use the
       * equivalent {@link InputStream#transferTo} method instead.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 31.1K bytes
    - Click Count (0)
  8. impl/maven-core/src/main/java/org/apache/maven/plugin/PluginParameterExpressionEvaluatorV4.java

             * ended up with a magic value that is not compatible with the type of the configured mojo parameter (a string
             * could still be converted by the configurator so we leave those alone). If so, back off to evaluating the
             * expression from properties only.
             */
            if (value != null && type != null && !(value instanceof String) && !isTypeCompatible(type, value)) {
                value = null;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jan 24 17:29:44 GMT 2025
    - 9.8K bytes
    - Click Count (0)
  9. src/test/java/jcifs/smb/SmbSessionImplSecurityTest.java

            Mockito.when(mockContext.getCredentials()).thenReturn(mockCredentials);
            Mockito.when(mockCredentials.unwrap(Mockito.any())).thenReturn(mockCredentialsInternal);
            Mockito.when(mockCredentialsInternal.clone()).thenReturn(mockCredentialsInternal);
            Mockito.when(mockTransport.acquire()).thenReturn(mockTransport);
        }
    
        /**
         * Test that concurrent tree operations are thread-safe with CopyOnWriteArrayList.
         */
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 11K bytes
    - Click Count (0)
  10. internal/event/rules_test.go

    		{rulesCase2, "2000*", TargetID{"2", "amqp"}},
    		{rulesCase3, "2010*", TargetID{"1", "webhook"}},
    	}
    
    	for i, testCase := range testCases {
    		result := testCase.rules.Clone()
    
    		if !reflect.DeepEqual(result, testCase.rules) {
    			t.Fatalf("test %v: result: expected: %v, got: %v", i+1, testCase.rules, result)
    		}
    
    		result.Add(NewPattern(testCase.prefix, ""), testCase.targetID)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 8.8K bytes
    - Click Count (0)
Back to Top