Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1231 - 1240 of 1,446 for needle (0.04 sec)

  1. internal/event/target/mysql.go

    		}
    	}
    
    	if m.Table == "" {
    		return fmt.Errorf("table unspecified")
    	}
    
    	if m.DSN != "" {
    		if _, err := mysql.ParseDSN(m.DSN); err != nil {
    			return err
    		}
    	} else {
    		// Some fields need to be specified when DSN is unspecified
    		if m.Port == "" {
    			return fmt.Errorf("unspecified port")
    		}
    		if _, err := strconv.Atoi(m.Port); err != nil {
    			return fmt.Errorf("invalid port")
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  2. src/main/java/jcifs/netbios/NbtAddress.java

    import jcifs.Address;
    import jcifs.CIFSContext;
    import jcifs.NetbiosAddress;
    import jcifs.NetbiosName;
    
    /**
     * This class represents a NetBIOS over TCP/IP address. Under normal
     * conditions, users of jCIFS need not be concerned with this class as
     * name resolution and session services are handled internally by the smb package.
     *
     *
     *  * Applications can use the methods <code>getLocalHost</code>,
     * <code>getByName</code>, and
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  3. src/test/java/jcifs/dcerpc/DcerpcPipeHandleTest.java

                // The finally block ensures pipe is closed even if handle close fails
                // Since the real method will propagate the exception from handle.close(),
                // we need to catch it to verify that pipe.close() was still called
                try {
                    handle.close();
                    fail("Expected IOException to be thrown");
                } catch (IOException e) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 21K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

      /**
       * Prepares the HTTP headers and sends them to the server.
       *
       * For streaming requests with a body, headers must be prepared **before** the output stream has
       * been written to. Otherwise the body would need to be buffered!
       *
       * For non-streaming requests with a body, headers must be prepared **after** the output stream
       * has been written to and closed. This ensures that the `Content-Length` header field receives
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 17.5K bytes
    - Viewed (7)
  5. android/guava/src/com/google/common/base/MoreObjects.java

         * helps to shortcut most calls to isEmpty(), which is important because the check for emptiness
         * is relatively expensive. Use a subtype so this also doesn't need any extra storage.
         */
        private static final class UnconditionalValueHolder extends ValueHolder {}
      }
    
      private MoreObjects() {}
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  6. cmd/admin-handlers_test.go

    	"net/url"
    	"sort"
    	"sync"
    	"testing"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/mux"
    )
    
    // adminErasureTestBed - encapsulates subsystems that need to be setup for
    // admin-handler unit tests.
    type adminErasureTestBed struct {
    	erasureDirs []string
    	objLayer    ObjectLayer
    	router      *mux.Router
    	done        context.CancelFunc
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (1)
  7. src/test/java/jcifs/smb/SIDCacheImplTest.java

        void resolveSids_withOffsetAndCache_behavesCorrectly() throws Exception {
            CIFSContext ctx = mock(CIFSContext.class);
            SIDCacheImpl cache = Mockito.spy(new SIDCacheImpl(ctx));
    
            // Prepare SIDs, two need resolution, one already resolved
            SID s1 = sid("S-1-5-21-10-11-12-1001");
            SID s2 = sid("S-1-5-21-10-11-12-1002");
            SID s3 = sid("S-1-5-21-10-11-12-1003");
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14K bytes
    - Viewed (0)
  8. src/archive/tar/strconv.go

    		return
    	}
    
    	f.formatOctal(b, 0) // Last resort, just write zero
    	f.err = ErrFieldTooLong
    }
    
    func (p *parser) parseOctal(b []byte) int64 {
    	// Because unused fields are filled with NULs, we need
    	// to skip leading NULs. Fields may also be padded with
    	// spaces or NULs.
    	// So we remove leading and trailing NULs and spaces to
    	// be sure.
    	b = bytes.Trim(b, " \x00")
    
    	if len(b) == 0 {
    		return 0
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Mon Sep 08 17:08:20 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  9. compat/maven-artifact/src/main/java/org/apache/maven/artifact/versioning/ComparableVersion.java

                // -1
                //  or QUALIFIERS.size and then resort to lexical ordering. Most comparisons are decided by the first
                // character,
                // so this is still fast. If more characters are needed then it requires a lexical sort anyway.
                return i == -1 ? (QUALIFIERS.size() + "-" + qualifier) : String.valueOf(i);
            }
    
            @Override
            public int compareTo(Item item) {
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Jul 23 17:27:08 UTC 2025
    - 26.4K bytes
    - Viewed (0)
  10. cmd/peer-rest-server.go

    	})
    	if err != nil {
    		return info, grid.NewRemoteErr(err)
    	}
    
    	return &VolInfo{
    		Name:    bucketInfo.Name,
    		Created: bucketInfo.Created,
    		Deleted: bucketInfo.Deleted, // needed for site replication
    	}, nil
    }
    
    // DeleteBucketHandler implements peer delete bucket call.
    func (s *peerRESTServer) DeleteBucketHandler(mss *grid.MSS) (np grid.NoPayload, nerr *grid.RemoteErr) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 53.6K bytes
    - Viewed (0)
Back to top