Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 853 for handle_ (0.05 sec)

  1. cmd/sftp-server-driver.go

    	}
    }
    
    // NewSFTPDriver initializes sftp.Handlers implementation of following interfaces
    //
    // - sftp.Fileread
    // - sftp.Filewrite
    // - sftp.Filelist
    // - sftp.Filecmd
    func NewSFTPDriver(perms *ssh.Permissions) sftp.Handlers {
    	handler := &sftpDriver{endpoint: fmt.Sprintf("127.0.0.1:%s", globalMinioPort), permissions: perms}
    	return sftp.Handlers{
    		FileGet:  handler,
    		FilePut:  handler,
    		FileCmd:  handler,
    		FileList: handler,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  2. internal/grid/types.go

    	"sort"
    	"strings"
    	"sync"
    
    	"github.com/tinylib/msgp/msgp"
    )
    
    // Recycler will override the internal reuse in typed handlers.
    // When this is supported, the handler will not do internal pooling of objects,
    // call Recycle() when the object is no longer needed.
    // The recycler should handle nil pointers.
    type Recycler interface {
    	Recycle()
    }
    
    // MSS is a map[string]string that can be serialized.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  3. tensorflow/c/eager/immediate_execution_tensor_handle.h

      // Returns a tensor for the handle. If tensor is remote, it will be copied.
      virtual AbstractTensorInterface* Resolve(absl::Status* status) = 0;
    
      std::string DebugString() const override;
    
      // Returns a Boolean hint indicating whether callers should prefer
      // `SummarizeValue` to resolving this handle and formatting the tensor.
      //
      // For example some tensor handles may represent distributed values, in which
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    // Usage hint: Should be used at the end of the API end points tests (ex: check the last few lines of `testAPIListObjectPartsHandler`),
    // need a sample HTTP request to be sent as argument so that the relevant handler is called, the handler registration is expected
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractBehavior.java

                    docMeta.primaryTerm(hit.getPrimaryTerm());
                    handler.handle(entity);
                });
    
                return !handler.isBreakCursor();
            });
        }
    
        protected <RESULT extends ENTITY> void delegateSelectBulk(final ConditionBean cb, final EntityRowHandler<List<RESULT>> handler,
                final Class<? extends RESULT> entityType) {
            assertCBStateValid(cb);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/es/config/allcommon/EsAbstractBehavior.java

                    docMeta.primaryTerm(hit.getPrimaryTerm());
                    handler.handle(entity);
                });
    
                return !handler.isBreakCursor();
            });
        }
    
        protected <RESULT extends ENTITY> void delegateSelectBulk(final ConditionBean cb, final EntityRowHandler<List<RESULT>> handler,
                final Class<? extends RESULT> entityType) {
            assertCBStateValid(cb);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  7. cmd/server-main.go

    			logger.Fatal(err, "invalid --logrorate-dir option")
    		}
    	})
    
    	// Always load ENV variables from files first.
    	loadEnvVarsFromFiles()
    
    	// Handle early server environment vars
    	serverHandleEarlyEnvVars()
    
    	// Handle all server command args and build the disks layout
    	bootstrapTrace("serverHandleCmdArgs", func() {
    		err := buildServerCtxt(ctx, &globalServerCtxt)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (2)
  8. impl/maven-core/src/main/java/org/apache/maven/RepositoryUtils.java

        }
    
        public static ArtifactType newArtifactType(String id, ArtifactHandler handler) {
            return new DefaultArtifactType(
                    id,
                    handler.getExtension(),
                    handler.getClassifier(),
                    handler.getLanguage(),
                    handler.isAddedToClasspath(),
                    handler.isIncludesDependencies());
        }
    
        public static Dependency toDependency(
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 16K bytes
    - Viewed (0)
  9. internal/grid/benchmark_test.go

    	errFatal(err)
    	b.Cleanup(grid.Cleanup)
    	const responses = 10
    	// Create n managers.
    	for _, remote := range grid.Managers {
    		// Register a single handler which echos the payload.
    		errFatal(remote.RegisterStreamingHandler(handlerTest, StreamHandler{
    			// Send 10x response.
    			Handle: func(ctx context.Context, payload []byte, _ <-chan []byte, out chan<- []byte) *RemoteErr {
    				for i := 0; i < responses; i++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  10. cmd/http-tracer.go

    	op = strings.Replace(op, "-fm", "", 1)
    	return op
    }
    
    // If trace is enabled, execute the request if it is traced by other handlers
    // otherwise, generate a trace event with request information but no response.
    func httpTracerMiddleware(h http.Handler) http.Handler {
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		// Setup a http request response recorder - this is needed for
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 6K bytes
    - Viewed (0)
Back to top