Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for sendErr (0.16 sec)

  1. internal/s3select/csv/reader_contrib_test.go

    			fieldDelimiter:  ",",
    			sendErr:         nil,
    			header:          true,
    			wantColumns:     []string{"header1", "header2", "header3"},
    			wantFields:      "ok1,ok2,ok3\n" + `a word,"b"""` + "\n",
    			wantErr:         io.EOF,
    		},
    		{
    			// This works since LazyQuotes is true:
    			file:            "invalid-badstartline.csv",
    			recordDelimiter: "\n",
    			fieldDelimiter:  ",",
    			sendErr:         nil,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 38.5K bytes
    - Viewed (0)
  2. internal/event/targetlist_test.go

    package event
    
    import (
    	"context"
    	"crypto/rand"
    	"errors"
    	"reflect"
    	"testing"
    	"time"
    
    	"github.com/minio/minio/internal/store"
    )
    
    type ExampleTarget struct {
    	id       TargetID
    	sendErr  bool
    	closeErr bool
    }
    
    func (target ExampleTarget) ID() TargetID {
    	return target.id
    }
    
    // Save - Sends event directly without persisting.
    func (target ExampleTarget) Save(eventData Event) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool.go

    	errCh := make(chan error, 1)
    	go func() {
    		sentErr := false
    		sendErr := func(err error) {
    			if !sentErr {
    				select {
    				case results <- itemOrErr[ObjectInfo]{Err: err}:
    					sentErr = true
    				case <-parentCtx.Done():
    				}
    			}
    		}
    		defer func() {
    			select {
    			case <-ctx.Done():
    				sendErr(ctx.Err())
    			default:
    			}
    			xioutil.SafeClose(results)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Settings.kt

        const val MAX_CONCURRENT_STREAMS = 4
    
        /** HTTP/2: Size in bytes of the largest frame payload the sender will accept. */
        const val MAX_FRAME_SIZE = 5
    
        /** HTTP/2: Advisory only. Size in bytes of the largest header list the sender will accept. */
        const val MAX_HEADER_LIST_SIZE = 6
    
        /** Window size in bytes. */
        const val INITIAL_WINDOW_SIZE = 7
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  5. cmd/admin-handlers-idp-ldap.go

    	}
    
    	// Check if we are creating svc account for request sender.
    	isSvcAccForRequestor := false
    	if targetUser == requestorUser || targetUser == requestorParentUser {
    		isSvcAccForRequestor = true
    	}
    
    	var (
    		targetGroups []string
    		err          error
    	)
    
    	// If we are creating svc account for request sender, ensure that targetUser
    	// is a real user (i.e. not derived credentials).
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 21 11:35:40 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  6. internal/s3select/sql/evaluate.go

    	stVal, stErr := e.Start.evalNode(r, tableAlias)
    	if stErr != nil {
    		return nil, stErr
    	}
    
    	endVal, endErr := e.End.evalNode(r, tableAlias)
    	if endErr != nil {
    		return nil, endErr
    	}
    
    	part1, err1 := stVal.compareOp(opLte, arg)
    	if err1 != nil {
    		return nil, err1
    	}
    
    	part2, err2 := arg.compareOp(opLte, endVal)
    	if err2 != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/base/Ascii.java

       *
       * @since 8.0
       */
      public static final byte ENQ = 5;
    
      /**
       * Acknowledge: A communication control character transmitted by a receiver as an affirmative
       * response to a sender.
       *
       * @since 8.0
       */
      public static final byte ACK = 6;
    
      /**
       * Bell ('\a'): A character for use when there is a need to call for human attention. It may
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 13:50:22 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

         * that trigger this are HEADERS and PUSH_PROMISE.
         *
         * @param inFinished true if the sender will not send further frames.
         * @param streamId the stream owning these headers.
         * @param associatedStreamId the stream that triggered the sender to create this stream.
         */
        fun headers(
          inFinished: Boolean,
          streamId: Int,
          associatedStreamId: Int,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  9. guava/src/com/google/common/base/Ascii.java

       *
       * @since 8.0
       */
      public static final byte ENQ = 5;
    
      /**
       * Acknowledge: A communication control character transmitted by a receiver as an affirmative
       * response to a sender.
       *
       * @since 8.0
       */
      public static final byte ACK = 6;
    
      /**
       * Bell ('\a'): A character for use when there is a need to call for human attention. It may
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 13:50:22 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/EmlExtractor.java

                putValue(data, "Message-Number", message.getMessageNumber());
                putValue(data, "Received-Date", getReceivedDate(message));
                putValue(data, "Reply-To", message.getReplyTo());
                putValue(data, "Sender", message.getSender());
                putValue(data, "Sent-Date", message.getSentDate());
                putValue(data, "Size", message.getSize());
                putValue(data, "Subject", message.getSubject());
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 10.8K bytes
    - Viewed (0)
Back to top