send - Code Search

cmd/listen-notification-handlers.go

	// Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers.
	// Use buffered channel to take care of burst sends or slow w.Write()
	mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames()))
	localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())

	// Convert local messages to JSON and send to mergeCh
	go func() {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Tue Feb 18 16:25:55 GMT 2025

- 6K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/SmbTransport.java

             */
            out.write(BUF, 0, 4 + n);
        }
    }

    /**
     * Internal method to send a request to the server.
     *
     * @param request the request to send
     * @throws IOException if an I/O error occurs
     */
    protected void doSend0(final Request request) throws IOException {
        try {
            doSend(request);

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sat Aug 16 01:32:48 GMT 2025

- 31.8K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/SmbTree.java

    @Override
    public boolean equals(final Object obj) {
        if (obj instanceof final SmbTree tree) {
            return matches(tree.share, tree.service);
        }
        return false;
    }

    void send(final ServerMessageBlock request, final ServerMessageBlock response) throws SmbException {
        synchronized (session.transport()) {
            if (response != null) {
                response.received = false;
            }

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Thu Aug 14 07:14:38 GMT 2025

- 8.1K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/websockets_/tutorial001_py310.py

    </head>
    <body>
        <h1>WebSocket Chat</h1>
        <form action="" onsubmit="sendMessage(event)">
            <input type="text" id="messageText" autocomplete="off"/>
            <button>Send</button>
        </form>
        <ul id='messages'>
        </ul>
        <script>
            var ws = new WebSocket("ws://localhost:8000/ws");
            ws.onmessage = function(event) {

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Fri Feb 27 12:34:37 GMT 2026

- 1.4K bytes

- Click Count (0)

github.com/minio/minio

internal/event/target/webhook.go

		return err
	}
	if err := target.init(); err != nil {
		return err
	}
	err := target.send(eventData)
	if err != nil {
		if xnet.IsNetworkOrHostDown(err, false) {
			return store.ErrNotConnected
		}
	}
	return err
}

// send - sends an event to the webhook.
func (target *WebhookTarget) send(eventData event.Event) error {
	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
	if err != nil {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Sep 06 23:06:30 GMT 2024

- 8.8K bytes

- Click Count (0)

github.com/minio/minio

internal/logger/target/loggertypes/types.go

type TargetStats struct {
	// QueueLength is the queue length if any messages are queued.
	QueueLength int

	// TotalMessages is the total number of messages sent in the lifetime of the target
	TotalMessages int64

	// FailedMessages should log message count that failed to send.
	FailedMessages int64

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Jul 18 21:56:31 GMT 2025

- 1.4K bytes

- Click Count (0)

github.com/golang/go

doc/go_mem.html

<h3 id="chan">Channel communication</h3>

<p>
Channel communication is the main method of synchronization
between goroutines.  Each send on a particular channel
is matched to a corresponding receive from that channel,
usually in a different goroutine.
</p>

<p class="rule">
A send on a channel is synchronized before the completion of the
corresponding receive from that channel.
</p>

<p>
This program:
</p>

Created: Tue Apr 07 11:13:11 GMT 2026

- Last Modified: Tue Aug 05 15:41:37 GMT 2025

- 26.6K bytes

- Click Count (0)

github.com/minio/minio

internal/config/lambda/target/webhook.go

		TotalRequests:  atomic.LoadInt64(&target.totalRequests),
		FailedRequests: atomic.LoadInt64(&target.failedRequests),
	}
}

// Send - sends an event to the webhook.
func (target *WebhookTarget) Send(eventData event.Event) (resp *http.Response, err error) {
	atomic.AddInt64(&target.activeRequests, 1)
	defer atomic.AddInt64(&target.activeRequests, -1)

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Mon Jul 08 21:39:49 GMT 2024

- 6.7K bytes

- Click Count (0)

github.com/elastic/elasticsearch

.github/ISSUE_TEMPLATE/bug.md

check your OS is [supported](https://www.elastic.co/support/matrix#show_os).
If it is not, the issue is likely to be closed.

For security vulnerabilities please only send reports to ******@****.***.
See https://www.elastic.co/community/security for more information.

Please fill in the following details to help us reproduce the bug:
-->

Created: Wed Apr 08 16:19:15 GMT 2026

- Last Modified: Thu May 07 00:50:18 GMT 2020

- 1.3K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/smb/SmbRandomAccessFileTest.java

        SmbTreeHandleImpl tree = fh.getTree();
        when(tree.send(any(Trans2SetFileInformation.class), any(Trans2SetFileInformationResponse.class), any(RequestParam.class)))
                .thenReturn(null);

        raf.setLength(200L);

        verify(tree, times(1)).send(any(Trans2SetFileInformation.class), any(Trans2SetFileInformationResponse.class),
                eq(RequestParam.NO_RETRY));
    }

    @Test

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Thu Aug 14 05:31:44 GMT 2025

- 18.1K bytes

- Click Count (0)

Search Options