Search Options

Results per page
Sort
Preferred Languages
Advance

Results 631 - 640 of 6,918 for RETURN (0.06 sec)

  1. internal/grid/stream.go

    				return err
    			}
    			// Fall through to be sure we have returned all responses.
    			doneCh = nil
    		case resp, ok := <-s.responses:
    			if !ok {
    				done = true
    				return nil
    			}
    			if resp.Err != nil {
    				s.cancel(resp.Err)
    				return resp.Err
    			}
    			err = next(resp.Msg)
    			if err != nil {
    				s.cancel(err)
    				return err
    			}
    		}
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/SmbPipeInputStream.java

            return this.handle.ensureTreeConnected();
        }
    
    
        @Override
        protected synchronized SmbFileHandleImpl ensureOpen () throws CIFSException {
            return this.handle.ensureOpen();
        }
    
    
        /**
         * This stream class is unbuffered. Therefore this method will always
         * return 0 for streams connected to regular files. However, a
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 05 07:12:23 UTC 2018
    - 3.5K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/util/UpgradeUtil.java

                        logger.info("Register {} to {}", path, indexName);
                        return true;
                    }
                    logger.warn("Invalid request for {}", path);
                }
            } catch (final Exception e) {
                logger.warn("Failed to register {}", filePath, e);
            }
            return false;
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  4. compat/maven-compat/src/test/java/org/apache/maven/artifact/AbstractArtifactComponentTestCase.java

            File f = new File(getBasedir(), path);
    
            f.createNewFile();
    
            return artifactRepositoryFactory.createArtifactRepository(
                    "test", "file://" + f.getPath(), repoLayout, null, null);
        }
    
        protected String getRepositoryLayout() {
            return "default";
        }
    
        protected ArtifactRepository localRepository() throws Exception {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  5. internal/grid/README.md

        stream, err := conn.NewStream(ctx, grid.HandlerDiskInfo, payload)
    	if err != nil {
            return err
        }
        // Read results from the stream
        err = stream.Results(func(result []byte) error {
            fmt.Println("Got result", string(result))
    
            // Return the response for reuse
            grid.PutByteBuffer(result)
            return nil
        })
    ```
    
    Context cancellation and timeouts are propagated to the handler. 
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  6. cmd/config-migrate.go

    			if errors.Is(err, errConfigNotFound) {
    				return newServerCfg()
    			}
    			return nil, err
    		}
    
    		data, err = decryptData(data, configFile)
    		if err != nil {
    			return nil, err
    		}
    
    		newCfg, err := readServerConfig(GlobalContext, objAPI, data)
    		if err == nil {
    			return newCfg, nil
    		}
    
    		// Read older `.minio.sys/config/config.json`, if not
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/FuturesGetChecked.java

        return GetCheckedTypeValidatorHolder.BEST_VALIDATOR;
      }
    
      @VisibleForTesting
      static GetCheckedTypeValidator weakSetValidator() {
        return GetCheckedTypeValidatorHolder.WeakSetValidator.INSTANCE;
      }
    
      @J2ObjCIncompatible // ClassValue
      @VisibleForTesting
      static GetCheckedTypeValidator classValueValidator() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 17:40:56 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/sso/SsoAction.java

                    saveError(messages -> messages.addErrorsSsoLoginError(GLOBAL));
                }
                return redirect(LoginAction.class);
            }
            if (loginCredential instanceof ActionResponseCredential) {
                return ((ActionResponseCredential) loginCredential).execute();
            }
            try {
                return fessLoginAssist.loginRedirect(loginCredential, op -> {}, () -> {
                    activityHelper.login(getUserBean());
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/es/config/exentity/CrawlingInfoParam.java

        private OptionalEntity<CrawlingInfo> crawlingInfo;
    
        public String getId() {
            return asDocMeta().id();
        }
    
        public void setId(final String id) {
            asDocMeta().id(id);
        }
    
        public Long getVersionNo() {
            return asDocMeta().version();
        }
    
        public void setVersionNo(final Long version) {
            asDocMeta().version(version);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  10. docs_src/sql_databases_peewee/sql_app/main.py

        if db_user:
            raise HTTPException(status_code=400, detail="Email already registered")
        return crud.create_user(user=user)
    
    
    @app.get("/users/", response_model=List[schemas.User], dependencies=[Depends(get_db)])
    def read_users(skip: int = 0, limit: int = 100):
        users = crud.get_users(skip=skip, limit=limit)
        return users
    
    
    @app.get(
        "/users/{user_id}", response_model=schemas.User, dependencies=[Depends(get_db)]
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Mar 26 19:09:53 UTC 2020
    - 2.2K bytes
    - Viewed (0)
Back to top