- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for ref (0.18 sec)
-
callbacks/delete.go
) for _, ref := range rel.References { if ref.OwnPrimaryKey { foreignFields = append(foreignFields, ref.PrimaryKey) relForeignKeys = append(relForeignKeys, ref.ForeignKey.DBName) } else if ref.PrimaryValue != "" { queryConds = append(queryConds, clause.Eq{ Column: clause.Column{Table: rel.JoinTable.Table, Name: ref.ForeignKey.DBName}, Value: ref.PrimaryValue,
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Feb 25 02:48:23 GMT 2022 - 5.6K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
lm.mu.Lock() defer lm.mu.Unlock() // Try to release lock. if isWriteLock { if lm.isWriteLock && lm.ref == 1 { lm.ref = 0 lm.isWriteLock = false unlocked = true } } else { if !lm.isWriteLock { if lm.ref > 0 { lm.ref-- unlocked = true } } } return unlocked } // ForceUnlock will forcefully clear a write or read lock.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
internal/lock/lock.go
var ErrAlreadyLocked = errors.New("file already locked") // RLockedFile represents a read locked file, implements a special // closer which only closes the associated *os.File when the ref count. // has reached zero, i.e when all the readers have given up their locks. type RLockedFile struct { *LockedFile mutex sync.Mutex refs int // Holds read lock refs. }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 2.5K bytes - Viewed (0) -
internal/hash/sha256/sh256_fips.go
import ( fipssha256 "crypto/sha256" "hash" ) // New returns a new hash.Hash computing the SHA256 checksum. // The SHA256 implementation is FIPS 140-2 compliant when the // boringcrypto branch of Go is used. // Ref: https://github.com/golang/go/tree/dev.boringcrypto func New() hash.Hash { return fipssha256.New() } // Sum256 returns the SHA256 checksum of the data.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Aug 29 23:57:16 GMT 2022 - 1.3K bytes - Viewed (0) -
internal/s3select/parquet/reader.go
dstRec.KVS = kvs return dstRec, nil } // convertFromAnnotation - converts values based on the Parquet column's type // annotations. LogicalType annotations if present override the deprecated // ConvertedType annotations. Ref: // https://github.com/apache/parquet-format/blob/master/LogicalTypes.md func convertFromAnnotation(se *parquettypes.SchemaElement, v interface{}) (interface{}, error) { if se == nil { return v, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 14 13:54:47 GMT 2022 - 4.5K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
Namespace: resource.Namespace(deployment.GetNamespace()), Name: resource.LocalName(deployment.GetName()), }, ResourceVersion: resource.Version(deployment.GetResourceVersion()), Ref: nil, FieldsMap: nil, }, } messages.Add(msg.NewUpdateIncompatibility(res, "ENHANCED_RESOURCE_SCOPING", "1.22",
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K bytes - Viewed (0) -
cmd/encryption-v1_test.go
oRef, lRef, skipRef, snRef, psRef := decryptedRangeRef(test.decSizes, skipLen, readLen, false) if o != oRef || l != lRef || skip != skipRef || sn != snRef || ps != psRef { t.Errorf("Case %d: test failed: %d %d %d %d %d (Ref: %d %d %d %d %d)", i, o, l, skip, sn, ps, oRef, lRef, skipRef, snRef, psRef) } } // Read the last 6Mib+1 bytes of the (decrypted) // object //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Sep 24 04:17:08 GMT 2022 - 19.9K bytes - Viewed (0) -
schema/relationship_test.go
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Apr 15 03:20:20 GMT 2024 - 25.5K bytes - Viewed (0) -
internal/s3select/select.go
func (s *ScanRange) Validate() error { if s == nil { return nil } if s.Start == nil && s.End == nil { // This parameter is optional, but when specified, it must not be empty. // Ref: https://docs.aws.amazon.com/AmazonS3/latest/API/API_SelectObjectContent.html#AmazonS3-SelectObjectContent-request-ScanRange return errors.New("ScanRange: No Start or End specified") } if s.Start == nil || s.End == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
internal/rest/client.go
} // Unwrap returns the error wrapped in NetworkError. func (n *NetworkError) Unwrap() error { return n.Err } // 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.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0)