Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 451 - 460 of 941 for var0 (0.03 seconds)

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

  1. internal/ioutil/ioutil.go

    func NewAlignedBytePool(sz int) *AlignedBytePool {
    	return &AlignedBytePool{size: sz, p: bpool.Pool[*[]byte]{New: func() *[]byte {
    		b := disk.AlignedBlock(sz)
    		return &b
    	}}}
    }
    
    // aligned sync.Pool's
    var (
    	ODirectPoolLarge  = NewAlignedBytePool(LargeBlock)
    	ODirectPoolMedium = NewAlignedBytePool(MediumBlock)
    	ODirectPoolSmall  = NewAlignedBytePool(SmallBlock)
    )
    
    // Get a block.
    func (p *AlignedBytePool) Get() *[]byte {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  2. internal/grid/connection_test.go

    	errFatal(remoteConn.WaitForConnect(t.Context()))
    
    	<-gotResp
    	// Killing should cancel the context on the request.
    	<-gotCall
    }
    
    func TestShouldConnect(t *testing.T) {
    	var c Connection
    	var cReverse Connection
    	hosts := []string{"a", "b", "c", "d", "e", "f", "g", "h", "i", "j", "k", "l", "m", "n", "o", "p", "q", "r", "s", "t", "u", "v", "x", "y", "z", "0", "1", "2", "3", "4", "5", "6", "7", "8", "9"}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  3. cmd/erasure-metadata-utils.go

    type counterMap[T comparable] map[T]int
    
    // GetValueWithQuorum returns the first key which occurs >= quorum number of times.
    func (c counterMap[T]) GetValueWithQuorum(quorum int) (T, bool) {
    	var zero T
    	for x, count := range c {
    		if count >= quorum {
    			return x, true
    		}
    	}
    	return zero, false
    }
    
    // figure out the most commonVersions across disk that satisfies
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  4. internal/s3select/sql/value_test.go

    package sql
    
    import (
    	"fmt"
    	"math"
    	"strconv"
    	"testing"
    	"time"
    )
    
    // valueBuilders contains one constructor for each value type.
    // Values should match if type is the same.
    var valueBuilders = []func() *Value{
    	FromNull,
    	func() *Value {
    		return FromBool(true)
    	},
    	func() *Value {
    		return FromBytes([]byte("byte contents"))
    	},
    	func() *Value {
    		return FromFloat(math.Pi)
    	},
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  5. okhttp/src/androidMain/kotlin/okhttp3/internal/platform/ContextAwarePlatform.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.internal.platform
    
    import android.content.Context
    
    interface ContextAwarePlatform {
      var applicationContext: Context?
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Dec 31 14:50:53 GMT 2024
    - 737 bytes
    - Click Count (0)
  6. docs/extensions/s3zip/examples/minio-go/main.go

    )
    
    func main() {
    	s3Client, err := minio.New("minio-server-address:9000", &minio.Options{
    		Creds: credentials.NewStaticV4("access-key", "secret-key", ""),
    	})
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	var opts minio.GetObjectOptions
    
    	// Add extract header to request:
    	opts.Set("x-minio-extract", "true")
    
    	// Download API.md from the archive
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jun 14 18:04:14 GMT 2021
    - 694 bytes
    - Click Count (0)
  7. internal/event/target/amqp.go

    		return false, err
    	}
    	defer func() {
    		ch.Close()
    	}()
    	return true, nil
    }
    
    func (target *AMQPTarget) channel() (*amqp091.Channel, chan amqp091.Confirmation, error) {
    	var err error
    	var conn *amqp091.Connection
    	var ch *amqp091.Channel
    
    	isAMQPClosedErr := func(err error) bool {
    		if err == amqp091.ErrClosed {
    			return true
    		}
    
    		if nerr, ok := err.(*net.OpError); ok {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 21 04:25:07 GMT 2025
    - 10K bytes
    - Click Count (0)
  8. misc/ios/go_ios_exec.go

    	"strings"
    	"syscall"
    )
    
    const debug = false
    
    var tmpdir string
    
    var (
    	devID    string
    	appID    string
    	teamID   string
    	bundleID string
    	deviceID string
    )
    
    // lock is a file lock to serialize iOS runs. It is global to avoid the
    // garbage collector finalizing it, closing the file and releasing the
    // lock prematurely.
    var lock *os.File
    
    func main() {
    	log.SetFlags(0)
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Sep 16 00:34:45 GMT 2025
    - 8.7K bytes
    - Click Count (0)
  9. cmd/object-handlers_test.go

    	credentials auth.Credentials, t *testing.T,
    ) {
    	var err error
    
    	var opts ObjectOptions
    	// object used for the test.
    	objectName := "test-object-new-multipart"
    
    	// upload IDs collected.
    	var uploadIDs []string
    
    	for range 2 {
    		// initiate new multipart uploadID.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 163.1K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/idn/IdnaMappingTableTest.kt

    import org.junit.jupiter.api.Test
    
    /** Confirm we get the expected table whether we build it from the .txt file or compact that. */
    class IdnaMappingTableTest {
      private lateinit var table: SimpleIdnaMappingTable
      private lateinit var compactTable: IdnaMappingTable
    
      @BeforeEach
      fun setUp() {
        val path = "/okhttp3/internal/idna/IdnaMappingTable.txt".toPath()
        val plainTable =
          FileSystem.RESOURCES.read(path) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 8.9K bytes
    - Click Count (0)
Back to Top