Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 856 for glog (0.07 sec)

  1. docs_src/background_tasks/tutorial002_an.py

    from typing import Union
    
    from fastapi import BackgroundTasks, Depends, FastAPI
    from typing_extensions import Annotated
    
    app = FastAPI()
    
    
    def write_log(message: str):
        with open("log.txt", mode="a") as log:
            log.write(message)
    
    
    def get_query(background_tasks: BackgroundTasks, q: Union[str, None] = None):
        if q:
            message = f"found query: {q}\n"
            background_tasks.add_task(write_log, message)
        return q
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Mar 18 12:29:59 UTC 2023
    - 725 bytes
    - Viewed (0)
  2. buildscripts/rewrite-old-new.sh

    	# remove mc source.
    	purge "${MC_BUILD_DIR}"
    
    	"${MINIO_OLD[@]}" --address ":$start_port" "${WORK_DIR}/xl{1...16}" >"${WORK_DIR}/server1.log" 2>&1 &
    	pid=$!
    	disown $pid
    
    	"${WORK_DIR}/mc" ready minio/
    
    	if ! ps -p ${pid} 1>&2 >/dev/null; then
    		echo "server1 log:"
    		cat "${WORK_DIR}/server1.log"
    		echo "FAILED"
    		purge "$WORK_DIR"
    		exit 1
    	fi
    
    	"${WORK_DIR}/mc" mb minio/healing-rewrite-bucket --quiet --with-lock
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java

            return isContinue;
        }
    
        protected void log(final LogHelper logHelper, final LogType key, final Object... objs) {
            if (logHelper != null) {
                logHelper.log(key, objs);
            }
        }
    
        /*
         * (non-Javadoc)
         *
         * @see java.lang.Runnable#run()
         */
        @Override
        public void run() {
            log(logHelper, LogType.START_THREAD, crawlerContext);
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:41:37 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  4. src/main/java/jcifs/internal/smb1/com/SmbComNegotiateResponse.java

                this.negotiatedFlags2 &= 0xFFFF ^ SmbConstants.FLAGS2_SECURITY_SIGNATURES;
                this.negotiatedFlags2 &= 0xFFFF ^ SmbConstants.FLAGS2_SECURITY_REQUIRE_SIGNATURES;
            }
    
            if ( log.isDebugEnabled() ) {
                log.debug(
                    "Signing " + ( ( this.negotiatedFlags2 & SmbConstants.FLAGS2_SECURITY_SIGNATURES ) != 0 ? "enabled " : "not-enabled " )
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Jul 07 10:52:42 UTC 2020
    - 15.4K bytes
    - Viewed (0)
  5. src/main/java/jcifs/pac/Pac.java

                        // PAC Server Signature
                        if ( this.serverSignature == null ) {
                            this.serverSignature = new PacSignature(bufferData);
                            if ( log.isDebugEnabled() ) {
                                log.debug(
                                    String.format("Server signature is type %d @ %d len %d", this.serverSignature.getType(), bufferOffset, bufferSize));
                            }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 6.5K bytes
    - Viewed (0)
  6. .github/workflows/mint/nginx-8-node.conf

    user  nginx;
    worker_processes  auto;
    
    error_log  /var/log/nginx/error.log warn;
    pid        /var/run/nginx.pid;
    
    events {
        worker_connections  4096;
    }
    
    http {
        include       /etc/nginx/mime.types;
        default_type  application/octet-stream;
    
        log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
                          '$status $body_bytes_sent "$http_referer" '
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 16:52:29 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/NtlmContext.java

                    token = msg1.toByteArray();
    
                    if (log.level >= 4) {
                        log.println(msg1);
                        if (log.level >= 6)
                            Hexdump.hexdump(log, token, 0, token.length);
                    }
    
                    state++;
                    break;
                case 2:
                    try {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 5.9K bytes
    - Viewed (0)
  8. okhttp-android/src/main/kotlin/okhttp3/android/AndroidLogging.kt

     */
    package okhttp3.android
    
    import android.util.Log
    import okhttp3.logging.HttpLoggingInterceptor
    import okhttp3.logging.LoggingEventListener
    
    /**
     * An OkHttp [LoggingEventListener], with android Log as the target.
     */
    fun LoggingEventListener.Companion.androidLogging(
      priority: Int = Log.INFO,
      tag: String = "OkHttp",
    ) = LoggingEventListener.Factory { Log.println(priority, tag, it) }
    
    /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 11:07:32 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  9. cmd/ftp-server-driver.go

    	stopFn := globalFtpMetrics.log(ctx, fromObjPath, toObjPath)
    	defer stopFn(0, err)
    
    	return NotImplemented{}
    }
    
    // MakeDir implements ftpDriver
    func (driver *ftpDriver) MakeDir(ctx *ftp.Context, objPath string) (err error) {
    	stopFn := globalFtpMetrics.log(ctx, objPath)
    	defer stopFn(0, err)
    
    	bucket, prefix := path2BucketObject(objPath)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt

          log.put("failing task running")
          throw RuntimeException("boom!")
        }
    
        queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(200)) {
          log.put("normal task running")
          return@schedule -1L
        }
    
        queue.idleLatch().await(500, TimeUnit.MILLISECONDS)
    
        assertThat(log.take()).isEqualTo("failing task running")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.5K bytes
    - Viewed (0)
Back to top