Search Options

Results per page
Sort
Preferred Languages
Advance

Results 931 - 940 of 1,063 for closed (0.07 sec)

  1. cmd/local-locker.go

    		if len(v) == 0 {
    			delete(l.lockMap, k)
    			continue
    		}
    		lockCopy[k] = append(make([]lockRequesterInfo, 0, len(v)), v...)
    	}
    	return lockCopy
    }
    
    func (l *localLocker) Close() error {
    	return nil
    }
    
    // IsOnline - local locker is always online.
    func (l *localLocker) IsOnline() bool {
    	return true
    }
    
    // IsLocal - local locker returns true.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/ExecutionList.java

       * note that listeners added after this point may be executed before those previously added, and
       * note that the execution order of all listeners is ultimately chosen by the implementations of
       * the supplied executors.
       *
       * <p>This method is idempotent. Calling it several times in parallel is semantically equivalent
       * to calling it exactly once.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb1/ServerMessageBlock.java

        /**
         * SMB command to delete a directory.
         */
        public static final byte SMB_COM_DELETE_DIRECTORY = (byte) 0x01;
    
        /**
         * SMB command to close a file handle.
         */
        public static final byte SMB_COM_CLOSE = (byte) 0x04;
    
        /**
         * SMB command to delete a file.
         */
        public static final byte SMB_COM_DELETE = (byte) 0x06;
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 38.9K bytes
    - Viewed (0)
  4. cmd/benchmark-utils_test.go

    	return []byte{letterBytes[rand.Intn(len(letterBytes))]}
    }
    
    // picks a random byte and repeats it to size bytes.
    func generateBytesData(size int) []byte {
    	// repeat the random character chosen size
    	return bytes.Repeat(getRandomByte(), size)
    }
    
    // Parallel benchmark utility functions for ObjectLayer.PutObject().
    // Creates Object layer setup ( MakeBucket ) and then runs the PutObject benchmark.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  5. src/cmd/asm/internal/lex/input.go

    	}
    	delete(in.macros, name)
    }
    
    func (in *Input) Push(r TokenReader) {
    	if len(in.tr) > 100 {
    		in.Error("input recursion")
    	}
    	in.Stack.Push(r)
    }
    
    func (in *Input) Close() {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Sep 06 13:17:27 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/Config.java

                if (filename != null && filename.length() > 1) {
                    in = new FileInputStream(filename);
                }
                Config.load(in);
                if (in != null) {
                    in.close();
                }
            } catch (final IOException ioe) {
                if (LogStream.level > 0) {
                    ioe.printStackTrace(log);
                }
            }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 14.5K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb/MultiChannelManager.java

            }
        }
    
        /**
         * Cleanup and shutdown the multi-channel manager.
         */
        public void shutdown() {
            log.info("Shutting down MultiChannelManager");
    
            // Close all channels
            for (String sessionId : new ArrayList<>(sessionChannels.keySet())) {
                removeChannels(sessionId);
            }
    
            // Shutdown thread pools
            healthCheckExecutor.shutdown();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 20.5K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/suggest/util/SuggestUtilTest.java

            // Create test index
            client.admin().indices().prepareCreate(TEST_INDEX).execute().actionGet();
        }
    
        @AfterClass
        public static void afterClass() throws Exception {
            runner.close();
            runner.clean();
        }
    
        @Before
        public void setUp() {
            // Setup for each test
        }
    
        @Test
        public void testPrivateConstructor() throws Exception {
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Mon Sep 01 13:33:03 UTC 2025
    - 18.2K bytes
    - Viewed (0)
  9. docs/en/docs/tutorial/bigger-applications.md

    This is because we want to include their *path operations* in the OpenAPI schema and the user interfaces.
    
    As we cannot just isolate them and "mount" them independently of the rest, the *path operations* are "cloned" (re-created), not included directly.
    
    ///
    
    ## Check the automatic API docs { #check-the-automatic-api-docs }
    
    Now, run your app:
    
    <div class="termy">
    
    ```console
    $ fastapi dev app/main.py
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/dict/synonym/SynonymFile.java

                        throw new DictionaryException("Failed to write: " + item, e);
                    }
                }
                return null;
            }
    
            @Override
            public void close() {
                try {
                    writer.flush();
                } catch (final IOException e) {
                    // ignore
                }
                CloseableUtil.closeQuietly(writer);
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 15.5K bytes
    - Viewed (0)
Back to top