- Sort Score
- Result 10 results
- Languages All
Results 641 - 650 of 2,998 for concept (0.06 sec)
-
src/main/java/jcifs/smb1/smb1/SmbNamedPipe.java
/** * This class will allow a Java program to read and write data to Named * Pipes and Transact NamedPipes. * * <p>There are three Win32 function calls provided by the Windows SDK * that are important in the context of using jCIFS. They are: * * <ul> * <li> <code>CallNamedPipe</code> A message-type pipe call that opens, * writes to, reads from, and closes the pipe in a single operation.
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 8.5K bytes - Viewed (0) -
internal/once/init.go
return nil } // DoWithContext is similar to Do except that it accepts a context as an argument to be passed. func (l *Init) DoWithContext(ctx context.Context, f func(context.Context) error) error { if atomic.LoadUint32(&l.done) == 0 { return l.doWithContext(ctx, f) } return nil } func (l *Init) doWithContext(ctx context.Context, f func(context.Context) error) error { l.m.Lock() defer l.m.Unlock()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 09 04:20:31 UTC 2023 - 2.1K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/util/ResponseDataUtilTest.java
assertTrue(tempFile.exists()); // Read and verify content try (FileInputStream fis = new FileInputStream(tempFile)) { byte[] buffer = new byte[1024]; int bytesRead = fis.read(buffer); String content = new String(buffer, 0, bytesRead); assertEquals("Test response body", content); } finally { // Clean up tempFile.delete();
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sat Nov 22 13:28:22 UTC 2025 - 7.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/DefaultQueryBuilder.java
/** * Creates a Lucene Query from this query builder. * * @param context the query shard context * @return the Lucene Query * @throws IOException if an I/O error occurs */ @Override public Query toQuery(final QueryShardContext context) throws IOException { return queryBuilder.toQuery(context); } /** * Returns whether this query builder is a fragment.Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 6.6K bytes - Viewed (0) -
callbacks/delete.go
rel, ok := db.Statement.Schema.Relationships.Relations[column] if !ok { continue } switch rel.Type { case schema.HasOne, schema.HasMany: queryConds := rel.ToQueryConditions(db.Statement.Context, db.Statement.ReflectValue) modelValue := reflect.New(rel.FieldSchema.ModelType).Interface() tx := db.Session(&gorm.Session{NewDB: true}).Model(modelValue) withoutConditions := false if db.Statement.Unscoped {
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Sun May 25 07:40:40 UTC 2025 - 5.8K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
bucketMovingAvgTicker *time.Ticker // Ticker for calculating moving averages ctx context.Context // Context for generate NodeCount uint64 } // NewMonitor returns a monitor with defaults. func NewMonitor(ctx context.Context, numNodes uint64) *Monitor { m := &Monitor{ bucketsMeasurement: make(map[BucketOptions]*bucketMeasurement),
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6K bytes - Viewed (0) -
association.go
relValuesMap, _ := schema.GetIdentityFieldValuesMapFromValues(association.DB.Statement.Context, values, rel.FieldSchema.PrimaryFields) cleanUpDeletedRelations := func(data reflect.Value) { if _, zero := rel.Field.ValueOf(association.DB.Statement.Context, data); !zero { fieldValue := reflect.Indirect(rel.Field.ReflectValueOf(association.DB.Statement.Context, data)) primaryValues := make([]interface{}, len(rel.FieldSchema.PrimaryFields))
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Sun Oct 26 12:09:12 UTC 2025 - 23.6K bytes - Viewed (0) -
cmd/bucket-quota.go
bucketStorageCache.InitOnce(10*time.Second, cachevalue.Opts{ReturnLastGood: true, NoWait: true}, func(ctx context.Context) (DataUsageInfo, error) { if objAPI == nil { return DataUsageInfo{}, errServerNotInitialized } ctx, done := context.WithTimeout(ctx, 2*time.Second) defer done() return loadDataUsageFromBackend(ctx, objAPI) }, ) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 4.4K bytes - Viewed (0) -
build-logic/documentation/src/test/groovy/gradlebuild/docs/UserGuideTransformTaskTest.groovy
given: String content = "test\ttest\ttest" when: def actual = UserGuideTransformTask.normalise(content) then: actual == "test test test" } def usesUnixLineEndings() { given: String content = "test\r\ntest\r\ntest" when: def actual = UserGuideTransformTask.normalise(content) then:Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Tue Jul 27 19:28:51 UTC 2021 - 1.9K bytes - Viewed (0) -
docs/en/docs/css/termynal.css
/* Set up defaults and ensure empty lines are displayed. */ content: ''; display: inline-block; vertical-align: middle; } [data-ty="input"]:before, [data-ty-prompt]:before { margin-right: 0.75em; color: var(--color-text-subtle); } [data-ty="input"]:before { content: '$'; } [data-ty][data-ty-prompt]:before { content: attr(data-ty-prompt); } [data-ty-cursor]:after {Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sun Nov 23 09:27:40 UTC 2025 - 2.2K bytes - Viewed (0)