Search Options

Results per page
Sort
Preferred Languages
Advance

Results 531 - 540 of 742 for Buffer$ (0.08 sec)

  1. schema/serializer.go

    	return
    }
    
    // Value implements serializer interface
    func (GobSerializer) Value(ctx context.Context, field *Field, dst reflect.Value, fieldValue interface{}) (interface{}, error) {
    	buf := new(bytes.Buffer)
    	err := gob.NewEncoder(buf).Encode(fieldValue)
    	return buf.Bytes(), err
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jun 20 08:45:38 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  2. istioctl/pkg/internaldebug/internal-debug_test.go

    			}
    			verifyExecTestOutput(t, DebugCommand(ctx), c)
    		})
    	}
    }
    
    func verifyExecTestOutput(t *testing.T, cmd *cobra.Command, c execTestCase) {
    	t.Helper()
    
    	var out bytes.Buffer
    	cmd.SetArgs(c.args)
    	cmd.SilenceUsage = true
    	cmd.SetOut(&out)
    	cmd.SetErr(&out)
    
    	fErr := cmd.Execute()
    	output := out.String()
    
    	if c.expectedOutput != "" && c.expectedOutput != output {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Mar 15 08:28:50 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb2/io/Smb2FlushRequest.java

        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.internal.smb2.ServerMessageBlock2#readBytesWireFormat(byte[], int)
         */
        @Override
        protected int readBytesWireFormat ( byte[] buffer, int bufferIndex ) {
            return 0;
        }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.7K bytes
    - Viewed (0)
  4. docs/debugging/pprofgoparser/main.go

    }
    
    func parseGoroutineType2(path string) (map[time.Duration][]string, error) {
    	f, err := os.Open(path)
    	if err != nil {
    		return nil, err
    	}
    
    	bf := bytes.Buffer{}
    
    	save := func(s string) {
    		bf.WriteString(s + "\n")
    	}
    	reset := func() {
    		bf.Reset()
    	}
    
    	ret := make(map[time.Duration][]string)
    
    	s := bufio.NewScanner(f)
    	s.Split(bufio.ScanLines)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Mar 06 11:43:16 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  5. internal/bpool/bpool_test.go

    	if uint64(len(bp.c)) != size {
    		t.Fatalf("bytepool size invalid: got %v want %v", len(bp.c), size)
    	}
    
    	// lets drain the buf channel first before we validate invalid buffers.
    	for i := uint64(0); i < size; i++ {
    		bp.Get() // discard
    	}
    
    	// Try putting some invalid buffers into pool
    	bp.Put(make([]byte, bp.w, bp.wcap-1)) // wrong capacity is rejected (less)
    	bp.Put(make([]byte, bp.w, bp.wcap+1)) // wrong capacity is rejected (more)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  6. istioctl/pkg/authz/analyzer_test.go

    					},
    					LastUpdated: timestamppb.Now(),
    				},
    				ClientStatus: 453,
    			},
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			var buf bytes.Buffer
    			a.Print(&buf)
    			expectedOutput := "ACTION   AuthorizationPolicy   RULES\n"
    			actualOutput := buf.String()
    			if !reflect.DeepEqual(expectedOutput, actualOutput) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  7. istioctl/pkg/ztunnelconfig/ztunnelconfig_test.go

    				Results:   c.execClientConfig,
    				Namespace: "default",
    			})), c)
    		})
    	}
    }
    
    func verifyExecTestOutput(t *testing.T, cmd *cobra.Command, c execTestCase) {
    	t.Helper()
    
    	var out bytes.Buffer
    	cmd.SetArgs(c.args)
    	cmd.SilenceUsage = true
    	cmd.SetOut(&out)
    	cmd.SetErr(&out)
    
    	fErr := cmd.Execute()
    	output := out.String()
    
    	if c.expectedOutput != "" && c.expectedOutput != output {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Apr 10 21:51:29 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/tree/Smb2TreeConnectRequest.java

        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.internal.smb2.ServerMessageBlock2#readBytesWireFormat(byte[], int)
         */
        @Override
        protected int readBytesWireFormat ( byte[] buffer, int bufferIndex ) {
            return 0;
        }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 3.2K bytes
    - Viewed (0)
  9. cmd/erasure-heal_test.go

    		}
    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "testobject", erasure.ShardFileSize(test.size), test.algorithm, erasure.ShardSize())
    		}
    		_, err = erasure.Encode(context.Background(), bytes.NewReader(data), writers, buffer, erasure.dataBlocks+1)
    		closeBitrotWriters(writers)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  10. src/bytes/compare_test.go

    	{nil, []byte("a"), -1},
    }
    
    func TestCompare(t *testing.T) {
    	for _, tt := range compareTests {
    		numShifts := 16
    		buffer := make([]byte, len(tt.b)+numShifts)
    		// vary the input alignment of tt.b
    		for offset := 0; offset <= numShifts; offset++ {
    			shiftedB := buffer[offset : len(tt.b)+offset]
    			copy(shiftedB, tt.b)
    			cmp := Compare(tt.a, shiftedB)
    			if cmp != tt.i {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 13 23:11:42 UTC 2023
    - 6.8K bytes
    - Viewed (0)
Back to top