Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 35 for Abort (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. docs/lambda/README.md

    ## Example Lambda handler
    
    Install the necessary dependencies.
    ```sh
    pip install flask requests
    ```
    
    Following is an example lambda handler.
    ```py
    from flask import Flask, request, abort, make_response
    import requests
    
    app = Flask(__name__)
    @app.route('/', methods=['POST'])
    def get_webhook():
    	if request.method == 'POST':
    		# obtain the request event from the 'POST' call
    		event = request.json
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt

            "01234567890123456789012345678901234567890123456789"
        )
        cache.edit(key)!!.abort()
        // Contains all valid characters.
        key = "abcdefghijklmnopqrstuvwxyz_0123456789"
        cache.edit(key)!!.abort()
        // Contains dash.
        key = "-20384573948576"
        cache.edit(key)!!.abort()
      }
    
      @Test
      fun writeAndReadEntry() {
        val creator = cache.edit("k1")!!
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 59.4K bytes
    - Click Count (0)
  3. ci/official/utilities/setup.sh

    # specifically. Use your best judgment to keep the scripts in this directory
    # lean and easy to follow. When in doubt, remember that for CI scripts, "keep it
    # simple" is MUCH more important than "don't repeat yourself."
    
    # -e: abort script if one command fails
    # -u: error if undefined variable used
    # -x: log all commands
    # -o pipefail: entire command fails if pipe fails. watch out for yes | ...
    # -o history: record shell history
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Thu Jan 09 18:37:25 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt

                super.close()
                editor.commit()
              }
            }
        }
    
        override fun abort() {
          synchronized(this@Cache) {
            if (done) return
            done = true
            writeAbortCount++
          }
          cacheOut.closeQuietly()
          try {
            editor.abort()
          } catch (_: IOException) {
          }
        }
    
        override fun body(): Sink = body
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Mar 20 09:13:37 GMT 2026
    - 26.9K bytes
    - Click Count (0)
  5. internal/event/target/kafka.go

    func (target *KafkaTarget) Close() error {
    	close(target.quitCh)
    
    	if target.batch != nil {
    		target.batch.Close()
    	}
    
    	if target.producer != nil {
    		if target.store != nil {
    			// It is safe to abort the current transaction if
    			// queue_dir is configured
    			target.producer.AbortTxn()
    		} else {
    			target.producer.CommitTxn()
    		}
    		target.producer.Close()
    		return target.client.Close()
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 13.6K bytes
    - Click Count (0)
  6. cmd/post-policy_test.go

    	// uploadIds [0].
    	// Create bucket before initiating NewMultipartUpload.
    	err := obj.MakeBucket(context.Background(), bucketName, MakeBucketOptions{})
    	if err != nil {
    		// Failed to create newbucket, abort.
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	// Test cases for signature-V2.
    	testCasesV2 := []struct {
    		expectedStatus int
    		secretKey      string
    		formData       map[string]string
    	}{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 30.6K bytes
    - Click Count (0)
  7. cmd/global-heal.go

    				bucket, humanize.Ordinal(er.setIndex+1))
    		}
    
    		disks, _, healing := er.getOnlineDisksWithHealingAndInfo(true)
    		if len(disks) == healing {
    			// All drives in this erasure set were reformatted for some reasons, abort healing and mark it as successful
    			healingLogIf(ctx, errors.New("all drives are in healing state, aborting.."))
    			return nil
    		}
    
    		disks = disks[:len(disks)-healing] // healing drives are always at the end of the list
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

        if (success && !entry.readable) {
          for (i in 0 until valueCount) {
            if (!editor.written!![i]) {
              editor.abort()
              throw IllegalStateException("Newly created entry didn't create value for index $i")
            }
            if (!fileSystem.exists(entry.dirtyFiles[i])) {
              editor.abort()
              return
            }
          }
        }
    
        for (i in 0 until valueCount) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 34.7K bytes
    - Click Count (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/Hc4HttpClient.java

                            }
                        }
                    }
                }
            } catch (final CrawlerSystemException e) {
                httpGet.abort();
                throw e;
            } catch (final Exception e) {
                httpGet.abort();
                throw new CrawlingAccessException("Could not process " + robotTxtUrl + ". ", e);
            } finally {
                EntityUtils.consumeQuietly(httpEntity);
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Fri Jan 09 23:46:52 GMT 2026
    - 54.4K bytes
    - Click Count (0)
  10. src/main/webapp/js/jquery-3.7.1.min.js

    ]?", "+zt+"; q=0.01":""):v.accepts["*"]),v.headers)T.setRequestHeader(i,v.headers[i]);if(v.beforeSend&&(!1===v.beforeSend.call(y,T,v)||h))return T.abort();if(u="abort",b.add(v.complete),T.done(v.success),T.fail(v.error),c=Vt(_t,v,t,T)){if(T.readyState=1,g&&m.trigger("ajaxSend",[T,v]),h)return T;v.async&&0<v.timeout&&(d=ie.setTimeout(function(){T.abort("timeout")},v.timeout));try{h=!1,c.send(a,l)}catch(e){if(h)throw e;l(-1,e)}}else l(-1,"No Transport");function l(e,t,n,r){var i,o,a,s,u,l=t;h||(h=...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Oct 26 01:07:52 GMT 2024
    - 85.5K bytes
    - Click Count (0)
Back to Top