Search Options

Results per page
Sort
Preferred Languages
Advance

Results 891 - 900 of 1,038 for functies (0.08 sec)

  1. cmd/peer-s3-client.go

    	return deleteBucketLocal(ctx, bucket, opts)
    }
    
    // client to talk to peer Nodes.
    type remotePeerS3Client struct {
    	node  Node
    	pools []int
    
    	// Function that returns the grid connection for this peer when initialized.
    	// Will return nil if the grid connection is not initialized yet.
    	gridConn func() *grid.Connection
    }
    
    // S3PeerSys - S3 peer call system.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    	res := make(DailyAllTierStats, len(t.lastDayStats))
    	for tier, st := range t.lastDayStats {
    		res[tier] = st.clone()
    	}
    	return res
    }
    
    // UpdateWorkers at the end of this function leaves n goroutines waiting for
    // transition tasks
    func (t *transitionState) UpdateWorkers(n int) {
    	t.mu.Lock()
    	defer t.mu.Unlock()
    	if t.objAPI == nil { // Init hasn't been called yet.
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  3. internal/rest/client.go

    // Client - http based RPC client.
    type Client struct {
    	connected int32 // ref: https://golang.org/pkg/sync/atomic/#pkg-note-BUG
    	_         int32 // For 64 bits alignment
    	lastConn  int64
    
    	// HealthCheckFn is the function set to test for health.
    	// If not set the client will not keep track of health.
    	// Calling this returns true or false if the target
    	// is online or offline.
    	HealthCheckFn func() bool
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  4. okhttp/api/okhttp.api

    	public final fun x509TrustManager ()Ljavax/net/ssl/X509TrustManager;
    }
    
    public final class okhttp3/OkHttpClient$Builder {
    	public final fun -addInterceptor (Lkotlin/jvm/functions/Function1;)Lokhttp3/OkHttpClient$Builder;
    	public final fun -addNetworkInterceptor (Lkotlin/jvm/functions/Function1;)Lokhttp3/OkHttpClient$Builder;
    	public fun <init> ()V
    	public final fun addInterceptor (Lokhttp3/Interceptor;)Lokhttp3/OkHttpClient$Builder;
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:41:01 UTC 2024
    - 70.2K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    	}
    
    	pr, pw := xioutil.WaitPipe()
    	go func() {
    		pw.CloseWithError(er.getObjectWithFileInfo(ctx, bucket, object, off, length, pw, fi, metaArr, onlineDisks))
    	}()
    
    	// Cleanup function to cause the go routine above to exit, in
    	// case of incomplete read.
    	pipeCloser := func() {
    		pr.CloseWithError(nil)
    	}
    
    	if !unlockOnDefer {
    		return fn(pr, h, pipeCloser, nsUnlocker)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.indexer;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Map;
    import java.util.function.Consumer;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.lang.ThreadUtil;
    import org.codelibs.fess.Constants;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  7. tensorflow/c/eager/BUILD

            "tfe_monitoring_internal.h",
            "tfe_op_attrs_internal.h",
            "tfe_tensor_debug_info_internal.h",
            "tfe_tensorhandle_internal.h",
        ],
        visibility = [
            "//tensorflow/core/function/runtime_client:__pkg__",
            "//tensorflow/python:__subpackages__",
        ],
    )
    
    cc_library(
        name = "c_api_internal",
        hdrs = [
            "c_api_experimental.h",
            "c_api_internal.h",
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Apr 11 23:52:39 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java

    import java.time.format.DateTimeFormatter;
    import java.util.Arrays;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.function.Consumer;
    import java.util.stream.Collectors;
    
    import org.apache.commons.text.StringEscapeUtils;
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:46 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  9. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

       * to dump the queue into a newly allocated array of {@code String}:
       *
       * <pre>
       *     String[] y = x.toArray(new String[0]);</pre>
       *
       * <p>Note that {@code toArray(new Object[0])} is identical in function to {@code toArray()}.
       *
       * @param a the array into which the elements of the queue are to be stored, if it is big enough;
       *     otherwise, a new array of the same runtime type is allocated for this purpose
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 07 21:36:32 UTC 2024
    - 19K bytes
    - Viewed (0)
  10. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/DefaultMavenInvoker.java

    import java.nio.file.Path;
    import java.util.ArrayList;
    import java.util.Date;
    import java.util.HashMap;
    import java.util.LinkedHashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.function.Consumer;
    import java.util.regex.Matcher;
    import java.util.regex.Pattern;
    
    import org.apache.maven.InternalErrorException;
    import org.apache.maven.Maven;
    import org.apache.maven.api.Constants;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 29.8K bytes
    - Viewed (0)
Back to top