CN119966858B

CN119966858B - Method, device, equipment and medium for scheduling equipment for registering streaming station by OLT (optical line terminal)

Info

Publication number: CN119966858B
Application number: CN202510415694.3A
Authority: CN
Inventors: 李娟�; 王波; 廖雄
Original assignee: Sichuan Tianyi Comheart Telecom Co Ltd
Current assignee: Sichuan Tianyi Comheart Telecom Co Ltd
Priority date: 2025-04-03
Filing date: 2025-04-03
Publication date: 2025-06-13
Anticipated expiration: 2045-04-03
Also published as: CN119966858A

Abstract

The application provides an equipment scheduling method, device, equipment and medium for an OLT registration streaming station, relates to the technical field of equipment debugging, and is used for solving the control problem of different types of external equipment on the OLT registration streaming station. The method is applied to a UDP server, the UDP server is connected with a client of an OLT registration streaming station, the OLT registration streaming station is integrated with a plurality of test devices, the UDP server is integrated with interfaces of the plurality of test devices, the method comprises the steps of receiving UDP messages sent by the client, analyzing the UDP messages to obtain a plurality of parameters, determining target test devices from the plurality of test devices according to protocol types, calling the target test devices to execute corresponding operations, and sending confirmation messages to the client. The UDP server is used for controlling the OLT to register a plurality of externally connected test devices of the streaming station in a centralized manner, so that the control problem of different types of externally connected devices is solved.

Description

Method, device, equipment and medium for scheduling equipment for registering streaming station by OLT (optical line terminal)

Technical Field

The application relates to the technical field of equipment debugging, and provides an equipment scheduling method, device, equipment and medium for registering a streaming station by an OLT.

Background

Fiber-to-room (Fiber To The Room, FTTR) is a novel fiber broadband access technology, in which a light cat converts external fiber signals into signals usable by a home network, and a convergence gateway is responsible for distributing network signals from the light cat to terminal devices in the respective rooms.

In the production process of the Optical cat product, the OLT registration and streaming station is the last procedure of production assembly measurement, and aims to simulate the actual use of the Optical cat, and an Optical network terminal (Optical Network Terminal, ONT) and an Optical network unit (Optical Network Unit, ONT) are connected into an Optical line terminal (Optical LINE TERMINAL, OLT) to finish the authentication and configuration process, so that the actual experience quality of a user after the service is opened is ensured.

In order to optimize the process flow of production and improve efficiency, BOB testing and voice testing can be combined into the OLT registration streaming station. However, the BOB device required for the BOB test and the voice card device required for the voice test may come from a plurality of different manufacturers, the communication modes of each manufacturer are different, the developed application programming interfaces (Application Programming Interface, APIs) are also different, and the production and test program provided by the streaming station manufacturer cannot develop the control interface of the third-party external device, so how to solve the control problem of different kinds of devices is a problem to be solved.

Disclosure of Invention

The application provides an equipment scheduling method, device and medium for an OLT registration streaming station, which are used for solving the control problem of different types of external equipment on the OLT registration streaming station.

In a first aspect, an apparatus scheduling method for an OLT registration streaming station is provided, and is applied to a UDP server, where the UDP server is connected to a client of the OLT registration streaming station, the OLT registration streaming station is integrated with a plurality of test apparatuses, and the UDP server is integrated with interfaces of the plurality of test apparatuses, and the method includes:

Receiving UDP messages sent by the client;

analyzing the UDP message to obtain a plurality of parameters, wherein the parameters comprise protocol types;

Determining a target test device from the plurality of test devices according to the protocol type;

And calling the target test equipment to execute corresponding operation, and sending a confirmation message to the client.

Optionally, before receiving the UDP message sent by the client, the method further includes:

creating a plurality of worker threads;

creating a local terminal node by using IPEndPoint types, and binding the local terminal node to all available network interfaces and designated ports;

and creating a UDP Socket by using Socket class, binding the UDP Socket to the local terminal point, and waiting for receiving UDP messages.

Optionally, the plurality of parameters further include a channel identifier, and the determining, according to the protocol type, a target test device from the plurality of test devices includes:

Obtaining a thread identifier according to the channel identifier;

If the thread identification does not exceed the identification range of the plurality of working threads, determining a target thread from the plurality of working threads according to the thread identification, and distributing the plurality of parameters to the target thread;

And starting the target thread, and determining target test equipment from the plurality of test equipment according to the protocol type.

Optionally, after obtaining the thread identifier according to the channel identifier, the method further includes:

And if the thread identification exceeds the identification range of the plurality of working threads, abnormal information is returned to the client.

Optionally, before the target thread is started, and the target test device is determined from the plurality of test devices according to the protocol type, the method further includes:

Storing the parameters and the endpoint information of the client into commands arrays corresponding to the target threads;

And accessing the commands array through mutual exclusion lock protection.

Optionally, the plurality of test devices include a BOB device and a voice card device, the BOB device includes a power meter, an attenuator and an optical switch, and the determining, according to the protocol type, a target test device from the plurality of test devices includes:

If the protocol type is BOB SET TXWL or GETPOWER, determining the power meter as a target test device;

if the protocol type is BOB SET RXWL or SETATT, determining the attenuator as a target test device;

If the protocol type is SWITCH, determining the optical SWITCH as target test equipment;

And if the protocol type is RING, determining the voice card equipment as target test equipment.

Optionally, the multiple parameters further include a test value, and the calling the target test device to execute a corresponding operation and sending a confirmation message to the client includes:

determining a target operation according to the protocol type;

And calling the target test equipment to execute the target operation according to the test value, and sending a confirmation message to the client.

In a second aspect, an apparatus scheduling device for an OLT registration streaming station is provided, where the apparatus scheduling device is disposed in a UDP server, the UDP server is connected to a client of the OLT registration streaming station, the OLT registration streaming station is integrated with a plurality of test apparatuses, and the UDP server is integrated with interfaces of the plurality of test apparatuses, and the apparatus includes:

The receiving module is used for receiving the UDP message sent by the client;

The analyzing module is used for analyzing the UDP message to obtain a plurality of parameters, wherein the parameters comprise a protocol type used for indicating a command type;

A determining module, configured to determine a target test device from the plurality of test devices according to the protocol type;

and the operation module is used for calling the target test equipment to execute corresponding operation and sending a confirmation message to the client.

In a third aspect, the present application provides a computer device, where the computer device includes a memory and a processor, where the memory stores a computer program, and the processor executes the computer program to implement the device scheduling method for registering an OLT with a streaming station in the first aspect.

In a fourth aspect, the present application provides a computer readable storage medium, where a computer program is stored on the computer readable storage medium, and a processor executes the computer program to implement the device scheduling method for registering a streaming station with an OLT in the first aspect.

Compared with the prior art, the application has the following beneficial effects:

The application provides an equipment scheduling method of an OLT registration streaming station, which is applied to a UDP server, wherein the UDP server is connected with a client of the OLT registration streaming station, the OLT registration streaming station is integrated with a plurality of test equipment, the UDP server is integrated with interfaces of the plurality of test equipment, the method comprises the steps of receiving UDP information sent by the client, analyzing the UDP information to obtain a plurality of parameters, the plurality of parameters comprise protocol types, determining target test equipment from the plurality of test equipment according to the protocol types, calling the target test equipment to execute corresponding operation, and sending a confirmation message to the client.

According to the application, the UDP server is used for intensively controlling the plurality of test devices of the external third party of the OLT registration and streaming station, so that the control problem of different types of external devices on the OLT registration and streaming station is solved, the combination of a plurality of test items can be realized on the OLT registration and streaming station, the coverage degree and the automation level of the test can be effectively improved, the manual intervention is reduced, and the overall test quality and the production efficiency are finally improved.

Drawings

In order to more clearly illustrate the embodiments of the present application or the technical solutions in the related art, the drawings that are required to be used in the embodiments or the related technical descriptions will be briefly described, and it is apparent that the drawings in the following description are only embodiments of the present application, and other drawings may be obtained according to the provided drawings without inventive effort for those skilled in the art.

Fig. 1 is a schematic view of an application scenario provided in an embodiment of the present application;

fig. 2 is a flow chart of an apparatus scheduling method for registering a streaming station by an OLT according to an embodiment of the present application;

FIG. 3 is a schematic diagram of a client configuration interface for setting attenuation according to an embodiment of the present application;

Fig. 4 is a schematic diagram of a client configuration interface for obtaining power according to an embodiment of the present application;

fig. 5 is a schematic diagram of a client configuration interface for setting an optical switch according to an embodiment of the present application;

Fig. 6 is a schematic structural diagram of an apparatus scheduling device for registering a streaming station by an OLT according to an embodiment of the present application.

Detailed Description

For the purpose of making the objects, technical solutions and advantages of the present application more apparent, the technical solutions in the embodiments of the present application will be clearly and completely described below with reference to the accompanying drawings in the embodiments of the present application, and it is apparent that the described embodiments are only some embodiments of the present application, not all embodiments of the present application. All other embodiments, which can be made by those skilled in the art based on the embodiments of the application without making any inventive effort, are intended to be within the scope of the application. Embodiments of the application and features of the embodiments may be combined with one another arbitrarily without conflict. Also, while a logical order is depicted in the flowchart, in some cases, the steps depicted or described may be performed in a different order than presented herein.

Because the secondary development interface provided by the equipment provider can only communicate through a UPD/TCP mode, but the BOB equipment (comprising an optical power meter and an attenuator) adopts a communication control mode of CH341, the voice card equipment adopts an external Tc08a32.dll control mode provided by the voice card equipment provider, and when the BOB test and the voice test are combined into the OLT to register a streaming station, the control problem of different types of external equipment exists.

In order to solve the control problem of different types of external devices on an OLT registration streaming station, the embodiment of the application provides a device scheduling method for the OLT registration streaming station, which is applied to a UDP server. Fig. 1 is a schematic diagram of an application scenario provided in an embodiment of the present application, or may be understood as a schematic diagram of an OLT registration streaming station.

The OLT registration streaming station comprises a UDP server, a client and a plurality of test devices. The UDP server is a server program developed by a user, runs in the background of the OLT registration streaming station, and integrates interfaces of a plurality of test devices. The client is an interface program for registering the streaming station by the OLT, and establishes connection with the UDP server through an interface protocol.

The plurality of test devices comprise a BOB device and a voice card device, wherein the BOB device is used for BOB testing of a BOB product (such as a photo cat), detecting whether the optical power emitted by the BOB product is within a required range or not, and detecting whether the optical power received by the BOB product is consistent with the optical power actually monitored or not. The voice card device is used for simulating the functions of ringing, off-hook, dialing, on-hook and the like of the telephone.

The BOB device includes a power meter, an attenuator, and an optical switch. The BOB product is an integrated product of light receiving and transmitting, and the light emitted by the BOB product needs power monitoring, so that the power meter is positioned at the emitting end of the BOB product and is mainly used for detecting and adjusting the power of the light signal emitted by the BOB product so as to ensure that the signal meets the requirements. The light received by the BOB product is attenuated, so that the attenuator is positioned at the receiving end of the BOB product and used for adjusting the intensity of the optical signal, and particularly when the signal is too strong, the intensity of the optical signal is reduced through the attenuator so as to avoid overload or the receiving end cannot process the too strong signal. The optical switch is positioned between the transmitting end and the receiving end and is used for switching signals among a plurality of optical paths and controlling the optical signals to flow in different directions.

It should be noted that fig. 1 is an example in which a plurality of test devices including BOD devices (power meters, attenuators, optical switches) and voice test devices are used, and the number of kinds of test devices is not limited in practice. The user can configure the plurality of test devices in the UDP server according to the actual devices produced.

In order to integrate the interfaces of a plurality of test devices at the UDP server and to select different kinds of test devices by configuration, communication interface protocols are formulated for the different test devices, and various interface protocols are described below, respectively.

1. The equipment's originating wavelength protocol is set up as BOB SET TXWL X X2.

Wherein BOB SET TXWL is a protocol type. X1 is a channel identifier, the device is provided with 8 channels, and the value range of X1 is a positive integer from 1 to 8. X2 is a test value and represents a specific wavelength set, and can be 1310nm or 1277nm.

2. Setting the receiving end wavelength protocol of the equipment, namely' BOB SET RXWL X X1 < 2 >.

Wherein BOB SET RXWL is protocol type, X1 is channel identification, the device has 8 channels, the value range of X1 is a positive integer of 1-8, X2 is test value, which indicates the specific wavelength set, and can be 1490nm or 1550nm.

3. The light power protocol of the transmitting end is obtained by GETPOWER X <1 >.

Wherein GETPOWER is protocol type, X1 is channel identification, the device has 8 channels, and the value range of X1 is a positive integer of 1-8.

4. Setting a receiving end optical attenuation protocol of SETATT X X1 and 2.

Wherein SETATT is protocol type, X1 is channel identification, the device has 8 channels, and the value range of X1 is a positive integer of 1-8. X2 is a test value, representing the set attenuation value.

5. The protocol of the optical SWITCH switching is set as SWITCH X1X 2.

Wherein SWITCH is a protocol type, X1 is a channel identifier, the device is provided with 8 channels, and the value range of X1 is a positive integer from 1 to 8. X2 is a test value, and the value of X2 is 1 or 2, which means that each channel has two optical paths, x2=1 represents the optical path set to the 1 st optical path, and x2=2 represents the optical path set to the 2 nd optical path.

6. Voice test protocol "RING X1" is set.

Wherein RING is a protocol type, X1 is a channel identifier, the device has 8 channels, and the value range of X1 is a positive integer from 1 to 8.

As can be seen from the above protocols, the acquisition-originating optical power protocol and the set-up voice test protocol do not contain test values.

Based on the application scenario shown in fig. 1, an apparatus scheduling method for registering a streaming station by an OLT shown in fig. 2 is described below.

S201, receiving UDP messages sent by the client.

In a specific implementation process, the UDP server may use the userver.receivefrom method to receive the UDP message (i.e. any one of the 6 interface protocols described above) sent by the client, and store the UDP message in the receiving buffer (ReceiveBuffer).

Before executing S201, a UDP server needs to be created in the background of the OLT registration streaming station, which specifically includes the following steps:

Creating a plurality of working threads, creating a local termination point by using IPEndPoint class, binding the local termination point to all available network interfaces and designated ports, creating a UDP Socket by using Socket class, binding the UDP Socket to the local termination point, waiting for receiving UDP message.

In an implementation, first, a plurality of worker threads may be created through a for loop, each of which performs WorkerThread methods, and passes an index as a parameter. commands sets are used to store command information for each worker thread. Second, a UDP Socket may be created using Socket classes, specifying the address family, socket type, and command type. A local endpoint may then be created using the IPEndPoint class, binding to all available network interfaces and designated ports. The UDP socket may then be bound to the local endpoint so that UDP messages may be received.

Considering that both the BOB device and the voice card device are multi-channel devices, multiple channels may be tested in parallel. Therefore, in the embodiment of the application, by creating a plurality of working threads, the plurality of working threads can process a plurality of UDP messages (interface protocols) in parallel, and different threads can be responsible for testing tasks of different channels, so that the multi-channel parallel test of the OLT group testing and streaming station is realized, and the overall test efficiency is improved.

S202, analyzing the UDP message to obtain a plurality of parameters.

After receiving the UDP message, the UDP server may convert the received byte array into a string, and parse the string to obtain a plurality of parameters. The plurality of parameters includes a protocol type, a channel identification, and a test value. The channel identification is used to uniquely identify each channel and the test value is used to indicate the specific parameter values, e.g. wavelength, attenuation values, etc., that the test needs to set. The protocol types comprise a device transmitting end wavelength protocol, a device receiving end wavelength protocol, a transmitting end optical power acquisition protocol, a receiving end optical attenuation protocol, an optical switch switching protocol and a voice test protocol.

It should be noted that, the acquisition of the transmit optical power protocol and the set voice test protocol of each channel has no test value.

S203, determining target test equipment from a plurality of test equipment according to the protocol type.

In one possible embodiment, the specific steps of S203 include:

The method comprises the steps of obtaining a thread identifier according to a channel identifier, determining a target thread from a plurality of working threads according to the thread identifier if the thread identifier does not exceed the identifier range of the plurality of working threads, distributing a plurality of parameters to the target thread, starting the target thread, and determining target test equipment from a plurality of test equipment according to a protocol type.

In a specific implementation process, after obtaining the channel identifiers, the UDP server may query a mapping table, where the mapping table includes a plurality of channel identifiers and thread identifiers corresponding to each channel identifier, and determine the corresponding thread identifier according to the channel identifier. Or the hash operation can be performed on the channel identifier, and the obtained hash value is the thread identifier. It may then be confirmed whether the thread identification is within a valid identification range. Assuming that the worker thread identification ranges from 1 to MaxCount (e.g., up to 10), if the calculated thread identification is less than MaxCount, then multiple parameters are assigned to the target thread, which can be used by the target thread to perform a particular task. Finally, the target thread is started to execute the execution task, and the target test equipment to be used can be determined through the protocol type when the target thread executes.

In the embodiment of the application, the tasks can be flexibly distributed to the corresponding working threads according to the thread identification, and different tasks can be processed in parallel, so that the blocking among threads is avoided. Each working thread independently operates, and in case that a certain working thread encounters an error (for example, a certain device cannot be started), the execution of other threads cannot be affected, and the system is easier to locate which thread has a problem, so that debugging and repairing are easier. And this structure is very suitable for expansion, if more test equipment needs to be supported in the future, only more thread pools need to be added, and the whole system does not need to be reconstructed.

In one possible embodiment, after obtaining the thread identification from the channel identification, the method further comprises:

if the thread identification exceeds the identification range of a plurality of working threads, abnormal information is returned to the client.

In the embodiment of the application, by checking the invalid thread ID, the system can be prevented from executing wrong operation, the program is prevented from being executed continuously when the invalid input is encountered, and the possibility of system failure is reduced. And once the client provides invalid input, the feedback can be received in time, so that meaningless processing in the subsequent steps is avoided, and time and calculation resources are saved.

In one possible embodiment, before starting the target thread, determining the target test device from the plurality of test devices according to the protocol type, the method further comprises:

Storing a plurality of parameters and endpoint information of the client into commands arrays corresponding to the target threads;

Access to commands arrays is protected by mutex locks.

In an implementation, a plurality of parameters and endpoint information for a client are stored in commands arrays associated with a target thread prior to starting the target thread. Endpoint information for a client generally refers to information about the client network interface used to identify and communicate, including IP addresses, port numbers, etc. Each working thread has its own commands array to store its related command information (i.e. multiple parameters), and accesses to commands array through mutex lock (mutex) protection, ensuring that only the target thread can modify or access commands array, which can avoid race conditions, and ensure data consistency and thread security.

In one possible embodiment, the step of determining the target test device from the plurality of test devices according to the protocol type comprises:

If the protocol type is BOB SET TXWL or GETPOWER, the power meter is determined to be the target test device, if the protocol type is BOB SET RXWL or SETATT, the attenuator is determined to be the target test device, if the protocol type is SWITCH, the optical SWITCH is determined to be the target test device, and if the protocol type is RING, the voice card device is determined to be the target test device.

In the embodiment of the application, the target test equipment can be screened out from a plurality of test equipment according to different protocol types through simple condition judgment, so that each protocol type is matched with the proper test equipment.

S204, calling the target test equipment to execute the corresponding operation, and sending a confirmation message to the client.

In the implementation process, if the multiple parameters do not include the test value, the target operation can be determined according to the protocol type, the target test equipment is directly called to execute the target operation, and the confirmation message is sent to the client. And calling target test equipment to execute target operation according to the test value and sending a confirmation message to the client. The acknowledgement message may be indicative of success or failure to perform the target operation and may also include a specific device return value, such as an optical power value.

Since the light received by the power meter is the light emitted by the BOB product, the power meter needs to be set to the same wavelength as the wavelength of the BOB product, for example, the client sends a protocol of BOB SET TXWL to 1310, the target thread may determine that the target operation is to set the wavelength of the BOB product according to the protocol type BOB SET TXWL, then set the wavelength of 1 channel of the power meter to 1310nm, and send a confirmation message to the client.

Since the light received by the BOB product is the light transmitted by the attenuator, the attenuator needs to be set to the same wavelength as the receiving end of the BOB product, for example, the client sends a protocol of BOB SET RXWL to 1 1490, and the target thread may determine that the target operation is to set the receiving end wavelength according to the protocol type BOB SET RXWL, then set the wavelength of 1 channel of the attenuator to 1490nm, and send an acknowledgement message to the client.

For example, the protocol sent by the client is GETPOWER 1, the target thread may determine, according to the protocol type GETPOWER, that the target operation is to obtain optical power, then call the power meter to obtain a power value of 1 channel, each channel corresponds to an actual line loss value, add the power value obtained by the power meter to the line loss value of 1 channel to obtain an actual power value, and send an acknowledgement message to the client, where the acknowledgement message may further include the actual power value.

For example, the protocol sent by the client is SWITCH 12, the target thread may determine that the target operation is a SWITCH according to the protocol type SWITCH, then call the optical SWITCH function to perform a switching operation on the optical SWITCH device, SWITCH the 1 channel of the optical SWITCH device to the 2 channel, and send a confirmation message to the client.

For example, the client may send a protocol SETATT to 10, and the target thread may determine that the target operation is to set an attenuation according to protocol type SETATT, then set the 1-channel of the attenuator to attenuate 10 units of power, and send an acknowledgement message to the client.

For example, the protocol sent by the client is RING 1, the target thread may determine that the target operation is a voice test according to the protocol type RING, then invoke the 1 channel of the voice card device to perform voice test such as voice ringing, off-hook, dialing, and the like, and send a confirmation message to the client, where the confirmation message may also include the voice test result.

In summary, the present application provides a method for registering a streaming station by an OLT for different kinds of test devices, developing a UDP server, which is a plug-in server program of UDP, and configuring an interface protocol of each test device in the UDP server, so as to integrate interfaces of different kinds of test devices, such as a BOD device and a voice card device, into the UDP server. The software of the OLT streaming station is communicated with a plurality of test devices (BOD devices and voice card devices) in a UDP communication mode, so that the function combination of BOB test and voice test is realized, and the efficiency of test and production is improved.

After the UDP server is started, the UDP server runs in the background all the time, continuously receives the UDP message sent by the client, calls corresponding test equipment to operate, and sends a return value of the test equipment to the client. The client may set the corresponding test device by sending a UDP message (i.e., an interface protocol) to the UDP server, and obtain a return value of the test device. The configuration interface of the client for setting attenuation is shown in fig. 3, the configuration interface of the client for obtaining power is shown in fig. 4, and the configuration interface of the client for setting an optical switch is shown in fig. 5.

Based on the same inventive concept, the application also provides a device scheduling device for an OLT registration streaming station, as shown in fig. 6, the device is arranged in a UDP server, the UDP server is connected with a client of the OLT registration streaming station, the OLT registration streaming station is integrated with a plurality of test devices, the UDP server is integrated with interfaces of the plurality of test devices, the device comprises:

The receiving module is used for receiving the UDP message sent by the client;

the analysis module is used for analyzing the UDP message to obtain a plurality of parameters, wherein the parameters comprise a protocol type used for indicating a command type;

the determining module is used for determining target test equipment from a plurality of test equipment according to the protocol type;

and the operation module is used for calling the target test equipment to execute the corresponding operation and sending a confirmation message to the client.

It should be noted that, each module in the device scheduling apparatus for registering a streaming station with an OLT in this embodiment corresponds to each step in the device scheduling method for registering a streaming station with an OLT in the foregoing embodiment, so specific implementation of this embodiment may refer to implementation of the device scheduling method for registering a streaming station with an OLT, which is not described herein again.

In addition, in one embodiment, the application further provides a computer device, which comprises a processor, a memory and a computer program stored in the memory, wherein the computer program is executed by the processor to realize the device scheduling method for registering the streaming station by the OLT.

In addition, in one embodiment, the application further provides a computer storage medium, and a computer program is stored on the computer storage medium, and the computer program is executed by a processor to realize the device scheduling method for registering the streaming station by the OLT.

In some embodiments, the computer readable storage medium may be FRAM, ROM, PROM, EPROM, EEPROM, flash memory, magnetic surface memory, optical disk, or CD-ROM, or various devices including one or any combination of the above. The computer may be a variety of computing devices including smart terminals and servers.

In some embodiments, the executable instructions may be in the form of programs, software modules, scripts, or code, written in any form of programming language (including compiled or interpreted languages, or declarative or procedural languages), and they may be deployed in any form, including as stand-alone programs or as modules, components, subroutines, or other units suitable for use in a computing environment.

As an example, the executable instructions may, but need not, correspond to files in a file system, may be stored as part of a file that holds other programs or data, such as in one or more scripts in a hypertext markup language (HTML, hyper Text Markup Language) document, in a single file dedicated to the program in question, or in multiple coordinated files (e.g., files that store one or more modules, sub-programs, or portions of code).

As an example, executable instructions may be deployed to be executed on one computing device or on multiple computing devices located at one site or distributed across multiple sites and interconnected by a communication network.

It should be noted that, in this document, the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or system that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or system. Without further limitation, an element defined by the phrase "comprising one does not exclude the presence of other like elements in a process, method, article, or system that comprises the element.

The above-mentioned embodiment numbers of the present application are merely for description, and do not represent advantages or disadvantages of the embodiments.

From the above description of the embodiments, it will be clear to those skilled in the art that the above-described embodiment method may be implemented by means of software plus a necessary general hardware platform, but of course may also be implemented by means of hardware, but in many cases the former is a preferred embodiment. Based on such understanding, the technical solution of the present application may be embodied essentially or in a part contributing to the prior art in the form of a software product stored in a storage medium (e.g. read only memory/random access memory, magnetic disk, optical disk) comprising instructions for causing a multimedia terminal device to perform the method according to the embodiments of the present application.

The foregoing description is only of the preferred embodiments of the present application, and is not intended to limit the scope of the application, but rather is intended to cover any equivalents of the structures or equivalent processes disclosed herein or in the alternative, which may be employed directly or indirectly in other related arts.

Claims

1. The equipment scheduling method for the OLT registration streaming station is characterized by being applied to a UDP server, wherein the UDP server is connected with a client of the OLT registration streaming station, the OLT registration streaming station is integrated with a plurality of test equipment, and the UDP server is integrated with interfaces of the plurality of test equipment, and the method comprises the following steps:

Receiving UDP messages sent by the client;

Analyzing the UDP message to obtain a plurality of parameters, wherein the plurality of parameters comprise a protocol type and a channel identifier, and the test equipment comprises a plurality of channels, wherein the channel identifier is used for uniquely identifying one channel in the plurality of channels;

Calling the target test equipment to execute corresponding operation, and sending a confirmation message to the client;

Creating a plurality of working threads before receiving UDP messages sent by the client, creating a local terminal point by using IPEndPoint types, binding the local terminal point to all available network interfaces and designated ports, creating a UDP Socket by using Socket types, binding the UDP Socket to the local terminal point, waiting for receiving UDP messages;

The method comprises the steps of determining target test equipment from a plurality of test equipment according to the protocol type, obtaining a thread identifier according to the channel identifier, determining a target thread from the plurality of working threads according to the thread identifier if the thread identifier does not exceed the identifier range of the plurality of working threads, distributing the plurality of parameters to the target thread, starting the target thread, and determining the target test equipment from the plurality of test equipment according to the protocol type.

2. The apparatus scheduling method for OLT registration of a streaming station according to claim 1, wherein after obtaining a thread identification from the channel identification, the method further comprises:

3. The device scheduling method of OLT registration streaming station of claim 1, wherein prior to starting the target thread to determine a target test device from the plurality of test devices according to the protocol type, the method further comprises:

And accessing the commands array through mutual exclusion lock protection.

4. The method for scheduling devices for an OLT to register a streaming station of claim 1, wherein the plurality of test devices includes a BOB device and a voice card device, wherein the BOB device includes a power meter, an attenuator, and an optical switch, and wherein the determining a target test device from the plurality of test devices according to the protocol type includes:

5. The method for scheduling devices for an OLT to register a streaming workstation of claim 1, wherein the plurality of parameters further includes a test value, wherein the invoking the target test device to perform the corresponding operation and sending a confirmation message to the client includes:

determining a target operation according to the protocol type;

6. The device scheduling device for the OLT registration streaming station is characterized by being arranged in a UDP server, wherein the UDP server is connected with a client of the OLT registration streaming station, the OLT registration streaming station is integrated with a plurality of test devices, and the UDP server is integrated with interfaces of the plurality of test devices, and the device comprises:

The receiving module is used for receiving the UDP message sent by the client;

The device comprises a UDP message, a parsing module, a testing device and a processing module, wherein the UDP message is parsed to obtain a plurality of parameters, the parameters comprise a protocol type for indicating a command type and a channel identifier, and the testing device comprises a plurality of channels;

The operation module is used for calling the target test equipment to execute corresponding operation and sending a confirmation message to the client;

Creating a plurality of working threads before receiving UDP messages sent by the client, creating a local terminal point by using IPEndPoint types, binding the local terminal point to all available network interfaces and designated ports, creating a UDP Socket by using Socket types, binding the UDP Socket to the local terminal point, and waiting for receiving UDP messages;

7. A computer device, characterized in that it comprises a memory and a processor, said memory storing a computer program, said processor executing said computer program, implementing a device scheduling method for OLT registration of a streaming station according to any of claims 1-5.

8. A computer readable storage medium, wherein a computer program is stored on the computer readable storage medium, and a processor executes the computer program to implement the device scheduling method for OLT registration of a streaming station according to any one of claims 1-5.