Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 694 for toSend (0.21 sec)

  1. internal/grid/connection.go

    		}
    
    		toSend = merged[:0]
    		m := message{Op: OpMerged, Seq: uint32(len(queue))}
    		var err error
    		toSend, err = m.MarshalMsg(toSend)
    		if err != nil {
    			gridLogIf(ctx, fmt.Errorf("msg.MarshalMsg: %w", err))
    			return
    		}
    		// Append as byte slices.
    		for _, q := range queue {
    			toSend = msgp.AppendBytes(toSend, q)
    			PutByteBuffer(q)
    		}
    		queue = queue[:0]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  2. internal/grid/benchmark_test.go

    				for i := 0; i < responses; i++ {
    					toSend := GetByteBuffer()[:0]
    					toSend = append(toSend, byte(i))
    					toSend = append(toSend, payload...)
    					select {
    					case <-ctx.Done():
    						return nil
    					case out <- toSend:
    					}
    				}
    				return nil
    			},
    
    			Subroute:    "some-subroute",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  3. internal/grid/muxserver.go

    }
    
    // sendResponses will send responses to the client.
    func (m *muxServer) sendResponses(ctx context.Context, toSend <-chan []byte, c *Connection, handlerErr *atomic.Pointer[RemoteErr], outBlock <-chan struct{}) {
    	for {
    		// Process outgoing message.
    		var payload []byte
    		var ok bool
    		select {
    		case payload, ok = <-toSend:
    		case <-ctx.Done():
    			return
    		}
    		select {
    		case <-ctx.Done():
    			return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/fess/dict/kuromoji/KuromojiFileTest.java

            List<KuromojiItem> itemList = new ArrayList<>();
            itemList.add(new KuromojiItem(1, "token1", "seg1", "reading1", "pos1"));
            itemList.add(new KuromojiItem(2, "token2", "seg2", "reading2", "pos2"));
            itemList.add(new KuromojiItem(3, "token3", "seg3", "reading3", "pos3"));
            kuromojiFile.kuromojiItemList = itemList;
        }
    
        public void test_selectList() {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  5. cni/test/testdata/k8s_svcacct/token

    John Howard <******@****.***> 1605827959 -0800
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Nov 19 23:19:19 UTC 2020
    - 860 bytes
    - Viewed (0)
  6. docs/sts/custom-token-identity.go

    	"net/url"
    	"time"
    
    	"github.com/minio/minio-go/v7"
    	cr "github.com/minio/minio-go/v7/pkg/credentials"
    )
    
    var (
    	// LDAP integrated Minio endpoint
    	stsEndpoint string
    
    	// token to use with AssumeRoleWithCustomToken
    	token string
    
    	// Role ARN to use
    	roleArn string
    
    	// Display credentials flag
    	displayCreds bool
    
    	// Credential expiry duration
    	expiryDuration time.Duration
    
    	// Bucket to list
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 27 00:58:09 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  7. docs/sts/custom-token-identity.md

    | Version         | String  | Yes      | Value must be `2011-06-15`                                           |
    | Token           | String  | Yes      | Token to be authenticated by identity plugin                         |
    | RoleArn         | String  | Yes      | Must match the Role ARN generated for the identity plugin            |
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 27 00:58:09 UTC 2022
    - 3K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/reflect/TypeTokenTest.java

      public void testAssignableClassToType() {
        TypeToken<List<String>> tokenL = new TypeToken<List<String>>() {};
        assertTrue(tokenL.isSupertypeOf(StringList.class));
        assertFalse(tokenL.isSupertypeOf(List.class));
    
        TypeToken<First<String>> tokenF = new TypeToken<First<String>>() {};
        assertTrue(tokenF.isSupertypeOf(ConcreteIS.class));
        assertFalse(tokenF.isSupertypeOf(ConcreteSI.class));
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 21:13:09 UTC 2024
    - 89.1K bytes
    - Viewed (0)
  9. cni/pkg/install/testdata/token-bar

    Sergei Gavrilov <******@****.***> 1657207540 +0200
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 07 15:25:40 UTC 2022
    - 3 bytes
    - Viewed (0)
  10. cni/pkg/install/testdata/token-foo

    Sergei Gavrilov <******@****.***> 1657207540 +0200
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 07 15:25:40 UTC 2022
    - 3 bytes
    - Viewed (0)
Back to top