Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 481 - 490 of 1,033 for Close (0.02 seconds)

  1. internal/logger/target/kafka/kafka.go

    		h.storeCtxCancel()
    	}
    
    	// Set logch to nil and close it.
    	// This will block all Send operations,
    	// and finish the existing ones.
    	// All future ones will be discarded.
    	h.logChMu.Lock()
    	xioutil.SafeClose(h.logCh)
    	h.logCh = nil
    	h.logChMu.Unlock()
    
    	if h.producer != nil {
    		h.producer.Close()
    		h.client.Close()
    	}
    
    	// Wait for messages to be sent...
    	h.wg.Wait()
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  2. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/vagrant/VagrantMachine.java

                String progress = progressHandler.apply(line);
                if (progress != null) {
                    progressLogger.progress(progress);
                }
            }
    
            @Override
            public void close() {
                progressLogger.completed();
            }
        }
    
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 7.5K bytes
    - Click Count (0)
  3. misc/go_android_exec/main.go

    	args += "; echo -n " + exitStr + "$?"
    
    	cmd := adbCmd("exec-out", args)
    	cmd.Stdout = filter
    	// If the adb subprocess somehow hangs, go test will kill this wrapper
    	// and wait for our os.Stderr (and os.Stdout) to close as a result.
    	// However, if the os.Stderr (or os.Stdout) file descriptors are
    	// passed on, the hanging adb subprocess will hold them open and
    	// go test will hang forever.
    	//
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Aug 21 17:46:57 GMT 2023
    - 15.3K bytes
    - Click Count (0)
  4. docs/changelogs/changelog_4x.md

        the certificate that follows and the last certificate is signed by a trusted root.
    
     *  Fix: Don't lose HTTP/2 flow control bytes when incoming data races with a stream close. If this
        happened enough then eventually the connection would stall.
    
     *  Fix: Acknowledge and apply inbound HTTP/2 settings atomically. Previously we had a race where we
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/hash/Funnels.java

       * funnel} an object to a {@code PrimitiveSink} if there is already a way to write the contents of
       * the object to an {@code OutputStream}.
       *
       * <p>The {@code close} and {@code flush} methods of the returned {@code OutputStream} do nothing,
       * and no method throws {@code IOException}.
       *
       * @since 13.0
       */
      public static OutputStream asOutputStream(PrimitiveSink sink) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 7.2K bytes
    - Click Count (0)
  6. src/main/webapp/js/admin/adminlte.min.js.map

    is._config.title))\n    }\n\n    if (this._config.subtitle != null) {\n      toastHeader.append($('<small />').html(this._config.subtitle))\n    }\n\n    if (this._config.close == true) {\n      const toastClose = $('<button data-dismiss=\"toast\" />').attr('type', 'button').addClass('ml-2 mb-1 close').attr('aria-label', 'Close').append('<span aria-hidden=\"true\">&times;</span>')\n\n      if (this._config.title == null) {\n        toastClose.toggleClass('ml-2 ml-auto')\n      }\n\n      toastHe...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Oct 26 01:49:09 GMT 2024
    - 132.4K bytes
    - Click Count (0)
  7. .github/DISCUSSION_TEMPLATE/questions.yml

            And there's a high chance that you will find the solution along the way and you won't even have to submit it and wait for an answer. 😎
    
            As there are too many questions, I'll have to discard and close the incomplete ones. That will allow me (and others) to focus on helping people like you that follow the whole process and help us help you. 🤓
      - type: checkboxes
        id: checks
        attributes:
          label: First Check
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Aug 03 15:59:41 GMT 2023
    - 5.8K bytes
    - Click Count (0)
  8. api/go1.17.txt

    pkg archive/zip, method (*Writer) CreateRaw(*FileHeader) (io.Writer, error)
    pkg compress/lzw, method (*Reader) Close() error
    pkg compress/lzw, method (*Reader) Read([]uint8) (int, error)
    pkg compress/lzw, method (*Reader) Reset(io.Reader, Order, int)
    pkg compress/lzw, method (*Writer) Close() error
    pkg compress/lzw, method (*Writer) Reset(io.Writer, Order, int)
    pkg compress/lzw, method (*Writer) Write([]uint8) (int, error)
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Feb 17 20:31:46 GMT 2023
    - 18K bytes
    - Click Count (0)
  9. cmd/streaming-v4-unsigned.go

    type s3UnsignedChunkedReader struct {
    	reader   *bufio.Reader
    	trailers http.Header
    
    	buffer []byte
    	offset int
    	err    error
    	debug  bool
    }
    
    func (cr *s3UnsignedChunkedReader) Close() (err error) {
    	return cr.err
    }
    
    // Read - implements `io.Reader`, which transparently decodes
    // the incoming AWS Signature V4 streaming signature.
    func (cr *s3UnsignedChunkedReader) Read(buf []byte) (n int, err error) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Apr 03 14:55:52 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  10. src/main/java/jcifs/http/NetworkExplorer.java

                        out.println("</a>");
                    }
                }
            }
    
            out.println("</td></tr></table>");
            out.println("</BODY></HTML>");
            out.close();
        }
    
        private static String parseServerAndShare(final String pathInfo) {
            final char[] out = new char[256];
            char ch;
            int len, p, i;
    
            if (pathInfo == null) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 23.4K bytes
    - Click Count (0)
Back to Top