- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 921 for opzione (0.19 sec)
-
src/test/java/jcifs/tests/OplockTests.java
int attrs = 0; int options = 0; String uncPath = "foo-oplock"; SmbComNTCreateAndXResponse resp = new SmbComNTCreateAndXResponse(sess.getConfig()); SmbComNTCreateAndX req = new SmbComNTCreateAndX(sess.getConfig(), uncPath, flags, access, sharing, attrs, options, null); req.addFlags0(0x2); // REQUEST_OPLOCK
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Thu Jan 05 13:09:03 GMT 2023 - 6.1K bytes - Viewed (0) -
common-protos/k8s.io/api/admission/v1beta1/generated.proto
// +optional optional bool dryRun = 11; // Options is the operation option structure of the operation being performed. // e.g. `meta.k8s.io/v1.DeleteOptions` or `meta.k8s.io/v1.CreateOptions`. This may be // different than the options the caller provided. e.g. for a patch request the performed // Operation might be a CREATE, in which case the Options will a
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 8.1K bytes - Viewed (0) -
cmd/etcd.go
etcdLogIf(ctx, err) return etcdErrToErr(err, client.Endpoints()) } func saveKeyEtcd(ctx context.Context, client *etcd.Client, key string, data []byte, opts ...options) error { timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() if len(opts) > 0 { return saveKeyEtcdWithTTL(ctx, client, key, data, opts[0].ttl) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.9K bytes - Viewed (0) -
cmd/os-readdir-common.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 cmd // Options for readDir function call type readDirOpts struct { // The maximum number of entries to return count int // Follow directory symlink followDirSymlink bool } // Return all the entries at the directory dirPath.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jul 09 23:20:51 GMT 2021 - 1.3K bytes - Viewed (0) -
internal/bucket/bandwidth/reader.go
type BucketOptions struct { Name string ReplicationARN string // This is optional, and not mandatory. } // MonitorReaderOptions provides configurable options for monitor reader implementation. type MonitorReaderOptions struct { BucketOptions HeaderSize int } // Read implements a throttled read func (r *MonitoredReader) Read(buf []byte) (n int, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 3.1K bytes - Viewed (0) -
src/main/assemblies/files/fess
#!/bin/sh # OPTIONS: # -d daemonize (run in background) # -p pidfile write PID to <pidfile> # -h # --help print command line options # -v print fess version, then exit # -D prop set JAVA system property # -X prop set non-standard JAVA system property # --prop=val # --prop val set fess property (i.e. -Des.<prop>=<val>) CDPATH="" SCRIPT="$0"
Shell Script - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Sun Jan 15 06:32:15 GMT 2023 - 5.4K bytes - Viewed (0) -
cmd/warm-backend-minio.go
} u, err := url.Parse(conf.Endpoint) if err != nil { return nil, err } creds := credentials.NewStaticV4(conf.AccessKey, conf.SecretKey, "") opts := &minio.Options{ Creds: creds, Secure: u.Scheme == "https", Transport: globalRemoteTargetTransport, TrailingHeaders: true, } client, err := minio.New(u.Host, opts) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.8K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
if !drwm1.GetRLock(ctx1, cancel1, id, source, Options{Timeout: time.Second}) { panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") drwm2 := NewDRWMutex(ds, "simplelock") ctx2, cancel2 := context.WithCancel(context.Background()) if !drwm2.GetRLock(ctx2, cancel2, id, source, Options{Timeout: time.Second}) { panic("Failed to acquire read lock") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 9.7K bytes - Viewed (0) -
internal/http/server.go
type Server struct { http.Server Addrs []string // addresses on which the server listens for new connection. TCPOptions TCPOptions // all the configurable TCP conn specific configurable options. ShutdownTimeout time.Duration // timeout used for graceful server shutdown. listenerMutex sync.Mutex // to guard 'listener' field. listener *httpListener // HTTP listener for all 'Addrs' field.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
cmd/post-policy-fan-out.go
var wg sync.WaitGroup for i, req := range fanOutEntries { wg.Add(1) go func(idx int, req minio.PutObjectFanOutEntry) { defer wg.Done() objInfos[idx] = ObjectInfo{Name: req.Key} hopts := hash.Options{ Size: int64(len(fanOutBuf)), MD5Hex: opts.MD5Hex, SHA256Hex: "", ActualSize: -1, DisableMD5: true, } hr, err := hash.NewReaderWithOpts(ctx, bytes.NewReader(fanOutBuf), hopts)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 3.5K bytes - Viewed (0)