Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 375 for jstream (0.14 sec)

  1. internal/grid/stream.go

    	// If the request context is canceled, the stream will no longer process requests.
    	// Requests sent cannot be used any further by the called.
    	Requests chan<- []byte
    
    	muxID uint64
    	ctx   context.Context
    }
    
    // Send a payload to the remote server.
    func (s *Stream) Send(b []byte) error {
    	if s.Requests == nil {
    		return errors.New("stream does not accept requests")
    	}
    	select {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  2. docs/debugging/inspect/decrypt-v2.go

    				}
    				if err := stream.Skip(); err != nil {
    					return fmt.Errorf("stream skip: %w", err)
    				}
    				continue
    			}
    			if extracted {
    				return keepFileErr{fmt.Errorf("next stream: %w", err)}
    			}
    			return fmt.Errorf("next stream: %w", err)
    		}
    		if stream.Name == "inspect.zip" {
    			if extracted {
    				return keepFileErr{errors.New("multiple inspect.zip streams found")}
    			}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 11 21:22:47 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/sso/aad/AzureAdAuthenticator.java

            final Pair<String[], String[]> groupsAndRoles = getParentGroup(user, id);
            StreamUtil.stream(groupsAndRoles.getFirst()).of(stream -> stream.forEach(groupList::add));
            StreamUtil.stream(groupsAndRoles.getSecond()).of(stream -> stream.forEach(roleList::add));
        }
    
        protected Pair<String[], String[]> getParentGroup(final AzureAdUser user, final String id) {
            try {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 28.2K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java

        @Execute
        @Secured({ ROLE, ROLE + VIEW })
        public ActionResponse download(final String id) {
            if (stream(fessConfig.getIndexBackupAllTargets()).get(stream -> stream.anyMatch(s -> s.equals(id)))) {
                if ("system.properties".equals(id)) {
                    return asStream(id).contentTypeOctetStream().stream(out -> {
                        try (final ByteArrayOutputStream baos = new ByteArrayOutputStream()) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Sat Oct 12 01:54:46 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  5. internal/grid/connection.go

    }
    
    // NewStream creates a new stream.
    // Initial payload can be reused by the caller.
    func (c *Connection) NewStream(ctx context.Context, h HandlerID, payload []byte) (st *Stream, err error) {
    	if !h.valid() {
    		return nil, ErrUnknownHandler
    	}
    	if c.State() != StateConnected {
    		return nil, ErrDisconnected
    	}
    	handler := c.handlers.streams[h]
    	if handler == nil {
    		return nil, ErrUnknownHandler
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/web/api/admin/backup/ApiAdminBackupAction.java

            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            if (stream(fessConfig.getIndexBackupAllTargets()).get(stream -> stream.anyMatch(s -> s.equals(id)))) {
                if ("system.properties".equals(id)) {
                    return asStream(id).contentTypeOctetStream().stream(out -> {
                        try (final ByteArrayOutputStream baos = new ByteArrayOutputStream()) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Sat Oct 12 01:54:15 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/web/admin/log/AdminLogAction.java

            final String logFilePath = systemHelper.getLogFilePath();
            if (StringUtil.isNotBlank(logFilePath)) {
                final Path logDirPath = Paths.get(logFilePath);
                try (Stream<Path> stream = Files.list(logDirPath)) {
                    stream.filter(entry -> isLogFilename(entry.getFileName().toString())).sorted().forEach(filePath -> {
                        final Map<String, Object> map = new HashMap<>();
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  8. cmd/testdata/xl-meta-consist.zip

    '’žÉ§MetaSys ¼X-Minio-Internal-actual-sizeÄ 141250§MetaUsr‚¬content-type¸application/octet-stream¤etagÙ"51fe09d68bacc8c5a68a-1Îøù{~ 2/xl.meta XL2 Æ b ¨Versions‘‚¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ ÔLã°ê8EÒŸˆ”Ù Sé6¦EcAlgo £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDistš ¨CSumAlgo ¨PartNums‘ ©PartETags‘ ©PartSizes‘Ò 'ªPartASizes‘Ò '¤SizeÒ 'Â¥MTimeÓ ¿W '’žÉ§MetaSys ¼X-Minio-Internal-actual-sizeÄ 141250§MetaUsr‚¬content-type¸application/octet-stream¤etagÙ"51fe09d68bacc8c5a68a-1Îe 00 3/xl.meta XL2 Æ b ¨Versions‘‚¤Type ¥V2ObjÞ ¢IDÄ...
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jan 19 18:48:00 UTC 2022
    - 4.1K bytes
    - Viewed (0)
  9. internal/grid/handlers.go

    			for req := range reqT {
    				b, err := req.MarshalMsg(GetByteBufferCap(req.Msgsize()))
    				if err != nil {
    					gridLogOnceIf(ctx, err, err.Error())
    				}
    				h.PutRequest(req)
    				stream.Requests <- b
    			}
    		}()
    	} else if stream.Requests != nil {
    		xioutil.SafeClose(stream.Requests)
    	}
    
    	return &TypedStream[Req, Resp]{responses: stream, newResp: h.NewResponse, Requests: reqT}, nil
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  10. .github/workflows/mint/nginx-4-node.conf

        sendfile        on;
        keepalive_timeout  65;
    
        # include /etc/nginx/conf.d/*.conf;
    
        upstream minio {
            server minio1:9000 max_fails=1 fail_timeout=10s;
            server minio2:9000 max_fails=1 fail_timeout=10s;
            server minio3:9000 max_fails=1 fail_timeout=10s;
        }
    
        upstream console {
            ip_hash;
            server minio1:9001;
            server minio2:9001;
            server minio3:9001;
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 16:52:29 UTC 2024
    - 3.1K bytes
    - Viewed (0)
Back to top