- Sort Score
- Result 10 results
- Languages All
Results 1041 - 1050 of 1,178 for rsync (0.04 sec)
-
guava/src/com/google/common/util/concurrent/FluentFuture.java
* AsyncFunction.apply}. Any heavyweight operations should occur in other threads responsible for * completing the returned {@code Future}.) * * <p>The returned {@code Future} attempts to keep its cancellation state in sync with that of the * input future and that of the future returned by the chain function. That is, if the returned * {@code Future} is cancelled, it will attempt to cancel the other two, and if either of the
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 19.6K bytes - Viewed (0) -
internal/logger/logrotate.go
wc = gzip.NewWriter(gw) if _, err = io.Copy(wc, r); err != nil { return err } if err = wc.Close(); err != nil { return err } // Persist to disk any caches. if err = gw.Sync(); err != nil { return err } // close everything before we delete. if err = gw.Close(); err != nil { return err } if err = r.Close(); err != nil { return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.8K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ReaderInputStream.java
* which is necessarily blocking. By implementing an {@code InputStream} it allows consumers to * "pull" as much data as they can handle, which is more convenient when dealing with flow * controlled, async APIs. * * @author Chris Nokleberg */ @J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault final class ReaderInputStream extends InputStream { private final Reader reader;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 9.3K bytes - Viewed (0) -
guava/src/com/google/common/io/ReaderInputStream.java
* which is necessarily blocking. By implementing an {@code InputStream} it allows consumers to * "pull" as much data as they can handle, which is more convenient when dealing with flow * controlled, async APIs. * * @author Chris Nokleberg */ @J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault final class ReaderInputStream extends InputStream { private final Reader reader;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 9.3K bytes - Viewed (0) -
api/go1.21.txt
pkg slices, func SortStableFunc[$0 interface{ ~[]$1 }, $1 interface{}]($0, func($1, $1) int) #60091 pkg strings, func ContainsFunc(string, func(int32) bool) bool #54386 pkg sync, func OnceFunc(func()) func() #56102 pkg sync, func OnceValue[$0 interface{}](func() $0) func() $0 #56102 pkg sync, func OnceValues[$0 interface{}, $1 interface{}](func() ($0, $1)) func() ($0, $1) #56102 pkg syscall (freebsd-386-cgo), type SysProcAttr struct, Jail int #46259
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Aug 07 09:39:17 UTC 2023 - 25.6K bytes - Viewed (0) -
cmd/erasure-multipart.go
var wg sync.WaitGroup for _, disk := range er.getLocalDisks() { if disk != nil { wg.Add(1) go func(disk StorageAPI) { defer wg.Done() er.cleanupStaleUploadsOnDisk(ctx, disk) }(disk) } } wg.Wait() } func (er erasureObjects) deleteAll(ctx context.Context, bucket, prefix string) { var wg sync.WaitGroup for _, disk := range er.getDisks() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 44.7K bytes - Viewed (0) -
cmd/admin-handlers.go
z, ok := objectAPI.(*erasureServerPools) if !ok { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL) return } vars := mux.Vars(r) var args dsync.LockArgs var lockers []dsync.NetLocker for _, path := range strings.Split(vars["paths"], ",") { if path == "" { continue } args.Resources = append(args.Resources, path) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 99.7K bytes - Viewed (0) -
docs/zh/docs/advanced/custom-response.md
包括许多与云存储,视频处理等交互的库。 ```Python hl_lines="2 10-12 14" {!../../docs_src/custom_response/tutorial008.py!} ``` /// tip | "小贴士" 注意在这里,因为我们使用的是不支持 `async` 和 `await` 的标准 `open()`,我们使用普通的 `def` 声明了路径操作。 /// ### `FileResponse` 异步传输文件作为响应。 与其他响应类型相比,接受不同的参数集进行实例化: * `path` - 要流式传输的文件的文件路径。 * `headers` - 任何自定义响应头,传入字典类型。
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 7.7K bytes - Viewed (0) -
src/cmd/asm/internal/asm/testdata/ppc64.s
STHCCC R3, (R4) // 7c6025ad STSW R3, (R4)(R5) // 7c65252a STSW R3, (R4)(R0) // 7c60252a STSW R3, (R4) // 7c60252a SYNC // 7c0004ac ISYNC // 4c00012c LWSYNC // 7c2004ac EIEIO // 7c0006ac PTESYNC // 7c4004ac
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Oct 29 13:14:38 UTC 2024 - 51K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
// See the License for the specific language governing permissions and // limitations under the License. package nodeagent import ( "context" "fmt" "net" "os" "sync/atomic" "testing" "time" "golang.org/x/sys/unix" "google.golang.org/protobuf/proto" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types"
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 8.6K bytes - Viewed (0)