System and method for simultaneous shared access to data buffers by two threads, in a connection-oriented data proxy service
View Patent ↗A method and system configured for detecting availability of destination port associated with a virtual connection between a client and server communicating using SCSI over a fiber channel network by a server fiber channel adapter, reading data from a head of a singly linked list of a data stream storing data to be forwarded by the virtual connection engine executing the virtual connection without a lock by a consumer process thread while a producer process thread has access to the linked list of the data stream, and forwarding the data read from the head of the linked list to the destination port.
1. A method comprising:
receiving a catalog of available transport paths from a client over a fibre channel network, the transport paths established based on fibre channel protocol;
detecting availability of destination port associated with a virtual connection between the client and a server communicating using SCSI (Small Computer System Interface) over the fibre channel network by a server fibre channel adapter,
the virtual connection identifying one of the available transport paths for the communication using SCSI;
in response to determining that a head buffer of a data stream is not empty, reading data from a head of a singly linked list of the data stream by a consumer process thread while a producer process thread has access to the singly linked list of the data stream,
the data stream storing data received via the virtual connection from the client,
each item in the singly linked list corresponding to a data buffer, the consumer process thread and the producer process thread having simultaneous access to individual data buffers of the singly linked list of the data stream without having to wait to obtain a lock;
forwarding the data read from the head of the singly linked list to the destination port by the consumer process thread; and
sending response data received from the destination port to the client via the one available path of the virtual connection by the producer process thread.
2. The method of claim 1 , further comprising:
detecting whether data is available in the data stream of the virtual connection.
3. The method of claim 1 , further comprising:
detecting whether all data from the head of the singly linked list has been read and forwarded.
4. The method of claim 3 , further comprising:
updating a head position for the singly linked list in response to detecting the location of the head is empty.
5. The method of claim 4 , further comprising:
obtaining a lock on the head position before updating the head position.
6. The method of claim 5 , further comprising:
releasing the lock on the head position after updating the head position.
7. A server system comprising:
a processor to execute a virtual connection engine in a server fiber channel adapter, the virtual connection engine to manage a virtual connection that support communication between a client and the server system using SCSI (Small Computer System Interface) over a fiber channel network,
the virtual connection engine having a producer process thread and a consumer process thread, to processor being configured to receive a catalog of available transport paths from the client over the fibre channel network,
the transport paths established based on fibre channel protocol,
the virtual connection identifying one of the available transport paths for the communication using SCSI,
detect availability of a destination port associated with the virtual connection,
in response to determining that a head buffer of a data stream is not empty, read data from a head of a singly linked list of the data stream by the consumer process thread while the producer process thread has access to the singly linked list of the data stream,
the data stream storing data received via the virtual connection from the client,
each item in the singly linked list corresponding to a data buffer, the consumer process thread and the producer process thread having simultaneous access to individual data buffers of the singly linked list of the data stream without having to wait to obtain a lock,
forward the data read from the head of the singly linked list to the destination port by the consumer process thread; and
send response data received from the destination port to the client via the one available path of the virtual connection by the producer process thread.
8. The server system of claim 7 , wherein the virtual connection engine is further configured to detect whether data is available in the data stream of the virtual connection.
9. The server system of claim 7 , wherein the virtual connection engine is
further configured to detect whether all data from the head of the singly linked list has been read and forwarded.
10. The server system of claim 9 , wherein the virtual connection engine is
further configured to update a head position for the singly linked list in response to detecting the location of the head is empty.
11. The server system of claim 10 , wherein the virtual connection engine is
further configured to obtain a lock on the head position before updating the head position.
12. The server system of claim 11 , wherein the virtual connection engine is
further configured to release the lock on the head position after updating the head position.
13. A machine-readable non-transitory storage medium having instructions therein, which when executed by a machine, cause the machine to perform operations, the operations comprising:
receiving a catalog of available transport paths from a client over a fibre channel network, the transport paths established based on fibre channel protocol;
detecting availability of destination port associated with a virtual connection between the client and a server communicating using SCSI (Small Computer System Interface) over the fibre channel network by a server fibre channel adapter,
the virtual connection identifying one of the available transport paths for the communication using SCSI;
in response to determining that a head buffer of a data stream is not empty, reading data from a head of a singly linked list of the data stream by a consumer process thread while a producer process thread has access to the singly linked list of the data stream,
the data stream storing data received via the virtual connection from the client,
each item in the singly linked list corresponding to a data buffer, the consumer process thread and the producer process thread having simultaneous access to individual data buffers of the singly linked list of the data stream without having to wait to obtain a lock;
forwarding the data read from the head of the singly linked list to the destination port by the consumer process thread; and
sending response data received from the destination port to the client via the one available path of the virtual connection by the producer process thread.
14. The medium of claim 13 , the operations further comprising:
detecting whether data is available in the data stream of the virtual connection.
15. The medium of claim 13 , the operations further comprising:
detecting whether all data from the head of the singly linked list has been read and forwarded.
16. The medium of claim 15 , the operations further comprising:
updating a head position for the singly linked list in response to detecting the location of the head is empty.
17. The medium of claim 16 , the operations further comprising:
obtaining a lock on the head position before updating the head position.
18. The medium of claim 17 , the operations further comprising:
releasing the lock on the head position after updating the head position.