- Sort Score
- Num 10 results
- Language All
Results 1021 - 1030 of 1,399 for int8 (0.23 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/s3select/csv/recordtransform.go
type recordTransform struct { reader io.Reader // recordDelimiter can be up to 2 characters. recordDelimiter []byte oneByte []byte useOneByte bool } func (rr *recordTransform) Read(p []byte) (n int, err error) { if rr.useOneByte { p[0] = rr.oneByte[0] rr.useOneByte = false n, err = rr.reader.Read(p[1:]) n++ } else { n, err = rr.reader.Read(p) } if err != nil { return n, err }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2.1K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/project/collector/DefaultProjectsSelector.java
long totalProblemsCount = 0; for (ProjectBuildingResult result : results) { projects.add(result.getProject()); int problemsCount = result.getProblems().size(); totalProblemsCount += problemsCount; if (problemsCount != 0 && LOGGER.isWarnEnabled()) { LOGGER.warn(""); LOGGER.warn(Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Sep 30 08:09:09 GMT 2025 - 4.1K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/configuration/internal/EnhancedConfigurationConverter.java
throws ComponentConfigurationException { final EnhancedCompositeBeanHelper helper = new EnhancedCompositeBeanHelper(lookup, loader, evaluator, listener); for (int i = 0, size = configuration.getChildCount(); i < size; i++) { final PlexusConfiguration element = configuration.getChild(i); final String propertyName = fromXML(element.getName());Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Thu Jul 17 07:40:49 GMT 2025 - 6.2K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/DefaultLifecycleStarter.java
throw new BuilderNotFoundException( String.format("The builder requested using id = %s cannot be" + " found", builderId)); } int degreeOfConcurrency = session.getRequest().getDegreeOfConcurrency(); if (degreeOfConcurrency > 1) { logger.info(""); logger.info(String.format(
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 5.8K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/UpgradeContext.java
} public Map<String, Goal> goals; public List<AttributedString> header; public AttributedStyle style; public LineReader reader; // Indentation control for nested logging private int indentLevel = 0; private String indentString = Indentation.DEFAULT; public void addInHeader(String text) { addInHeader(AttributedStyle.DEFAULT, text); }Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Nov 18 18:03:26 GMT 2025 - 4.7K bytes - Click Count (0) -
cmd/admin-handlers-users-race_test.go
c.Fatalf("Unable to attach policy: %v", err) } accessKeys[i] = accessKey secretKeys[i] = secretKey } g := errgroup.Group{} for i := range userCount { g.Go(func(i int) func() error { return func() error { uClient := s.getUserClient(c, accessKeys[i], secretKeys[i], "") err := s.adm.RemoveUser(ctx, accessKeys[i]) if err != nil { return err }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4K bytes - Click Count (0) -
cmd/admin-handlers.go
} func getPoolsInfo(ctx context.Context, allDisks []madmin.Disk) (map[int]map[int]madmin.ErasureSetInfo, error) { objectAPI := newObjectLayerFn() if objectAPI == nil { return nil, errServerNotInitialized } z, ok := objectAPI.(*erasureServerPools) if !ok { return nil, errServerNotInitialized } poolsInfo := make(map[int]map[int]madmin.ErasureSetInfo) for _, d := range allDisks {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 99.7K bytes - Click Count (0) -
internal/kms/context.go
default: // This encodes bytes < 0x20 except for \t, \n and \r. // If escapeHTML is set, it also escapes <, >, and & // because they can lead to security holes when // user-controlled strings are rendered into JSON // and served to some browsers. dst.WriteString(`u00`) dst.WriteByte(hexTable[b>>4]) dst.WriteByte(hexTable[b&0xF]) } i++ start = i continue }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 6K bytes - Click Count (0) -
internal/grid/grid.go
var GetByteBuffer = func() []byte { b := *internalByteBuffer.Get() return b[:0] } // GetByteBufferCap returns a length 0 byte buffer with at least the given capacity. func GetByteBufferCap(wantSz int) []byte { if wantSz < defaultBufferSize { b := GetByteBuffer()[:0] if cap(b) >= wantSz { return b } PutByteBuffer(b) } if wantSz <= maxBufferSize { b := *internal32KByteBuffer.Get()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/ArtifactRepositoryMetadata.java
@Override public boolean isSnapshot() { // Don't consider the artifact's version in here, as this is stored in the directory above that return false; } @Override public int getNature() { if (artifact.getVersion() != null) { return artifact.isSnapshot() ? SNAPSHOT : RELEASE; } VersionRange range = artifact.getVersionRange(); if (range != null) {Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 3.6K bytes - Click Count (0)