- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for doRecv (0.09 sec)
-
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) -
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) -
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) -
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) -
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) -
internal/pubsub/pubsub.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Feb 06 16:57:30 UTC 2024 - 5.2K bytes - Viewed (0) -
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) -
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) -
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)