Skip to content

Commit

Permalink
refine style
Browse files Browse the repository at this point in the history
  • Loading branch information
jenrryyou committed Sep 4, 2024
1 parent cc63f3e commit f2315ca
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion src/brpc/controller.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1414,7 +1414,7 @@ void Controller::HandleStreamConnection(Socket *host_socket) {
for (size_t i = 1; i < stream_num; ++i) {
Stream* extra_stream = (Stream *) ptrs[i]->conn();
_remote_stream_settings->set_stream_id(extra_stream_ids[i - 1]);
s->shareHostSocket(*extra_stream);
s->ShareHostSocket(*extra_stream);
extra_stream->SetConnected(_remote_stream_settings);
}
}
Expand Down
2 changes: 1 addition & 1 deletion src/brpc/stream.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -666,7 +666,7 @@ void Stream::Close(int error_code, const char* reason_fmt, ...) {
return TriggerOnConnectIfNeed();
}

int Stream::shareHostSocket(Stream& other_stream) {
int Stream::ShareHostSocket(Stream& other_stream) {
return other_stream.SetHostSocket(_host_socket);
}

Expand Down
2 changes: 1 addition & 1 deletion src/brpc/stream_impl.h
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ class BAIDU_CACHELINE_ALIGNMENT Stream : public SocketConnection {
__attribute__ ((__format__ (__printf__, 3, 4)));
void Close(int error_code, const char* reason_fmt, ...)
__attribute__ ((__format__ (__printf__, 3, 4)));
int shareHostSocket(Stream& other_stream);
int ShareHostSocket(Stream& other_stream);

private:
friend void StreamWait(StreamId stream_id, const timespec *due_time,
Expand Down

0 comments on commit f2315ca

Please sign in to comment.