Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for doRecv (0.05 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. src/main/java/jcifs/smb1/smb1/SmbTransport.java

            /* Unless key returned is null or invalid Transport.loop() always
             * calls doRecv() after and no one else but the transport thread
             * should call doRecv(). Therefore it is ok to expect that the data
             * in sbuf will be preserved for copying into BUF in doRecv().
             */
    
            return key;
        }
    
        protected void doSend( Request request ) throws IOException {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 31.2K bytes
    - Viewed (0)
  5. src/main/java/jcifs/util/transport/Transport.java

    
        protected abstract Long peekKey () throws IOException;
    
    
        protected abstract void doSend ( Request request ) throws IOException;
    
    
        protected abstract void doRecv ( Response response ) throws IOException;
    
    
        protected abstract void doSkip ( Long key ) throws IOException;
    
    
        /**
         * 
         * @return whether the transport is disconnected
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 01 18:12:21 UTC 2020
    - 24.1K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbTransportImpl.java

            }
    
            /*
             * Unless key returned is null or invalid Transport.loop() always
             * calls doRecv() after and no one else but the transport thread
             * should call doRecv(). Therefore it is ok to expect that the data
             * in sbuf will be preserved for copying into BUF in doRecv().
             */
    
            return (long) Encdec.dec_uint16le(this.sbuf, 34) & 0xFFFF;
        }
    
    
        @Override
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Wed Jan 18 23:47:00 UTC 2023
    - 67K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. cmd/storage-rest-server.go

    				}
    				return
    			}
    		}
    	}()
    	return func(err error) {
    		if doneCh == nil {
    			return
    		}
    
    		// Indicate we are ready to write.
    		doneCh <- err
    
    		// Wait for channel to be closed so we don't race on writes.
    		<-doneCh
    
    		// Clear so we can be called multiple times without crashing.
    		doneCh = nil
    	}, &closeNotifier{rc: r.Body, done: bodyDoneCh}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
Back to top