Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 321 - 330 of 1,033 for Close (0.02 seconds)

  1. internal/once/singleton.go

    		return true
    	default:
    		return false
    	}
    }
    
    // Set the value and unblock all Get requests.
    // This may only be called once, a second call will panic.
    func (s *Singleton[T]) Set(v *T) {
    	s.v = v
    	close(s.set)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 15 12:04:40 GMT 2024
    - 952 bytes
    - Click Count (0)
  2. src/main/java/jcifs/internal/smb2/Smb2SigningDigest.java

                }
                this.closed = true;
            } finally {
                this.signingLock.unlock();
            }
        }
    
        /**
         * Close the signing digest and securely wipe keys
         */
        @Override
        public void close() {
            secureWipeKey();
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  3. internal/rest/client.go

    }
    
    func (r *respBodyMonitor) Read(p []byte) (n int, err error) {
    	n, err = r.ReadCloser.Read(p)
    	r.errorStatus(err)
    	return n, err
    }
    
    func (r *respBodyMonitor) Close() (err error) {
    	err = r.ReadCloser.Close()
    	r.errorStatus(err)
    	return err
    }
    
    func (r *respBodyMonitor) errorStatus(err error) {
    	if xnet.IsNetworkOrHostDown(err, r.expectTimeouts) {
    		r.errorStatusOnce.Do(func() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  4. src/main/java/jcifs/smb1/netbios/SocketInputStream.java

        public int available() throws IOException {
            if (bip > 0) {
                return bip;
            }
            return in.available();
        }
    
        @Override
        public void close() throws IOException {
            in.close();
        }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  5. internal/config/lambda/target/webhook.go

    		req.Header.Set("Authorization", "Bearer "+target.args.AuthToken)
    	}
    
    	req.Header.Set("Content-Type", "application/json")
    
    	return target.httpClient.Do(req)
    }
    
    // Close the target. Will cancel all active requests.
    func (target *WebhookTarget) Close() error {
    	target.cancel()
    	return nil
    }
    
    func (target *WebhookTarget) init() error {
    	return target.lazyInit.Do(target.initWebhook)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jul 08 21:39:49 GMT 2024
    - 6.7K bytes
    - Click Count (0)
  6. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java

            SocketException exception = new SocketException();
            exception.initCause(e);
            throw exception;
          }
        }
    
        @Override public void close() throws IOException {
          serverSocketChannel.close();
        }
      }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 12 16:33:52 GMT 2019
    - 3.1K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/fess/dict/stopwords/StopwordsFileTest.java

                                return new FileInputStream(testFile);
                            }
    
                            @Override
                            public void close() throws IOException {
                                // Nothing to close
                            }
                        };
                    } catch (Exception e) {
                        throw new RuntimeException(e);
                    }
                }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 18K bytes
    - Click Count (0)
  8. mockwebserver/src/main/kotlin/mockwebserver3/Dispatcher.kt

       * should return immediately. Responses returned after shutdown will not be transmitted: their
       * socket connections have already been closed.
       */
      public open override fun close() {}
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Jun 20 11:46:46 GMT 2025
    - 1.6K bytes
    - Click Count (0)
  9. .github/stale.yml

    onlyLabels: []
    
    # Issues or Pull Requests with these labels will never be considered stale. Set to `[]` to disable
    exemptLabels:
      - "security"
      - "pending discussion"
      - "do-not-close"
    
    # Set to true to ignore issues in a project (defaults to false)
    exemptProjects: false
    
    # Set to true to ignore issues in a milestone (defaults to false)
    exemptMilestones: false
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jan 24 04:36:59 GMT 2022
    - 2K bytes
    - Click Count (0)
  10. src/main/java/jcifs/internal/smb2/rdma/disni/DisniRdmaConnection.java

            }
        }
    
        @Override
        public void close() throws IOException {
            state = RdmaConnectionState.CLOSING;
    
            try {
                // In real implementation, this would close the DiSNI endpoint:
                // if (endpoint != null) {
                //     endpoint.close();
                // }
            } finally {
                state = RdmaConnectionState.CLOSED;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 10.2K bytes
    - Click Count (0)
Back to Top