diff --git a/.travis.yml b/.travis.yml
index a71a761e..9bb828e8 100644
--- a/.travis.yml
+++ b/.travis.yml
@@ -9,8 +9,8 @@ services:
 
 script:
   - go test -v -race -coverprofile=coverage.txt -covermode=atomic -coverpkg .,github.com/aerokube/selenoid/session,github.com/aerokube/selenoid/config,github.com/aerokube/selenoid/protect,github.com/aerokube/selenoid/service
-  - GOOS=linux GOARCH=amd64 CGO_ENABLED=0 go build -ldflags "-X main.buildStamp=`date -u '+%Y-%m-%d_%I:%M:%S%p'` -X main.gitRevision=`git describe --tags || git rev-parse HEAD`"
-  - gox -os "linux darwin windows" -arch "amd64" -osarch="windows/386" -output "dist/{{.Dir}}_{{.OS}}_{{.Arch}}" -ldflags "-X main.buildStamp=`date -u '+%Y-%m-%d_%I:%M:%S%p'` -X main.gitRevision=`git describe --tags || git rev-parse HEAD`"
+  - GOOS=linux GOARCH=amd64 CGO_ENABLED=0 go build -ldflags "-X main.buildStamp=`date -u '+%Y-%m-%d_%I:%M:%S%p'` -X main.gitRevision=`git describe --tags || git rev-parse HEAD` -s -w"
+  - gox -os "linux darwin windows" -arch "amd64" -osarch="windows/386" -output "dist/{{.Dir}}_{{.OS}}_{{.Arch}}" -ldflags "-X main.buildStamp=`date -u '+%Y-%m-%d_%I:%M:%S%p'` -X main.gitRevision=`git describe --tags || git rev-parse HEAD` -s -w"
 
 before_install:
   - go get -u github.com/golang/dep/cmd/dep
diff --git a/config/config.go b/config/config.go
index f0403ee2..90531a10 100644
--- a/config/config.go
+++ b/config/config.go
@@ -58,6 +58,7 @@ type Browser struct {
 	Env     []string          `json:"env,omitempty"`
 	Hosts   []string          `json:"hosts,omitempty"`
 	ShmSize int64             `json:"shmSize,omitempty"`
+	Labels  map[string]string `json:"labels,omitempty"`
 }
 
 // Versions configuration
@@ -92,20 +93,20 @@ func loadJSON(filename string, v interface{}) error {
 
 // Load loads config from file
 func (config *Config) Load(browsers, containerLogs string) error {
-	log.Println("Loading configuration files...")
+	log.Println("[-] [INIT] [Loading configuration files...]")
 	br := make(map[string]Versions)
 	err := loadJSON(browsers, &br)
 	if err != nil {
 		return fmt.Errorf("browsers config: %v", err)
 	}
-	log.Printf("Loaded configuration from [%s]\n", browsers)
+	log.Printf("[-] [INIT] [Loaded configuration from %s]", browsers)
 	var cl *container.LogConfig
 	err = loadJSON(containerLogs, &cl)
 	if err != nil {
-		log.Printf("Using default containers log configuration because of: %v\n", err)
+		log.Printf("[-] [INIT] [Using default containers log configuration because of: %v]", err)
 		cl = &container.LogConfig{}
 	} else {
-		log.Printf("Loaded configuration from [%s]\n", containerLogs)
+		log.Printf("[-] [INIT] [Loaded log configuration from %s]", containerLogs)
 	}
 	config.lock.Lock()
 	defer config.lock.Unlock()
@@ -123,7 +124,7 @@ func (config *Config) Find(name string, version string) (*Browser, string, bool)
 		return nil, "", false
 	}
 	if version == "" {
-		log.Println("Using default version:", browser.Default)
+		log.Printf("[-] [DEFAULT_VERSION] [Using default version: %s]", browser.Default)
 		version = browser.Default
 		if version == "" {
 			return nil, "", false
diff --git a/config_test.go b/config_test.go
index fe7bf4c9..7907a0ca 100644
--- a/config_test.go
+++ b/config_test.go
@@ -41,7 +41,6 @@ func TestConfigError(t *testing.T) {
 	os.Remove(confFile)
 	conf := config.NewConfig()
 	err := conf.Load(confFile, logConfPath)
-	log.Println(err)
 	AssertThat(t, err.Error(), EqualTo{fmt.Sprintf("browsers config: read error: open %s: no such file or directory", confFile)})
 }
 
diff --git a/docs/browser-image-information.adoc b/docs/browser-image-information.adoc
index 8fc10d76..80bf1b60 100644
--- a/docs/browser-image-information.adoc
+++ b/docs/browser-image-information.adoc
@@ -64,7 +64,7 @@ WARNING: Firefox 53.0+ images require Selenium client 3.4.0 or newer.
 |===
 | Image | VNC Image | Selenoid Version | Geckodriver Version | Firefox Version | Client Version
 
-| selenoid/firefox:48.0 | selenoid/vnc:firefox_48.0 | 1.3.9 | 0.13.0 | 48.0.2 (page load timeout, native events and proxies don't work) .10+<.^|
+| selenoid/firefox:48.0 | selenoid/vnc:firefox_48.0 | 1.3.9 | 0.13.0 | 48.0.2 (page load timeout, native events and proxies don't work) .11+<.^|
 **Java, selenium-webdriver.js**: 3.4.0 and above
 **Python**: 3.5.0 and above 
 | selenoid/firefox:49.0 | selenoid/vnc:firefox_49.0 | 1.3.9 | 0.13.0 | 49.0.2 (page load timeout, native events and switching between windows don't work) 
@@ -76,6 +76,7 @@ WARNING: Firefox 53.0+ images require Selenium client 3.4.0 or newer.
 | selenoid/firefox:55.0 | selenoid/vnc:firefox_55.0 | 1.3.9 | 0.18.0 | 55.0.1 (switching windows may not work) 
 | selenoid/firefox:56.0 | selenoid/vnc:firefox_56.0 | 1.3.9 | 0.19.1 | 56.0.1 
 | selenoid/firefox:57.0 | selenoid/vnc:firefox_57.0 | 1.3.9 | 0.19.1 | 57.0 
+| selenoid/firefox:58.0 | selenoid/vnc:firefox_58.0 | 1.3.9 | 0.19.1 | 58.0
 |===
 
 
@@ -150,6 +151,7 @@ We do not consider these images really stable. Many of base operations like work
 | selenoid/opera:48.0 | selenoid/vnc:opera_48.0 | 2.30 | 48.0.2685.35
 | selenoid/opera:49.0 | selenoid/vnc:opera_49.0 | 2.32 | 49.0.2725.39
 | selenoid/opera:50.0 | selenoid/vnc:opera_50.0 | 2.32 | 50.0.2762.45
+| selenoid/opera:51.0 | selenoid/vnc:opera_51.0 | 2.33 | 51.0.2830.26
 |===
 
 [NOTE]
diff --git a/docs/browser-images.adoc b/docs/browser-images.adoc
index 223a7005..2948a443 100644
--- a/docs/browser-images.adoc
+++ b/docs/browser-images.adoc
@@ -9,4 +9,23 @@ We maintain a set of prebuilt Docker container images for different browsers inc
 All these images are free to use. See image tags for a list of supported versions. Build files are stored in http://github.com/aerokube/selenoid-images[selenoid-images] repository.
 Feel free to create issues or request images for new versions.
 
-NOTE: Complete list of browser images can be found in <<Browser Image information>>
+[NOTE]
+====
+. Complete list of browser images can be found in <<Browser Image information>>
+. These images support all UTF-8 locales. This can be important if you want to save files using national alphabet symbols. You can enable your preferred locale in browsers configuration file by setting respective environment variables:
+```
+{
+    "chrome": {
+        "default": "64.0",
+        "versions": {
+            "64.0": {
+                "image": "selenoid/vnc:chrome_64.0",
+                //...
+                "env" : ["LANG=ru_RU.UTF-8", "LANGUAGE=ru:en", "LC_ALL=ru_RU.UTF-8"]
+            }
+        }
+    }
+}
+```
+====
+
diff --git a/docs/browsers-configuration-file.adoc b/docs/browsers-configuration-file.adoc
index 8d3885e8..6b3602d2 100644
--- a/docs/browsers-configuration-file.adoc
+++ b/docs/browsers-configuration-file.adoc
@@ -14,7 +14,7 @@ Selenoid requires a simple JSON configuration file of the following format:
           "port": "4444",                            <6>
           "tmpfs": {"/tmp": "size=512m"},            <7>
           "path" : "/wd/hub",                        <8>
-          "volumes" : ["/to:/from:ro"],              <9>
+          "volumes" : ["/from:/to:ro"],              <9>
           "env" : ["TZ=Europe/Moscow"],              <10>
           "hosts" : ["example.com:192.168.0.1"],     <11>
           "shmSize" : 268435456,                     <12>
@@ -113,12 +113,13 @@ Selenoid proxies connections to either Selenium server or standalone driver bina
 ----
 "46.0": {
     //...
-    "port": ""
+    "port": "",
     "tmpfs": {"/tmp": "size=512m", "/var": "size=128m"},
     "path" : "",
-    "volumes": ["/to:/from", "/another:/one:ro"],
+    "volumes": ["/from:/to", "/another:/one:ro"],
     "env" : ["TZ=Europe/Moscow", "ONE_MORE_VARIABLE=itsValue"],
     "hosts" : ["one.example.com:192.168.0.1", "two.example.com:192.168.0.2"],
+    "labels" : {"component": "frontend", "project": "my-project"},
     "shmSize" : 268435456,
 },
 ----
@@ -142,6 +143,8 @@ We recommend to use our https://github.com/aerokube/cm[configuration tool] to av
 
 * *hosts* (_optional_) - This field allows to add custom `/etc/hosts` entries to running container. Specified as an array of `hostname:ip` pairs.
 
+* *labels* (_optional_) - This field allows to add custom labels to running container. Specified as an object of `"key": "value"` pairs.
+
 * *shmSize* (_optional_) - Use it to override shared memory size for browser container.
 
 === Syncing Browser Images from Existing File
diff --git a/docs/index.adoc b/docs/index.adoc
index 12b48f8c..5633b3d0 100644
--- a/docs/index.adoc
+++ b/docs/index.adoc
@@ -10,7 +10,7 @@
 :source-highlighter: coderay
 :docinfo: shared
 
-This reference for version: _{revnumber}_
+This reference covers version: _{revnumber}_
 
 Selenoid is a powerful http://golang.org/[Go] implementation of original http://github.com/SeleniumHQ/selenium[Selenium] hub code.
 It is using Docker to launch browsers. Please refer to https://github.com/aerokube/selenoid[GitHub repository] if you need sources.
diff --git a/docs/log-files.adoc b/docs/log-files.adoc
index f59b187d..4948a70d 100644
--- a/docs/log-files.adoc
+++ b/docs/log-files.adoc
@@ -1,8 +1,8 @@
 == Log Files
 A typical log file looks like the following:
 ```
-2017/11/01 19:12:38 [NEW_REQUEST]
-2017/11/01 19:12:38 [NEW_REQUEST_ACCEPTED]
+2017/11/01 19:12:38 [-] [NEW_REQUEST]
+2017/11/01 19:12:38 [-] [NEW_REQUEST_ACCEPTED]
 2017/11/01 19:12:38 [41301] [LOCATING_SERVICE] [firefox-45.0]
 2017/11/01 19:12:38 [41301] [USING_DOCKER] [firefox-45.0]
 2017/11/01 19:12:38 [41301] [CREATING_CONTAINER] [selenoid/firefox:45.0]
@@ -24,11 +24,10 @@ Every line contains:
 | Time | 2017/11/01 19:12:42 | - 
 | Request counter | [41301] | So far as session ID is unknown when doing attempts this counter is used to find all session attempts for each new session request. 
 | Status | [SESSION_ATTEMPTED] | See table below for complete list of statuses. 
-| Quota name | [my_quota] | Extracted from basic HTTP auth headers. 
 | Browser | [firefox-45.0] | Name and version. Only present for new session requests.
 | Attempt number | [1] | For SESSION_ATTEMPTED entries means current attempt number. For SESSION_CREATED entries means total number of attempts to create this session. 
 | Session ID | [345bb886-7026-46d7-82d4-4788c0460110] | This value is unique for every browser session 
-| Session start time | [4.155712239s] | - 
+| Session start time | [4.15s] | - 
 |===
 
 The following statuses are available:
@@ -50,10 +49,12 @@ The following statuses are available:
 | CONTAINER_REMOVED | Docker container was successfully removed 
 | CONTAINER_STARTED | Docker container has successfully started 
 | CREATING_CONTAINER | Docker container with browser is creating 
+| DEFAULT_VERSION | Selenoid is using default browser version 
 | DELETED_VIDEO_FILE | Video file was deleted by user 
 | ENVIRONMENT_NOT_AVAILABLE | Browser with desired name and version does not exist
 | FAILED_TO_REMOVE_CONTAINER | Failed to remove Docker container 
 | FAILED_TO_TERMINATE_PROCESS | An error occurred while terminating driver process 
+| INIT | Server is starting 
 | PROCESS_STARTED | Driver process successfully started 
 | PROXY_TO | Starting to proxy requests to running container or driver process 
 | REMOVING_CONTAINER | Docker container with browser or video recorder is being removed
@@ -66,7 +67,8 @@ The following statuses are available:
 | SESSION_FAILED | An attempt to create a new session failed - user receives an error
 | SESSION_NOT_FOUND | Requested VNC or logs for unknown session.
 | STARTING_CONTAINER | Docker container with browser was created and is starting
-| STARTING_PROCESS | Starting driver process 
+| STARTING_PROCESS | Starting driver process
+| SHUTTING_DOWN | Server is stopping 
 | TERMINATING_PROCESS | Stopping driver process 
 | TERMINATED_PROCESS | Driver process was successfully stopped 
 | VNC_ENABLED | User requested VNC traffic 
diff --git a/docs/special-capabilities.adoc b/docs/special-capabilities.adoc
index 01b462ff..9f14c02b 100644
--- a/docs/special-capabilities.adoc
+++ b/docs/special-capabilities.adoc
@@ -39,7 +39,7 @@ You need to use `setSize` method instead.
 
 === Video Recording: enableVideo, videoName, videoScreenSize, videoFrameRate
 
-NOTE: This feature requires some preparation. Please refer <<Video Recording>> section for details.
+NOTE: This feature requires some preparation. Please refer to <<Video Recording>> section for details.
 
 To enable video recording for session, add:
 
@@ -124,6 +124,17 @@ hostsEntries: "example.com:192.168.0.1,test.com:192.168.0.2"
 Entries will be inserted to `/etc/hosts` before entries from browsers configuration file.
 Thus entries from capabilities override entries from configuration file if some hosts are equal.
 
+=== Container Labels: labels
+
+In big clusters you may want to pass additional metadata to every browser session: environment, VCS revision, build number and so on. These labels can be then used to enrich session logs and send them to a centralized log storage. Later this metadata can be used for more efficient search through logs. 
+
+.Type: string, format: <key>:<value> (comma-separated)
+----
+labels: "environment:testing,build-number:14353"
+----
+
+Labels from this capability override labels from browsers configuration file. When `name` capability is specified - it is automatically added as a label to container.
+
 === Specifying Capabilities via Protocol Extensions
 
 Some Selenium clients allow passing only a limited number of capabilities specified in https://w3c.github.io/webdriver/webdriver-spec.html[WebDriver specification]. For such cases Selenoid supports reading capabilities using https://w3c.github.io/webdriver/webdriver-spec.html#protocol-extensions[WebDriver protocol extensions] feature. The following two examples deliver the same result. Usually capabilities are passed like this:
diff --git a/docs/video.adoc b/docs/video.adoc
index 601fa728..80842c85 100644
--- a/docs/video.adoc
+++ b/docs/video.adoc
@@ -1,10 +1,16 @@
 == Video Recording
-NOTE: This feature only works when browsers are run in containers. This can be both vnc or non-vnc containers.
+
+[NOTE]
+====
+. This feature only works when browsers are run in containers.
+. Video can be recorded with both vnc or non-vnc browser images.
+. An additional `enableVideo` capability should be added to tests. See <<Special Capabilities>> section for more details.
+====
 
 Selenoid can capture browser screen and save it to https://en.wikipedia.org/wiki/MPEG-4[MPEG-4] video file using https://en.wikipedia.org/wiki/H.264/MPEG-4_AVC[H264] codec.
 Video recording works by attaching a separate container with https://www.ffmpeg.org/[video capturing software] to running browser container.
 
-To setup this feature you should:
+To use this feature you should:
 
 . Pull video recorder image once:
 +
diff --git a/main.go b/main.go
index ae692f36..4671168f 100644
--- a/main.go
+++ b/main.go
@@ -125,18 +125,18 @@ func init() {
 	var err error
 	hostname, err = os.Hostname()
 	if err != nil {
-		log.Fatalf("%s: %v", os.Args[0], err)
+		log.Fatalf("[-] [INIT] [%s: %v]", os.Args[0], err)
 	}
 	queue = protect.New(limit, disableQueue)
 	conf = config.NewConfig()
 	err = conf.Load(confPath, logConfPath)
 	if err != nil {
-		log.Fatalf("%s: %v", os.Args[0], err)
+		log.Fatalf("[-] [INIT] [%s: %v]", os.Args[0], err)
 	}
 	onSIGHUP(func() {
 		err := conf.Load(confPath, logConfPath)
 		if err != nil {
-			log.Printf("%s: %v", os.Args[0], err)
+			log.Printf("[-] [INIT] [%s: %v]", os.Args[0], err)
 		}
 	})
 	cancelOnSignal()
@@ -145,14 +145,18 @@ func init() {
 	if err == nil {
 		inDocker = true
 	}
-	videoOutputDir, err = filepath.Abs(videoOutputDir)
-	if err != nil {
-		log.Fatalf("Invalid video output dir %s: %v", videoOutputDir, err)
-	}
-	err = os.MkdirAll(videoOutputDir, os.FileMode(0644))
-	if err != nil {
-		log.Fatalf("Failed to create video output dir %s: %v", videoOutputDir, err)
+
+	if !disableDocker {
+		videoOutputDir, err = filepath.Abs(videoOutputDir)
+		if err != nil {
+			log.Fatalf("[-] [INIT] [Invalid video output dir %s: %v]", videoOutputDir, err)
+		}
+		err = os.MkdirAll(videoOutputDir, os.FileMode(0644))
+		if err != nil {
+			log.Fatalf("[-] [INIT] [Failed to create video output dir %s: %v]", videoOutputDir, err)
+		}
 	}
+
 	environment := service.Environment{
 		InDocker:            inDocker,
 		CPU:                 int64(cpu),
@@ -173,21 +177,21 @@ func init() {
 	if dockerHost == "" {
 		dockerHost = client.DefaultDockerHost
 	}
-	_, addr, _, err := client.ParseHost(dockerHost)
+	u, err := client.ParseHostURL(dockerHost)
 	if err != nil {
-		log.Fatal(err)
+		log.Fatalf("[-] [INIT] [%v]", err)
 	}
-	ip, _, _ := net.SplitHostPort(addr)
+	ip, _, _ := net.SplitHostPort(u.Host)
 	environment.IP = ip
 	cli, err = client.NewEnvClient()
 	if err != nil {
-		log.Fatalf("new docker client: %v\n", err)
+		log.Fatalf("[-] [INIT] [New docker client: %v]", err)
 	}
 	manager = &service.DefaultManager{Environment: &environment, Client: cli, Config: conf}
 
 	if mesosMasterURL != "" {
 		log.Printf("[TRY TO REGISTER ON MESOS MASTER] [%s]", mesosMasterURL)
-		go scheduler.Run(mesosMasterURL)
+		go scheduler.Run(mesosMasterURL, float64(cpu), float64(mem))
 	}
 
 }
@@ -206,7 +210,7 @@ func cancelOnSignal() {
 		if !disableDocker {
 			err := cli.Close()
 			if err != nil {
-				log.Fatalf("close docker client: %v", err)
+				log.Fatalf("[-] [SHUTTING_DOWN] [Error closing docker client: %v]", err)
 				os.Exit(1)
 			}
 		}
@@ -243,6 +247,7 @@ func post(next http.HandlerFunc) http.HandlerFunc {
 }
 
 func ping(w http.ResponseWriter, _ *http.Request) {
+	w.Header().Add("Content-Type", "application/json")
 	json.NewEncoder(w).Encode(struct {
 		Uptime         string `json:"uptime"`
 		LastReloadTime string `json:"lastReloadTime"`
@@ -275,7 +280,7 @@ func deleteFileIfExists(w http.ResponseWriter, r *http.Request) {
 		http.Error(w, fmt.Sprintf("Failed to delete file %s: %v", filePath, err), http.StatusInternalServerError)
 		return
 	}
-	log.Printf("[%d] [DELETED_VIDEO_FILE] [%s]\n", serial(), fileName)
+	log.Printf("[%d] [DELETED_VIDEO_FILE] [%s]", serial(), fileName)
 }
 
 func handler() http.Handler {
@@ -291,6 +296,7 @@ func handler() http.Handler {
 		jsonError(w, "Session timed out or not found", http.StatusNotFound)
 	})
 	root.HandleFunc("/status", func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Add("Content-Type", "application/json")
 		json.NewEncoder(w).Encode(conf.State(sessions, limit, queue.Queued(), queue.Pending()))
 	})
 	root.HandleFunc("/ping", ping)
@@ -309,8 +315,8 @@ func showVersion() {
 }
 
 func main() {
-	log.Printf("Timezone: %s\n", time.Local)
-	log.Printf("Video Dir: %s\n", videoOutputDir)
-	log.Printf("Listening on %s\n", listen)
+	log.Printf("[-] [INIT] [Timezone: %s]", time.Local)
+	log.Printf("[-] [INIT] [Video Dir: %s]", videoOutputDir)
+	log.Printf("[-] [INIT] [Listening on %s]", listen)
 	log.Fatal(http.ListenAndServe(listen, handler()))
 }
diff --git a/mesos/scheduler/messages.go b/mesos/scheduler/messages.go
index 8b53b893..4431e105 100644
--- a/mesos/scheduler/messages.go
+++ b/mesos/scheduler/messages.go
@@ -189,8 +189,8 @@ func NewLaunchTaskInfo(offer Offer, taskId string) *Launch {
 		Container: NewContainer(portRange),
 		Resources: []Resource{
 			NewResourcePorts(portRange),
-			NewResourcesContainer("cpus", 1.0),
-			NewResourcesContainer("mem", 128.0),
+			NewResourcesContainer("cpus", CpuLimit),
+			NewResourcesContainer("mem", MemLimit),
 		},
 	}
 
diff --git a/mesos/scheduler/scheduler.go b/mesos/scheduler/scheduler.go
index 9b04fccc..c8d66b88 100644
--- a/mesos/scheduler/scheduler.go
+++ b/mesos/scheduler/scheduler.go
@@ -1,19 +1,22 @@
 package scheduler
 
 import (
+	"bufio"
+	"bytes"
+	"encoding/base64"
 	"encoding/json"
 	"fmt"
+	"log"
 	"net/http"
+	"sort"
 	"strings"
-	"log"
-	"bufio"
-	"encoding/base64"
-	"bytes"
 )
 
 var (
-	Sched   *Scheduler
-	Channel = make(chan Task)
+	Sched    *Scheduler
+	Channel  = make(chan Task)
+	CpuLimit float64
+	MemLimit float64
 )
 
 const schedulerUrlTemplate = "[MASTER]/api/v1/scheduler"
@@ -25,7 +28,7 @@ type Task struct {
 }
 
 type DockerInfo struct {
-	Id string
+	Id              string
 	NetworkSettings struct {
 		Ports struct {
 			ContainerPort []struct {
@@ -69,7 +72,14 @@ type Offer struct {
 	Resources []Resource `json:"resources"`
 }
 
-func Run(URL string) {
+type ResourcesForOneTask struct {
+	OfferId ID
+	AgentId ID
+	Range
+}
+
+func Run(URL string, cpu float64, mem float64) {
+	setResourceLimits(cpu, mem)
 	notRunningTasks := make(map[string]chan *DockerInfo)
 	schedulerUrl := strings.Replace(schedulerUrlTemplate, "[MASTER]", URL, 1)
 
@@ -95,7 +105,7 @@ func Run(URL string) {
 		fmt.Println(line)
 		var index = strings.LastIndex(line, "}")
 		if index != -1 {
-			jsonMessage := line[0:index+1]
+			jsonMessage := line[0 : index+1]
 			json.Unmarshal([]byte(jsonMessage), &m)
 			handle(m)
 			if m.Type == "SUBSCRIBED" {
@@ -109,6 +119,9 @@ func Run(URL string) {
 					offersIds = append(offersIds, n.Id)
 					fmt.Println(offersIds)
 				}
+				tasksCanRun, resourcesForTasks := getTotalOffersCapacity(offers)
+				log.Printf("[MESOS CONTAINERS CAN BE RUN NOW] [%d]\n", tasksCanRun)
+				log.Printf("[CURRENT FREE MESOS CONTAINERS RESOURCES] [%v]\n", resourcesForTasks)
 				select {
 				case task := <-Channel:
 					notRunningTasks[task.TaskId] = task.ReturnChannel
@@ -134,6 +147,20 @@ func Run(URL string) {
 	}
 }
 
+func setResourceLimits(cpu float64, mem float64) {
+	if cpu > 0 {
+		CpuLimit = cpu / 1000000000
+	} else {
+		CpuLimit = 0.2
+	}
+
+	if mem > 0 {
+		MemLimit = mem
+	} else {
+		MemLimit = 128
+	}
+}
+
 func handle(m Message) {
 	if m.Type == "HEARTBEAT" {
 		fmt.Println("Мезос жил, мезос жив, мезос будет жить!!!")
@@ -144,3 +171,55 @@ func handle(m Message) {
 		Sched.Acknowledge(m.Update.Status.AgentId, uuid, m.Update.Status.ExecutorId)
 	}
 }
+
+func getTotalOffersCapacity(offers []Offer) (int, []ResourcesForOneTask) {
+	tasksCanRun := 0
+	var resourcesForTasks []ResourcesForOneTask
+	for _, offer := range offers {
+		offerCapacity, resources := getCapacityOfCurrentOffer(offer)
+		tasksCanRun = tasksCanRun + offerCapacity
+		resourcesForTasks = append(resourcesForTasks, resources...)
+	}
+
+	return tasksCanRun, resourcesForTasks
+}
+
+func getCapacityOfCurrentOffer(offer Offer) (int, []ResourcesForOneTask) {
+	cpuCapacity := 0
+	memCapacity := 0
+	portsCapacity := 0
+	var offersPortsResources []Range
+	for _, resource := range offer.Resources {
+		switch resource.Name {
+		case "cpus":
+			cpuCapacity = int(resource.Scalar.Value / CpuLimit)
+		case "mem":
+			memCapacity = int(resource.Scalar.Value / MemLimit)
+		case "ports":
+			offersPortsResources = resource.Ranges.Range
+			for _, ports := range offersPortsResources {
+				portsCapacity = int(portsCapacity + ((ports.End - ports.Begin) / 2))
+			}
+		}
+	}
+	allResourcesCapacity := []int{cpuCapacity, memCapacity, portsCapacity}
+	sort.Ints(allResourcesCapacity)
+	totalCapacityOfCurrentOffer := allResourcesCapacity[0]
+	resourcesForTasks := getResourcesForTasks(offer, totalCapacityOfCurrentOffer, offersPortsResources)
+	return totalCapacityOfCurrentOffer, resourcesForTasks
+}
+
+func getResourcesForTasks(offer Offer, offerCapacity int, ranges []Range) []ResourcesForOneTask {
+	resourcesForTasks := make([]ResourcesForOneTask, 0)
+	for i := 0; len(ranges) > i && len(resourcesForTasks) != offerCapacity; i++ {
+		portsBegin := ranges[i].Begin
+		portsEnd := ranges[i].End
+		for portsEnd-portsBegin >= 1 && len(resourcesForTasks) != offerCapacity {
+			portRange := Range{portsBegin, portsBegin + 1}
+			resourcesForTasks = append(resourcesForTasks, ResourcesForOneTask{offer.Id, offer.AgentId, portRange})
+			portsBegin = portsBegin + 2
+		}
+
+	}
+	return resourcesForTasks
+}
diff --git a/protect/queue.go b/protect/queue.go
index b42c7744..0219ef0c 100644
--- a/protect/queue.go
+++ b/protect/queue.go
@@ -5,6 +5,7 @@ import (
 	"net/http"
 	"time"
 
+	"github.com/aerokube/selenoid/util"
 	"math"
 )
 
@@ -25,8 +26,9 @@ func (q *Queue) Check(next http.HandlerFunc) http.HandlerFunc {
 			<-q.limit
 		default:
 			if q.disabled {
-				log.Println("[QUEUE_IS_FULL]")
-				http.Error(w, "Queue full, see other", http.StatusSeeOther)
+				user, remote := util.RequestInfo(r)
+				log.Printf("[-] [QUEUE_IS_FULL] [%s] [%s]", user, remote)
+				http.Error(w, "Queue is full, see other", http.StatusSeeOther)
 				return
 			}
 		}
@@ -37,7 +39,8 @@ func (q *Queue) Check(next http.HandlerFunc) http.HandlerFunc {
 // Protect - handler to control limit of sessions
 func (q *Queue) Protect(next http.HandlerFunc) http.HandlerFunc {
 	return func(w http.ResponseWriter, r *http.Request) {
-		log.Println("[NEW_REQUEST]")
+		user, remote := util.RequestInfo(r)
+		log.Printf("[-] [NEW_REQUEST] [%s] [%s]", user, remote)
 		cn := w.(http.CloseNotifier)
 		s := time.Now()
 		go func() {
@@ -46,13 +49,13 @@ func (q *Queue) Protect(next http.HandlerFunc) http.HandlerFunc {
 		select {
 		case <-cn.CloseNotify():
 			<-q.queued
-			log.Printf("connection from %s closed by client after %s waiting in queue\n", r.RemoteAddr, time.Since(s))
+			log.Printf("[-] [CLIENT_DISCONNECTED] [%s] [%s] [%s]", user, remote, time.Since(s))
 			return
 		case q.limit <- struct{}{}:
 			q.pending <- struct{}{}
 		}
 		<-q.queued
-		log.Println("[NEW_REQUEST_ACCEPTED]")
+		log.Printf("[-] [NEW_REQUEST_ACCEPTED] [%s] [%s]", user, remote)
 		next.ServeHTTP(w, r)
 	}
 }
diff --git a/selenoid.go b/selenoid.go
index ec8cef89..0f5e2de8 100644
--- a/selenoid.go
+++ b/selenoid.go
@@ -24,12 +24,13 @@ import (
 	"crypto/rand"
 	"encoding/hex"
 	"github.com/aerokube/selenoid/session"
+	"github.com/aerokube/selenoid/util"
 	"github.com/docker/docker/api/types"
 	"golang.org/x/net/websocket"
 )
 
 var (
-	httpClient *http.Client = &http.Client{
+	httpClient = &http.Client{
 		CheckRedirect: func(req *http.Request, via []*http.Request) error {
 			return http.ErrUseLastResponse
 		},
@@ -74,11 +75,11 @@ func jsonError(w http.ResponseWriter, msg string, code int) {
 		})
 }
 
-func (s *sess) Delete() {
-	log.Printf("[SESSION_TIMED_OUT] [%s]\n", s.id)
+func (s *sess) Delete(requestId uint64) {
+	log.Printf("[%d] [SESSION_TIMED_OUT] [%s]", requestId, s.id)
 	r, err := http.NewRequest(http.MethodDelete, s.url(), nil)
 	if err != nil {
-		log.Printf("[DELETE_FAILED] [%s] [%v]\n", s.id, err)
+		log.Printf("[%d] [DELETE_FAILED] [%s] [%v]", requestId, s.id, err)
 		return
 	}
 	ctx, cancel := context.WithTimeout(context.Background(), sessionDeleteTimeout)
@@ -91,9 +92,9 @@ func (s *sess) Delete() {
 		return
 	}
 	if err != nil {
-		log.Printf("[DELETE_FAILED] [%s] [%v]\n", s.id, err)
+		log.Printf("[%d] [DELETE_FAILED] [%s] [%v]", requestId, s.id, err)
 	} else {
-		log.Printf("[DELETE_FAILED] [%s] [%s]\n", s.id, resp.Status)
+		log.Printf("[%d] [DELETE_FAILED] [%s] [%s]", requestId, s.id, resp.Status)
 	}
 }
 
@@ -114,14 +115,11 @@ func getSerial() uint64 {
 func create(w http.ResponseWriter, r *http.Request) {
 	sessionStartTime := time.Now()
 	requestId := serial()
-	quota, _, ok := r.BasicAuth()
-	if !ok {
-		quota = "unknown"
-	}
+	user, remote := util.RequestInfo(r)
 	body, err := ioutil.ReadAll(r.Body)
 	r.Body.Close()
 	if err != nil {
-		log.Printf("[%d] [ERROR_READING_REQUEST] [%s] [%v]\n", requestId, quota, err)
+		log.Printf("[%d] [ERROR_READING_REQUEST] [%v]", requestId, err)
 		jsonError(w, err.Error(), http.StatusBadRequest)
 		queue.Drop()
 		return
@@ -131,7 +129,7 @@ func create(w http.ResponseWriter, r *http.Request) {
 	}
 	err = json.Unmarshal(body, &browser)
 	if err != nil {
-		log.Printf("[%d] [BAD_JSON_FORMAT] [%s] [%v]\n", requestId, quota, err)
+		log.Printf("[%d] [BAD_JSON_FORMAT] [%v]", requestId, err)
 		jsonError(w, err.Error(), http.StatusBadRequest)
 		queue.Drop()
 		return
@@ -139,7 +137,7 @@ func create(w http.ResponseWriter, r *http.Request) {
 	browser.Caps.ProcessExtensionCapabilities()
 	resolution, err := getScreenResolution(browser.Caps.ScreenResolution)
 	if err != nil {
-		log.Printf("[%d] [BAD_SCREEN_RESOLUTION] [%s] [%s]\n", requestId, quota, browser.Caps.ScreenResolution)
+		log.Printf("[%d] [BAD_SCREEN_RESOLUTION] [%s]", requestId, browser.Caps.ScreenResolution)
 		jsonError(w, err.Error(), http.StatusBadRequest)
 		queue.Drop()
 		return
@@ -147,7 +145,7 @@ func create(w http.ResponseWriter, r *http.Request) {
 	browser.Caps.ScreenResolution = resolution
 	videoScreenSize, err := getVideoScreenSize(browser.Caps.VideoScreenSize, resolution)
 	if err != nil {
-		log.Printf("[%d] [BAD_VIDEO_SCREEN_SIZE] [%s] [%s]\n", requestId, quota, browser.Caps.VideoScreenSize)
+		log.Printf("[%d] [BAD_VIDEO_SCREEN_SIZE] [%s]", requestId, browser.Caps.VideoScreenSize)
 		jsonError(w, err.Error(), http.StatusBadRequest)
 		queue.Drop()
 		return
@@ -159,14 +157,14 @@ func create(w http.ResponseWriter, r *http.Request) {
 	}
 	starter, ok := manager.Find(browser.Caps, requestId)
 	if !ok {
-		log.Printf("[%d] [ENVIRONMENT_NOT_AVAILABLE] [%s] [%s-%s]\n", requestId, quota, browser.Caps.Name, browser.Caps.Version)
+		log.Printf("[%d] [ENVIRONMENT_NOT_AVAILABLE] [%s] [%s]", requestId, browser.Caps.Name, browser.Caps.Version)
 		jsonError(w, "Requested environment is not available", http.StatusBadRequest)
 		queue.Drop()
 		return
 	}
 	startedService, err := starter.StartWithCancel()
 	if err != nil {
-		log.Printf("[%d] [SERVICE_STARTUP_FAILED] [%s] [%v]\n", requestId, quota, err)
+		log.Printf("[%d] [SERVICE_STARTUP_FAILED] [%v]", requestId, err)
 		jsonError(w, err.Error(), http.StatusInternalServerError)
 		queue.Drop()
 		return
@@ -180,7 +178,7 @@ func create(w http.ResponseWriter, r *http.Request) {
 		req, _ := http.NewRequest(http.MethodPost, r.URL.String(), bytes.NewReader(body))
 		ctx, done := context.WithTimeout(r.Context(), newSessionAttemptTimeout)
 		defer done()
-		log.Printf("[%d] [SESSION_ATTEMPTED] [%s] [%s] [%d]\n", requestId, quota, u.String(), i)
+		log.Printf("[%d] [SESSION_ATTEMPTED] [%s] [%d]", requestId, u.String(), i)
 		rsp, err := httpClient.Do(req.WithContext(ctx))
 		select {
 		case <-ctx.Done():
@@ -189,15 +187,15 @@ func create(w http.ResponseWriter, r *http.Request) {
 			}
 			switch ctx.Err() {
 			case context.DeadlineExceeded:
-				log.Printf("[%d] [SESSION_ATTEMPT_TIMED_OUT] [%s]\n", requestId, quota)
+				log.Printf("[%d] [SESSION_ATTEMPT_TIMED_OUT] [%s]", requestId, newSessionAttemptTimeout)
 				if i < retryCount {
 					continue
 				}
 				err := fmt.Errorf("New session attempts retry count exceeded")
-				log.Printf("[%d] [SESSION_FAILED] [%s] - [%s]\n", requestId, u.String(), err)
+				log.Printf("[%d] [SESSION_FAILED] [%s] [%s]", requestId, u.String(), err)
 				jsonError(w, err.Error(), http.StatusInternalServerError)
 			case context.Canceled:
-				log.Printf("[%d] [CLIENT_DISCONNECTED] [%s]\n", requestId, quota)
+				log.Printf("[%d] [CLIENT_DISCONNECTED] [%s] [%s] [%.2fs]", requestId, user, remote, util.SecondsSince(sessionStartTime))
 			}
 			queue.Drop()
 			cancel()
@@ -208,7 +206,7 @@ func create(w http.ResponseWriter, r *http.Request) {
 			if rsp != nil {
 				rsp.Body.Close()
 			}
-			log.Printf("[%d] [SESSION_FAILED] [%s] - [%s]\n", requestId, u.String(), err)
+			log.Printf("[%d] [SESSION_FAILED] [%s] [%s]", requestId, u.String(), err)
 			jsonError(w, err.Error(), http.StatusInternalServerError)
 			queue.Drop()
 			cancel()
@@ -251,7 +249,7 @@ func create(w http.ResponseWriter, r *http.Request) {
 		}
 	}
 	if s.ID == "" {
-		log.Printf("[%d] [SESSION_FAILED] [%s] [Bad response from %s - %v]\n", requestId, quota, u.String(), resp.Status)
+		log.Printf("[%d] [SESSION_FAILED] [%s] [%s]", requestId, u.String(), resp.Status)
 		queue.Drop()
 		cancel()
 		return
@@ -266,22 +264,22 @@ func create(w http.ResponseWriter, r *http.Request) {
 			newVideoName := filepath.Join(videoOutputDir, finalVideoName)
 			err := os.Rename(oldVideoName, newVideoName)
 			if err != nil {
-				log.Printf("[%d] [VIDEO_ERROR] [%s]\n", requestId, fmt.Sprintf("Failed to rename %s to %s: %v", oldVideoName, newVideoName, err))
+				log.Printf("[%d] [VIDEO_ERROR] [%s]", requestId, fmt.Sprintf("Failed to rename %s to %s: %v", oldVideoName, newVideoName, err))
 			}
 		}
 	}
 	sessions.Put(s.ID, &session.Session{
-		Quota:     quota,
+		Quota:     user,
 		Caps:      browser.Caps,
 		URL:       u,
 		Container: startedService.Container,
 		VNC:       startedService.VNCHostPort,
 		Cancel:    cancelAndRenameVideo,
 		Timeout: onTimeout(timeout, func() {
-			request{r}.session(s.ID).Delete()
+			request{r}.session(s.ID).Delete(requestId)
 		})})
 	queue.Create()
-	log.Printf("[%d] [SESSION_CREATED] [%s] [%s] [%s] [%d] [%v]\n", requestId, quota, s.ID, u, i, time.Since(sessionStartTime))
+	log.Printf("[%d] [SESSION_CREATED] [%s] [%d] [%.2fs]", requestId, s.ID, i, util.SecondsSince(sessionStartTime))
 }
 
 const videoFileExtension = ".mp4"
@@ -351,6 +349,7 @@ func proxy(w http.ResponseWriter, r *http.Request) {
 		}()
 		(&httputil.ReverseProxy{
 			Director: func(r *http.Request) {
+				requestId := serial()
 				fragments := strings.Split(r.URL.Path, "/")
 				id := fragments[2]
 				sess, ok := sessions.Get(id)
@@ -369,10 +368,10 @@ func proxy(w http.ResponseWriter, r *http.Request) {
 						cancel = sess.Cancel
 						sessions.Remove(id)
 						queue.Release()
-						log.Printf("[SESSION_DELETED] [%s]\n", id)
+						log.Printf("[%d] [SESSION_DELETED] [%s]", requestId, id)
 					} else {
 						sess.Timeout = onTimeout(timeout, func() {
-							request{r}.session(id).Delete()
+							request{r}.session(id).Delete(requestId)
 						})
 						if len(fragments) == 4 && fragments[len(fragments)-1] == "file" && enableFileUpload {
 							r.Header.Set("X-Selenoid-File", filepath.Join(os.TempDir(), id))
@@ -444,15 +443,16 @@ func fileUpload(w http.ResponseWriter, r *http.Request) {
 
 func vnc(wsconn *websocket.Conn) {
 	defer wsconn.Close()
+	requestId := serial()
 	sid := strings.Split(wsconn.Request().URL.Path, "/")[2]
 	sess, ok := sessions.Get(sid)
 	if ok {
 		if sess.VNC != "" {
-			log.Printf("[VNC_ENABLED] [%s]\n", sid)
+			log.Printf("[%d] [VNC_ENABLED] [%s]", requestId, sid)
 			var d net.Dialer
 			conn, err := d.DialContext(wsconn.Request().Context(), "tcp", sess.VNC)
 			if err != nil {
-				log.Printf("[VNC_ERROR] [%v]\n", err)
+				log.Printf("[%d] [VNC_ERROR] [%v]", requestId, err)
 				return
 			}
 			defer conn.Close()
@@ -460,39 +460,40 @@ func vnc(wsconn *websocket.Conn) {
 			go func() {
 				io.Copy(wsconn, conn)
 				wsconn.Close()
-				log.Printf("[VNC_SESSION_CLOSED] [%s]\n", sid)
+				log.Printf("[%d] [VNC_SESSION_CLOSED] [%s]", requestId, sid)
 			}()
 			io.Copy(conn, wsconn)
-			log.Printf("[VNC_CLIENT_DISCONNECTED] [%s]\n", sid)
+			log.Printf("[%d] [VNC_CLIENT_DISCONNECTED] [%s]", requestId, sid)
 		} else {
-			log.Printf("[VNC_NOT_ENABLED] [%s]\n", sid)
+			log.Printf("[%d] [VNC_NOT_ENABLED] [%s]", requestId, sid)
 		}
 	} else {
-		log.Printf("[SESSION_NOT_FOUND] [%s]\n", sid)
+		log.Printf("[%d] [SESSION_NOT_FOUND] [%s]", requestId, sid)
 	}
 }
 
 func logs(wsconn *websocket.Conn) {
 	defer wsconn.Close()
+	requestId := serial()
 	sid := strings.Split(wsconn.Request().URL.Path, "/")[2]
 	sess, ok := sessions.Get(sid)
 	if ok && sess.Container != nil {
-		log.Printf("[CONTAINER_LOGS] [%s]\n", sess.Container)
+		log.Printf("[%d] [CONTAINER_LOGS] [%s]", requestId, sess.Container)
 		r, err := cli.ContainerLogs(wsconn.Request().Context(), sess.Container.ID, types.ContainerLogsOptions{
 			ShowStdout: true,
 			ShowStderr: true,
 			Follow:     true,
 		})
 		if err != nil {
-			log.Printf("[CONTAINER_LOGS_ERROR] [%v]\n", err)
+			log.Printf("[%d] [CONTAINER_LOGS_ERROR] [%v]", requestId, err)
 			return
 		}
 		defer r.Close()
 		wsconn.PayloadType = websocket.BinaryFrame
 		io.Copy(wsconn, r)
-		log.Printf("[CONTAINER_LOGS_DISCONNECTED] [%s]\n", sid)
+		log.Printf("[%d] [CONTAINER_LOGS_DISCONNECTED] [%s]", requestId, sid)
 	} else {
-		log.Printf("[SESSION_NOT_FOUND] [%s]\n", sid)
+		log.Printf("[%d] [SESSION_NOT_FOUND] [%s]", requestId, sid)
 	}
 }
 
diff --git a/service/docker.go b/service/docker.go
index 856f0a23..6688abad 100644
--- a/service/docker.go
+++ b/service/docker.go
@@ -10,6 +10,7 @@ import (
 
 	"github.com/aerokube/selenoid/config"
 	"github.com/aerokube/selenoid/session"
+	"github.com/aerokube/selenoid/util"
 	"github.com/docker/docker/api/types"
 	ctr "github.com/docker/docker/api/types/container"
 	"github.com/docker/docker/api/types/network"
@@ -22,6 +23,7 @@ import (
 
 const (
 	comma                  = ","
+	colon                  = ":"
 	sysAdmin               = "SYS_ADMIN"
 	overrideVideoOutputDir = "OVERRIDE_VIDEO_OUTPUT_DIR"
 )
@@ -53,7 +55,7 @@ func (d *Docker) StartWithCancel() (*StartedService, error) {
 	requestId := d.RequestId
 	image := d.Service.Image
 	ctx := context.Background()
-	log.Printf("[%d] [CREATING_CONTAINER] [%s]\n", requestId, image)
+	log.Printf("[%d] [CREATING_CONTAINER] [%s]", requestId, image)
 	hostConfig := ctr.HostConfig{
 		Binds:        d.Service.Volumes,
 		AutoRemove:   true,
@@ -84,6 +86,7 @@ func (d *Docker) StartWithCancel() (*StartedService, error) {
 			Image:        image.(string),
 			Env:          env,
 			ExposedPorts: portConfig.ExposedPorts,
+			Labels:       getLabels(d.Service, d.Caps),
 		},
 		&hostConfig,
 		&network.NetworkingConfig{}, "")
@@ -93,13 +96,13 @@ func (d *Docker) StartWithCancel() (*StartedService, error) {
 	browserContainerStartTime := time.Now()
 	browserContainerId := container.ID
 	videoContainerId := ""
-	log.Printf("[%d] [STARTING_CONTAINER] [%s] [%s]\n", requestId, image, browserContainerId)
+	log.Printf("[%d] [STARTING_CONTAINER] [%s] [%s]", requestId, image, browserContainerId)
 	err = cl.ContainerStart(ctx, browserContainerId, types.ContainerStartOptions{})
 	if err != nil {
 		removeContainer(ctx, cl, requestId, browserContainerId)
 		return nil, fmt.Errorf("start container: %v", err)
 	}
-	log.Printf("[%d] [CONTAINER_STARTED] [%s] [%s] [%v]\n", requestId, image, browserContainerId, time.Since(browserContainerStartTime))
+	log.Printf("[%d] [CONTAINER_STARTED] [%s] [%s] [%.2fs]", requestId, image, browserContainerId, util.SecondsSince(browserContainerStartTime))
 	stat, err := cl.ContainerInspect(ctx, browserContainerId)
 	if err != nil {
 		removeContainer(ctx, cl, requestId, browserContainerId)
@@ -126,8 +129,8 @@ func (d *Docker) StartWithCancel() (*StartedService, error) {
 		removeContainer(ctx, cl, requestId, browserContainerId)
 		return nil, fmt.Errorf("wait: %v", err)
 	}
-	log.Printf("[%d] [SERVICE_STARTED] [%s] [%s] [%v]\n", requestId, image, browserContainerId, time.Since(serviceStartTime))
-	log.Printf("[%d] [PROXY_TO] [%s] [%s] [%s]\n", requestId, image, browserContainerId, u.String())
+	log.Printf("[%d] [SERVICE_STARTED] [%s] [%s] [%.2fs]", requestId, image, browserContainerId, util.SecondsSince(serviceStartTime))
+	log.Printf("[%d] [PROXY_TO] [%s] [%s]", requestId, browserContainerId, u.String())
 	s := StartedService{
 		Url: u,
 		Container: &session.Container{
@@ -173,13 +176,21 @@ func getPortConfig(service *config.Browser, caps session.Caps, env Environment)
 		ExposedPorts: exposedPorts}, nil
 }
 
+const (
+	tag    = "tag"
+	labels = "labels"
+)
+
 func getLogConfig(logConfig ctr.LogConfig, caps session.Caps) ctr.LogConfig {
 	if logConfig.Config != nil {
-		const tag = "tag"
 		_, ok := logConfig.Config[tag]
 		if caps.TestName != "" && !ok {
 			logConfig.Config[tag] = caps.TestName
 		}
+		_, ok = logConfig.Config[labels]
+		if caps.Labels != "" && !ok {
+			logConfig.Config[labels] = caps.Labels
+		}
 	}
 	return logConfig
 }
@@ -189,7 +200,7 @@ func getTimeZone(service ServiceBase, caps session.Caps) *time.Location {
 	if caps.TimeZone != "" {
 		tz, err := time.LoadLocation(caps.TimeZone)
 		if err != nil {
-			log.Printf("[%d] [BAD_TIMEZONE] [%s]\n", service.RequestId, caps.TimeZone)
+			log.Printf("[%d] [BAD_TIMEZONE] [%s]", service.RequestId, caps.TimeZone)
 		} else {
 			timeZone = tz
 		}
@@ -229,6 +240,29 @@ func getExtraHosts(service *config.Browser, caps session.Caps) []string {
 	return extraHosts
 }
 
+func getLabels(service *config.Browser, caps session.Caps) map[string]string {
+	labels := make(map[string]string)
+	if caps.TestName != "" {
+		labels["name"] = caps.TestName
+	}
+	for k, v := range service.Labels {
+		labels[k] = v
+	}
+	if caps.Labels != "" {
+		for _, lbl := range strings.Split(caps.Labels, comma) {
+			kv := strings.SplitN(lbl, colon, 2)
+			if len(kv) == 2 {
+				key := kv[0]
+				value := kv[1]
+				labels[key] = value
+			} else {
+				labels[lbl] = ""
+			}
+		}
+	}
+	return labels
+}
+
 func getHostPort(env Environment, service *config.Browser, caps session.Caps, stat types.ContainerJSON, selenium nat.Port, vnc nat.Port) (string, string) {
 	seleniumHostPort, vncHostPort := "", ""
 	if env.IP == "" {
@@ -299,7 +333,7 @@ func startVideoContainer(ctx context.Context, cl *client.Client, requestId uint6
 		browserContainerName = defaultBrowserContainerName
 	}
 	env = append(env, fmt.Sprintf("BROWSER_CONTAINER_NAME=%s", browserContainerName))
-	log.Printf("[%d] [CREATING_VIDEO_CONTAINER] [%s]\n", requestId, videoContainerImage)
+	log.Printf("[%d] [CREATING_VIDEO_CONTAINER] [%s]", requestId, videoContainerImage)
 	videoContainer, err := cl.ContainerCreate(ctx,
 		&ctr.Config{
 			Image: videoContainerImage,
@@ -313,14 +347,14 @@ func startVideoContainer(ctx context.Context, cl *client.Client, requestId uint6
 	}
 
 	videoContainerId := videoContainer.ID
-	log.Printf("[%d] [STARTING_VIDEO_CONTAINER] [%s] [%s]\n", requestId, videoContainerImage, videoContainerId)
+	log.Printf("[%d] [STARTING_VIDEO_CONTAINER] [%s] [%s]", requestId, videoContainerImage, videoContainerId)
 	err = cl.ContainerStart(ctx, videoContainerId, types.ContainerStartOptions{})
 	if err != nil {
 		removeContainer(ctx, cl, requestId, browserContainer.ID)
 		removeContainer(ctx, cl, requestId, videoContainerId)
 		return "", fmt.Errorf("start video container: %v", err)
 	}
-	log.Printf("[%d] [VIDEO_CONTAINER_STARTED] [%s] [%s] [%v]\n", requestId, videoContainerImage, videoContainerId, time.Since(videoContainerStartTime))
+	log.Printf("[%d] [VIDEO_CONTAINER_STARTED] [%s] [%s] [%.2fs]", requestId, videoContainerImage, videoContainerId, util.SecondsSince(videoContainerStartTime))
 	return videoContainerId, nil
 }
 
@@ -333,21 +367,21 @@ func getVideoOutputDir(env Environment) string {
 }
 
 func stopVideoContainer(ctx context.Context, cli *client.Client, requestId uint64, containerId string) {
-	log.Printf("[%d] [STOPPING_VIDEO_CONTAINER] [%s]\n", requestId, containerId)
+	log.Printf("[%d] [STOPPING_VIDEO_CONTAINER] [%s]", requestId, containerId)
 	err := cli.ContainerKill(ctx, containerId, "TERM")
 	if err != nil {
-		log.Printf("[%d] [FAILED_TO_STOP_VIDEO_CONTAINER] [%s] [%v]\n", requestId, containerId, err)
+		log.Printf("[%d] [FAILED_TO_STOP_VIDEO_CONTAINER] [%s] [%v]", requestId, containerId, err)
 		return
 	}
-	log.Printf("[%d] [STOPPED_VIDEO_CONTAINER] [%s]\n", requestId, containerId)
+	log.Printf("[%d] [STOPPED_VIDEO_CONTAINER] [%s]", requestId, containerId)
 }
 
 func removeContainer(ctx context.Context, cli *client.Client, requestId uint64, id string) {
-	log.Printf("[%d] [REMOVING_CONTAINER] [%s]\n", requestId, id)
+	log.Printf("[%d] [REMOVING_CONTAINER] [%s]", requestId, id)
 	err := cli.ContainerRemove(ctx, id, types.ContainerRemoveOptions{Force: true, RemoveVolumes: true})
 	if err != nil {
-		log.Printf("[%d] [FAILED_TO_REMOVE_CONTAINER] [%s] [%v]\n", requestId, id, err)
+		log.Printf("[%d] [FAILED_TO_REMOVE_CONTAINER] [%s] [%v]", requestId, id, err)
 		return
 	}
-	log.Printf("[%d] [CONTAINER_REMOVED] [%s]\n", requestId, id)
+	log.Printf("[%d] [CONTAINER_REMOVED] [%s]", requestId, id)
 }
diff --git a/service/driver.go b/service/driver.go
index 91c657db..d534513e 100644
--- a/service/driver.go
+++ b/service/driver.go
@@ -9,6 +9,7 @@ import (
 	"time"
 
 	"errors"
+	"github.com/aerokube/selenoid/util"
 	"os"
 )
 
@@ -35,14 +36,14 @@ func (d *Driver) StartWithCancel() (*StartedService, error) {
 	if len(cmdLine) == 0 {
 		return nil, errors.New("configuration error: image is empty")
 	}
-	log.Printf("[%d] [ALLOCATING_PORT]\n", requestId)
+	log.Printf("[%d] [ALLOCATING_PORT]", requestId)
 	l, err := net.Listen("tcp", "localhost:0")
 	if err != nil {
 		return nil, fmt.Errorf("cannot bind to port: %v", err)
 	}
 	u := &url.URL{Scheme: "http", Host: l.Addr().String()}
 	_, port, _ := net.SplitHostPort(l.Addr().String())
-	log.Printf("[%d] [ALLOCATED_PORT] [%s]\n", requestId, port)
+	log.Printf("[%d] [ALLOCATED_PORT] [%s]", requestId, port)
 	cmdLine = append(cmdLine, fmt.Sprintf("--port=%s", port))
 	cmd := exec.Command(cmdLine[0], cmdLine[1:]...)
 	cmd.Env = append(cmd.Env, d.Service.Env...)
@@ -51,7 +52,7 @@ func (d *Driver) StartWithCancel() (*StartedService, error) {
 		cmd.Stderr = os.Stderr
 	}
 	l.Close()
-	log.Printf("[%d] [STARTING_PROCESS] [%s]\n", requestId, cmdLine)
+	log.Printf("[%d] [STARTING_PROCESS] [%s]", requestId, cmdLine)
 	s := time.Now()
 	err = cmd.Start()
 	if err != nil {
@@ -63,17 +64,17 @@ func (d *Driver) StartWithCancel() (*StartedService, error) {
 		d.stopProcess(cmd)
 		return nil, err
 	}
-	log.Printf("[%d] [PROCESS_STARTED] [%d] [%v]\n", requestId, cmd.Process.Pid, time.Since(s))
-	log.Printf("[%d] [PROXYING_REQUESTS] [%s]\n", requestId, u.String())
+	log.Printf("[%d] [PROCESS_STARTED] [%d] [%v]", requestId, cmd.Process.Pid, util.SecondsSince(s))
+	log.Printf("[%d] [PROXY_TO] [%s]", requestId, u.String())
 	return &StartedService{Url: u, Cancel: func() { d.stopProcess(cmd) }}, nil
 }
 
 func (d *Driver) stopProcess(cmd *exec.Cmd) {
-	log.Printf("[%d] [TERMINATING_PROCESS] [%d]\n", d.RequestId, cmd.Process.Pid)
+	log.Printf("[%d] [TERMINATING_PROCESS] [%d]", d.RequestId, cmd.Process.Pid)
 	err := stopProc(cmd)
 	if err != nil {
-		log.Printf("[%d] [FAILED_TO_TERMINATE_PROCESS] [%d]: %v\n", d.RequestId, cmd.Process.Pid, err)
+		log.Printf("[%d] [FAILED_TO_TERMINATE_PROCESS] [%d] [%v]", d.RequestId, cmd.Process.Pid, err)
 		return
 	}
-	log.Printf("[%d] [TERMINATED_PROCESS] [%d]\n", d.RequestId, cmd.Process.Pid)
+	log.Printf("[%d] [TERMINATED_PROCESS] [%d]", d.RequestId, cmd.Process.Pid)
 }
diff --git a/service/service.go b/service/service.go
index 07fb00be..2d24b590 100644
--- a/service/service.go
+++ b/service/service.go
@@ -67,7 +67,7 @@ type DefaultManager struct {
 func (m *DefaultManager) Find(caps session.Caps, requestId uint64) (Starter, bool) {
 	browserName := caps.Name
 	version := caps.Version
-	log.Printf("[%d] [LOCATING_SERVICE] [%s-%s]\n", requestId, browserName, version)
+	log.Printf("[%d] [LOCATING_SERVICE] [%s] [%s]", requestId, browserName, version)
 	service, version, ok := m.Config.Find(browserName, version)
 	serviceBase := ServiceBase{RequestId: requestId, Service: service}
 	if !ok {
@@ -88,7 +88,7 @@ func (m *DefaultManager) Find(caps session.Caps, requestId uint64) (Starter, boo
 		if m.Client == nil {
 			return nil, false
 		}
-		log.Printf("[%d] [USING_DOCKER] [%s-%s]\n", requestId, browserName, version)
+		log.Printf("[%d] [USING_DOCKER] [%s] [%s]", requestId, browserName, version)
 		return &Docker{
 			ServiceBase: serviceBase,
 			Environment: *m.Environment,
@@ -96,7 +96,7 @@ func (m *DefaultManager) Find(caps session.Caps, requestId uint64) (Starter, boo
 			Client:      m.Client,
 			LogConfig:   m.Config.ContainerLogs}, true
 	case []interface{}:
-		log.Printf("[%d] [USING_DRIVER] [%s-%s]\n", requestId, browserName, version)
+		log.Printf("[%d] [USING_DRIVER] [%s] [%s]", requestId, browserName, version)
 		return &Driver{ServiceBase: serviceBase, Environment: *m.Environment}, true
 	}
 	}
diff --git a/service_test.go b/service_test.go
index e8623813..a66743b9 100644
--- a/service_test.go
+++ b/service_test.go
@@ -159,6 +159,7 @@ func testConfig(env *service.Environment) *config.Config {
 				Tmpfs:   map[string]string{"/tmp": "size=128m"},
 				Port:    p,
 				Volumes: []string{"/test:/test"},
+				Labels:  map[string]string{"key": "value"},
 			},
 		},
 	}
@@ -237,6 +238,7 @@ func createDockerStarter(t *testing.T, env *service.Environment, cfg *config.Con
 		VideoScreenSize:       "1024x768",
 		VideoFrameRate:        25,
 		HostsEntries:          "example.com:192.168.0.1,test.com:192.168.0.2",
+		Labels:                "label1:some-value,label2",
 		ApplicationContainers: "one,two",
 		TimeZone:              "Europe/Moscow",
 		ContainerHostname:     "some-hostname",
diff --git a/session/session.go b/session/session.go
index f8bdf827..96370fa5 100644
--- a/session/session.go
+++ b/session/session.go
@@ -21,6 +21,7 @@ type Caps struct {
 	ContainerHostname     string                 `json:"containerHostname"`
 	ApplicationContainers string                 `json:"applicationContainers"`
 	HostsEntries          string                 `json:"hostsEntries"`
+	Labels                string                 `json:"labels"`
 	ExtensionCapabilities map[string]interface{} `json:"selenoid:options"`
 }
 
diff --git a/util/util.go b/util/util.go
new file mode 100644
index 00000000..f9e8ae9c
--- /dev/null
+++ b/util/util.go
@@ -0,0 +1,26 @@
+package util
+
+import (
+	"net"
+	"net/http"
+	"time"
+)
+
+func SecondsSince(start time.Time) float64 {
+	return float64(time.Now().Sub(start).Seconds())
+}
+
+func RequestInfo(r *http.Request) (string, string) {
+	user := ""
+	if u, _, ok := r.BasicAuth(); ok {
+		user = u
+	} else {
+		user = "unknown"
+	}
+	remote := r.Header.Get("X-Forwarded-For")
+	if remote != "" {
+		return user, remote
+	}
+	remote, _, _ = net.SplitHostPort(r.RemoteAddr)
+	return user, remote
+}