- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 160 for reply (0.18 sec)
-
cmd/notification.go
for index, err := range g.Wait() { if err != nil { sys.addNodeErr(&reply[index], sys.peerClients[index], err) } } return reply } // GetNetInfo - Network information func (sys *NotificationSys) GetNetInfo(ctx context.Context) []madmin.NetInfo { reply := make([]madmin.NetInfo, len(sys.peerClients)) g := errgroup.WithNErrs(len(sys.peerClients)) for index, client := range sys.peerClients { if client == nil {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 44.9K bytes - Viewed (0) -
configure.py
if not question: question = 'Do you wish to build TensorFlow with {} support?'.format( query_item) if not yes_reply: yes_reply = '{} support will be enabled for TensorFlow.'.format(query_item) if not no_reply: no_reply = 'No {}'.format(yes_reply) yes_reply += '\n' no_reply += '\n' if enabled_by_default: question += ' [Y/n]: ' else: question += ' [y/N]: '
Python - Registered: Tue Mar 26 12:39:09 GMT 2024 - Last Modified: Fri Oct 27 17:03:15 GMT 2023 - 51.8K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
func (l *lockServer) Lock(args *LockArgs) (reply bool, err error) { if d := atomic.LoadInt64(&l.responseDelay); d != 0 { time.Sleep(time.Duration(d)) } l.mutex.Lock() defer l.mutex.Unlock() if _, reply = l.lockMap[args.Resources[0]]; !reply { l.lockMap[args.Resources[0]] = WriteLock // No locks held on the given name, so claim write lock }
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Mon Jan 23 16:46:37 GMT 2023 - 8.3K bytes - Viewed (0) -
internal/amztime/iso8601_time.go
"strings" "time" ) // RFC3339 a subset of the ISO8601 timestamp format. e.g 2014-04-29T18:30:38Z const ( iso8601TimeFormat = "2006-01-02T15:04:05.000Z" // Reply date format with millisecond precision. iso8601TimeFormatLong = "2006-01-02T15:04:05.000000Z" // Reply date format with nanosecond precision. ) // ISO8601Format converts time 't' into ISO8601 time format expected in AWS S3 spec. //
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Mon Jan 16 23:38:33 GMT 2023 - 1.9K bytes - Viewed (0) -
cmd/lock-rest-server.go
resp := lockRPCUnlock.NewResponse() _, err := l.ll.Unlock(context.Background(), *args) // Ignore the Unlock() "reply" return value because if err == nil, "reply" is always true // Consequently, if err != nil, reply is always false return l.makeResp(resp, err) } // RLockHandler - Acquires an RLock.
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
cmd/local-locker.go
l.lockMap[resource] = []lockRequesterInfo{lrInfo} l.lockUID[formatUUID(args.UID, 0)] = resource reply = true } return reply, nil } func (l *localLocker) RUnlock(_ context.Context, args dsync.LockArgs) (reply bool, err error) { if len(args.Resources) > 1 { return false, fmt.Errorf("internal error: localLocker.RUnlock called with more than one resource") } l.mutex.Lock()
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 10.6K bytes - Viewed (0) -
.github/actions/people/app/main.py
Python - Registered: Sun Mar 24 07:19:08 GMT 2024 - Last Modified: Sat Mar 16 23:54:24 GMT 2024 - 19.2K bytes - Viewed (1) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/Prompter.java
} /** * Prompts the user for a string using a list of possible values and a default reply. * * @param message the message to display * @param possibleValues the list of possible values * @param defaultReply the default reply value * @return the string entered by the user * @throws PrompterException if an exception occurs */ @Nonnull
Java - Registered: Sun Mar 24 03:35:10 GMT 2024 - Last Modified: Fri Nov 17 15:52:15 GMT 2023 - 3.5K bytes - Viewed (0) -
cmd/lock-rest-client.go
return c.call(ctx, lockRPCRLock, &args) } // Lock calls lock REST API. func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCLock, &args) } // RUnlock calls read unlock REST API. func (c *lockRESTClient) RUnlock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Fri Nov 24 17:07:14 GMT 2023 - 3.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SocksProxy.kt
if (localAddress.size != 4) { throw ProtocolException("unexpected address: " + toSocket.localAddress) } // Write the reply. fromSink.writeByte(VERSION_5) fromSink.writeByte(REPLY_SUCCEEDED) fromSink.writeByte(0) fromSink.writeByte(ADDRESS_TYPE_IPV4) fromSink.write(localAddress) fromSink.writeShort(toSocket.localPort)
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.7K bytes - Viewed (0)