Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 441 - 450 of 859 for initializers (0.06 seconds)

  1. src/test/java/org/codelibs/fess/job/GenerateThumbnailJobTest.java

            } catch (JobProcessingException e) {
                assertTrue(e.getMessage().contains("Thumbnail Process terminated."));
            } catch (NullPointerException e) {
                // May occur if ServletContext is not fully initialized
                // This is acceptable in test environment
            }
        }
    
        // Test executeThumbnailGenerator with timeout
        @Test
        public void test_executeThumbnailGenerator_withTimeout() {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 19K bytes
    - Click Count (0)
  2. src/test/java/jcifs/netbios/NodeStatusResponseTest.java

            assertSame(mockQueryAddress, queryAddressField.get(response));
    
            // Verify recordName is initialized
            Field recordNameField = NameServicePacket.class.getDeclaredField("recordName");
            recordNameField.setAccessible(true);
            assertNotNull(recordNameField.get(response));
    
            // Verify macAddress is initialized with correct size
            Field macAddressField = NodeStatusResponse.class.getDeclaredField("macAddress");
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 19.3K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

            @Override
            public String toString() {
                return "Options [sessionId=" + sessionId + ", name=" + name + ", propertiesPath=" + propertiesPath + "]";
            }
        }
    
        /**
         * Initializes the necessary probes for monitoring system resources.
         */
        static void initializeProbes() {
            // Force probes to be loaded
            ProcessProbe.getInstance();
            OsProbe.getInstance();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  4. src/test/java/jcifs/internal/smb1/trans/TransTransactNamedPipeTest.java

        private static final int TEST_LENGTH = TEST_DATA.length;
    
        @BeforeEach
        void setUp() {
            MockitoAnnotations.openMocks(this);
        }
    
        @Test
        @DisplayName("Test constructor initializes fields correctly")
        void testConstructor() {
            // Act
            TransTransactNamedPipe trans = new TransTransactNamedPipe(mockConfig, TEST_FID, TEST_DATA, TEST_OFFSET, TEST_LENGTH);
    
            // Assert
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 9.7K bytes
    - Click Count (0)
  5. src/test/java/jcifs/internal/smb2/Smb2SigningDigestTest.java

                // Close the digest
                digest.close();
    
                // Verify operations fail after close
                byte[] data = new byte[128];
                // Initialize the data buffer with proper SMB2 header structure
                SMBUtil.writeInt4(0xFE534D42, data, 0); // SMB2 signature
                SMBUtil.writeInt4(0x0000, data, 12); // Command = 0
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 43.7K bytes
    - Click Count (0)
  6. cmd/erasure-healing.go

    	if globalTrace.NumSubscribers(madmin.TraceHealing) > 0 {
    		startTime := time.Now()
    		defer func() {
    			healTrace(healingMetricObject, startTime, bucket, object, &opts, err, &result)
    		}()
    	}
    
    	// Initialize heal result object
    	result = madmin.HealResultItem{
    		Type:      madmin.HealItemObject,
    		Bucket:    bucket,
    		Object:    object,
    		VersionID: versionID,
    		DiskCount: len(storageDisks),
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  7. internal/http/listener.go

    			listenErrs[i] = e
    			continue
    		}
    		opts.Trace("adding listener to " + l.Addr().String())
    
    		listeners = append(listeners, l)
    	}
    
    	if len(listeners) == 0 {
    		// No listeners initialized, no need to continue
    		return listener, listenErrs
    	}
    	listeners = slices.Clip(listeners)
    
    	ctx, cancel := context.WithCancel(ctx)
    	listener = &httpListener{
    		listeners:   listeners,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  8. docs/smb3-features/06-witness-protocol-design.md

                witnessClient = new WitnessClient(witnessServer, context);
                witnessEnabled = true;
                
                log.info("Initialized witness support with server: {}", witnessServer);
            }
        } catch (Exception e) {
            log.warn("Failed to initialize witness support", e);
        }
    }
    
    private InetAddress discoverWitnessService() throws IOException {
        // Try the same server first
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 42K bytes
    - Click Count (0)
  9. logger/logger.go

    	RecorderParamsFilter = func(ctx context.Context, sql string, params ...interface{}) (string, []interface{}) {
    		return sql, params
    	}
    )
    
    // New initialize logger
    func New(writer Writer, config Config) Interface {
    	var (
    		infoStr      = "%s\n[info] "
    		warnStr      = "%s\n[warn] "
    		errStr       = "%s\n[error] "
    		traceStr     = "%s\n[%.3fms] [rows:%v] %s"
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 6.3K bytes
    - Click Count (0)
  10. cmd/lock-rest-server.go

    )
    
    // lockMaintenance loops over all locks and discards locks
    // that have not been refreshed for some time.
    func lockMaintenance(ctx context.Context) {
    	if !globalIsDistErasure {
    		return
    	}
    
    	// Initialize a new ticker with 1 minute between each ticks.
    	lkTimer := time.NewTimer(lockMaintenanceInterval)
    	// Stop the timer upon returning.
    	defer lkTimer.Stop()
    
    	for {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jan 31 19:54:34 GMT 2025
    - 6.3K bytes
    - Click Count (0)
Back to Top