Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for doRecv (0.09 sec)

  1. src/main/java/jcifs/smb1/util/transport/Transport.java

        protected abstract Request peekKey() throws IOException;
        protected abstract void doSend( Request request ) throws IOException;
        protected abstract void doRecv( Response response ) throws IOException;
        protected abstract void doSkip() throws IOException;
    
        public synchronized void sendrecv( Request request,
                        Response response,
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 9K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/smb1/com/SmbComReadAndXResponse.java

            return bufferIndex - start;
        }
    
    
        @Override
        protected int readBytesWireFormat ( byte[] buffer, int bufferIndex ) {
            // handled special in SmbTransport.doRecv()
            return 0;
        }
    
    
        @Override
        public String toString () {
            return new String(
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 3.4K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/smb1/SmbComReadAndXResponse.java

            bufferIndex += 12; // 10 reserved
    
            return bufferIndex - start;
        }
        int readBytesWireFormat( byte[] buffer, int bufferIndex ) {
            // handled special in SmbTransport.doRecv()
            return 0;
        }
        public String toString() {
            return new String( "SmbComReadAndXResponse[" +
                super.toString() +
                ",dataCompactionMode=" + dataCompactionMode +
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 2.2K bytes
    - Viewed (0)
  4. internal/pubsub/pubsub_test.go

    	ch2 := make(chan Maskable, 1)
    	ch3 := make(chan Maskable, 1)
    	doneCh := make(chan struct{})
    	defer close(doneCh)
    	if err := ps.Subscribe(MaskAll, ch1, doneCh, nil); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	if err := ps.Subscribe(MaskAll, ch2, doneCh, nil); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	if err := ps.Subscribe(MaskAll, ch3, doneCh, nil); err == nil {
    		t.Fatalf("unexpected nil err")
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  5. internal/store/store.go

    func StreamItems[I any](store Store[I], target Target, doneCh <-chan struct{}, logger logger) {
    	go func() {
    		keyCh := replayItems(store, doneCh, logger, target.Name())
    		sendItems(target, keyCh, doneCh, logger)
    	}()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  6. internal/pubsub/pubsub.go

    		enc := json.NewEncoder(&buf)
    		for {
    			select {
    			case <-doneCh:
    				return
    			case v, ok := <-subChT:
    				if !ok {
    					return
    				}
    				buf.Reset()
    				err := enc.Encode(v)
    				if err != nil {
    					return
    				}
    
    				select {
    				case subCh <- append(GetByteBuffer()[:0], buf.Bytes()...):
    					continue
    				case <-doneCh:
    					return
    				}
    			}
    		}
    	}()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  7. internal/grid/stream.go

    		}
    
    		if !done {
    			// Drain channel.
    			for range s.responses {
    			}
    		}
    	}()
    	doneCh := s.ctx.Done()
    	for {
    		select {
    		case <-doneCh:
    			if err := context.Cause(s.ctx); !errors.Is(err, errStreamEOF) {
    				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
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  8. cmd/consolelogger.go

    			entry := lastN[(cnt+i)%last]
    			if (entry == log.Info{}) {
    				continue
    			}
    			select {
    			case subCh <- entry:
    			case <-doneCh:
    				return nil
    			}
    		}
    	}
    	return sys.pubsub.Subscribe(madmin.LogMaskAll, subCh, doneCh, filter)
    }
    
    // Init if HTTPConsoleLoggerSys is valid, always returns nil right now
    func (sys *HTTPConsoleLoggerSys) Init(_ context.Context) error {
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. internal/http/listener.go

    func (listener *httpListener) start() {
    	// Closure to send acceptResult to acceptCh.
    	// It returns true if the result is sent else false if returns when doneCh is closed.
    	send := func(result acceptResult) bool {
    		select {
    		case listener.acceptCh <- result:
    			// Successfully written to acceptCh
    			return true
    		case <-listener.ctx.Done():
    			return false
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
Back to top