- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 294 for callGet (0.09 sec)
-
src/main/java/org/codelibs/fess/sso/spnego/SpnegoAuthenticator.java
} final HttpServletResponse response = LaResponseUtil.getResponse(); final SpnegoHttpServletResponse spnegoResponse = new SpnegoHttpServletResponse(response); // client/caller principal final SpnegoPrincipal principal; try { principal = getAuthenticator().authenticate(request, spnegoResponse); if (logger.isDebugEnabled()) {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Sat Oct 12 01:54:46 UTC 2024 - 11.2K bytes - Viewed (0) -
cmd/object-handlers_test.go
// since the `objectLayer==nil` check is performed before any other checks inside the handlers. // The only aim is to generate an HTTP request in a way that the relevant/registered end point is evoked/called. nilBucket := "dummy-bucket" nilObject := "dummy-object" nilReq, err := newTestSignedRequestV4(http.MethodHead, getGetObjectURL("", nilBucket, nilObject), 0, nil, "", "", nil) if err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Sep 12 20:10:44 UTC 2024 - 163.2K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
if d := atomic.LoadInt64(&l.responseDelay); d != 0 { time.Sleep(time.Duration(d)) } l.mutex.Lock() defer l.mutex.Unlock() if len(args.UID) != 0 { return false, fmt.Errorf("ForceUnlock called with non-empty UID: %s", args.UID) } delete(l.lockMap, args.Resources[0]) // Remove the lock (irrespective of write or read lock) reply = true return reply, nil
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jan 23 16:46:37 UTC 2023 - 8.3K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
// since the `objectLayer==nil` check is performed before any other checks inside the handlers. // The only aim is to generate an HTTP request in a way that the relevant/registered end point is evoked/called. nilBucket := "dummy-bucket" nilReq, err := newTestSignedRequestV4(http.MethodPut, getPutPolicyURL("", nilBucket), 0, nil, "", "", nil) if err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 32.9K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
} // noopDoneFunc is a no-op done func. // Can be reused. var noopDoneFunc = func(_ int64, _ *error) {} // TrackDiskHealth for this request. // When a non-nil error is returned 'done' MUST be called // with the status of the response, if it corresponds to disk health. // If the pointer sent to done is non-nil AND the error // is either nil or io.EOF the disk is considered good.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Oct 26 09:56:26 UTC 2024 - 34.5K bytes - Viewed (0) -
cmd/endpoint.go
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 34.2K bytes - Viewed (0) -
common/scripts/kind_provisioner.sh
return 2 fi done } # load_cluster_topology function reads cluster configuration topology file and # sets up environment variables used by other functions. So this should be called # before anything else. # # Note: Cluster configuration topology file specifies basic configuration of each # KinD cluster like its name, pod and service subnets and network_id. If two cluster
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Wed Aug 21 04:47:23 UTC 2024 - 17.2K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
// UpdateWorkers at the end of this function leaves n goroutines waiting for // transition tasks func (t *transitionState) UpdateWorkers(n int) { t.mu.Lock() defer t.mu.Unlock() if t.objAPI == nil { // Init hasn't been called yet. return } t.updateWorkers(n) } func (t *transitionState) updateWorkers(n int) { if n == 0 { n = 100 } for t.numWorkers < n { go t.worker(t.objAPI) t.numWorkers++
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 33.7K bytes - Viewed (0) -
tensorflow/c/eager/c_api.cc
tensorflow::unwrap(ctx)->SetThreadLocalDevicePlacementPolicy( static_cast<tensorflow::ContextDevicePlacementPolicy>(policy)); } // Note: this function looks up a thread local policy. So it should be called in // the appropriate client thread. In particular, in async mode, it may not be // safe to call this function from the async EagerExecutor threads. extern TFE_ContextDevicePlacementPolicy TFE_ContextGetDevicePlacementPolicy(
Registered: Tue Oct 29 12:39:09 UTC 2024 - Last Modified: Sat Oct 12 05:11:17 UTC 2024 - 43.9K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
t.Fatalf("%s : %s", instanceType, err.Error()) } // uploadIds [4-9]. uploadIDs = append(uploadIDs, res.UploadID) } // Create multipart parts. // Need parts to be uploaded before MultipartLists can be called and tested. createPartCases := []struct { bucketName string objName string uploadID string PartID int inputReaderData string inputMd5 string
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 09:42:21 UTC 2024 - 88.8K bytes - Viewed (0)