Search Options

Results per page
Sort
Preferred Languages
Advance

Results 441 - 450 of 737 for chosen (0.04 sec)

  1. istioctl/pkg/proxystatus/proxystatus.go

    	file := os.Stdin
    	if filename != "-" {
    		var err error
    		file, err = os.Open(filename)
    		if err != nil {
    			return nil, err
    		}
    	}
    	defer func() {
    		if err := file.Close(); err != nil {
    			log.Errorf("failed to close %s: %s", filename, err)
    		}
    	}()
    	data, err := io.ReadAll(file)
    	if err != nil {
    		return nil, err
    	}
    	return data, nil
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/SmbFileOutputStream.java

        }
    
    
        /**
         * Closes this output stream and releases any system resources associated
         * with it.
         *
         * @throws IOException
         *             if a network error occurs
         */
    
        @Override
        public void close () throws IOException {
            try {
                if ( this.handle.isValid() ) {
                    this.handle.close();
                }
            }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sat Nov 13 15:14:04 UTC 2021
    - 11.9K bytes
    - Viewed (0)
  3. docs/ja/docs/help-fastapi.md

    「Releases only」ではなく「Watching」を選択すると、新たなissueが立てられた際に通知されます。
    
    そして、issueを解決し他の人を助けることができます。
    
    ## issuesを立てる
    
    GitHubレポジトリで<a href="https://github.com/fastapi/fastapi/issues/new/choose" class="external-link" target="_blank">新たなissueを立てられます</a>。例えば:
    
    * 質問、または、問題の報告
    * 新機能の提案
    
    **Note**: issueを立てた人は、他の人の手助けもお願いします。😉
    
    ## プルリクエストをする
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Jul 29 23:35:07 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  4. internal/s3select/csv/reader.go

    	dstRec.nameIndexMap = r.nameIndexMap
    
    	return dstRec, nil
    }
    
    // Close - closes underlying reader.
    func (r *Reader) Close() error {
    	if r.close != nil {
    		close(r.close)
    		r.readerWg.Wait()
    		r.close = nil
    	}
    	r.recordsRead = len(r.current)
    	if r.err == nil {
    		r.err = io.EOF
    	}
    	return r.readCloser.Close()
    }
    
    // nextSplit will attempt to skip a number of bytes and
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  5. internal/event/target/amqp.go

    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Close - does nothing and available for interface compatibility.
    func (target *AMQPTarget) Close() error {
    	close(target.quitCh)
    	if target.conn != nil {
    		return target.conn.Close()
    	}
    	return nil
    }
    
    func (target *AMQPTarget) init() error {
    	return target.initOnce.Do(target.initAMQP)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. internal/event/targetlist.go

    	Err error
    }
    
    // Remove - closes and removes targets by given target IDs.
    func (list *TargetList) Remove(targetIDSet TargetIDSet) {
    	list.Lock()
    	defer list.Unlock()
    
    	for id := range targetIDSet {
    		target, ok := list.targets[id]
    		if ok {
    			target.Close()
    			delete(list.targets, id)
    		}
    	}
    }
    
    // Targets - list all targets
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool.go

    	total := serverPools.TotalAvailable()
    	if total == 0 {
    		return -1
    	}
    	// choose when we reach this many
    	choose := rand.Uint64() % total
    	atTotal := uint64(0)
    	for _, pool := range serverPools {
    		atTotal += pool.Available
    		if atTotal > choose && pool.Available > 0 {
    			return pool.Index
    		}
    	}
    	// Should not happen, but print values just in case.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/dcerpc/msrpc/LsaPolicyHandle.java

            MsrpcLsarOpenPolicy2 rpc = new MsrpcLsarOpenPolicy2(server, access, this);
            handle.sendrecv(rpc);
            if (rpc.retval != 0)
                throw new SmbException(rpc.retval, false);
        }
    
        public void close() throws IOException {
            MsrpcLsarClose rpc = new MsrpcLsarClose(this);
            handle.sendrecv(rpc);
            if (rpc.retval != 0)
                throw new SmbException(rpc.retval, false);
        }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 1.7K bytes
    - Viewed (0)
  9. build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/BinaryCompatibilityRepositoryLifecycle.kt

            val userData = context.userData as MutableMap<String, Any?>
            val key = BinaryCompatibilityRepositorySetupRule.REPOSITORY_CONTEXT_KEY
            (userData[key] as BinaryCompatibilityRepository).close()
            userData[key] = null
        }
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 2.2K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/RegularImmutableMap.java

      @SuppressWarnings("unchecked")
      static final ImmutableMap<Object, Object> EMPTY =
          new RegularImmutableMap<>((Entry<Object, Object>[]) ImmutableMap.EMPTY_ENTRY_ARRAY, null, 0);
    
      /**
       * Closed addressing tends to perform well even with high load factors. Being conservative here
       * ensures that the table is still likely to be relatively sparse (hence it misses fast) while
       * saving space.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 28 18:11:09 UTC 2024
    - 16.2K bytes
    - Viewed (0)
Back to top