Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 171 - 180 of 1,135 for closed (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/storage-interface.go

    	IsLocal() bool
    
    	// Returns hostname if disk is remote.
    	Hostname() string
    
    	// Returns the entire endpoint.
    	Endpoint() Endpoint
    
    	// Close the disk, mark it purposefully closed, only implemented for remote disks.
    	Close() error
    
    	// Returns the unique 'uuid' of this disk.
    	GetDiskID() (string, error)
    
    	// Set a unique 'uuid' for this disk, only used when
    	// disk is replaced and formatted.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt

                    for (i in 0..9) {
                      sink.writeByte(0)
                      sink.flush()
                      sleep(100)
                    }
                    fail("Expected connection to be closed")
                  }
                },
              ).build(),
          )
        interruptLater(500)
        assertFailsWith<IOException> {
          call.execute()
        }
      }
    
      @Test
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 18:33:48 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  3. tests/transaction_test.go

    	if err != nil {
    		t.Fatalf("failed to connect database, got error %v", err)
    	}
    	rawDB, _ := DB.DB()
    	rawDB.Close()
    
    	if err := DB.Transaction(func(tx *gorm.DB) error {
    		return nil
    	}); err == nil {
    		t.Errorf("should returns error when commit with closed conn, got error %v", err)
    	}
    
    	if err := DB.Session(&gorm.Session{PrepareStmt: true}).Transaction(func(tx *gorm.DB) error {
    		return nil
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Mon Sep 08 09:19:22 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  4. internal/grid/grid_test.go

    		time.Sleep(time.Millisecond)
    	}
    	cancel()
    	<-serverCanceled
    	local.debugMsg(debugIsOutgoingClosed, st.muxID, func(closed bool) {
    		if !closed {
    			t.Error("expected outgoing closed")
    		} else {
    			t.Log("outgoing was closed")
    		}
    	})
    
    	// Drain responses and check if error propagated.
    	err = st.Results(func(b []byte) error {
    		return nil
    	})
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
  5. guava/src/com/google/common/collect/RegularImmutableMultiset.java

            bucketLength++;
            if (bucketLength > MAX_HASH_BUCKET_LENGTH) {
              return true;
            }
          }
        }
        return false;
      }
    
      /**
       * Closed addressing tends to perform well even with high load factors. Being conservative here
       * ensures that the table is still likely to be relatively sparse (hence it misses fast) while
       * saving space.
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 20:08:09 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  6. internal/http/listener.go

    	case <-listener.ctxDoneCh:
    	}
    	return nil, syscall.EINVAL
    }
    
    // Close - closes underneath all TCP listeners.
    func (listener *httpListener) Close() (err error) {
    	listener.ctxCanceler()
    
    	for i := range listener.listeners {
    		listener.listeners[i].Close()
    	}
    
    	return nil
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  7. internal/logger/logrotate.go

    // Write is blocking otherwise.
    func (w *Writer) Write(p []byte) (n int, err error) {
    	return w.pw.Write(p)
    }
    
    // Close closes the writer.
    // Any accepted writes will be flushed. Any new writes will be rejected.
    // Once Close() exits, files are synchronized to disk.
    func (w *Writer) Close() error {
    	w.pw.CloseWithError(nil)
    
    	if w.f != nil {
    		if err := w.closeCurrentFile(); err != nil {
    			return err
    		}
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  8. src/builtin/builtin.go

    func clear[T ~[]Type | ~map[Type]Type1](t T)
    
    // The close built-in function closes a channel, which must be either
    // bidirectional or send-only. It should be executed only by the sender,
    // never the receiver, and has the effect of shutting down the channel after
    // the last sent value is received. After the last value has been received
    // from a closed channel c, any receive from c will succeed without
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Feb 26 17:14:40 GMT 2026
    - 13.2K bytes
    - Click Count (0)
  9. internal/grid/handlers.go

    	// responses from the remote server.
    	// Channel will be closed after error or when remote closes.
    	// responses *must* be read to either an error is returned or the channel is closed.
    	responses *Stream
    	newResp   func() Resp
    
    	// Requests sent to the server.
    	// If the handler is defined with 0 incoming capacity this will be nil.
    	// Channel *must* be closed to signal the end of the stream.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  10. cmd/metacache-stream.go

    				continue
    			}
    		}
    	}()
    
    	return objs, nil
    }
    
    // Close and release resources.
    func (w *metacacheWriter) Close() error {
    	if w == nil || w.closer == nil {
    		return nil
    	}
    	w.streamWg.Wait()
    	err := w.closer()
    	w.closer = nil
    	return err
    }
    
    // Reset and start writing to new writer.
    // Close must have been called before this.
    func (w *metacacheWriter) Reset(out io.Writer) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed May 07 15:37:12 GMT 2025
    - 19.5K bytes
    - Click Count (0)
Back to Top