Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for getDriver (0.07 sec)

  1. cmd/tier.go

    	binary.LittleEndian.PutUint16(data[2:4], tierConfigVersion)
    
    	// Marshal the tier config
    	return config.MarshalMsg(data)
    }
    
    // getDriver returns a warmBackend interface object initialized with remote tier config matching tierName
    func (config *TierConfigMgr) getDriver(ctx context.Context, tierName string) (d WarmBackend, err error) {
    	config.Lock()
    	defer config.Unlock()
    
    	var ok bool
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    func getTransitionedObjectReader(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, oi ObjectInfo, opts ObjectOptions) (gr *GetObjectReader, err error) {
    	tgtClient, err := globalTierConfigMgr.getDriver(ctx, oi.TransitionedObject.Tier)
    	if err != nil {
    		return nil, fmt.Errorf("transition storage class not configured: %w", err)
    	}
    
    	fn, off, length, err := NewGetObjectReader(rs, oi, opts, h)
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    }
    
    // TransitionObject - transition object content to target tier.
    func (er erasureObjects) TransitionObject(ctx context.Context, bucket, object string, opts ObjectOptions) error {
    	tgtClient, err := globalTierConfigMgr.getDriver(ctx, opts.Transition.Tier)
    	if err != nil {
    		return err
    	}
    
    	if !opts.NoLock {
    		// Acquire write lock before starting to transition the object.
    		lk := er.NewNSLock(bucket, object)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/api/WebApiResponse.java

         *
         * @return A PrintWriter for response output
         * @throws IOException If an I/O error occurs
         */
        @Override
        public PrintWriter getWriter() throws IOException {
            // dummy stream
            return new PrintWriter(new ByteArrayOutputStream());
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/core/sql/DriverManagerUtil.java

        /**
         * Deregisters all JDBC drivers associated with the current class loader.
         */
        public static synchronized void deregisterAllDrivers() {
            for (final Enumeration<Driver> e = DriverManager.getDrivers(); e.hasMoreElements();) {
                deregisterDriver(e.nextElement());
            }
        }
    
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/api/WebApiManagerTest.java

            public void process(HttpServletRequest request, HttpServletResponse response, FilterChain chain)
                    throws IOException, ServletException {
                response.setStatus(200);
                response.getWriter().write(responseContent);
            }
        }
    
        private static class ErrorWebApiManager implements WebApiManager {
            @Override
            public boolean matches(HttpServletRequest request) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/cors/CorsHandlerTest.java

                @Override
                public jakarta.servlet.ServletOutputStream getOutputStream() {
                    return null;
                }
    
                @Override
                public java.io.PrintWriter getWriter() {
                    return null;
                }
    
                @Override
                public void setCharacterEncoding(String charset) {
                }
    
                @Override
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 25.9K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/filter/CorsFilterTest.java

            }
    
            @Override
            public jakarta.servlet.ServletOutputStream getOutputStream() {
                return null;
            }
    
            @Override
            public java.io.PrintWriter getWriter() {
                return null;
            }
    
            @Override
            public void setCharacterEncoding(String charset) {
            }
    
            @Override
            public void setContentLength(int len) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  9. src/test/java/jcifs/http/NetworkExplorerTest.java

                    return true;
                }
    
                @Override
                public void setWriteListener(WriteListener listener) {
                }
            };
    
            lenient().when(response.getWriter()).thenReturn(printWriter);
            lenient().when(response.getOutputStream()).thenReturn(servletOutputStream);
    
            // Setup servlet config
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 04:51:33 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/filter/WebApiFilterTest.java

                public jakarta.servlet.ServletOutputStream getOutputStream() throws IOException {
                    return null;
                }
    
                @Override
                public java.io.PrintWriter getWriter() throws IOException {
                    return null;
                }
    
                @Override
                public void setCharacterEncoding(String charset) {
                }
    
                @Override
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 26.2K bytes
    - Viewed (0)
Back to top