-
Notifications
You must be signed in to change notification settings - Fork 47
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
# Conflicts: # src/main/java/ru/vk/itmo/test/pelogeikomakar/Convertor.java # src/main/java/ru/vk/itmo/test/pelogeikomakar/DaoHttpServer.java # src/main/java/ru/vk/itmo/test/pelogeikomakar/MainServ.java # src/main/java/ru/vk/itmo/test/pelogeikomakar/ServiceImpl.java
- Loading branch information
Showing
2,080 changed files
with
2,354,629 additions
and
10,093 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -42,4 +42,8 @@ build | |
| .Spotlight-V100 | ||
| .Trashes | ||
| ehthumbs.db | ||
| Thumbs.db | ||
| Thumbs.db | ||
|
|
||
| # Ignoring database # | ||
| ###################### | ||
| db | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,272 @@ | ||
| <!DOCTYPE html> | ||
| <html lang='en'> | ||
| <head> | ||
| <meta charset='utf-8'> | ||
| <style> | ||
| body {margin: 0; padding: 10px 10px 22px 10px; background-color: #ffffff} | ||
| h1 {margin: 5px 0 0 0; font-size: 18px; font-weight: normal; text-align: center} | ||
| header {margin: -24px 0 5px 0; line-height: 24px} | ||
| button {font: 12px sans-serif; cursor: pointer} | ||
| p {position: fixed; bottom: 0; margin: 0; padding: 2px 3px 2px 3px; outline: 1px solid #ffc000; display: none; overflow: hidden; white-space: nowrap; background-color: #ffffe0} | ||
| a {color: #0366d6} | ||
| #hl {position: absolute; display: none; overflow: hidden; white-space: nowrap; pointer-events: none; background-color: #ffffe0; outline: 1px solid #ffc000; height: 15px} | ||
| #hl span {padding: 0 3px 0 3px} | ||
| #status {left: 0} | ||
| #match {right: 0} | ||
| #reset {cursor: pointer} | ||
| #canvas {width: 100%; height: 112px} | ||
| </style> | ||
| </head> | ||
| <body style='font: 12px Verdana, sans-serif'> | ||
| <h1>CPU profile</h1> | ||
| <header style='text-align: left'><button id='reverse' title='Reverse'>🔻</button> <button id='search' title='Search'>🔍</button></header> | ||
| <header style='text-align: right'>Produced by <a href='https://github.com/async-profiler/async-profiler'>async-profiler</a></header> | ||
| <canvas id='canvas'></canvas> | ||
| <div id='hl'><span></span></div> | ||
| <p id='status'></p> | ||
| <p id='match'>Matched: <span id='matchval'></span> <span id='reset' title='Clear'>❌</span></p> | ||
| <script> | ||
| // Copyright The async-profiler authors | ||
| // SPDX-License-Identifier: Apache-2.0 | ||
| 'use strict'; | ||
| let root, rootLevel, px, pattern; | ||
| let level0 = 0, left0 = 0, width0 = 0; | ||
| let reverse = false; | ||
| const levels = Array(7); | ||
| for (let h = 0; h < levels.length; h++) { | ||
| levels[h] = []; | ||
| } | ||
|
|
||
| const canvas = document.getElementById('canvas'); | ||
| const c = canvas.getContext('2d'); | ||
| const hl = document.getElementById('hl'); | ||
| const status = document.getElementById('status'); | ||
|
|
||
| const canvasWidth = canvas.offsetWidth; | ||
| const canvasHeight = canvas.offsetHeight; | ||
| canvas.style.width = canvasWidth + 'px'; | ||
| canvas.width = canvasWidth * (devicePixelRatio || 1); | ||
| canvas.height = canvasHeight * (devicePixelRatio || 1); | ||
| if (devicePixelRatio) c.scale(devicePixelRatio, devicePixelRatio); | ||
| c.font = document.body.style.font; | ||
|
|
||
| const palette = [ | ||
| [0xb2e1b2, 20, 20, 20], | ||
| [0x50e150, 30, 30, 30], | ||
| [0x50cccc, 30, 30, 30], | ||
| [0xe15a5a, 30, 40, 40], | ||
| [0xc8c83c, 30, 30, 10], | ||
| [0xe17d00, 30, 30, 0], | ||
| [0xcce880, 20, 20, 20], | ||
| ]; | ||
|
|
||
| function getColor(p) { | ||
| const v = Math.random(); | ||
| return '#' + (p[0] + ((p[1] * v) << 16 | (p[2] * v) << 8 | (p[3] * v))).toString(16); | ||
| } | ||
|
|
||
| function f(key, level, left, width, inln, c1, int) { | ||
| levels[level0 = level].push({left: left0 += left, width: width0 = width || width0, | ||
| color: getColor(palette[key & 7]), title: cpool[key >>> 3], | ||
| details: (int ? ', int=' + int : '') + (c1 ? ', c1=' + c1 : '') + (inln ? ', inln=' + inln : '') | ||
| }); | ||
| } | ||
|
|
||
| function u(key, width, inln, c1, int) { | ||
| f(key, level0 + 1, 0, width, inln, c1, int) | ||
| } | ||
|
|
||
| function n(key, width, inln, c1, int) { | ||
| f(key, level0, width0, width, inln, c1, int) | ||
| } | ||
|
|
||
| function samples(n) { | ||
| return n === 1 ? '1 sample' : n.toString().replace(/\B(?=(\d{3})+(?!\d))/g, ',') + ' samples'; | ||
| } | ||
|
|
||
| function pct(a, b) { | ||
| return a >= b ? '100' : (100 * a / b).toFixed(2); | ||
| } | ||
|
|
||
| function findFrame(frames, x) { | ||
| let left = 0; | ||
| let right = frames.length - 1; | ||
|
|
||
| while (left <= right) { | ||
| const mid = (left + right) >>> 1; | ||
| const f = frames[mid]; | ||
|
|
||
| if (f.left > x) { | ||
| right = mid - 1; | ||
| } else if (f.left + f.width <= x) { | ||
| left = mid + 1; | ||
| } else { | ||
| return f; | ||
| } | ||
| } | ||
|
|
||
| if (frames[left] && (frames[left].left - x) * px < 0.5) return frames[left]; | ||
| if (frames[right] && (x - (frames[right].left + frames[right].width)) * px < 0.5) return frames[right]; | ||
|
|
||
| return null; | ||
| } | ||
|
|
||
| function search(r) { | ||
| if (r === true && (r = prompt('Enter regexp to search:', '')) === null) { | ||
| return; | ||
| } | ||
|
|
||
| pattern = r ? RegExp(r) : undefined; | ||
| const matched = render(root, rootLevel); | ||
| document.getElementById('matchval').textContent = pct(matched, root.width) + '%'; | ||
| document.getElementById('match').style.display = r ? 'inline-block' : 'none'; | ||
| } | ||
|
|
||
| function render(newRoot, newLevel) { | ||
| if (root) { | ||
| c.fillStyle = '#ffffff'; | ||
| c.fillRect(0, 0, canvasWidth, canvasHeight); | ||
| } | ||
|
|
||
| root = newRoot || levels[0][0]; | ||
| rootLevel = newLevel || 0; | ||
| px = canvasWidth / root.width; | ||
|
|
||
| const x0 = root.left; | ||
| const x1 = x0 + root.width; | ||
| const marked = []; | ||
|
|
||
| function mark(f) { | ||
| return marked[f.left] >= f.width || (marked[f.left] = f.width); | ||
| } | ||
|
|
||
| function totalMarked() { | ||
| let total = 0; | ||
| let left = 0; | ||
| Object.keys(marked).sort(function(a, b) { return a - b; }).forEach(function(x) { | ||
| if (+x >= left) { | ||
| total += marked[x]; | ||
| left = +x + marked[x]; | ||
| } | ||
| }); | ||
| return total; | ||
| } | ||
|
|
||
| function drawFrame(f, y, alpha) { | ||
| if (f.left < x1 && f.left + f.width > x0) { | ||
| c.fillStyle = pattern && f.title.match(pattern) && mark(f) ? '#ee00ee' : f.color; | ||
| c.fillRect((f.left - x0) * px, y, f.width * px, 15); | ||
|
|
||
| if (f.width * px >= 21) { | ||
| const chars = Math.floor(f.width * px / 7); | ||
| const title = f.title.length <= chars ? f.title : f.title.substring(0, chars - 2) + '..'; | ||
| c.fillStyle = '#000000'; | ||
| c.fillText(title, Math.max(f.left - x0, 0) * px + 3, y + 12, f.width * px - 6); | ||
| } | ||
|
|
||
| if (alpha) { | ||
| c.fillStyle = 'rgba(255, 255, 255, 0.5)'; | ||
| c.fillRect((f.left - x0) * px, y, f.width * px, 15); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| for (let h = 0; h < levels.length; h++) { | ||
| const y = reverse ? h * 16 : canvasHeight - (h + 1) * 16; | ||
| const frames = levels[h]; | ||
| for (let i = 0; i < frames.length; i++) { | ||
| drawFrame(frames[i], y, h < rootLevel); | ||
| } | ||
| } | ||
|
|
||
| return totalMarked(); | ||
| } | ||
|
|
||
| function unpack(cpool) { | ||
| for (let i = 1; i < cpool.length; i++) { | ||
| cpool[i] = cpool[i - 1].substring(0, cpool[i].charCodeAt(0) - 32) + cpool[i].substring(1); | ||
| } | ||
| } | ||
|
|
||
| canvas.onmousemove = function() { | ||
| const h = Math.floor((reverse ? event.offsetY : (canvasHeight - event.offsetY)) / 16); | ||
| if (h >= 0 && h < levels.length) { | ||
| const f = findFrame(levels[h], event.offsetX / px + root.left); | ||
| if (f) { | ||
| if (f !== root) getSelection().removeAllRanges(); | ||
| hl.style.left = (Math.max(f.left - root.left, 0) * px + canvas.offsetLeft) + 'px'; | ||
| hl.style.width = (Math.min(f.width, root.width) * px) + 'px'; | ||
| hl.style.top = ((reverse ? h * 16 : canvasHeight - (h + 1) * 16) + canvas.offsetTop) + 'px'; | ||
| hl.firstChild.textContent = f.title; | ||
| hl.style.display = 'block'; | ||
| canvas.title = f.title + '\n(' + samples(f.width) + f.details + ', ' + pct(f.width, levels[0][0].width) + '%)'; | ||
| canvas.style.cursor = 'pointer'; | ||
| canvas.onclick = function() { | ||
| if (f !== root) { | ||
| render(f, h); | ||
| canvas.onmousemove(); | ||
| } | ||
| }; | ||
| status.textContent = 'Function: ' + canvas.title; | ||
| status.style.display = 'inline-block'; | ||
| return; | ||
| } | ||
| } | ||
| canvas.onmouseout(); | ||
| } | ||
|
|
||
| canvas.onmouseout = function() { | ||
| hl.style.display = 'none'; | ||
| status.style.display = 'none'; | ||
| canvas.title = ''; | ||
| canvas.style.cursor = ''; | ||
| canvas.onclick = null; | ||
| } | ||
|
|
||
| canvas.ondblclick = function() { | ||
| getSelection().selectAllChildren(hl); | ||
| } | ||
|
|
||
| document.getElementById('reverse').onclick = function() { | ||
| reverse = !reverse; | ||
| render(); | ||
| } | ||
|
|
||
| document.getElementById('search').onclick = function() { | ||
| search(true); | ||
| } | ||
|
|
||
| document.getElementById('reset').onclick = function() { | ||
| search(false); | ||
| } | ||
|
|
||
| window.onkeydown = function() { | ||
| if (event.ctrlKey && event.keyCode === 70) { | ||
| event.preventDefault(); | ||
| search(true); | ||
| } else if (event.keyCode === 27) { | ||
| search(false); | ||
| } | ||
| } | ||
|
|
||
| const cpool = [ | ||
| 'all', | ||
| ' Thread::call_run', | ||
| ' WatcherThread::run', | ||
| '/sleep', | ||
| ' clock_gettime@@GLIBC_2.17', | ||
| ' start_thread', | ||
| ' thread_native_entry' | ||
| ]; | ||
| unpack(cpool); | ||
|
|
||
| n(3,1) | ||
| u(43) | ||
| u(52) | ||
| u(12) | ||
| u(20) | ||
| u(28) | ||
| u(35) | ||
|
|
||
| search(); | ||
| </script></body></html> |
30 changes: 30 additions & 0 deletions
30
src/main/java/ru/vk/itmo/test/abramovilya/NodesCommunicationHandler.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,30 @@ | ||
| package ru.vk.itmo.test.abramovilya; | ||
|
|
||
| import one.nio.http.HttpClient; | ||
| import one.nio.http.Response; | ||
| import ru.vk.itmo.ServiceConfig; | ||
|
|
||
| import java.util.Map; | ||
| import java.util.Optional; | ||
|
|
||
| public final class NodesCommunicationHandler { | ||
| private NodesCommunicationHandler() { | ||
| } | ||
|
|
||
| static Optional<Response> getResponseFromAnotherNode(int nodeNumber, Server.ResponseProducer responseProducer, | ||
| ServiceConfig config, Map<String, HttpClient> httpClients) { | ||
| String nodeUrl = config.clusterUrls().get(nodeNumber); | ||
| if (nodeUrl.equals(config.selfUrl())) { | ||
| return Optional.empty(); | ||
| } | ||
| HttpClient client = httpClients.get(nodeUrl); | ||
| try { | ||
| return Optional.of(responseProducer.getResponse(client)); | ||
| } catch (InterruptedException e) { | ||
| Thread.currentThread().interrupt(); | ||
| return Optional.of(new Response(Response.INTERNAL_ERROR, Response.EMPTY)); | ||
| } catch (Exception e) { | ||
| return Optional.of(new Response(Response.INTERNAL_ERROR, Response.EMPTY)); | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.