Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 291 - 300 of 1,721 for filled (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/pubsub/pubsub.go

    	defer ps.RUnlock()
    	for _, sub := range ps.subs {
    		if sub.types.Contains(Mask(item.Mask())) && (sub.filter == nil || sub.filter(item)) {
    			select {
    			case sub.ch <- item:
    			default:
    			}
    		}
    	}
    }
    
    // Subscribe - Adds a subscriber to pubsub system
    func (ps *PubSub[T, M]) Subscribe(mask M, subCh chan T, doneCh <-chan struct{}, filter func(entry T) bool) error {
    	totalSubs := atomic.AddInt32(&ps.numSubscribers, 1)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 06 16:57:30 GMT 2024
    - 5.2K bytes
    - Click Count (0)
  2. internal/store/queuestore_test.go

    	defer func() {
    		if err := tearDownQueueStore(); err != nil {
    			t.Fatal("Failed to tear down store ", err)
    		}
    	}()
    	store, err := setUpQueueStore(queueDir, 100)
    	if err != nil {
    		t.Fatal("Failed to create a queue store ", err)
    	}
    	// Put 100 items.
    	for range 100 {
    		if _, err := store.Put(testItem); err != nil {
    			t.Fatal("Failed to put to queue store ", err)
    		}
    	}
    	// Count the items.
    	keys := store.List()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  3. src/test/java/jcifs/internal/smb2/lock/Smb2OplockBreakNotificationTest.java

                // Set up notification with known values
                byte oplockLevel = 0x02;
                byte[] fileId = new byte[16];
                Arrays.fill(fileId, 0, 8, (byte) 0xAB);
                Arrays.fill(fileId, 8, 16, (byte) 0xCD);
    
                // Use reflection to set private fields
                Field oplockLevelField = Smb2OplockBreakNotification.class.getDeclaredField("oplockLevel");
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 17.6K bytes
    - Click Count (0)
  4. internal/kms/errors.go

    		Err:     "key with given key ID does not exist",
    	}
    
    	// ErrDecrypt is an error returned by the KMS when the decryption
    	// of a ciphertext failed.
    	ErrDecrypt = Error{
    		Code:    http.StatusBadRequest,
    		APICode: "kms:InvalidCiphertextException",
    		Err:     "failed to decrypt ciphertext",
    	}
    
    	// ErrNotSupported is an error returned by the KMS when the requested
    	// functionality is not supported by the KMS service.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jul 16 14:03:03 GMT 2024
    - 3.6K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/util/QueryStringBuilder.java

            stream(conditions.get(SearchRequestParams.AS_OCCURRENCE))
                    .of(stream -> stream.filter(this::isOccurrence).findFirst().ifPresent(q -> queryBuf.insert(0, q + ":")));
    
            stream(conditions.get(SearchRequestParams.AS_Q))
                    .of(stream -> stream.filter(q -> StringUtil.isNotBlank(q) && q.length() <= maxQueryLength)
                            .forEach(q -> queryBuf.append(' ').append(q)));
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  6. src/main/java/jcifs/internal/smb2/io/Smb2ReadRequest.java

         */
        @Override
        public void setFileId(final byte[] fileId) {
            this.fileId = fileId;
        }
    
        /**
         * Sets the padding for the read request
         *
         * @param padding
         *            the padding to set
         */
        public void setPadding(final byte padding) {
            this.padding = padding;
        }
    
        /**
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  7. impl/maven-core/src/main/java/org/apache/maven/classrealm/DefaultClassRealmManager.java

    /*
     * Licensed to the Apache Software Foundation (ASF) under one
     * or more contributor license agreements.  See the NOTICE file
     * distributed with this work for additional information
     * regarding copyright ownership.  The ASF licenses this file
     * to you under the Apache License, Version 2.0 (the
     * "License"); you may not use this file except in compliance
     * with the License.  You may obtain a copy of the License at
     *
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  8. src/main/java/jcifs/internal/smb2/rdma/RdmaWorkRequest.java

        }
    
        /**
         * Mark request as failed with error
         *
         * @param error exception that caused the failure
         */
        public void markFailed(Exception error) {
            this.error = error;
            this.completed = true;
        }
    
        /**
         * Get error if request failed
         *
         * @return exception if failed, null if successful
         */
        public Exception getError() {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 24 00:12:28 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  9. impl/maven-core/src/main/java/org/apache/maven/project/DefaultDependencyResolutionRequest.java

            return filter;
        }
    
        @Override
        public MavenProject getMavenProject() {
            return project;
        }
    
        @Override
        public RepositorySystemSession getRepositorySession() {
            return session;
        }
    
        @Override
        public DependencyResolutionRequest setResolutionFilter(DependencyFilter filter) {
            this.filter = filter;
            return this;
        }
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Jul 23 10:13:56 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  10. src/test/java/jcifs/smb1/smb1/SmbFilenameFilterTest.java

            SmbFilenameFilter filter = (d, n) -> n.equalsIgnoreCase("hello.txt");
            assertTrue(filter.accept(dir, "Hello.TXT"));
        }
    
        @Test
        void acceptReturnsFalseWhenNameDoesNotMatch() throws Exception {
            SmbFile dir = Mockito.mock(SmbFile.class);
            SmbFilenameFilter filter = (d, n) -> n.equalsIgnoreCase("hello.txt");
            assertFalse(filter.accept(dir, "world.txt"));
        }
    
        @Test
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 1.6K bytes
    - Click Count (0)
Back to Top