// 1: Echo
	errFatal(local.RegisterSingleHandler(handlerTest, func(payload []byte) ([]byte, *RemoteErr) {
		t.Log("1: server payload: ", len(payload), "bytes.")
		return append([]byte{}, payload...), nil
	}))
	// 2: Return as error
	errFatal(local.RegisterSingleHandler(handlerTest2, func(payload []byte) ([]byte, *RemoteErr) {
		t.Log("2: server payload: ", len(payload), "bytes.")
		err := RemoteErr(payload)
		return nil, &err
	}))

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" '

<Configuration status="WARN">

	<Properties>
		<Property name="domain.name" value="${sys:fess.log.name:-fess}" />
		<Property name="log.level" value="${sys:fess.log.level:-debug}" />
		<Property name="root.log.level" value="${sys:fess.log.level:-info}" />
		<Property name="log.pattern" value="%d [%t] %-5p %msg%n" />
		<Property name="log.file.basedir" value="${sys:fess.log.path:-target/logs}" />
		<Property name="backup.date.suffix" value="_%d{yyyyMMdd}" />

 */
package org.codelibs.fess.opensearch.log.bsbhv;

import java.util.List;
import java.util.Map;

import org.codelibs.fess.opensearch.log.allcommon.EsAbstractBehavior;
import org.codelibs.fess.opensearch.log.allcommon.EsAbstractEntity.RequestOptionCall;
import org.codelibs.fess.opensearch.log.bsentity.dbmeta.ClickLogDbm;
import org.codelibs.fess.opensearch.log.cbean.ClickLogCB;

	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)

        if ((inUse ? l != 1 : l > 0)) {
            log.warn("Disconnecting transport while still in use " + this + ": " + this.sessions);
            wasInUse = true;
        }

        if (log.isDebugEnabled()) {
            log.debug("Disconnecting transport " + this);
        }

        try {
            if (log.isTraceEnabled()) {

	if certFile != "" || keyFile != "" {
		if certFile == "" || keyFile == "" {
			log.Fatal("Please provide both a key file and a cert file to enable TLS.")
		}
		serveFunc = func() error {
			return http.ListenAndServeTLS(":8080", certFile, keyFile, nil)
		}
	}

	http.HandleFunc("/", mainHandler)

	log.Print("Listening on :8080")
	log.Fatal(serveFunc())

     * @param logMessage
     *            Log message. Must not be {@literal null}.
     */
    public void log(final LogMessage logMessage) {
        assertArgumentNotNull("logMessage", logMessage);

        log(logMessage, null);
    }

    /**
     * Outputs a log entry.
     * <p>
     * The log message should be created using the {@link #format(String, Object...)} method.

            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 ")

 */
package org.codelibs.fess.opensearch.log.cbean.ca.bs;

import org.codelibs.fess.opensearch.log.allcommon.EsAbstractConditionAggregation;
import org.codelibs.fess.opensearch.log.allcommon.EsAbstractConditionQuery;
import org.codelibs.fess.opensearch.log.cbean.ca.UserInfoCA;
import org.codelibs.fess.opensearch.log.cbean.cq.UserInfoCQ;
import org.codelibs.fess.opensearch.log.cbean.cq.bs.BsUserInfoCQ;