Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1431 - 1440 of 2,107 for writeFn (0.11 seconds)

  1. src/main/java/jcifs/pac/kerberos/KerberosTicket.java

     * Lesser General Public License for more details.
     *
     * You should have received a copy of the GNU Lesser General Public
     * License along with this library; if not, write to the Free Software
     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    package jcifs.pac.kerberos;
    
    import java.io.ByteArrayInputStream;
    import java.io.IOException;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  2. src/main/java/jcifs/smb1/netbios/NodeStatusResponse.java

     * Lesser General Public License for more details.
     *
     * You should have received a copy of the GNU Lesser General Public
     * License along with this library; if not, write to the Free Software
     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    
    package jcifs.smb1.netbios;
    
    import java.io.UnsupportedEncodingException;
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  3. cmd/object-lambda-handlers_test.go

    				w.Header().Set(xhttp.AmzRequestToken, functionToken)
    				w.Header().Set(xhttp.AmzFwdHeaderContentType, contentType)
    				w.Header().Set(xhttp.AmzFwdStatus, strconv.Itoa(lambdaStatus))
    				w.WriteHeader(lambdaStatus)
    				w.Write([]byte(lambdaBody))
    			}))
    			defer lambdaServer.Close()
    
    			lambdaARN := "arn:minio:s3-object-lambda::lambda1:webhook"
    
    			cfg := config.New()
    			cfg[config.LambdaWebhookSubSys] = map[string]config.KVS{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jul 18 21:56:31 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  4. build-conventions/src/main/java/org/elasticsearch/gradle/internal/checkstyle/MissingJavadocTypeCheck.java

     * Lesser General Public License for more details.
     *
     * You should have received a copy of the GNU Lesser General Public
     * License along with this library; if not, write to the Free Software
     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    
    package org.elasticsearch.gradle.internal.checkstyle;
    
    import com.puppycrawl.tools.checkstyle.StatelessCheck;
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Thu Jun 10 23:06:44 GMT 2021
    - 5.5K bytes
    - Click Count (0)
  5. src/test/java/jcifs/smb/StaticJAASConfigurationTest.java

            assertEquals(e1.getOptions(), e2.getOptions(), "Options content should be equivalent across calls");
        }
    
        @Test
        @DisplayName("Options map is not mutated by configuration (verify no writes)")
        void optionsMap_notMutated_verifyNoWrites() {
            // Arrange: create a regular map first, then spy on it
            Map<String, Object> originalMap = new HashMap<>();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 7K bytes
    - Click Count (0)
  6. internal/jwt/parser.go

    		return jwtgo.ErrSignatureInvalid
    	}
    
    	n, err := base64DecodeBytes(token[i+1:], *bufp)
    	if err != nil {
    		return err
    	}
    	borrow := signer.HashBorrower()
    	hasher := hmac.New(borrow.Borrow, key)
    	hasher.Write(token[:i])
    	if !hmac.Equal((*bufp)[:n], hasher.Sum(nil)) {
    		borrow.ReturnAll()
    		return jwtgo.ErrSignatureInvalid
    	}
    	borrow.ReturnAll()
    
    	if claims.AccessKey == "" && claims.Subject == "" {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.1K bytes
    - Click Count (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/gcs/GcsClient.java

     *   <li>credentialsFile - Path to service account JSON file (optional)</li>
     *   <li>connectTimeout - Connection timeout in milliseconds (default: 10000)</li>
     *   <li>writeTimeout - Write timeout in milliseconds (default: 10000)</li>
     *   <li>readTimeout - Read timeout in milliseconds (default: 10000)</li>
     * </ul>
     *
     * <p>The client supports URLs in the format: {@code gcs://bucket-name/object-path}
     *
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Thu Dec 11 08:38:29 GMT 2025
    - 17.5K bytes
    - Click Count (0)
  8. android/guava-testlib/src/com/google/common/collect/testing/AbstractMapTester.java

    import org.jspecify.annotations.NullMarked;
    import org.jspecify.annotations.Nullable;
    import org.junit.Ignore;
    
    /**
     * Base class for map testers.
     *
     * <p>TODO: see how much of this is actually needed once Map testers are written. (It was cloned
     * from AbstractCollectionTester.)
     *
     * @param <K> the key type of the map to be tested.
     * @param <V> the value type of the map to be tested.
     * @author George van den Driessche
     */
    @GwtCompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Jan 18 02:54:30 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  9. src/test/java/jcifs/internal/fscc/FileEndOfFileInformationTest.java

            // Create buffer for encoding
            byte[] buffer = new byte[16];
            int bytesWritten = info.encode(buffer, 0);
    
            // Verify bytes written
            assertEquals(8, bytesWritten);
    
            // Verify encoded value
            long decodedValue = SMBUtil.readInt8(buffer, 0);
            assertEquals(endOfFile, decodedValue);
        }
    
        @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  10. internal/etag/etag.go

    func Multipart(etags ...ETag) ETag {
    	if len(etags) == 0 {
    		return nil
    	}
    
    	var n int64
    	h := md5.New()
    	for _, etag := range etags {
    		if !etag.IsMultipart() && !etag.IsEncrypted() {
    			h.Write(etag)
    			n++
    		}
    	}
    	etag := append(h.Sum(nil), '-')
    	return strconv.AppendInt(etag, n, 10)
    }
    
    // Set adds the ETag to the HTTP headers. It overwrites any
    // existing ETag entry.
    //
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 13.2K bytes
    - Click Count (0)
Back to Top