公开(公告)号：US10768983B2

公开(公告)日：2020-09-08

申请号：US13841588

申请日：2013-03-15

Applicant: salesforce.com, inc.

Inventor： Xiaodan Wang ,  John Buisson ,  Vijayanth Devadhar ,  Praveen Murugesan

IPC: G06F9/50 ,  G06Q30/08 ,  H04L12/26 ,  H04L12/911 ,  H04L12/24 ,  H04L12/863 ,  G06F21/40

Abstract: In accordance with embodiments, there are provided mechanisms and methods for facilitating a quorum-based coordination of broker health for management of resources for application servers in an on-demand services environment. In one embodiment and by way of example, a method includes monitoring, via health checkers, health of a cluster of brokers in a distributed environment having application servers in communication over a network, receiving an indication from at least one health checker that a broker is failing, wherein the broker is associated with a cluster of worker nodes, collecting health status reports relating to the broker from the health checkers, examining the health status reports based on a quorum-based voting policy, and classifying the broker as unhealthy if, based on the quorum-based voting policy, a percentage of the health status reports regards the broker as failed, wherein the percentage is greater than a first threshold percentage.

公开(公告)号：US10693709B2

公开(公告)日：2020-06-23

申请号：US15937945

申请日：2018-03-28

Applicant: salesforce.com, inc.

Inventor： Mikhail Chainani ,  Vijay Devadhar ,  William Dumaresq ,  Venkat Chandrasekaran ,  Jia Chen ,  Utsavi Benani ,  Xiaodan Wang

IPC: G06F15/173 ,  G06F15/16 ,  H04L12/24 ,  G06F15/177

Abstract: A system may identify gap events in a change detection stream. When changes in data are transmitted to a downstream system, the system may identify intermittent portions of the transmission where data is missing (e.g., a gap event). In some examples, a gap event may be caused by system maintenance or one or more system errors. After identifying the gap event, the system may bridge the gap event using metadata associated with the gap event. The associated metadata may be transmitted (e.g., via a gap event identification message) to the downstream system, which may prevent the downstream system from experiencing computational inefficiencies due to the gap event.

公开(公告)号：US20190236201A1

公开(公告)日：2019-08-01

申请号：US15885512

申请日：2018-01-31

Applicant: salesforce.com, inc.

Inventor： Xiaodan Wang ,  Mikhail Chainani ,  Alan Arbizu ,  Ashwini Bijwe

IPC: G06F17/30

CPC classification number: G06F16/278 ,  G06F16/2272 ,  G06F16/2282 ,  G06F16/2453

Abstract: Techniques are disclosed relating to processing data stored within database tables in a parallelized manner. In various embodiments, a computer system maintains a database having a database table storing data for a plurality of tenants and an index structure storing indexes for accessing data stored in the database table. In some embodiments, the computer system receives, from a particular tenant, a request to perform a task that includes operating on particular data. In some embodiments, the computer system determines a portion of the index structure corresponding to the particular tenant and divides a range of indexes within that portion into a plurality of index sub-ranges. In various embodiments, the computer system processes portions of the task in parallel by determining an index sub-range for each of a plurality of threads and causing each of the threads to operate on a portion of the particular data specified by its index sub-range.

公开(公告)号：US20190236150A1

公开(公告)日：2019-08-01

申请号：US15882266

申请日：2018-01-29

Applicant: salesforce.com, inc.

Inventor： Ilya Zaslavsky ,  Mikhail Chainani ,  Alex Ovesea ,  Vijayanth Devadhar ,  Xiaodan Wang ,  Alan Arbizu

IPC: G06F17/30 ,  G06F9/455

Abstract: Migration specific action requests to perform a set of migration specific actions are sent from a source system instance to a target system instance. Migration specific action responses are received from the target system instance. Based on the migration specific action responses, traffic lights for resource utilization of the target system instance are determined. Based on the traffic lights, a concurrency limit is determined for the specific time. The concurrency limit is applied to scale a total number of ongoing migration specific actions to be requested of the target system instance at the specific time.

公开(公告)号：US20190235918A1

公开(公告)日：2019-08-01

申请号：US15882194

申请日：2018-01-29

Applicant: salesforce.com, inc.

Inventor： Chen Liu ,  Ilya Zaslavsky ,  Alex Ovesea ,  Mikhail Chainani ,  Xiaodan Wang ,  Sridevi Gopala Krishnan

IPC: G06F9/48 ,  G06F9/455 ,  G06F3/06 ,  G06F11/34

CPC classification number: G06F9/4856 ,  G06F3/0647 ,  G06F3/067 ,  G06F9/45558 ,  G06F11/3442 ,  G06F2009/4557

Abstract: A request for an organization migration to move application data and application services of an organization hosted at a source system instance in a multi-tenant computing system to a target system instance in the multi-tenant computing system is received. Based on operational parameters, a time window is selected to execute the organization migration. Computing resource usages of one or both of the source and target system instances in the selected time window are monitored. If computing resources are available, the organization migration is enqueued.

公开(公告)号：US10169090B2

公开(公告)日：2019-01-01

申请号：US14634289

申请日：2015-02-27

Applicant: salesforce.com, inc.

Inventor： Xiaodan Wang

IPC: G06F9/455 ,  G06F9/50 ,  G06F17/30 ,  H04L12/755 ,  H04L12/747 ,  H04L12/24

Abstract: In accordance with embodiments, there are provided mechanisms and methods for facilitating tiered service model-based fair allocation of resources for application servers in multi-tenant environments. In one embodiment and by way of example, a method includes collecting, by and incorporating into the database system, data relating to job types associated with one or more tenants of a plurality of tenants within a multi-tenant database system, computing, based on the data, an actual resource use and an expected resource allocation associated with each job type, and assigning classifications to the job types based on their corresponding actual resource use and the expected resource allocation. The method may further include routing the job types between tiers based on the assigned classifications, where the routing includes at least one of promoting, demoting, and maintaining one or more tiers for the job types.

公开(公告)号：US09813516B2

公开(公告)日：2017-11-07

申请号：US14614146

申请日：2015-02-04

Applicant: salesforce.com, inc.

Inventor： Xiaodan Wang

IPC: G06F15/173 ,  H04L29/08 ,  H04L12/24 ,  G06F17/30 ,  H04L12/26

CPC classification number: H04L67/2809 ,  G06F17/30584 ,  H04L41/0668 ,  H04L43/0817 ,  H04L67/1002

Abstract: Embodiments regard transparent sharding of traffic across messaging brokers. An embodiment of a method of sharding message traffic across messaging brokers includes providing a message sharding service for message sharding among a plurality of registered message brokers, wherein providing the message sharding service includes applying a current message sharding strategy; and sharding messages among the registered message brokers according to the current message sharding strategy, including registering the message brokers and assigning message queues to registered message brokers according to the current message sharding strategy; wherein the current message sharding strategy is one of a plurality of message sharding strategies.

公开(公告)号：US09529626B2

公开(公告)日：2016-12-27

申请号：US13841417

申请日：2013-03-15

Applicant: salesforce.com,inc.

Inventor： Xiaodan Wang ,  Vijayanth Devadhar ,  Praveen Murugesan

IPC: H04L9/32 ,  G06F15/173 ,  G06F17/30 ,  G06F21/00 ,  G06F9/50 ,  G06Q30/08 ,  H04L12/26 ,  H04L12/911

CPC classification number: G06F9/50 ,  G06F9/5027 ,  G06F2209/508 ,  G06Q30/08 ,  H04L43/08 ,  H04L47/70

Abstract: In accordance with embodiments, there are provided mechanisms and methods for facilitating a fair allocation and usage of thread resources for user messages according to one embodiment in an on-demand services environment. In one embodiment and by way of example, a method includes tracking resource usage associated with a plurality of messages performed and completed in response to requests placed by a user via a user interface at a computing device, where the tracking includes recording an amount of resources consumed by each completed message. The method may further include classifying the plurality of messages into job types based on the tracked resource usage associated with the plurality of messages, and enforcing, based on the classification of the messages, a message selection process to ensure equitable distribution of resources to subsequently received messages.

Abstract translation: 根据实施例，提供了根据一个实施例在按需服务环境中促进用户消息的线程资源的公平分配和使用的机制和方法。 在一个实施例中，作为示例，一种方法包括跟踪与响应于用户经由计算设备处的用户界面发出的请求执行和完成的多个消息相关联的资源使用，其中跟踪包括记录资源量 每个完成的消息消耗。 该方法可以进一步包括基于与多个消息相关联的跟踪资源使用将多个消息分类为作业类型，并且基于消息的分类来执行消息选择过程以确保资源的公平分配以便随后接收 消息。

公开(公告)号：US20160055042A1

公开(公告)日：2016-02-25

申请号：US14661206

申请日：2015-03-18

Applicant: salesforce.com, inc.

Inventor： Hui Lam Kwong ,  Xiaodan Wang ,  Vipul Modani ,  John B. Buisson

IPC: G06F9/54 ,  G06F9/50

CPC classification number: G06F9/546 ,  G06F9/5083 ,  G06F2209/547 ,  H04L67/1008 ,  H04L67/1029 ,  H04L67/2842

Abstract: A messaging system implements messaging among application servers and databases, utilizing other servers that implement messaging brokers. A large flood of incoming messages can bring down messaging brokers by overflowing the message queues, negatively impacting performance of the overall system. This disclosure in some embodiments detects and identifies “flooders” in a timely manner and isolates their message traffic to dedicated queues to avoid impacting other system users. Subsequently, a preferred system de-allocates the queues and returns the messaging system to normal operation when flooding conditions subside, and “sweeps” up any remaining orphan messages.

Abstract translation: 消息系统在应用服务器和数据库之间实现消息传递，利用实现消息传递代理的其他服务器。 大量传入的消息可以通过溢出消息队列来消除消息传递代理，从而对整个系统的性能产生负面影响。 在一些实施例中的本公开以及时的方式检测和识别“淹没器”，并将其消息业务隔离到专用队列，以避免影响其他系统用户。 随后，优选的系统取消分配队列，并且当洪泛条件消退时将消息收发系统返回到正常操作，并且“扫描”任何剩余的孤儿消息。

公开(公告)号：US09268605B2

公开(公告)日：2016-02-23

申请号：US13841713

申请日：2013-03-15

Applicant: salesforce.com,inc.

Inventor： Xiaodan Wang ,  Vijayanth Devadhar ,  Praveen Murugesan

IPC: G06F9/46 ,  G06F15/173 ,  G06F9/50 ,  G06Q30/08 ,  H04L12/26 ,  H04L12/911

CPC classification number: G06F9/50 ,  G06F9/5027 ,  G06F2209/508 ,  G06Q30/08 ,  H04L43/08 ,  H04L47/70

Abstract: In accordance with embodiments, there are provided mechanisms and methods for facilitating sliding window resource tracking in message queues for fair management of resources for application servers in an on-demand services environment. In one embodiment and by way of example, a method includes monitoring, in real-time, in-flight jobs in message queues for incoming jobs from organizations in a distributed environment having application servers in communication over a network, applying local sliding windows to the message queues to estimate wait time associated with each incoming job in a message queue. A local sliding window may include segment of time being monitored in each message queue for estimating the wait time. The method may further include allocating, in real-time, based on the estimated wait time, thread resources to one or more of the incoming jobs associated with the one or more of the organizations.

Abstract translation: 根据实施例，提供了用于促进消息队列中的滑动窗口资源跟踪以用于按需服务环境中的应用服务器的资源的公平管理的机制和方法。 在一个实施例中，作为示例，一种方法包括实时地监视来自具有通过网络通信的应用服务器的分布式环境中的组织的来自作业的消息队列中的飞行中作业，将本地滑动窗口应用于 消息队列来估计与消息队列中的每个传入作业相关联的等待时间。 本地滑动窗口可以包括在每个消息队列中被监视的时间段，用于估计等待时间。 该方法可以进一步包括实时地基于估计的等待时间将线程资源分配给与一个或多个组织相关联的一个或多个进入作业。