Skip to content

Commit

Permalink
Fix wrong mame in method
Browse files Browse the repository at this point in the history
  • Loading branch information
testillano authored and Eduardo Ramos Testillano (eramedu) committed Jul 23, 2023
1 parent 4b550d8 commit 61e4a78
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 7 deletions.
6 changes: 3 additions & 3 deletions include/ert/http2comm/Http2Server.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -133,12 +133,12 @@ class Http2Server
/**
* Gets the queue dispatcher number of scheduled threads
*/
int getQueueDispacherThreads() const;
int getQueueDispatcherThreads() const;

/**
* Gets the queue dispatcher size
*/
int getQueueDispacherSize() const;
int getQueueDispatcherSize() const;

/**
* Gets the queue dispatcher maximum size allowed on congestion control
Expand All @@ -148,7 +148,7 @@ class Http2Server
* queue dispatcher has no idle consumer threads and also, queue size is over this specific
* value.
*/
int getQueueDispacherMaxSize() const;
int getQueueDispatcherMaxSize() const;

/**
* Enable metrics
Expand Down
6 changes: 3 additions & 3 deletions src/Http2Server.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -68,15 +68,15 @@ int Http2Server::getQueueDispatcherBusyThreads() const {
return (queue_dispatcher_ ? queue_dispatcher_->getBusyThreads():0);
}

int Http2Server::getQueueDispacherThreads() const {
int Http2Server::getQueueDispatcherThreads() const {
return (queue_dispatcher_ ? queue_dispatcher_->getSize():0);
}

int Http2Server::getQueueDispacherSize() const {
int Http2Server::getQueueDispatcherSize() const {
return (queue_dispatcher_ ? queue_dispatcher_->getSize():0);
}

int Http2Server::getQueueDispacherMaxSize() const {
int Http2Server::getQueueDispatcherMaxSize() const {
return queue_dispatcher_max_size_;
}

Expand Down
2 changes: 1 addition & 1 deletion src/Stream.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ void Stream::appendData(const uint8_t* data, std::size_t len) {
}

void Stream::process(bool busyConsumers, int queueSize) {
reception(server_->getQueueDispacherMaxSize() >= 0 /* congestion control enabled */ && busyConsumers && queueSize > server_->getQueueDispacherMaxSize());
reception(server_->getQueueDispatcherMaxSize() >= 0 /* congestion control enabled */ && busyConsumers && queueSize > server_->getQueueDispatcherMaxSize());
commit();
}

Expand Down

0 comments on commit 61e4a78

Please sign in to comment.