Skip to content

Commit 98784c9

Browse files
eastspireeastspire
committed
Merge remote-tracking branch 'upstream/master'
2 parents c7ada5d + c588c09 commit 98784c9

File tree

121 files changed

+6714
-1424
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

121 files changed

+6714
-1424
lines changed

‎frameworks/Go/ronykit/src/go.mod‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ require (
2727
github.com/valyala/bytebufferpool v1.0.0 // indirect
2828
github.com/valyala/fasthttp v1.50.0 // indirect
2929
github.com/valyala/tcplisten v1.0.0 // indirect
30-
golang.org/x/net v0.23.0 // indirect
31-
golang.org/x/sys v0.18.0 // indirect
30+
golang.org/x/net v0.38.0 // indirect
31+
golang.org/x/sys v0.31.0 // indirect
3232
gopkg.in/yaml.v3 v3.0.1 // indirect
3333
)

‎frameworks/Go/ronykit/src/go.sum‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -62,13 +62,13 @@ github.com/valyala/fasthttp v1.50.0 h1:H7fweIlBm0rXLs2q0XbalvJ6r0CUPFWK3/bB4N13e
6262
github.com/valyala/fasthttp v1.50.0/go.mod h1:k2zXd82h/7UZc3VOdJ2WaUqt1uZ/XpXAfE9i+HBC3lA=
6363
github.com/valyala/tcplisten v1.0.0 h1:rBHj/Xf+E1tRGZyWIWwJDiRY0zc1Js+CV5DqwacVSA8=
6464
github.com/valyala/tcplisten v1.0.0/go.mod h1:T0xQ8SeCZGxckz9qRXTfG43PvQ/mcWh7FwZEA7Ioqkc=
65-
golang.org/x/net v0.23.0 h1:7EYJ93RZ9vYSZAIb2x3lnuvqO5zneoD6IvWjuhfxjTs=
66-
golang.org/x/net v0.23.0/go.mod h1:JKghWKKOSdJwpW2GEx0Ja7fmaKnMsbu+MWVZTokSYmg=
65+
golang.org/x/net v0.38.0 h1:vRMAPTMaeGqVhG5QyLJHqNDwecKTomGeqbnfZyKlBI8=
66+
golang.org/x/net v0.38.0/go.mod h1:ivrbrMbzFq5J41QOQh0siUuly180yBYtLp+CKbEaFx8=
6767
golang.org/x/sys v0.1.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
6868
golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
69-
golang.org/x/sys v0.18.0 h1:DBdB3niSjOA/O0blCZBqDefyWNYveAYMNF1Wum0DYQ4=
70-
golang.org/x/sys v0.18.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
71-
golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ=
69+
golang.org/x/sys v0.31.0 h1:ioabZlmFYtWhL+TRYpcnNlLwhyxaM9kWTDEmfnprqik=
70+
golang.org/x/sys v0.31.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
71+
golang.org/x/text v0.23.0 h1:D71I7dUrlY+VX0gQShAThNGHFxZ13dGLBHQLVl1mJlY=
7272
golang.org/x/tools v0.12.0 h1:YW6HUoUmYBpwSgyaGaZq1fHjrBjX1rlpZ54T6mu2kss=
7373
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
7474
gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=

‎frameworks/Kotlin/ktor/ktor-asyncdb/src/main/resources/logback.xml‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,11 +11,11 @@
1111
</appender>
1212

1313

14-
<root level="INFO">
14+
<root level="ERROR">
1515
<appender-ref ref="ASYNC"/>
1616
</root>
1717

18-
<logger name="org.eclipse.jetty" level="INFO"/>
19-
<logger name="io.netty" level="INFO"/>
18+
<logger name="org.eclipse.jetty" level="ERROR"/>
19+
<logger name="io.netty" level="ERROR"/>
2020

2121
</configuration>

‎frameworks/Kotlin/ktor/ktor-pgclient/src/main/resources/logback.xml‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,11 +11,11 @@
1111
</appender>
1212

1313

14-
<root level="INFO">
14+
<root level="ERROR">
1515
<appender-ref ref="ASYNC"/>
1616
</root>
1717

18-
<logger name="org.eclipse.jetty" level="INFO"/>
19-
<logger name="io.netty" level="INFO"/>
18+
<logger name="org.eclipse.jetty" level="ERROR"/>
19+
<logger name="io.netty" level="ERROR"/>
2020

2121
</configuration>

‎frameworks/Kotlin/ktor/ktor-r2dbc/src/main/resources/logback.xml‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -10,12 +10,12 @@
1010
<appender-ref ref="STDOUT" />
1111
</appender>
1212

13-
<root level="WARN">
13+
<root level="ERROR">
1414
<appender-ref ref="ASYNC"/>
1515
</root>
1616

17-
<logger name="org.eclipse.jetty" level="WARN"/>
18-
<logger name="io.netty" level="WARN"/>
19-
<logger name="io.r2dbc" level="WARN"/>
20-
<logger name="reactor" level="WARN"/>
17+
<logger name="org.eclipse.jetty" level="ERROR"/>
18+
<logger name="io.netty" level="ERROR"/>
19+
<logger name="io.r2dbc" level="ERROR"/>
20+
<logger name="reactor" level="ERROR"/>
2121
</configuration>

‎frameworks/Kotlin/ktor/ktor/src/main/resources/logback.xml‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,11 +11,11 @@
1111
</appender>
1212

1313

14-
<root level="INFO">
14+
<root level="ERROR">
1515
<appender-ref ref="ASYNC"/>
1616
</root>
1717

18-
<logger name="org.eclipse.jetty" level="INFO"/>
19-
<logger name="io.netty" level="INFO"/>
18+
<logger name="org.eclipse.jetty" level="ERROR"/>
19+
<logger name="io.netty" level="ERROR"/>
2020

2121
</configuration>

‎frameworks/Python/aiohttp/app/main.py‎

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,11 @@ def pg_dsn(dialect=None) -> str:
3737
)
3838
return url.render_as_string(hide_password=False)
3939

40+
class NoResetConnection(asyncpg.Connection):
41+
__slots__ = ()
42+
43+
def get_reset_query(self):
44+
return ''
4045

4146
async def db_ctx(app: web.Application):
4247
# number of gunicorn workers = multiprocessing.cpu_count() as per gunicorn_conf.py
@@ -52,7 +57,7 @@ async def db_ctx(app: web.Application):
5257
app['db_session'] = async_sessionmaker(engine)
5358
else:
5459
dsn = pg_dsn()
55-
app['pg'] = await asyncpg.create_pool(dsn=dsn, min_size=min_size, max_size=max_size, loop=app.loop)
60+
app['pg'] = await asyncpg.create_pool(dsn=dsn, min_size=min_size, max_size=max_size, loop=app.loop, connection_class=NoResetConnection)
5661

5762
yield
5863

‎frameworks/Python/aiohttp/app/views.py‎

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ async def single_database_query_raw(request):
6666
id_ = randint(1, 10000)
6767

6868
async with request.app['pg'].acquire() as conn:
69-
r = await conn.fetchval('SELECT id,randomnumber FROM world WHERE id = $1', id_)
69+
r = await conn.fetchval(READ_ROW_SQL, id_)
7070
return json_response({'id': id_, 'randomNumber': r})
7171

7272

@@ -96,11 +96,10 @@ async def multiple_database_queries_raw(request):
9696

9797
result = []
9898
async with request.app['pg'].acquire() as conn:
99-
stmt = await conn.prepare(READ_ROW_SQL)
10099
for id_ in ids:
101100
result.append({
102101
'id': id_,
103-
'randomNumber': await stmt.fetchval(id_),
102+
'randomNumber': await conn.fetchval(READ_ROW_SQL, id_),
104103
})
105104
return json_response(result)
106105

@@ -160,10 +159,9 @@ async def updates_raw(request):
160159
worlds = [{'id': row_id, 'randomNumber': number} for row_id, number in updates]
161160

162161
async with request.app['pg'].acquire() as conn:
163-
stmt = await conn.prepare(READ_ROW_SQL)
164162
for id_, _ in updates:
165163
# the result of this is the int previous random number which we don't actually use
166-
await stmt.fetchval(id_)
164+
await conn.fetchval(READ_ROW_SQL, id_)
167165
await conn.executemany(WRITE_ROW_SQL, updates)
168166

169167
return json_response(worlds)

‎frameworks/Rust/hyperlane/Cargo.lock‎

Lines changed: 1 addition & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎frameworks/Rust/hyperlane/src/server.rs‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,8 @@ use tokio::runtime::{Builder, Runtime};
33

44
fn runtime() -> Runtime {
55
Builder::new_multi_thread()
6+
.worker_threads(get_thread_count() >> 1)
7+
.thread_stack_size(1_048_576)
68
.worker_threads(get_thread_count() >> 1)
79
.thread_stack_size(1_048_576)
810
.max_blocking_threads(5120)

0 commit comments

Comments
 (0)