- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for deadline (0.16 sec)
-
cmd/callhome.go
} } } func performCallhome(ctx context.Context) { deadline := 10 * time.Second // Default deadline is 10secs for callhome objectAPI := newObjectLayerFn() if objectAPI == nil { internalLogIf(ctx, errors.New("Callhome: object layer not ready")) return } healthCtx, healthCancel := context.WithTimeout(ctx, deadline) defer healthCancel() healthInfoCh := make(chan madmin.HealthInfo)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.1K bytes - Viewed (1) -
internal/config/api/help.go
}, config.HelpKV{ Key: apiRequestsDeadline, Description: `set the deadline for API requests waiting to be processed` + defaultHelpPostfix(apiRequestsDeadline), Optional: true, Type: "duration", }, config.HelpKV{ Key: apiClusterDeadline, Description: `set the deadline for cluster readiness check` + defaultHelpPostfix(apiClusterDeadline), Optional: true,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 15 01:07:19 GMT 2024 - 4.7K bytes - Viewed (0) -
internal/grid/grid.go
// clientPingInterval will ping the remote handler every 15 seconds. // Clients disconnect when we exceed 2 intervals. clientPingInterval = 15 * time.Second // Deadline for single (non-streaming) requests to complete. // Used if no deadline is provided on context. defaultSingleRequestTimeout = time.Minute ) var internalByteBuffer = sync.Pool{ New: func() any { m := make([]byte, 0, defaultBufferSize) return &m
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0) -
common-protos/k8s.io/api/batch/v1beta1/generated.proto
// reason UnknownTimeZone. // More information can be found in https://kubernetes.io/docs/concepts/workloads/controllers/cron-jobs/#time-zones // +optional optional string timeZone = 8; // Optional deadline in seconds for starting the job if it misses scheduled // time for any reason. Missed jobs executions will be counted as failed ones. // +optional optional int64 startingDeadlineSeconds = 2;
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 5.7K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/ReaderUtil.java
* @return 一行の文字列。終端に達した場合は{@literal null} * @see BufferedReader#readLine() */ public static String readLine(final BufferedReader reader) { assertArgumentNotNull("reader", reader); try { return reader.readLine(); } catch (final IOException e) { throw new IORuntimeException(e); } } /**
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 4.5K bytes - Viewed (0) -
internal/grid/muxserver.go
} func newMuxStateless(ctx context.Context, msg message, c *Connection, handler StatelessHandler) *muxServer { var cancel context.CancelFunc ctx = setCaller(ctx, c.remote) if msg.DeadlineMS > 0 { ctx, cancel = context.WithTimeout(ctx, time.Duration(msg.DeadlineMS)*time.Millisecond) } else { ctx, cancel = context.WithCancel(ctx) } m := muxServer{ ID: msg.MuxID, RecvSeq: msg.Seq + 1, SendSeq: msg.Seq,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
common/scripts/setup_env.sh
if [[ ${TARGET_OS} ]]; then # Target explicitly set : elif [[ $LOCAL_OS == Linux ]]; then TARGET_OS=linux readlink_flags="-f" elif [[ $LOCAL_OS == Darwin ]]; then TARGET_OS=darwin readlink_flags="" else echo "This system's OS, $LOCAL_OS, isn't supported" exit 1 fi # Build image to use TOOLS_REGISTRY_PROVIDER=${TOOLS_REGISTRY_PROVIDER:-gcr.io}
Shell Script - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 16:31:40 GMT 2024 - 7.6K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/LineIterator.java
assertArgumentNotNull("reader", reader); this.reader = reader; } @Override public boolean hasNext() { if (line == EMPTY) { line = ReaderUtil.readLine(reader); } return line != null; } @Override public String next() { if (!hasNext()) { throw new NoSuchElementException(); }
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 3.8K bytes - Viewed (0) -
doc/next/6-stdlib/99-minor/os/63703.md
On Windows, [Readlink] no longer tries to normalize volumes to drive letters, which was not always even possible. This behavior is controlled by the `winreadlinkvolume` setting. For Go 1.23, it defaults to `winreadlinkvolume=1`.
Plain Text - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Fri Apr 12 20:57:18 GMT 2024 - 280 bytes - Viewed (0) -
internal/disk/stat_linux.go
// Check if there is a parent device: // e.g. if the mount is based on /dev/nvme0n1p1, let's calculate the // real device name (nvme0n1) to get its sysfs information parentDevPath, e := os.Readlink("/sys/class/block/" + devName) if e == nil { parentDev := filepath.Base(filepath.Dir(parentDevPath)) qst, err = bfs.SysBlockDeviceQueueStats(parentDev) } } if err == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 4.8K bytes - Viewed (0)