Search Options

Results per page
Sort
Preferred Languages
Advance

Results 511 - 520 of 2,300 for _context (0.09 sec)

  1. src/main/java/org/codelibs/fess/helper/ViewHelper.java

                doc.put(HL_CACHE, StringUtil.EMPTY);
            }
    
            try {
                final Template template = handlebars.compile(cacheTemplateName);
                final Context hbsContext = Context.newContext(doc);
                return template.apply(hbsContext);
            } catch (final Exception e) {
                logger.warn("Failed to create a cache response.", e);
            }
    
            return null;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 40.2K bytes
    - Viewed (0)
  2. cmd/bucket-listobjects-handlers.go

    	return subToken, nodeIndex
    }
    
    func proxyRequestByToken(ctx context.Context, w http.ResponseWriter, r *http.Request, token string) (string, bool) {
    	subToken, nodeIndex := parseRequestToken(token)
    	if nodeIndex > 0 {
    		return subToken, proxyRequestByNodeIndex(ctx, w, r, nodeIndex)
    	}
    	return subToken, false
    }
    
    func proxyRequestByNodeIndex(ctx context.Context, w http.ResponseWriter, r *http.Request, index int) (success bool) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  3. internal/event/target/kafka.go

    	if err != nil {
    		if !errors.Is(err, sarama.ErrOutOfBrokers) {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    		}
    		return err
    	}
    
    	producer, err := sarama.NewSyncProducerFromClient(client)
    	if err != nil {
    		if !errors.Is(err, sarama.ErrOutOfBrokers) {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    		}
    		return err
    	}
    	target.client = client
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-rebalance.go

    			ps.RebalancedBuckets = append(ps.RebalancedBuckets, bucket)
    			break
    		}
    	}
    }
    
    func (r *rebalanceMeta) load(ctx context.Context, store objectIO) error {
    	return r.loadWithOpts(ctx, store, ObjectOptions{})
    }
    
    func (r *rebalanceMeta) loadWithOpts(ctx context.Context, store objectIO, opts ObjectOptions) error {
    	data, _, err := readConfigWithMetadata(ctx, store, rebalMetaName, opts)
    	if err != nil {
    		return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb2/Smb3KeyDerivation.java

    
        /**
         * @param sessionKey
         * @param label
         * @param context
         */
        private static byte[] derive ( byte[] sessionKey, byte[] label, byte[] context ) {
            KDFCounterBytesGenerator gen = new KDFCounterBytesGenerator(new HMac(new SHA256Digest()));
    
            int r = 32;
            byte[] suffix = new byte[label.length + context.length + 5];
            // per bouncycastle
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 5.7K bytes
    - Viewed (0)
  6. internal/ioutil/ioutil.go

    // If the deadline/context passes before the function finishes executing,
    // the zero value and the context error is returned.
    func WithDeadline[V any](ctx context.Context, timeout time.Duration, work func(ctx context.Context) (result V, err error)) (result V, err error) {
    	ctx, cancel := context.WithTimeout(ctx, timeout)
    	defer cancel()
    
    	c := make(chan ioret[V], 1)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  7. scan.go

    	for idx, field := range fields {
    		if field == nil {
    			continue
    		}
    
    		if len(joinFields) == 0 || len(joinFields[idx]) == 0 {
    			db.AddError(field.Set(db.Statement.Context, reflectValue, values[idx]))
    		} else { // joinFields count is larger than 2 when using join
    			var isNilPtrValue bool
    			var relValue reflect.Value
    			// does not contain raw dbname
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/server.go

    	Start(ctx context.Context)
    
    	//	IsPodInMesh(ctx context.Context, pod *metav1.ObjectMeta, netNs string) (bool, error)
    	AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error
    	RemovePodFromMesh(ctx context.Context, pod *corev1.Pod, isDelete bool) error
    
    	Stop()
    }
    
    type Server struct {
    	ctx        context.Context
    	kubeClient kube.Client
    
    	handlers  K8sHandlers
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  9. cmd/lock-rest-server.go

    	success, err := l.ll.Lock(context.Background(), *args)
    	if err == nil && !success {
    		return l.makeResp(resp, errLockConflict)
    	}
    	return l.makeResp(resp, err)
    }
    
    // UnlockHandler - releases the acquired lock.
    func (l *lockRESTServer) UnlockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) {
    	resp := lockRPCUnlock.NewResponse()
    	_, err := l.ll.Unlock(context.Background(), *args)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  10. impl/maven-core/src/main/java/org/apache/maven/eventspy/internal/EventSpyDispatcher.java

            }
            return new EventSpyRepositoryListener(this, listener);
        }
    
        public void init(EventSpy.Context context) {
            if (eventSpies.isEmpty()) {
                return;
            }
            for (EventSpy eventSpy : eventSpies) {
                try {
                    eventSpy.init(context);
                } catch (Exception | LinkageError e) {
                    logError("initialize", e, eventSpy);
                }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.3K bytes
    - Viewed (0)
Back to top