Search Options

Results per page
Sort
Preferred Languages
Advance

Results 641 - 650 of 1,049 for closes (0.03 sec)

  1. cmd/config-common.go

    	if err != nil {
    		if isErrObjectNotFound(err) {
    			return nil, ObjectInfo{}, errConfigNotFound
    		}
    
    		return nil, ObjectInfo{}, err
    	}
    	defer r.Close()
    
    	buf, err := io.ReadAll(r)
    	if err != nil {
    		return nil, ObjectInfo{}, err
    	}
    	if len(buf) == 0 {
    		return nil, ObjectInfo{}, errConfigNotFound
    	}
    	return buf, r.ObjInfo, nil
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  2. src/test/java/jcifs/spnego/NegTokenInitTest.java

            }
        }
    
        @Nested
        @DisplayName("Edge Cases and Error Conditions")
        class EdgeCasesTests {
    
            @Test
            @DisplayName("Parse handles empty token gracefully")
            void testParseEmptyToken() {
                byte[] emptyToken = new byte[0];
                assertThrows(IOException.class, () -> new NegTokenInit(emptyToken));
            }
    
            @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 21K bytes
    - Viewed (0)
  3. cmd/global-heal.go

    			bytes:   sz,
    			skipped: true,
    		}
    	}
    
    	// Collect updates to tracker from concurrent healEntry calls
    	results := make(chan healEntryResult, 1000)
    	quitting := make(chan struct{})
    	defer func() {
    		close(results)
    		<-quitting
    	}()
    
    	go func() {
    		for res := range results {
    			if res.entryDone {
    				tracker.setObject(res.name)
    				if time.Since(tracker.getLastUpdate()) > time.Minute {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  4. src/main/java/jcifs/http/NetworkExplorer.java

            out.println("</head><body>");
    
            out.print("<a class=\"sort\" style=\"width: " + maxLen + ";\" href=\"?fmt=detail&sort=name\">Name</a>");
            out.println("<a class=\"sort\" href=\"?fmt=detail&sort=size\">Size</a>");
            out.println("<a class=\"sort\" href=\"?fmt=detail&sort=type\">Type</a>");
            out.println("<a class=\"sort\" style=\"width: 180\" href=\"?fmt=detail&sort=date\">Modified</a><br clear='all'><p>");
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 23.4K bytes
    - Viewed (0)
  5. okhttp/src/commonTest/kotlin/okhttp3/CompressionInterceptorTest.kt

        assertThat(response.body.string()).isEqualTo("Hello")
      }
    
      private fun gzip(data: String): Buffer {
        val result = Buffer()
        val sink = GzipSink(result).buffer()
        sink.writeUtf8(data)
        sink.close()
        return result
      }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Aug 01 06:04:22 UTC 2025
    - 3K bytes
    - Viewed (0)
  6. okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/TestDohMain.kt

            getOnly = true,
          )
        runBatch(dnsProviders, names)
      } finally {
        bootstrapClient.connectionPool.evictAll()
        bootstrapClient.dispatcher.executorService.shutdownNow()
        bootstrapClient.cache?.close()
      }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/testing/TestLogHandler.java

        synchronized (lock) {
          if (record != null) {
            list.add(record);
          }
        }
      }
    
      @Override
      public void flush() {}
    
      @Override
      public void close() {}
    
      public void clear() {
        synchronized (lock) {
          list.clear();
        }
      }
    
      /** Returns a snapshot of the logged records. */
      /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  8. src/main/java/jcifs/dcerpc/msrpc/SamrAliasHandle.java

    import jcifs.dcerpc.rpc;
    import jcifs.smb.SmbException;
    
    /**
     * Handle for Security Account Manager (SAM) alias operations.
     * This class represents an open handle to a SAM alias and provides
     * operations for managing alias membership and properties.
     */
    public class SamrAliasHandle extends rpc.policy_handle implements AutoCloseable {
    
        private final DcerpcHandle handle;
        private boolean opened;
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.5K bytes
    - Viewed (0)
  9. cmd/callhome.go

    		return nil
    	}
    
    	if e := enc.Encode(healthInfo); e != nil {
    		internalLogIf(ctx, fmt.Errorf("Could not encode health info: %w", e))
    		return nil
    	}
    
    	gzWriter.Flush()
    	gzWriter.Close()
    
    	return b.Bytes()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  10. src/main/java/jcifs/dcerpc/msrpc/SamrDomainHandle.java

    import jcifs.dcerpc.rpc;
    import jcifs.smb.SmbException;
    
    /**
     * Handle for Security Account Manager (SAM) domain operations.
     * This class represents an open handle to a SAM domain and provides
     * operations for managing domain users, groups, and aliases.
     */
    public class SamrDomainHandle extends rpc.policy_handle implements AutoCloseable {
    
        private final DcerpcHandle handle;
        private boolean opened;
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.5K bytes
    - Viewed (0)
Back to top