Home
last modified time | relevance | path

Searched refs:operations (Results 1 - 25 of 59) sorted by relevance

123

/kernel/linux/linux-6.6/fs/hmdfs/comm/
H A Dsocket_adapter.c100 struct hmdfs_cmd operations) in msg_init()
105 ret = hmdfs_alloc_msg_idr(con, MSG_IDR_MESSAGE_SYNC, msg_wq, operations); in msg_init()
133 head->operations.command); in hmdfs_sendmessage()
139 head->operations.command); in hmdfs_sendmessage()
151 node->device_id, head->operations.command); in hmdfs_sendmessage()
168 node->device_id, head->operations.command); in hmdfs_sendmessage()
193 statistic_con_sb_dirty(node, &head->operations); in hmdfs_sendmessage()
195 if (head->operations.cmd_flag == C_REQUEST) in hmdfs_sendmessage()
197 head->operations.command, ret); in hmdfs_sendmessage()
198 else if (head->operations in hmdfs_sendmessage()
99 msg_init(struct hmdfs_peer *con, struct sendmsg_wait_queue *msg_wq, struct hmdfs_cmd operations) msg_init() argument
[all...]
H A Dconnection.h224 __u8 operations; member
307 void connection_send_handshake(struct connection *conn_impl, __u8 operations,
334 void *ptr, struct hmdfs_cmd operations);
336 struct hmdfs_cmd operations);
H A Dprotocol.h31 struct hmdfs_cmd operations; member
81 struct hmdfs_cmd operations; member
91 struct hmdfs_cmd operations; member
H A Dmessage_verify.c890 if (head->operations.cmd_flag == C_RESPONSE) { in handle_bad_message()
899 if (head->operations.command >= F_SIZE) in handle_bad_message()
907 if (need_response[head->operations.command]) in handle_bad_message()
931 flag = head->operations.cmd_flag; in hmdfs_message_verify()
935 cmd = head->operations.command; in hmdfs_message_verify()
944 if (head->operations.command == F_ITERATE && flag == C_RESPONSE) in hmdfs_message_verify()
H A Dtransport.c238 le32_to_cpu(recv->msg_id), recv->operations); in tcp_recvpage_tls()
537 recv->operations.command == F_READPAGE && in tcp_receive_from_sock()
538 recv->operations.cmd_flag == C_RESPONSE) { in tcp_receive_from_sock()
759 struct hmdfs_cmd operations; in tcp_send_rekey_request() local
761 hmdfs_init_cmd(&operations, F_CONNECT_REKEY); in tcp_send_rekey_request()
775 head->operations = operations; in tcp_send_rekey_request()
H A Dconnection.c392 hs_head->operations = ops; in do_send_handshake()
626 ops = head->operations; in connection_handshake_recv_handler()
728 return head->operations.command == F_CONNECT_REKEY; in cmd_update_tls_crypto_key()
1240 int id, struct hmdfs_cmd operations) in hmdfs_find_msg_head()
1246 if (head && head->send_cmd_operations.command == operations.command) in hmdfs_find_msg_head()
1256 void *ptr, struct hmdfs_cmd operations) in hmdfs_alloc_msg_idr()
1271 head->send_cmd_operations = operations; in hmdfs_alloc_msg_idr()
1239 hmdfs_find_msg_head(struct hmdfs_peer *peer, int id, struct hmdfs_cmd operations) hmdfs_find_msg_head() argument
1255 hmdfs_alloc_msg_idr(struct hmdfs_peer *peer, enum MSG_IDR_TYPE type, void *ptr, struct hmdfs_cmd operations) hmdfs_alloc_msg_idr() argument
/kernel/linux/linux-5.10/fs/hmdfs/comm/
H A Dsocket_adapter.c100 struct hmdfs_cmd operations) in msg_init()
105 ret = hmdfs_alloc_msg_idr(con, MSG_IDR_MESSAGE_SYNC, msg_wq, operations); in msg_init()
133 head->operations.command); in hmdfs_sendmessage()
139 head->operations.command); in hmdfs_sendmessage()
151 node->device_id, head->operations.command); in hmdfs_sendmessage()
168 node->device_id, head->operations.command); in hmdfs_sendmessage()
193 statistic_con_sb_dirty(node, &head->operations); in hmdfs_sendmessage()
195 if (head->operations.cmd_flag == C_REQUEST) in hmdfs_sendmessage()
197 head->operations.command, ret); in hmdfs_sendmessage()
198 else if (head->operations in hmdfs_sendmessage()
99 msg_init(struct hmdfs_peer *con, struct sendmsg_wait_queue *msg_wq, struct hmdfs_cmd operations) msg_init() argument
[all...]
H A Dconnection.h224 __u8 operations; member
307 void connection_send_handshake(struct connection *conn_impl, __u8 operations,
334 void *ptr, struct hmdfs_cmd operations);
336 struct hmdfs_cmd operations);
H A Dprotocol.h31 struct hmdfs_cmd operations; member
81 struct hmdfs_cmd operations; member
91 struct hmdfs_cmd operations; member
H A Dmessage_verify.c890 if (head->operations.cmd_flag == C_RESPONSE) { in handle_bad_message()
899 if (head->operations.command >= F_SIZE) in handle_bad_message()
907 if (need_response[head->operations.command]) in handle_bad_message()
931 flag = head->operations.cmd_flag; in hmdfs_message_verify()
935 cmd = head->operations.command; in hmdfs_message_verify()
944 if (head->operations.command == F_ITERATE && flag == C_RESPONSE) in hmdfs_message_verify()
H A Dtransport.c238 le32_to_cpu(recv->msg_id), recv->operations); in tcp_recvpage_tls()
537 recv->operations.command == F_READPAGE && in tcp_receive_from_sock()
538 recv->operations.cmd_flag == C_RESPONSE) { in tcp_receive_from_sock()
759 struct hmdfs_cmd operations; in tcp_send_rekey_request() local
761 hmdfs_init_cmd(&operations, F_CONNECT_REKEY); in tcp_send_rekey_request()
775 head->operations = operations; in tcp_send_rekey_request()
H A Dconnection.c392 hs_head->operations = ops; in do_send_handshake()
626 ops = head->operations; in connection_handshake_recv_handler()
728 return head->operations.command == F_CONNECT_REKEY; in cmd_update_tls_crypto_key()
1240 int id, struct hmdfs_cmd operations) in hmdfs_find_msg_head()
1246 if (head && head->send_cmd_operations.command == operations.command) in hmdfs_find_msg_head()
1256 void *ptr, struct hmdfs_cmd operations) in hmdfs_alloc_msg_idr()
1271 head->send_cmd_operations = operations; in hmdfs_alloc_msg_idr()
1239 hmdfs_find_msg_head(struct hmdfs_peer *peer, int id, struct hmdfs_cmd operations) hmdfs_find_msg_head() argument
1255 hmdfs_alloc_msg_idr(struct hmdfs_peer *peer, enum MSG_IDR_TYPE type, void *ptr, struct hmdfs_cmd operations) hmdfs_alloc_msg_idr() argument
/kernel/linux/linux-5.10/fs/hmdfs/
H A Dhmdfs_client.c46 hmdfs_init_cmd(&sm.operations, F_OPEN); in hmdfs_send_open()
87 hmdfs_init_cmd(&sm.operations, F_RELEASE); in hmdfs_send_close()
112 hmdfs_init_cmd(&sm.operations, F_FSYNC); in hmdfs_send_fsync()
141 hmdfs_init_cmd(&sm.operations, F_READPAGE); in hmdfs_client_readpage()
388 hmdfs_init_cmd(&req.operations, F_WRITEPAGE); in hmdfs_client_writepage()
432 hmdfs_init_cmd(&sm.operations, F_ITERATE); in hmdfs_client_start_readdir()
477 hmdfs_init_cmd(&sm.operations, F_MKDIR); in hmdfs_client_start_mkdir()
526 hmdfs_init_cmd(&sm.operations, F_CREATE); in hmdfs_client_start_create()
573 hmdfs_init_cmd(&sm.operations, F_RMDIR); in hmdfs_client_start_rmdir()
604 hmdfs_init_cmd(&sm.operations, F_UNLIN in hmdfs_client_start_unlink()
[all...]
H A Dhmdfs_trace.h54 __entry->command = cmd->operations.command;
55 __entry->cmd_flag = cmd->operations.cmd_flag;
83 __entry->command = cmd->operations.command;
84 __entry->cmd_flag = cmd->operations.cmd_flag;
/kernel/linux/linux-6.6/fs/hmdfs/
H A Dhmdfs_client.c46 hmdfs_init_cmd(&sm.operations, F_OPEN); in hmdfs_send_open()
87 hmdfs_init_cmd(&sm.operations, F_RELEASE); in hmdfs_send_close()
112 hmdfs_init_cmd(&sm.operations, F_FSYNC); in hmdfs_send_fsync()
141 hmdfs_init_cmd(&sm.operations, F_READPAGE); in hmdfs_client_readpage()
387 hmdfs_init_cmd(&req.operations, F_WRITEPAGE); in hmdfs_client_writepage()
431 hmdfs_init_cmd(&sm.operations, F_ITERATE); in hmdfs_client_start_readdir()
476 hmdfs_init_cmd(&sm.operations, F_MKDIR); in hmdfs_client_start_mkdir()
525 hmdfs_init_cmd(&sm.operations, F_CREATE); in hmdfs_client_start_create()
572 hmdfs_init_cmd(&sm.operations, F_RMDIR); in hmdfs_client_start_rmdir()
603 hmdfs_init_cmd(&sm.operations, F_UNLIN in hmdfs_client_start_unlink()
[all...]
/kernel/linux/linux-6.6/scripts/atomic/
H A Dgen-atomic-instrumented.sh138 * This file provoides atomic operations with explicit instrumentation (e.g.
141 * raw_atomic*() operations should be used.
/kernel/linux/linux-5.10/drivers/greybus/
H A Dconnection.c134 * A connection also maintains the state of operations sent over the
188 INIT_LIST_HEAD(&connection->operations); in _gb_connection_create()
596 * Cancel all active operations on a connection.
607 while (!list_empty(&connection->operations)) {
608 operation = list_last_entry(&connection->operations,
625 * Cancel all active incoming operations on a connection.
637 while (!list_empty(&connection->operations)) {
639 list_for_each_entry(operation, &connection->operations,
/kernel/linux/linux-6.6/drivers/greybus/
H A Dconnection.c134 * A connection also maintains the state of operations sent over the
188 INIT_LIST_HEAD(&connection->operations); in _gb_connection_create()
596 * Cancel all active operations on a connection.
607 while (!list_empty(&connection->operations)) {
608 operation = list_last_entry(&connection->operations,
625 * Cancel all active incoming operations on a connection.
637 while (!list_empty(&connection->operations)) {
639 list_for_each_entry(operation, &connection->operations,
/kernel/linux/linux-5.10/arch/arm/include/asm/
H A Dpage.h104 #error Unknown user operations model
/kernel/linux/linux-6.6/arch/arm/include/asm/
H A Dpage.h104 #error Unknown user operations model
/kernel/linux/linux-5.10/scripts/atomic/
H A Dgen-atomic-instrumented.sh145 * This file provides wrappers with KASAN instrumentation for atomic operations.
147 * atomic operations with arch_ prefix (e.g. arch_atomic_read()) and include
151 * operations (e.g. atomic_read()/atomic_cmpxchg() loop), then it needs to use
/kernel/linux/linux-5.10/include/linux/greybus/
H A Dconnection.h55 struct list_head operations; member
/kernel/linux/linux-6.6/include/linux/greybus/
H A Dconnection.h55 struct list_head operations; member
/kernel/linux/linux-5.10/drivers/block/
H A Dsunvdc.c81 u64 operations; member
251 pkt->tag.stype, pkt->operations, in vdc_handle_attr()
276 port->operations = pkt->operations; in vdc_handle_attr()
581 if (!(((u64)1 << (u64)op) & port->operations)) in generic_request()
/kernel/linux/linux-6.6/drivers/block/
H A Dsunvdc.c80 u64 operations; member
253 pkt->tag.stype, pkt->operations, in vdc_handle_attr()
278 port->operations = pkt->operations; in vdc_handle_attr()
583 if (!(((u64)1 << (u64)op) & port->operations)) in generic_request()

Completed in 30 milliseconds

123