Search Options

Results per page
Sort
Preferred Languages
Advance

Results 841 - 850 of 1,174 for async (0.08 sec)

  1. src/main/webapp/js/jquery-3.7.1.min.map

    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 131.6K bytes
    - Viewed (0)
  2. cmd/iam-etcd-store.go

    	return ies.loadMappedPolicy(ctx, name, userType, isGroup, m)
    }
    
    func (ies *IAMEtcdStore) loadMappedPolicy(ctx context.Context, name string, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy]) error {
    	var p MappedPolicy
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
  3. internal/lsync/lrwmutex_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package lsync_test
    
    import (
    	"context"
    	"fmt"
    	"runtime"
    	"sync"
    	"sync/atomic"
    	"testing"
    	"time"
    
    	. "github.com/minio/minio/internal/lsync"
    )
    
    func testSimpleWriteLock(t *testing.T, duration time.Duration) (locked bool) {
    	ctx := context.Background()
    	lrwm := NewLRWMutex()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  4. internal/dsync/drwmutex_test.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package dsync
    
    import (
    	"context"
    	"fmt"
    	"runtime"
    	"sync/atomic"
    	"testing"
    	"time"
    )
    
    const (
    	id     = "1234-5678"
    	source = "main.go"
    )
    
    func testSimpleWriteLock(t *testing.T, duration time.Duration) (locked bool) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 24 03:49:07 UTC 2022
    - 9.7K bytes
    - Viewed (0)
  5. cmd/iam-object-store.go

    	"errors"
    	"fmt"
    	"path"
    	"strings"
    	"sync"
    	"time"
    	"unicode/utf8"
    
    	jsoniter "github.com/json-iterator/go"
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/config"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/kms"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/sync/errgroup"
    	"github.com/puzpuzpuz/xsync/v3"
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  6. internal/grid/connection.go

    		id:                 o.id,
    		ctx:                o.ctx,
    		outgoing:           xsync.NewMapOfPresized[uint64, *muxClient](1000),
    		inStream:           xsync.NewMapOfPresized[uint64, *muxServer](1000),
    		outQueue:           make(chan []byte, defaultOutQueue),
    		side:               ws.StateServerSide,
    		connChange:         &sync.Cond{L: &sync.Mutex{}},
    		handlers:           o.handlers,
    		remote:             &RemoteClient{Name: o.remote},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  7. cmd/lock-rest-client.go

    	r, err := h.Call(ctx, c.connection, args)
    	if err != nil {
    		return false, err
    	}
    	defer h.PutResponse(r)
    	ok = r.Code == dsync.RespOK
    	switch r.Code {
    	case dsync.RespLockConflict, dsync.RespLockNotFound, dsync.RespOK:
    	// no error
    	case dsync.RespLockNotInitialized:
    		err = errLockNotInitialized
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  8. cmd/lock-rest-server.go

    	lockRPCRUnlock     = newLockHandler(grid.HandlerLockRUnlock)
    )
    
    func newLockHandler(h grid.HandlerID) *grid.SingleHandler[*dsync.LockArgs, *dsync.LockResp] {
    	return grid.NewSingleHandler[*dsync.LockArgs, *dsync.LockResp](h, func() *dsync.LockArgs {
    		return &dsync.LockArgs{}
    	}, func() *dsync.LockResp {
    		return &dsync.LockResp{}
    	})
    }
    
    // registerLockRESTHandlers - register lock rest router.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  9. api/go1.19.txt

    pkg sync/atomic, method (*Uintptr) Load() uintptr #50860
    pkg sync/atomic, method (*Uintptr) Store(uintptr) #50860
    pkg sync/atomic, method (*Uintptr) Swap(uintptr) uintptr #50860
    pkg sync/atomic, type Bool struct #50860
    pkg sync/atomic, type Int32 struct #50860
    pkg sync/atomic, type Int64 struct #50860
    pkg sync/atomic, type Pointer[$0 interface{}] struct #50860
    pkg sync/atomic, type Uint32 struct #50860
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Dec 02 16:29:41 UTC 2022
    - 17.9K bytes
    - Viewed (0)
  10. api/go1.23.txt

    pkg sync/atomic, func OrInt64(*int64, int64) int64 #61395
    pkg sync/atomic, func OrUint32(*uint32, uint32) uint32 #61395
    pkg sync/atomic, func OrUint64(*uint64, uint64) uint64 #61395
    pkg sync/atomic, func OrUintptr(*uintptr, uintptr) uintptr #61395
    pkg sync/atomic, method (*Int32) And(int32) int32 #61395
    pkg sync/atomic, method (*Int32) Or(int32) int32 #61395
    pkg sync/atomic, method (*Int64) And(int64) int64 #61395
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jun 25 17:08:08 UTC 2024
    - 10.1K bytes
    - Viewed (0)
Back to top