- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 91 for street (0.3 sec)
-
src/main/resources/fess_config.properties
application/vnd.ms-excel=excel\n\ application/vnd.ms-excel.sheet.2=excel\n\ application/vnd.ms-excel.sheet.3=excel\n\ application/vnd.ms-excel.sheet.4=excel\n\ application/vnd.ms-excel.workspace.3=excel\n\ application/vnd.ms-excel.workspace.4=excel\n\ application/vnd.openxmlformats-officedocument.spreadsheetml.sheet=excel\n\ application/vnd.ms-powerpoint=powerpoint\n\
Properties - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Apr 11 02:34:53 GMT 2024 - 30.6K bytes - Viewed (1) -
cmd/postpolicyform.go
type contentLengthRange struct { Min int64 Max int64 Valid bool // If content-length-range was part of policy } // PostPolicyForm provides strict static type conversion and validation for Amazon S3's POST policy JSON string. type PostPolicyForm struct { Expiration time.Time // Expiration date and time of the POST policy. Conditions struct { // Conditional policy structure. Policies []struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.2K bytes - Viewed (0) -
internal/ioutil/ioutil.go
// Multiple calls to Run will run independently of each other. func (d *DeadlineWorker) Run(work func() error) error { c := make(chan ioret[struct{}], 1) t := time.NewTimer(d.timeout) go func() { c <- ioret[struct{}]{val: struct{}{}, err: work()} }() select { case r := <-c: if !t.Stop() { <-t.C } return r.err case <-t.C: return context.DeadlineExceeded
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/DefaultArtifactDescriptorReader.java
} try { InternalSession iSession = InternalSession.from(session); Session iSessionWithRepos = iSession.withRemoteRepositories(request.getRepositories().stream() .map(iSession::getRemoteRepository) .toList()); String gav =
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 14.6K bytes - Viewed (0) -
cmd/metacache-set.go
// from a single drive, shuffling of the drives is subsequently. disks = newDisks askDisks = 1 } else { // If we did not find suitable disks, perform strict quorum listing // as no disk agrees on quorum anymore. askDisks = getListQuorum("strict", er.setDriveCount) } } var fallbackDisks []StorageAPI // Special case: ask all disks if the drive count is 4
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/globals.go
func init() { // Injected to prevent circular dependency. pubsub.GetByteBuffer = grid.GetByteBuffer } type poolDisksLayout struct { cmdline string layout [][]string } type disksLayout struct { legacy bool pools []poolDisksLayout } type serverCtxt struct { JSON, Quiet bool Anonymous bool StrictS3Compat bool Addr, ConsoleAddr string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
internal/grid/handlers.go
for req := range reqT { b, err := req.MarshalMsg(GetByteBufferCap(req.Msgsize())) if err != nil { gridLogOnceIf(ctx, err, err.Error()) } h.PutRequest(req) stream.Requests <- b } }() } else if stream.Requests != nil { xioutil.SafeClose(stream.Requests) } return &TypedStream[Req, Resp]{responses: stream, newResp: h.NewResponse, Requests: reqT}, nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/ReactorReader.java
} } /** * Retrieve a stream of the project's artifacts */ private Stream<Artifact> getProjectArtifacts(MavenProject project) { Stream<org.apache.maven.artifact.Artifact> artifacts = Stream.concat( Stream.concat( // pom artifact Stream.of(new ProjectArtifact(project)),
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 16:33:18 GMT 2024 - 21.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
return socket.isHealthy(source) } return true } /** Refuse incoming streams. */ @Throws(IOException::class) override fun onStream(stream: Http2Stream) { stream.close(ErrorCode.REFUSED_STREAM, null) } /** When settings are received, adjust the allocation limit. */ override fun onSettings( connection: Http2Connection, settings: Settings, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
internal/grid/grid_test.go
start := time.Now() stream, err := handler.Call(context.Background(), remoteConn, &testRequest{Num: 1, String: testPayload}) errFatal(err) go func() { defer close(stream.Requests) for i := 0; i < payloads; i++ { // t.Log("sending new client request") stream.Requests <- &testRequest{Num: i, String: testPayload} } }() var n int err = stream.Results(func(resp *testResponse) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0)