Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 314 for connectEnd (0.12 sec)

  1. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/smb1/SmbClientTest.java

            smbClient.setInitParameterMap(params);
            smbClient.init();
    
            boolean connected = false;
            for (int i = 0; i < 30; i++) {
                try {
                    smbClient.doGet(baseUrl);
                } catch (final ChildUrlsException e) {
                    connected = true;
                    break;
                } catch (final Exception e) {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Tue Sep 23 06:42:59 UTC 2025
    - 30K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/collect/RangeTest.java

        assertThat(expected).hasMessageThat().contains("connected");
        expected =
            assertThrows(IllegalArgumentException.class, () -> range.intersection(Range.closed(0, 2)));
        assertThat(expected).hasMessageThat().contains("connected");
      }
    
      public void testIntersection_deFactoEmpty() {
        {
          Range<Integer> range = Range.open(3, 4);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 24.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/RangeMap.java

       * connect to the given range and value.
       *
       * <p>Even if the input range is empty, if it is connected on both sides by ranges mapped to the
       * same value those two ranges will be coalesced.
       *
       * <p><b>Note:</b> coalescing requires calling {@code .equals()} on any connected values, which
       * may be expensive depending on the value type. Using this method on range maps with large values
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  4. src/main/java/jcifs/SmbTreeHandle.java

         * {@inheritDoc}
         *
         * @see java.lang.AutoCloseable#close()
         */
        @Override
        void close() throws CIFSException;
    
        /**
         * Checks whether the tree is currently connected
         * @return the tree is connected
         */
        boolean isConnected();
    
        /**
         * Gets the server timezone offset in milliseconds
         * @return server timezone offset
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  5. src/main/java/jcifs/SmbTransport.java

         */
        @Override
        void close();
    
        /**
         * Gets the address of the remote SMB server.
         *
         * @return the connected address
         */
        Address getRemoteAddress();
    
        /**
         * Gets the host name of the remote SMB server.
         *
         * @return the connected host name
         */
        String getRemoteHostName();
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  6. src/test/java/jcifs/SmbTreeHandleTest.java

        /**
         * Test for getConnectedShare() method.
         * Verifies that the method returns the correct connected share name.
         */
        @Test
        void testGetConnectedShare() {
            when(smbTreeHandle.getConnectedShare()).thenReturn("TEST_SHARE");
            assertEquals("TEST_SHARE", smbTreeHandle.getConnectedShare(), "Connected share should be TEST_SHARE");
        }
    
        /**
         * Test for isSameTree() method.
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  7. internal/grid/connection.go

    			return
    		}
    		dialStarted := time.Now()
    		if debugPrint {
    			fmt.Println(c.Local, "Connecting to ", c.Remote)
    		}
    		conn, err := c.dial(c.ctx, c.Remote)
    		c.connMu.Lock()
    		c.debugOutConn = conn
    		c.connMu.Unlock()
    		retry := func(err error) {
    			if debugPrint {
    				fmt.Printf("%v Connecting to %v: %v. Retrying.\n", c.Local, c.Remote, err)
    			}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 46.9K bytes
    - Viewed (0)
  8. internal/rest/client.go

    func (c *Client) Close() {
    	atomic.StoreInt32(&c.connected, closed)
    }
    
    // NewClient - returns new REST client.
    func NewClient(uu *url.URL, tr http.RoundTripper, auth func() string) *Client {
    	connected := int32(online)
    	urlStr := uu.String()
    	u, err := url.Parse(urlStr)
    	if err != nil {
    		// Mark offline, with no reconnection attempts.
    		connected = int32(offline)
    		err = &url.Error{URL: urlStr, Err: err}
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  9. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/smb/SmbClientTest.java

            smbClient.setInitParameterMap(params);
            smbClient.init();
    
            boolean connected = false;
            for (int i = 0; i < 30; i++) {
                try {
                    smbClient.doGet(baseUrl);
                } catch (final ChildUrlsException e) {
                    connected = true;
                    break;
                } catch (final Exception e) {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Tue Sep 23 06:42:59 UTC 2025
    - 31.9K bytes
    - Viewed (0)
  10. helm/minio/templates/_helper_create_bucket.txt

    	ATTEMPTS=0
    	LIMIT=29 # Allow 30 attempts
    	set -e   # fail if we can't read the keys.
    	ACCESS=$(cat /config/rootUser)
    	SECRET=$(cat /config/rootPassword)
    	set +e # The connections to minio are allowed to fail.
    	echo "Connecting to MinIO server: $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT"
    	MC_COMMAND="${MC} alias set myminio $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT $ACCESS $SECRET"
    	$MC_COMMAND
    	STATUS=$?
    	until [ $STATUS = 0 ]; do
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Aug 07 09:47:02 UTC 2025
    - 3.5K bytes
    - Viewed (0)
Back to top