Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 1,043 for channel (0.19 sec)

  1. doc/go1.17_spec.html

    <p>
    A send statement sends a value on a channel.
    The channel expression must be of <a href="#Channel_types">channel type</a>,
    the channel direction must permit send operations,
    and the type of the value to be sent must be <a href="#Assignability">assignable</a>
    to the channel's element type.
    </p>
    
    <pre class="ebnf">
    SendStmt = Channel "&lt;-" Expression .
    Channel  = Expression .
    </pre>
    
    <p>
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 10 18:25:45 UTC 2024
    - 211.6K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/ntlmssp/NtlmFlags.java

        /**
        * Specifies that communication across the authenticated channel
        * should carry a digital signature (message integrity).
        */
        public static final int NTLMSSP_NEGOTIATE_SIGN = 0x00000010;
    
        /**
        * Specifies that communication across the authenticated channel
        * should be encrypted (message confidentiality).
        */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 5.3K bytes
    - Viewed (0)
  3. CONTRIBUTING.md

    Making and Submitting Changes
    --------------
    
    We accept Pull Requests via GitHub. The [developer mailing list][dev-ml-list] is the
    main channel of communication for contributors.  
    There are some guidelines which will make applying PRs easier for us:
    + Create a topic branch from where you want to base your work (this is usually the master branch).
      Push your changes to a topic branch in your fork of the repository.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Sun Oct 10 09:48:27 UTC 2021
    - 4.7K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/core/io/FileUtil.java

            final FileInputStream is = InputStreamUtil.create(file);
            try {
                final FileChannel channel = is.getChannel();
                final ByteBuffer buffer = ByteBuffer.allocate((int) ChannelUtil.size(channel));
                ChannelUtil.read(channel, buffer);
                return buffer.array();
            } finally {
                CloseableUtil.close(is);
            }
        }
    
        /**
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 9K bytes
    - Viewed (0)
  5. cmd/grid.go

    // globalLockGrid is the global lock grid manager.
    var globalLockGrid atomic.Pointer[grid.Manager]
    
    // globalGridStart is a channel that will block startup of grid connections until closed.
    var globalGridStart = make(chan struct{})
    
    // globalLockGridStart is a channel that will block startup of lock grid connections until closed.
    var globalLockGridStart = make(chan struct{})
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  6. cmd/metacache-stream.go

    		if err != nil {
    			return err
    		}
    		if w.reuseBlocks || o.reusable {
    			metaDataPoolPut(o.metadata)
    		}
    	}
    
    	return nil
    }
    
    // stream entries to the output.
    // The returned channel should be closed when done.
    // Any error is reported when closing the metacacheWriter.
    func (w *metacacheWriter) stream() (chan<- metaCacheEntry, error) {
    	if w.creator != nil {
    		err := w.creator()
    		w.creator = nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  7. internal/bpool/bpool_test.go

    	}
    
    	bp.Put(b)
    
    	// Check the size of the pool.
    	if uint64(len(bp.c)) != size {
    		t.Fatalf("bytepool size invalid: got %v want %v", len(bp.c), size)
    	}
    
    	// lets drain the buf channel first before we validate invalid buffers.
    	for i := uint64(0); i < size; i++ {
    		bp.Get() // discard
    	}
    
    	// Try putting some invalid buffers into pool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  8. doc/go_spec.html

    <p>
    A send statement sends a value on a channel.
    The channel expression's <a href="#Core_types">core type</a>
    must be a <a href="#Channel_types">channel</a>,
    the channel direction must permit send operations,
    and the type of the value to be sent must be <a href="#Assignability">assignable</a>
    to the channel's element type.
    </p>
    
    <pre class="ebnf">
    SendStmt = Channel "&lt;-" Expression .
    Channel  = Expression .
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 00:58:01 UTC 2024
    - 282.5K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/io/Smb2WriteRequest.java

        private byte[] data;
        private int dataOffset;
        private int dataLength;
    
        private byte[] fileId;
        private long offset;
        private int channel;
        private int remainingBytes;
        private int writeFlags;
    
    
        /**
         * @param config
         * @param fileId
         */
        public Smb2WriteRequest ( Configuration config, byte[] fileId ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 4.8K bytes
    - Viewed (0)
  10. internal/grid/grid.go

    		return len(p), nil
    	case <-w.ctx.Done():
    		return 0, context.Cause(w.ctx)
    	}
    }
    
    // WriterToChannel will return an io.Writer that writes to the given channel.
    // The context both allows returning errors on writes and to ensure that
    // this isn't abandoned if the channel is no longer being read from.
    func WriterToChannel(ctx context.Context, ch chan<- []byte) io.Writer {
    	return &writerWrapper{ch: ch, ctx: ctx}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
Back to top