Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 638 for Skip (0.04 sec)

  1. cmd/site-replication-utils_gen_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left)
    	}
    
    	left, err = msgp.Skip(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgSiteResyncStatus(b *testing.B) {
    	v := SiteResyncStatus{}
    	b.ReportAllocs()
    	b.ResetTimer()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Nov 14 15:16:40 UTC 2022
    - 2.4K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-decom_gen.go

    				return
    			}
    		case "bf":
    			z.BytesFailed, err = dc.ReadInt64()
    			if err != nil {
    				err = msgp.WrapError(err, "BytesFailed")
    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 04 21:02:54 UTC 2022
    - 26.7K bytes
    - Viewed (0)
  3. cmd/tier-last-day-stats_gen.go

    						return
    					}
    				}
    			case "UpdatedAt":
    				zb0002.UpdatedAt, err = dc.ReadTime()
    				if err != nil {
    					err = msgp.WrapError(err, zb0001, "UpdatedAt")
    					return
    				}
    			default:
    				err = dc.Skip()
    				if err != nil {
    					err = msgp.WrapError(err, zb0001)
    					return
    				}
    			}
    		}
    		(*z)[zb0001] = zb0002
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/io/TestInputStream.java

        throwIf(closed);
        throwIf(READ_THROWS);
        return in.read(b, off, len);
      }
    
      @Override
      public long skip(long n) throws IOException {
        throwIf(closed);
        throwIf(SKIP_THROWS);
        return in.skip(n);
      }
    
      @Override
      public int available() throws IOException {
        throwIf(closed);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 2.5K bytes
    - Viewed (0)
  5. tests/main_test.go

    package tests_test
    
    import (
    	"testing"
    
    	. "gorm.io/gorm/utils/tests"
    )
    
    func TestExceptionsWithInvalidSql(t *testing.T) {
    	if name := DB.Dialector.Name(); name == "sqlserver" {
    		t.Skip("skip sqlserver due to it will raise data race for invalid sql")
    	}
    
    	var columns []string
    	if DB.Where("sdsd.zaaa = ?", "sd;;;aa").Pluck("aaa", &columns).Error == nil {
    		t.Errorf("Should got error with invalid SQL")
    	}
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Mar 24 01:31:58 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  6. internal/s3select/csv/reader.go

    	}
    	return r.readCloser.Close()
    }
    
    // nextSplit will attempt to skip a number of bytes and
    // return the buffer until the next newline occurs.
    // The last block will be sent along with an io.EOF.
    func (r *Reader) nextSplit(skip int, dst []byte) ([]byte, error) {
    	if cap(dst) < skip {
    		dst = make([]byte, 0, skip+1024)
    	}
    	dst = dst[:skip]
    	if skip > 0 {
    		n, err := io.ReadFull(r.buf, dst)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  7. internal/bucket/bandwidth/monitor_gen.go

    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		switch msgp.UnsafeString(field) {
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z BucketBandwidthReport) EncodeMsg(en *msgp.Writer) (err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  8. cmd/batch-replicate_gen.go

    						return
    					}
    				default:
    					err = dc.Skip()
    					if err != nil {
    						err = msgp.WrapError(err, "Creds")
    						return
    					}
    				}
    			}
    		case "Snowball":
    			err = z.Snowball.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Snowball")
    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 40.7K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/MultipartReaderTest.kt

          )
    
        assertFailsWith<ProtocolException> {
          parts.nextPart()
        }.also { expected ->
          assertThat(expected).hasMessage("expected at least 1 part")
        }
      }
    
      @Test fun `skip preamble`() {
        val multipart =
          """
          |this is the preamble! it is invisible to application code
          |
          |--simple boundary
          |
          |abcd
          |--simple boundary--
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  10. tests/postgres_test.go

    	"github.com/lib/pq"
    	"gorm.io/gorm"
    	"gorm.io/gorm/clause"
    	. "gorm.io/gorm/utils/tests"
    )
    
    func TestPostgresReturningIDWhichHasStringType(t *testing.T) {
    	if DB.Dialector.Name() != "postgres" {
    		t.Skip()
    	}
    
    	type Yasuo struct {
    		ID        string `gorm:"default:gen_random_uuid()"`
    		Name      string
    		CreatedAt time.Time `gorm:"type:TIMESTAMP WITHOUT TIME ZONE"`
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Oct 08 09:16:32 UTC 2022
    - 6.4K bytes
    - Viewed (0)
Back to top