Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 1,384 for _context (0.05 sec)

  1. src/main/java/org/codelibs/fess/api/WebApiResponse.java

    import org.apache.commons.io.output.ByteArrayOutputStream;
    
    import jakarta.servlet.http.HttpServletResponse;
    import jakarta.servlet.http.HttpServletResponseWrapper;
    
    /**
     * Wrapper for HTTP servlet responses in web API context.
     * This class extends HttpServletResponseWrapper to provide custom response handling
     * for web API responses, including dummy output stream management.
     */
    public class WebApiResponse extends HttpServletResponseWrapper {
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  2. cmd/object-api-utils_test.go

    	}{
    		{
    			name:     "1",
    			metadata: map[string]string{"content-type": "application/octet-stream", "etag": "de75a98baf2c6aef435b57dd0fc33c86", "x-amz-storage-class": "STANDARD"},
    			want:     map[string]string{"content-type": "application/octet-stream", "etag": "de75a98baf2c6aef435b57dd0fc33c86"},
    		},
    		{
    			name:     "2",
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 24.1K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java

         */
        public void setCookieStore(final CookieStore cookieStore) {
            this.cookieStore = cookieStore;
        }
    
        /**
         * Sets the HTTP client context for requests.
         *
         * @param httpClientContext The HTTP client context
         */
        public void setHttpClientContext(final HttpClientContext httpClientContext) {
            this.httpClientContext = httpClientContext;
        }
    
        /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 52.2K bytes
    - Viewed (0)
  4. cmd/metacache-walk.go

    // On success a sorted meta cache stream will be returned.
    // Metadata has data stripped, if any.
    // The function tries to quit as fast as the context is canceled to avoid further drive IO
    func (s *xlStorage) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) (err error) {
    	legacyFS := s.fsType != xfs && s.fsType != ext4
    
    	s.RLock()
    	legacy := s.formatLegacy
    	s.RUnlock()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 26 07:06:43 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  5. cmd/bucket-handlers.go

    		return
    	}
    
    	// Content-Md5 is required should be set
    	// http://docs.aws.amazon.com/AmazonS3/latest/API/multiobjectdeleteapi.html
    	if !validateLengthAndChecksum(r) {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrMissingContentMD5), r.URL)
    		return
    	}
    
    	// Content-Length is required and should be non-zero
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  6. cmd/erasure-healing_test.go

    	_, err = er.getDisks()[0].StatVol(t.Context(), bucket)
    	if err != nil {
    		t.Fatal(err)
    	}
    }
    
    // Tests both object and bucket healing.
    func TestHealingVersioned(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    	obj, fsDirs, err := prepareErasure16(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer obj.Shutdown(t.Context())
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java

            return clientFactory.getClient(url);
        }
    
        /**
         * Checks if the content has been updated since the last crawl.
         * @param client The crawler client.
         * @param urlQueue The URL queue entry.
         * @return true if content is updated, false otherwise.
         */
        protected boolean isContentUpdated(final CrawlerClient client, final UrlQueue<?> urlQueue) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  8. cmd/xl-storage.go

    }
    
    func (s *xlStorage) readMetadata(ctx context.Context, itemPath string) ([]byte, error) {
    	return xioutil.WithDeadline[[]byte](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) ([]byte, error) {
    		buf, _, err := s.readMetadataWithDMTime(ctx, itemPath)
    		return buf, err
    	})
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  9. cmd/erasure-healing.go

    	healingMetricCheckAbandonedParts
    )
    
    // List a prefix or a single object versions and heal
    func (er erasureObjects) listAndHeal(ctx context.Context, bucket, prefix string, recursive bool, scanMode madmin.HealScanMode, healEntry func(string, metaCacheEntry, madmin.HealScanMode) error) error {
    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    
    	disks, _ := er.getOnlineDisksWithHealing(false)
    	if len(disks) == 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
  10. cmd/admin-handlers-users.go

    	condValues["DurationSeconds"] = []string{strconv.FormatInt(int64(dur.Seconds()), 10)}
    	return nil
    }
    
    func commonAddServiceAccount(r *http.Request, ldap bool) (context.Context, auth.Credentials, newServiceAccountOpts, madmin.AddServiceAccountReq, string, APIError) {
    	ctx := r.Context()
    
    	// Get current object layer instance.
    	objectAPI := newObjectLayerFn()
    	if objectAPI == nil || globalNotificationSys == nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 90.6K bytes
    - Viewed (0)
Back to top