Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 665 for closeFD (0.13 sec)

  1. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/AbstractFileLockManagerTest.groovy

            thrown(IllegalStateException)
        }
    
        def "can close a lock multiple times"() {
            given:
            def lock = createLock(Exclusive)
            lock.close()
    
            expect:
            lock.close()
        }
    
        def "cannot read from file after lock has been closed"() {
            given:
            def lock = createLock(Exclusive)
            lock.close()
    
            when:
            lock.readFile({} as Supplier)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  2. src/main/webapp/js/suggestor.js

                        function() {
                          listSelNum =
                            $(this)
                              .closest("ol")
                              .children("li")
                              .index(this) + 1;
                          $(this)
                            .closest("ol")
                            .children("li")
                            .each(function(i) {
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Mar 30 05:45:24 UTC 2023
    - 13.3K bytes
    - Viewed (0)
  3. src/internal/poll/fd_unix.go

    }
    
    // Close closes the FD. The underlying file descriptor is closed by the
    // destroy method when there are no remaining references.
    func (fd *FD) Close() error {
    	if !fd.fdmu.increfAndClose() {
    		return errClosing(fd.isFile)
    	}
    
    	// Unblock any I/O.  Once it all unblocks and returns,
    	// so that it cannot be referring to fd.sysfd anymore,
    	// the final decref will close fd.sysfd. This should happen
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 04:09:44 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  4. src/net/listen_test.go

    	}()
    
    	if ln, err := Listen("tcp", ""); err == nil {
    		ln.Close()
    	}
    	if ln, err := ListenPacket("udp", ""); err == nil {
    		ln.Close()
    	}
    	if ln, err := ListenTCP("tcp", nil); err == nil {
    		ln.Close()
    	}
    	if ln, err := ListenUDP("udp", nil); err == nil {
    		ln.Close()
    	}
    	if ln, err := ListenIP("ip:icmp", nil); err == nil {
    		ln.Close()
    	}
    }
    
    var ipv4MulticastListenerTests = []struct {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 20.5K bytes
    - Viewed (0)
  5. platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/inet/TcpConnectorTest.groovy

                def conn = event.create(serializer)
                conn.dispatch("bye")
                conn.stop()
                instant.closed
            } as Action, false)
    
            def connection = outgoingConnector.connect(acceptor.address).create(serializer)
            thread.blockUntil.closed
    
            then:
            connection.receive() == "bye"
            connection.receive() == null
    
            cleanup:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:59:22 UTC 2023
    - 10.4K bytes
    - Viewed (0)
  6. internal/event/target/postgresql.go

    	}
    
    	// Delete the event from store.
    	return target.store.Del(key.Name)
    }
    
    // Close - closes underneath connections to PostgreSQL database.
    func (target *PostgreSQLTarget) Close() error {
    	close(target.quitCh)
    	if target.updateStmt != nil {
    		// FIXME: log returned error. ignore time being.
    		_ = target.updateStmt.Close()
    	}
    
    	if target.deleteStmt != nil {
    		// FIXME: log returned error. ignore time being.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. internal/rest/client.go

    	return
    }
    
    // ErrClientClosed returned when *Client is closed.
    var ErrClientClosed = errors.New("rest client is closed")
    
    // Call - make a REST call with context.
    func (c *Client) Call(ctx context.Context, method string, values url.Values, body io.Reader, length int64) (reply io.ReadCloser, err error) {
    	switch atomic.LoadInt32(&c.connected) {
    	case closed:
    		// client closed, this is usually a manual process
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  8. src/net/http/transfer.go

    	mu         sync.Mutex // guards following, and calls to Read and Close
    	sawEOF     bool
    	closed     bool
    	earlyClose bool   // Close called and we didn't read to the end of src
    	onHitEOF   func() // if non-nil, func to call when EOF is Read
    }
    
    // ErrBodyReadAfterClose is returned when reading a [Request] or [Response]
    // Body after the body has been closed. This typically happens when the body is
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 21 22:14:00 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  9. src/internal/xcoff/file.go

    // If the File was created using NewFile directly instead of Open,
    // Close has no effect.
    func (f *File) Close() error {
    	var err error
    	if f.closer != nil {
    		err = f.closer.Close()
    		f.closer = nil
    	}
    	return err
    }
    
    // Section returns the first section with the given name, or nil if no such
    // section exists.
    // Xcoff have section's name limited to 8 bytes. Some sections like .gosymtab
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 12 14:42:29 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/Response.kt

      fun receivedResponseAtMillis(): Long = receivedResponseAtMillis
    
      /**
       * 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() = commonClose()
    
      override fun toString(): String = commonToString()
    
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 15.5K bytes
    - Viewed (0)
Back to top