Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 81 - 90 of 489 for atomic (0.05 seconds)

  1. internal/kms/config.go

    package kms
    
    import (
    	"bytes"
    	"context"
    	"crypto/tls"
    	"crypto/x509"
    	"encoding/pem"
    	"errors"
    	"fmt"
    	"os"
    	"path/filepath"
    	"strings"
    	"sync"
    	"sync/atomic"
    	"syscall"
    	"time"
    
    	"aead.dev/mtls"
    	"github.com/minio/kms-go/kes"
    	"github.com/minio/kms-go/kms"
    	"github.com/minio/pkg/v3/certs"
    	"github.com/minio/pkg/v3/ellipses"
    	"github.com/minio/pkg/v3/env"
    )
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15K bytes
    - Click Count (0)
  2. internal/logger/target/http/http.go

    // buffer is full, new logs are just ignored and an error
    // is returned to the caller.
    type Target struct {
    	totalMessages  atomic.Int64
    	failedMessages atomic.Int64
    	status         atomic.Int32
    
    	// Worker control
    	workers    atomic.Int64
    	maxWorkers int64
    
    	// workerStartMu sync.Mutex
    	lastStarted time.Time
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/cache/Striped64.java

       *
       * Table entries are of class Cell; a variant of AtomicLong padded
       * to reduce cache contention on most processors. Padding is
       * overkill for most Atomics because they are usually irregularly
       * scattered in memory and thus don't interfere much with each
       * other. But Atomic objects residing in arrays will tend to be
       * placed adjacent to each other, and so will most often share
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 15 22:17:15 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  4. cmd/handler-utils.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"net/http"
    	"net/textproto"
    	"regexp"
    	"strings"
    	"sync/atomic"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/minio/internal/handlers"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.4K bytes
    - Click Count (1)
  5. src/main/java/org/codelibs/fess/dict/mapping/CharMappingFile.java

        }
    
        /**
         * Inner class for handling updates to the character mapping file.
         * This class manages the temporary file creation, writing operations,
         * and atomic updates to ensure data consistency during modifications.
         */
        protected class MappingUpdater implements Closeable {
    
            /** Flag indicating whether changes should be committed to the file. */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Dec 20 05:56:45 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb1/util/MD4.java

            B = HH(B, C, D, A, X[15], 15);
    
            context[0] += A;
            context[1] += B;
            context[2] += C;
            context[3] += D;
        }
    
        // The basic MD4 atomic functions.
    
        private int FF(final int a, final int b, final int c, final int d, final int x, final int s) {
            final int t = a + (b & c | ~b & d) + x;
            return t << s | t >>> 32 - s;
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 9.6K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/hash/Striped64.java

       *
       * Table entries are of class Cell; a variant of AtomicLong padded
       * to reduce cache contention on most processors. Padding is
       * overkill for most Atomics because they are usually irregularly
       * scattered in memory and thus don't interfere much with each
       * other. But Atomic objects residing in arrays will tend to be
       * placed adjacent to each other, and so will most often share
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 15 22:17:15 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  8. internal/s3select/jstream/decoder.go

    package jstream
    
    import (
    	"bytes"
    	"encoding/json"
    	"io"
    	"strconv"
    	"sync/atomic"
    	"unicode/utf16"
    )
    
    // ValueType - defines the type of each JSON value
    type ValueType int
    
    // Different types of JSON value
    const (
    	Unknown ValueType = iota
    	Null
    	String
    	Number
    	Boolean
    	Array
    	Object
    )
    
    // MetaValue wraps a decoded interface value with the document
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  9. go.mod

    	github.com/tinylib/msgp v1.4.0
    	github.com/valyala/bytebufferpool v1.0.0
    	github.com/xdg/scram v1.0.5
    	github.com/zeebo/xxh3 v1.0.2
    	go.etcd.io/etcd/api/v3 v3.5.21
    	go.etcd.io/etcd/client/v3 v3.5.21
    	go.uber.org/atomic v1.11.0
    	go.uber.org/zap v1.27.0
    	goftp.io/server/v2 v2.0.1
    	golang.org/x/crypto v0.37.0
    	golang.org/x/oauth2 v0.29.0
    	golang.org/x/sync v0.13.0
    	golang.org/x/sys v0.32.0
    	golang.org/x/term v0.31.0
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 12.2K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java

     */
    package org.codelibs.fess.helper;
    
    import java.util.Date;
    import java.util.LinkedHashMap;
    import java.util.Locale;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.crawler.entity.UrlQueue;
    import org.codelibs.fess.taglib.FessFunctions;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 17.4K bytes
    - Click Count (0)
Back to Top