Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for locksResp (0.14 sec)

  1. cmd/notification.go

    		ctx := logger.SetReqInfo(ctx, reqInfo)
    		peersLogOnceIf(ctx, err, sys.peerClients[index].host.String())
    	}
    	locksResp = append(locksResp, &PeerLocks{
    		Addr:  getHostName(r),
    		Locks: globalLockServer.DupLockMap(),
    	})
    	return locksResp
    }
    
    // LoadBucketMetadata - calls LoadBucketMetadata call on all peers
    func (sys *NotificationSys) LoadBucketMetadata(ctx context.Context, bucketName string) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  2. internal/dsync/lock-args_gen.go

    	if z.Quorum == nil {
    		s += msgp.NilSize
    	} else {
    		s += msgp.IntSize
    	}
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *LockResp) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.2K bytes
    - Viewed (0)
Back to top