send0 - Code Search

internal/grid/benchmark_test.go

							dst = (dst + 1) % len(managers)
						}
						local := managers[src]
						conn := local.Connection(hosts[dst])
						if conn == nil {
							b.Fatal("No connection")
						}
						// Send the payload.
						t := time.Now()
						resp, err := conn.Request(ctx, handlerTest, payload)
						latency += time.Since(t).Nanoseconds()
						if err != nil {
							if debugReqs {
								fmt.Println(err.Error())

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Fri Jun 07 15:51:52 UTC 2024

- 15.7K bytes

- Viewed (0)

github.com/gradle/gradle

.github/workflows/notify-on-rc-for-manual-test.yml

run-name: Notify the IDE Experience team about new RCs for manual testing
on:
  push:
    tags:
      - 'v*.*.*-RC1'

permissions: {}

jobs:
  send-slack-notification:
    runs-on: ubuntu-latest
    steps:
      - name: Send Slack notification about new RCs for manual testing
        id: slack
        uses: slackapi/slack-github-action@v1.23.0
        with:
          payload: |
            {

Registered: Wed Nov 06 11:36:14 UTC 2024

- Last Modified: Thu May 02 09:13:16 UTC 2024

- 1K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/netbios/NameServiceClientImpl.java

        }

        do {
            try {
                send(request, response, config.getNetbiosRetryTimeout());
            }
            catch ( InterruptedIOException ioe ) {
                // second query thread to finish gets interrupted so this is expected
                if ( log.isTraceEnabled() ) {
                    log.trace("Failed to send nameservice request for " + name.name, ioe);
                }

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Sun Aug 14 14:26:22 UTC 2022

- 38.2K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb/SmbSessionImpl.java

    }


    <T extends CommonServerMessageBlockResponse> T send ( CommonServerMessageBlockRequest request, T response ) throws CIFSException {
        return send(request, response, Collections.<RequestParam> emptySet());
    }


    <T extends CommonServerMessageBlockResponse> T send ( CommonServerMessageBlockRequest request, T response, Set<RequestParam> params )
            throws CIFSException {

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Sun Nov 14 17:41:04 UTC 2021

- 49K bytes

- Viewed (0)

github.com/minio/minio

internal/logger/target/console/console.go

func (c *Target) Endpoint() string {
	return ""
}

func (c *Target) String() string {
	return "console"
}

// Send log message 'e' to console
func (c *Target) Send(e interface{}) error {
	entry, ok := e.(log.Entry)
	if !ok {
		return fmt.Errorf("Uexpected log entry structure %#v", e)
	}
	if logger.IsJSON() {
		logJSON, err := json.Marshal(&entry)
		if err != nil {
			return err
		}

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Fri May 24 23:05:23 UTC 2024

- 3.9K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/websockets/tutorial001.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) {

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Thu Mar 26 19:09:53 UTC 2020

- 1.4K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/websockets/tutorial003.py

        <h1>WebSocket Chat</h1>
        <h2>Your ID: <span id="ws-id"></span></h2>
        <form action="" onsubmit="sendMessage(event)">
            <input type="text" id="messageText" autocomplete="off"/>
            <button>Send</button>
        </form>
        <ul id='messages'>
        </ul>
        <script>
            var client_id = Date.now()
            document.querySelector("#ws-id").textContent = client_id;

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Sun Aug 09 13:52:19 UTC 2020

- 2.5K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/en/docs/tutorial/header-param-models.md

///

```Python hl_lines="10"
{!> ../../docs_src/header_param_models/tutorial002.py!}
```

////

If a client tries to send some **extra headers**, they will receive an **error** response.

For example, if the client tries to send a `tool` header with a value of `plumbus`, they will receive an **error** response telling them that the header parameter `tool` is not allowed:

```json
{

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Sun Oct 06 20:36:54 UTC 2024

- 3.5K bytes

- Viewed (0)

github.com/minio/minio

cmd/metacache-walk.go

				}
				if err := send(meta); err != nil {
					return err
				}
			case osIsNotExist(err), isSysErrIsDir(err):
				if legacy {
					meta.metadata, err = xioutil.ReadFile(pathJoinBuf(sb, volumeDir, meta.name, xlStorageFormatFileV1))
					diskHealthCheckOK(ctx, err)
					if err == nil {
						// It was an object
						if err := send(meta); err != nil {
							return err
						}

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Sat Jun 01 05:17:37 UTC 2024

- 12.4K bytes

- Viewed (0)

github.com/minio/minio

internal/store/store.go

	retryTicker := time.NewTicker(retryInterval)
	defer retryTicker.Stop()

	send := func(key Key) bool {
		for {
			err := target.SendFromStore(key)
			if err == nil {
				break
			}

			logger(
				context.Background(),
				fmt.Errorf("unable to send log entry to '%s' err '%w'", target.Name(), err),
				target.Name(),
			)

			select {

Registered: Sun Nov 03 19:28:11 UTC 2024

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

- 4.2K bytes

- Viewed (0)

Search Options