Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1041 - 1050 of 1,178 for rsync (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top